setup

Documentation

Index

• Variables
• func EnsureConsumer(js nats.JetStreamContext, streamName string, ...) error
• func EnsureStream(js nats.JetStreamContext, streamConfig nats.StreamConfig) error
• func EnsureWorkflowStream(js nats.JetStreamContext, storageType nats.StorageType) 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) 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 upgrades it.

func EnsureStream

func EnsureStream(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 upgrades it.

func EnsureWorkflowStream

func EnsureWorkflowStream(js nats.JetStreamContext, storageType nats.StorageType) error

EnsureWorkflowStream ensures that the workflow stream exists