Documentation
¶
Overview ¶
Package schedule provides explicit correlation lifecycle helpers for scheduled work. Independent invocations start independent workflows unless application-owned metadata is deliberately propagated.
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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) Enqueue ¶
func (adapter *Adapter) Enqueue(metadata map[string]string, parent correlation.Values) (correlation.Values, error)
Enqueue creates a child scheduled-work message.
type Options ¶
type Options struct {
Queue queuecorrelation.Options
}
Options configure optional scheduled metadata propagation.
Source Files
Click to show internal directories.
Click to hide internal directories.