Documentation
¶
Overview ¶
Package schedule provides explicit correlation lifecycle helpers for scheduled work. Independent invocations start independent workflows unless application-owned metadata is deliberately propagated.
Deprecated: use github.com/faustbrian/go-correlation/adapters/schedule. This package remains supported through the documented compatibility interval.
Index ¶
- Variables
- type Adapter
- func (adapter *Adapter) Create() (correlation.Values, error)
- func (adapter *Adapter) Enqueue(metadata map[string]string, parent correlation.Values) (correlation.Values, error)
- func (adapter *Adapter) Receive(metadata map[string]string, trusted bool) (correlation.Values, error)
- func (adapter *Adapter) Run(metadata map[string]string, trusted bool) (correlation.Values, error)deprecated
- func (adapter *Adapter) Start() (correlation.Values, error)deprecated
- type Options
Constants ¶
This section is empty.
Variables ¶
var ErrInvalidOptions = errors.New("schedule correlation: invalid options")
ErrInvalidOptions reports missing scheduled-work dependencies.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
Adapter starts independent runs and explicitly propagates scheduled jobs.
func New ¶
func New(factory *correlation.Factory, options Options) (*Adapter, error)
New constructs a scheduled-work adapter.
func (*Adapter) Create ¶ added in v1.1.0
func (adapter *Adapter) Create() (correlation.Values, error)
Create begins an independent scheduler invocation with no implicit derived or stable workflow identity.
func (*Adapter) Enqueue ¶
func (adapter *Adapter) Enqueue(metadata map[string]string, parent correlation.Values) (correlation.Values, error)
Enqueue creates a child scheduled-work message.
func (*Adapter) Receive ¶ added in v1.1.0
func (adapter *Adapter) Receive(metadata map[string]string, trusted bool) (correlation.Values, error)
Receive receives explicitly trusted scheduler metadata as a fresh attempt.
func (*Adapter) Start
deprecated
func (adapter *Adapter) Start() (correlation.Values, error)
Start begins an independent scheduler invocation with no implicit derived or stable workflow identity.
Deprecated: use Create.
type Options ¶
type Options struct {
Queue queuecorrelation.Options
}
Options configure optional scheduled metadata propagation.
Source Files