workflows

Documentation

Index

• type Registry
  • func NewRegistry() *Registry
  • func (s *Registry) Create(name, version, logName string) (wfs.Workflow, error)
  • func (s *Registry) RegisterComponent(componentFactory func(logger.Logger) wfs.Workflow, names ...string)

Types

type Registry

type Registry struct {
	Logger logger.Logger
	// contains filtered or unexported fields
}

Registry is an interface for a component that returns registered state store implementations.

var DefaultRegistry *Registry = NewRegistry()

DefaultRegistry is the singleton with the registry .

func NewRegistry

func NewRegistry() *Registry

NewRegistry is used to create workflow registry.

func (*Registry) Create

func (s *Registry) Create(name, version, logName string) (wfs.Workflow, error)

func (*Registry) RegisterComponent

func (s *Registry) RegisterComponent(componentFactory func(logger.Logger) wfs.Workflow, names ...string)

RegisterComponent adds a new workflow to the registry.