event.go 258 B

12345678910111213141516
  1. package handler
  2. import (
  3. "GtDataStore/app/cmd/events/internal/logic/job"
  4. "context"
  5. )
  6. func handlerEvent(ctx context.Context, task *job.Task, technologyName string) error {
  7. queue := task.Job.SvcCtx.Cache
  8. for info := range eventChan {
  9. }
  10. return nil
  11. }