Documentation ¶
Index ¶
- type ErrActivityAlreadyRegistered
- type ErrInvalidActivity
- type ErrInvalidWorkflow
- type ErrWorkflowAlreadyRegistered
- type RegisterOption
- type Registry
- 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
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 ¶
func (e *ErrActivityAlreadyRegistered) Error() string
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 ¶
func (e *ErrWorkflowAlreadyRegistered) Error() string
type RegisterOption ¶
type RegisterOption interface {
// contains filtered or unexported methods
}
func WithName ¶
func WithName(name string) RegisterOption
type Registry ¶
func (*Registry) GetActivity ¶
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
Click to show internal directories.
Click to hide internal directories.