utils

Documentation

Index

• Constants
• func ConnectToLocalServer(s *server.Server) (*nats.Conn, nats.JetStreamContext, error)
• func CreateOrGetKeyValueStore(jsc nats.JetStreamContext, conf *nats.KeyValueConfig, logger server.Logger) (nats.KeyValue, error)
• func CreateStream(s *server.Server, jsc nats.JetStreamContext, conf *nats.StreamConfig, ...) bool
• func WaitForKeyValue(s *server.Server, jsc nats.JetStreamContext, bucketName string, ...) nats.KeyValue
• func WaitForStream(s *server.Server, jsc nats.JetStreamContext, streamName string, ...) *nats.StreamInfo

Constants

const RetrySecond = 1

Functions

func ConnectToLocalServer

func ConnectToLocalServer(s *server.Server) (*nats.Conn, nats.JetStreamContext, error)

func CreateOrGetKeyValueStore

func CreateOrGetKeyValueStore(jsc nats.JetStreamContext, conf *nats.KeyValueConfig, logger server.Logger) (nats.KeyValue, error)

func CreateStream

func CreateStream(s *server.Server, jsc nats.JetStreamContext, conf *nats.StreamConfig, logger server.Logger) bool

func WaitForKeyValue

func WaitForKeyValue(s *server.Server, jsc nats.JetStreamContext, bucketName string, logger server.Logger) nats.KeyValue

func WaitForStream

func WaitForStream(s *server.Server, jsc nats.JetStreamContext, streamName string, logger server.Logger) *nats.StreamInfo