worker

Documentation

Index

• func At(t ...time.Time) scheduled
• func Cron(c string) cron
• func Crons(c ...string) cronArr
• func Event(e string) event
• func Events(events ...string) eventsArr
• type Action
• type MiddlewareFunc
• type Service
  • func (s *Service) On(t triggerConverter, workflow workflowConverter) error
  • func (s *Service) RegisterAction(fn any) error
  • func (s *Service) Use(mws ...MiddlewareFunc)
• type Worker
  • func NewWorker(fs ...WorkerOpt) (*Worker, error)
  • func (w *Worker) NewService(name string) *Service
  • func (w *Worker) On(t triggerConverter, workflow workflowConverter) error
  • func (w *Worker) RegisterAction(name string, method any) error
  • func (w *Worker) Start(ctx context.Context) error
  • func (w *Worker) Use(mws ...MiddlewareFunc)
• type WorkerOpt
  • func WithClient(client client.Client) WorkerOpt
  • func WithErrorAlerter(alerter errors.Alerter) WorkerOpt
  • func WithIntegration(integration integrations.Integration) WorkerOpt
  • func WithName(name string) WorkerOpt
• type WorkerOpts
• type Workflow
• type WorkflowJob
  • func (j *WorkflowJob) ToActionMap(svcName string) map[string]any
  • func (j *WorkflowJob) ToWorkflow(svcName string) types.Workflow
  • func (j *WorkflowJob) ToWorkflowJob(svcName string) (*types.WorkflowJob, error)
• type WorkflowStep
  • func Fn(f any) WorkflowStep
  • func (s *WorkflowStep) GetActionId(svcName string, index int) string
  • func (s *WorkflowStep) GetStepId(index int) string
  • func (w WorkflowStep) SetName(name string) WorkflowStep
  • func (w WorkflowStep) SetTimeout(timeout string) WorkflowStep
  • func (w WorkflowStep) ToActionMap(svcName string) map[string]any
  • func (w WorkflowStep) ToWorkflow(svcName string) types.Workflow
  • func (s *WorkflowStep) ToWorkflowStep(prevStep *step, svcName string, index int) (*step, error)

Functions

func At

func At(t ...time.Time) scheduled

func Cron

func Cron(c string) cron

func Crons

func Crons(c ...string) cronArr

func Event

func Event(e string) event

func Events

func Events(events ...string) eventsArr

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

	// Service returns the service that the action belongs to
	Service() string
}

Action is an individual action that can be run by the worker.

type MiddlewareFunc

type MiddlewareFunc func(ctx context.Context, next func(context.Context) error) error

type Service

type Service struct {
	Name string
	// contains filtered or unexported fields
}

func (*Service) On

func (s *Service) On(t triggerConverter, workflow workflowConverter) error

func (*Service) RegisterAction

func (s *Service) RegisterAction(fn any) error

func (*Service) Use

func (s *Service) Use(mws ...MiddlewareFunc)

type Worker

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

func NewWorker

func NewWorker(fs ...WorkerOpt) (*Worker, error)

NewWorker creates a new worker instance

func (*Worker) NewService

func (w *Worker) NewService(name string) *Service

func (*Worker) On

func (w *Worker) On(t triggerConverter, workflow workflowConverter) error

func (*Worker) RegisterAction

func (w *Worker) RegisterAction(name string, method any) error

func (*Worker) Start

func (w *Worker) Start(ctx context.Context) error

Start starts the worker in blocking fashion

func (*Worker) Use

func (w *Worker) Use(mws ...MiddlewareFunc)

type WorkerOpt

type WorkerOpt func(*WorkerOpts)

func WithClient

func WithClient(client client.Client) WorkerOpt

func WithErrorAlerter

func WithErrorAlerter(alerter errors.Alerter) WorkerOpt

func WithIntegration

func WithIntegration(integration integrations.Integration) WorkerOpt

func WithName

func WithName(name string) 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

	// The step id/name. If not set, one will be generated from the function name
	Name string
}

func Fn

func Fn(f any) WorkflowStep

func (*WorkflowStep) GetActionId

func (s *WorkflowStep) GetActionId(svcName string, index int) string

func (*WorkflowStep) GetStepId

func (s *WorkflowStep) GetStepId(index int) string

func (WorkflowStep) SetName

func (w WorkflowStep) SetName(name string) WorkflowStep

func (WorkflowStep) SetTimeout

func (w WorkflowStep) SetTimeout(timeout string) WorkflowStep

func (WorkflowStep) ToActionMap

func (w WorkflowStep) ToActionMap(svcName string) map[string]any

func (WorkflowStep) ToWorkflow

func (w WorkflowStep) ToWorkflow(svcName string) types.Workflow

func (*WorkflowStep) ToWorkflowStep

func (s *WorkflowStep) ToWorkflowStep(prevStep *step, svcName string, index int) (*step, error)