executor

Mar 22, 2025

Changes in this version

+ type TaskExecutor struct

+ func NewTaskExecutor() *TaskExecutor

+ func (e *TaskExecutor) ExecuteAsync(ctx context.Context, taskName string, params interface{}, ...) (<-chan *interfaces.TaskResult, error)

+ func (e *TaskExecutor) ExecuteStep(ctx context.Context, t *core.Task, step *core.Step) error

+ func (e *TaskExecutor) ExecuteSync(ctx context.Context, taskName string, params interface{}, ...) (*interfaces.TaskResult, error)

+ func (e *TaskExecutor) ExecuteTask(ctx context.Context, t *core.Task) error

+ func (e *TaskExecutor) RegisterTask(name string, taskFunc TaskFunc)

+ type TaskFunc func(ctx context.Context, params interface{}) (interface{}, error)

+ type TaskOptions struct

+ MaxRetries *int

+ Metadata map[string]interface{}

+ RetryBackoff *time.Duration

+ Timeout *time.Duration