event

package
v1.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 7, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const ExecuteResultEventName = "result_execute_events"

Variables

This section is empty.

Functions

This section is empty.

Types

type ExecuteResultConsumer

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

func NewExecuteResultConsumer

func NewExecuteResultConsumer(q mq.MQ, svc service.Service, codebookSvc codebook.Service,
	userSvc user.Service, lark *lark.Client) (
	*ExecuteResultConsumer, error)

func (*ExecuteResultConsumer) Consume

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

func (*ExecuteResultConsumer) Start

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

func (*ExecuteResultConsumer) Stop

type ExecuteResultEvent

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

type Status

type Status uint8
const (
	// SUCCESS 成功
	SUCCESS Status = 1

	FAILED Status = 2
)

func (Status) ToUint8

func (s Status) ToUint8() uint8

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL