Documentation
¶
Index ¶
- func AddOrUpdateExecutionComplete(ctx context.Context, js jetstream.JetStream, ...) (jetstream.ConsumeContext, error)
- func AddOrUpdateProcessComplete(ctx context.Context, js jetstream.JetStream, ...) (jetstream.ConsumeContext, error)
- func RemoveCompletionListener(ctx context.Context, js jetstream.JetStream, stream string, durableName string, ...) error
- type CompletionOption
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddOrUpdateExecutionComplete ¶
func AddOrUpdateExecutionComplete(ctx context.Context, js jetstream.JetStream, fn func(state *model.WorkflowState, vars model.Vars) error, opts ...CompletionOption) (jetstream.ConsumeContext, error)
AddOrUpdateExecutionComplete - adds a durable consumer for the execution complete subject.
func AddOrUpdateProcessComplete ¶ added in v1.1.2115
func AddOrUpdateProcessComplete(ctx context.Context, js jetstream.JetStream, fn func(state *model.WorkflowState, vars model.Vars) error, opts ...CompletionOption) (jetstream.ConsumeContext, error)
AddOrUpdateProcessComplete - adds a durable consumer for the process complete subject.
func RemoveCompletionListener ¶ added in v1.1.2115
func RemoveCompletionListener(ctx context.Context, js jetstream.JetStream, stream string, durableName string, consumeContext jetstream.ConsumeContext) error
RemoveCompletionListener - removes the subscription for the execution complete subject. If a non-empty durable name is provided, it also removes the consumer.
Types ¶
type CompletionOption ¶ added in v1.1.2115
type CompletionOption func(options *completionOptions)
CompletionOption represents a function that modifies completionOptions for execution complete events configuration.
func WithDurableName ¶ added in v1.1.1929
func WithDurableName(durableName string) CompletionOption
WithDurableName - set the durable name for the consumer.
func WithExecutionID ¶ added in v1.1.1953
func WithExecutionID(filter string) CompletionOption
WithExecutionID - filter by execution id
func WithMemoryStorage ¶ added in v1.1.1929
func WithMemoryStorage() CompletionOption
WithMemoryStorage - use memory storage for ephemeral behaviour.
func WithNamespace ¶ added in v1.1.1929
func WithNamespace(namespace string) CompletionOption
WithNamespace - filter by namespace
func WithProcessID ¶ added in v1.1.1953
func WithProcessID(filter string) CompletionOption
WithProcessID - filter by process id
Source Files
Click to show internal directories.
Click to hide internal directories.