Versions in this module Expand all Collapse all v0 v0.1.0 Oct 24, 2025 Changes in this version + func CallTask(t Task, args ...interface{}) ([]interface{}, error) + func GetFunctionName(t Task) (string, error) + func VerifySignature(t Task) error + type Options struct + Retry *Retry + type Retry struct + Factor float32 + MaxRetries int + WaitDuration time.Duration + type Task interface + type TaskContext interface + ExecuteTask func(task Task, input ...interface{}) *TaskResult + type TaskInfo struct + Options *Options + Task Task + type TaskResult struct + Error error + Result []interface{} + func (t *TaskResult) Get(output ...interface{}) error + type Tasks struct + Tasks map[string]*TaskInfo + func NewTasks() *Tasks + func (t *Tasks) ExecuteTaskByName(name string, tctx TaskContext, input ...interface{}) ([]interface{}, error) + func (t *Tasks) GetTaskByName(name string) (Task, error) + func (t *Tasks) GetTaskInfoByName(name string) (*TaskInfo, error) + func (t *Tasks) GetTaskNames() []string + func (t *Tasks) RegisterTask(task Task) error + func (t *Tasks) RegisterTaskWithOptions(task Task, options *Options) error
Go to main page