Versions in this module Expand all Collapse all v1 v1.38.0 Jun 14, 2026 v1.37.0 Jun 13, 2026 Changes in this version + const Hostname + var HandleHigh = Def + var HandleLow = Def + var HandleMid = Def + var Router = Def + var Switch = Def + var SwitchNoMatch = Def + type Client struct + func NewClient(caller service.Publisher) Client + func (_c Client) ForHost(host string) Client + func (_c Client) WithOptions(opts ...pub.Option) Client + type Def struct + Method string + Route string + func (d Def) URL() string + type Executor struct + func NewExecutor(caller service.Publisher) Executor + func (_c Executor) ForHost(host string) Executor + func (_c Executor) HandleHigh(ctx context.Context, amount int) (branch string, err error) + func (_c Executor) HandleLow(ctx context.Context, amount int) (branch string, err error) + func (_c Executor) HandleMid(ctx context.Context, amount int) (branch string, err error) + func (_c Executor) Router(ctx context.Context, amount int) (amountOut int, err error) + func (_c Executor) Switch(ctx context.Context, amount int) (branch string, status string, err error) + func (_c Executor) SwitchNoMatch(ctx context.Context, amount int) (branch string, status string, err error) + func (_c Executor) WithFlowOptions(flowOptions *workflow.FlowOptions) Executor + func (_c Executor) WithInputFlow(flow *workflow.Flow) Executor + func (_c Executor) WithOptions(opts ...pub.Option) Executor + func (_c Executor) WithOutputFlow(flow *workflow.Flow) Executor + func (_c Executor) WithWorkflowRunner(runner WorkflowRunner) Executor + type HandleHighIn struct + Amount int + type HandleHighOut struct + Branch string + type HandleLowIn struct + Amount int + type HandleLowOut struct + Branch string + type HandleMidIn struct + Amount int + type HandleMidOut struct + Branch string + type Hook struct + func NewHook(listener service.Subscriber) Hook + func (c Hook) ForHost(host string) Hook + func (c Hook) WithOptions(opts ...sub.Option) Hook + type MulticastClient struct + func NewMulticastClient(caller service.Publisher) MulticastClient + func (_c MulticastClient) ForHost(host string) MulticastClient + func (_c MulticastClient) WithOptions(opts ...pub.Option) MulticastClient + type MulticastTrigger struct + func NewMulticastTrigger(caller service.Publisher) MulticastTrigger + func (_c MulticastTrigger) ForHost(host string) MulticastTrigger + func (_c MulticastTrigger) WithOptions(opts ...pub.Option) MulticastTrigger + type RouterIn struct + Amount int + type RouterOut struct + AmountOut int + type SwitchIn struct + Amount int + type SwitchNoMatchIn struct + Amount int + type SwitchNoMatchOut struct + Branch string + type SwitchOut struct + Branch string + type WorkflowRunner interface + Run func(ctx context.Context, workflowName string, initialState any, ...) (outcome *workflow.FlowOutcome, err error)
Go to main page