nats

Documentation

Index

• Variables
• func Broker(options ...Option) eventsource.Broker
• type Option
  • func WithAddress(address string) Option
  • func WithMaxAge(ttl time.Duration) Option
  • func WithMaxBytes(maxBytes int64) Option
  • func WithMaxMsgs(maxMsgs int64) Option

Variables

var ErrInvalidNamespace = fmt.Errorf("key does not have valid namespace: e.g. 'usercreated' instead of 'user.created'")

var ErrNotConnected = fmt.Errorf("not connected")

Functions

func Broker

func Broker(options ...Option) eventsource.Broker

Types

type Option

type Option func(c *client)

func WithAddress

func WithAddress(address string) Option

func WithMaxAge

func WithMaxAge(ttl time.Duration) Option

func WithMaxBytes

func WithMaxBytes(maxBytes int64) Option

func WithMaxMsgs

func WithMaxMsgs(maxMsgs int64) Option