start

Documentation

Index

• Variables
• func EnsureConsumer(js nats.JetStreamContext, streamName string, ...) error

Variables

var Cmd = &cobra.Command{
	Use:   "start",
	Short: "Starts a new execution",
	Long:  `shar workflow start "ProcessID"`,
	RunE:  run,
	Args:  cobra.MatchAll(cobra.ExactArgs(1), cobra.OnlyValidArgs),
}

Cmd is the cobra command object

Functions

func EnsureConsumer

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

EnsureConsumer sets up the consumer in NATS if one doesn't exist already