jetstream

Documentation

Index

• Constants
• Variables
• func Init(opts ...options.Option) (axon.EventStore, error)
• func PrettyJson(data interface{})

Constants

const Empty = ""

Variables

var (
	ErrJetstreamServerRequired = errors.New("jetstream must be connected to a jetstream enabled nats-server")
	ErrJetstreamMustBeEnabled  = errors.New("jetstream must be enabled on this axon client")
)

Functions

func Init

func Init(opts ...options.Option) (axon.EventStore, error)

func PrettyJson

func PrettyJson(data interface{})