wfbackend

Documentation

Index

• type Metadata
• type Registry
  • func NewRegistry() *Registry
  • func (s *Registry) Create(name, version, logName string) (func(Metadata) (backend.Backend, error), error)
  • func (s *Registry) RegisterComponent(componentFactory workflowBackendFactory, names ...string)

Types

type Metadata

type Metadata struct {
	metadata.Base `json:",inline"`

	// Dapr app ID
	AppID string
}

Metadata represents a set of properties specific for workflow backends.

type Registry

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

Registry is an interface for a component that returns registered workflow backend 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) (func(Metadata) (backend.Backend, error), error)

func (*Registry) RegisterComponent

func (s *Registry) RegisterComponent(componentFactory workflowBackendFactory, names ...string)

RegisterComponent adds a new workflow to the registry.