event

type EworkRunnerExecuteEvent struct {
	TaskId    int64                  `json:"task_id"`
	Language  string                 `json:"language"`
	Code      string                 `json:"code"`
	Args      map[string]interface{} `json:"args"`
	Variables string                 `json:"variables"`
}

type Status uint8

type TaskWorkerEventProducer interface {
	Produce(ctx context.Context, topic string, evt EworkRunnerExecuteEvent) error
	AddProducer(topic string) error
	DelProducer(topic string) error
}

type WorkerEvent struct {
	Name   string `json:"name"`
	Desc   string `json:"desc"`
	Topic  string `json:"topic"`
	Status Status `json:"status"`
}