registry

package

v1.0.0 Latest Latest Go to latest Published: Jul 9, 2025 License: MIT Imports: 6 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) (any, error)

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

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