registry

package

v1.1.2 Latest Latest Go to latest Published: Apr 5, 2025 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (e *ErrActivityAlreadyRegistered) Error() string

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

func (e *ErrInvalidActivity) Error() string

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

func (e *ErrInvalidWorkflow) Error() string

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

func (e *ErrWorkflowAlreadyRegistered) Error() string

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

func WithName(name string) RegisterOption

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

func New() *Registry

New creates a new registry instance.

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

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

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

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