worker

Documentation

Index

• type RegisterActivityOptions
• type RegisterWorkflowOptions
• type Registry
• type Worker

Types

type RegisterActivityOptions

type RegisterActivityOptions = internal.RegisterActivityOptions

type RegisterWorkflowOptions

type RegisterWorkflowOptions = internal.RegisterWorkflowOptions

type Registry

type Registry interface {
	RegisterWorkflow(w interface{}, name string)
	RegisterWorkflowWithOptions(w interface{}, options RegisterWorkflowOptions)
	RegisterActivity(a interface{})
	RegisterActivityWithOptions(a interface{}, options RegisterActivityOptions)
}

type Worker

type Worker interface {
	Registry
	Start() error
	// Run is a blocking start and cleans up resources when killed
	// returns error only if it fails to start the worker
	Run(interruptCh <-chan interface{}) error
	// Stop cleans up any resources opened by worker
	Stop()
}