event

package

v1.3.0 Latest Latest Go to latest Published: Aug 15, 2024 License: MIT Imports: 7 Imported by: 0

Details

View Source

const ExecuteResultEventName = "result_execute_events"

This section is empty.

This section is empty.

type ExecuteResultConsumer struct {
	// contains filtered or unexported fields
}

func NewExecuteResultConsumer(q mq.MQ, svc service.Service) (
	*ExecuteResultConsumer, error)

func (c *ExecuteResultConsumer) Consume(ctx context.Context) error

func (c *ExecuteResultConsumer) Start(ctx context.Context)

func (c *ExecuteResultConsumer) Stop(_ context.Context) error

type ExecuteResultEvent struct {
	TaskId int64  `json:"task_id"`
	Result string `json:"result"`
	Status Status `json:"status"`
}

type Status uint8

const (
	// SUCCESS 成功
	SUCCESS Status = 1

	FAILED Status = 2
)

func (s Status) ToUint8() uint8