Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Action ¶
type Action interface {
// Name returns the name of the action
Name() string
// Run runs the action
Run(args ...any) []any
MethodFn() any
}
Action is an individual action that can be run by the worker.
type Cron ¶
type Cron string
func (Cron) ToWorkflowTriggers ¶
func (c Cron) ToWorkflowTriggers(wt *types.WorkflowTriggers)
type Event ¶
type Event string
func (Event) ToWorkflowTriggers ¶
func (e Event) ToWorkflowTriggers(wt *types.WorkflowTriggers)
type Service ¶
type Service struct {
Name string
// contains filtered or unexported fields
}
func (*Service) RegisterAction ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) NewService ¶
type WorkerOpt ¶
type WorkerOpt func(*WorkerOpts)
func WithClient ¶
func WithIntegration ¶
func WithIntegration(integration integrations.Integration) WorkerOpt
type WorkerOpts ¶
type WorkerOpts struct {
// contains filtered or unexported fields
}
type Workflow ¶
type Workflow struct {
Jobs []WorkflowJob
}
type WorkflowJob ¶
type WorkflowJob struct {
// The name of the job
Name string
Description string
Timeout string
// The steps that are run in the job
Steps []WorkflowStep
}
func (*WorkflowJob) ToActionMap ¶
func (j *WorkflowJob) ToActionMap(svcName string) map[string]any
func (*WorkflowJob) ToWorkflow ¶
func (j *WorkflowJob) ToWorkflow(svcName string) types.Workflow
func (*WorkflowJob) ToWorkflowJob ¶
func (j *WorkflowJob) ToWorkflowJob(svcName string) (*types.WorkflowJob, error)
type WorkflowStep ¶
type WorkflowStep struct {
// The step timeout
Timeout string
// The executed function
Function any
}
func (*WorkflowStep) GetActionId ¶
func (s *WorkflowStep) GetActionId(svcName string, index int) string
func (*WorkflowStep) GetStepId ¶
func (s *WorkflowStep) GetStepId(index int) string
func (*WorkflowStep) ToWorkflowStep ¶
func (s *WorkflowStep) ToWorkflowStep(prevStep *step, svcName string, index int) (*step, error)
Click to show internal directories.
Click to hide internal directories.