setup

Documentation

Index

• Variables
• func EnsureConsumer(js nats.JetStreamContext, streamName string, ...) error
• func EnsureStream(ctx context.Context, nc common.NatsConn, js nats.JetStreamContext, ...) error
• func EnsureWorkflowStream(ctx context.Context, nc common.NatsConn, js nats.JetStreamContext, ...) error

Variables

var ConsumerDurableNames map[string]struct{}

ConsumerDurableNames is a list of all consumers used by the engine

Functions

func EnsureConsumer

func EnsureConsumer(js nats.JetStreamContext, streamName string, consumerConfig nats.ConsumerConfig, update bool) error

EnsureConsumer creates a new consumer appending the current semantic version number to the description. If the consumer exists and has a previous version, it upgrader it.

func EnsureStream

func EnsureStream(ctx context.Context, nc common.NatsConn, js nats.JetStreamContext, streamConfig nats.StreamConfig) error

EnsureStream creates a new stream appending the current semantic version number to the description. If the stream exists and has a previous version, it upgrader it.

func EnsureWorkflowStream

func EnsureWorkflowStream(ctx context.Context, nc common.NatsConn, js nats.JetStreamContext, storageType nats.StorageType, update bool) error

EnsureWorkflowStream ensures that the workflow stream exists