registry

package
v0.18.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 21, 2024 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ErrActivityAlreadyRegistered

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

func (*ErrActivityAlreadyRegistered) Error

type ErrInvalidActivity

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

func (*ErrInvalidActivity) Error

func (e *ErrInvalidActivity) Error() string

type ErrInvalidWorkflow

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

func (*ErrInvalidWorkflow) Error

func (e *ErrInvalidWorkflow) Error() string

type ErrWorkflowAlreadyRegistered

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

func (*ErrWorkflowAlreadyRegistered) Error

type RegisterOption

type RegisterOption interface {
	// contains filtered or unexported methods
}

func WithName

func WithName(name string) RegisterOption

type Registry

type Registry struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New() *Registry

New creates a new registry instance.

func (*Registry) GetActivity

func (r *Registry) GetActivity(name string) (interface{}, error)

func (*Registry) GetWorkflow

func (r *Registry) GetWorkflow(name string) (wf.Workflow, error)

func (*Registry) RegisterActivity

func (r *Registry) RegisterActivity(activity wf.Activity, opts ...RegisterOption) error

func (*Registry) RegisterWorkflow

func (r *Registry) RegisterWorkflow(workflow wf.Workflow, opts ...RegisterOption) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL