broker

Documentation

Index

• func DrainConnection() broker.Option
• func NewBroker(opts ...broker.Option) broker.Broker
• func Options(opts natsGo.Options) broker.Option
• func WithDeliverAll() broker.SubscribeOption
• func WithDeliverLast() broker.SubscribeOption
• func WithDeliverNew() broker.SubscribeOption
• func WithHeaders(h map[string][]string) broker.PublishOption
• func WithJetStream(streamCnf natsGo.StreamConfig) broker.Option
• type MessageCarrier
  • func NewMessageCarrier(msg *natsGo.Msg) MessageCarrier
  • func (c MessageCarrier) Get(key string) string
  • func (c MessageCarrier) Keys() []string
  • func (c MessageCarrier) Set(key, val string)

Functions

func DrainConnection

func DrainConnection() broker.Option

func NewBroker

func NewBroker(opts ...broker.Option) broker.Broker

func Options

func Options(opts natsGo.Options) broker.Option

func WithDeliverAll

func WithDeliverAll() broker.SubscribeOption

func WithDeliverLast

func WithDeliverLast() broker.SubscribeOption

func WithDeliverNew

func WithDeliverNew() broker.SubscribeOption

func WithHeaders

func WithHeaders(h map[string][]string) broker.PublishOption

func WithJetStream

func WithJetStream(streamCnf natsGo.StreamConfig) broker.Option

Types

type MessageCarrier

type MessageCarrier struct {
	// contains filtered or unexported fields
}

func NewMessageCarrier

func NewMessageCarrier(msg *natsGo.Msg) MessageCarrier

func (MessageCarrier) Get

func (c MessageCarrier) Get(key string) string

func (MessageCarrier) Keys

func (c MessageCarrier) Keys() []string

func (MessageCarrier) Set

func (c MessageCarrier) Set(key, val string)