Documentation
¶
Index ¶
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 ...ExecutionCompleteOption) (jetstream.ConsumeContext, error)
AddOrUpdateExecutionComplete - adds a durable consumer for the execution complete subject.
func RemoveExecutionComplete ¶
func RemoveExecutionComplete(ctx context.Context, js jetstream.JetStream, stream string, durableName string, consumeContext jetstream.ConsumeContext) error
RemoveExecutionComplete - removes the subscription for the execution complete subject. If a non-empty durable name is provided, it also removes the consumer.
Types ¶
type ExecCompleteOptions ¶ added in v1.1.1929
type ExecCompleteOptions struct {
// contains filtered or unexported fields
}
ExecCompleteOptions defines configuration options for handling execution complete events. It allows filtering and customization of the consumer's behavior.
type ExecutionCompleteOption ¶ added in v1.1.1929
type ExecutionCompleteOption func(options *ExecCompleteOptions)
ExecutionCompleteOption represents a function that modifies ExecCompleteOptions for execution complete events configuration.
func WithDurableName ¶ added in v1.1.1929
func WithDurableName(durableName string) ExecutionCompleteOption
WithDurableName - set the durable name for the consumer.
func WithExecutionID ¶ added in v1.1.1953
func WithExecutionID(filter string) ExecutionCompleteOption
WithExecutionID - filter by execution id
func WithMemoryStorage ¶ added in v1.1.1929
func WithMemoryStorage() ExecutionCompleteOption
WithMemoryStorage - use memory storage for ephemeral behaviour.
func WithNamespace ¶ added in v1.1.1929
func WithNamespace(namespace string) ExecutionCompleteOption
WithNamespace - filter by namespace
func WithProcessID ¶ added in v1.1.1953
func WithProcessID(filter string) ExecutionCompleteOption
WithProcessID - filter by process id
Source Files