watch

package
v1.1.1921 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddOrUpdateExecutionComplete 

func AddOrUpdateExecutionComplete(ctx context.Context, js jetstream.JetStream, namespacce string, stream string, durableName string, memoryStorage bool, fn func(state *model.WorkflowState, vars model.Vars) error) (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 durable consumer for the execution complete subject.

Types

This section is empty.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.