mb

Documentation

Index

• func NewNatsPublisher(nc *nats.Conn) *natsPublisher
• func NewNatsServer() *natsServer
• func NewNatsSubscriber(nc *nats.Conn) *natsSubscriber
• type PubOpts
• type Publisher
• type SubRec
• type Subscriber

Functions

func NewNatsPublisher

func NewNatsPublisher(nc *nats.Conn) *natsPublisher

func NewNatsServer

func NewNatsServer() *natsServer

func NewNatsSubscriber

func NewNatsSubscriber(nc *nats.Conn) *natsSubscriber

Types

type PubOpts

type PubOpts func(o *options)

type Publisher

type Publisher interface {
	Publish(stream, subj string, sender interface{}, o ...PubOpts) (interface{}, error)
}

type SubRec

type SubRec func(o *options)

type Subscriber

type Subscriber interface {
	Delivery(receivers ...SubRec) error

	Subscribe(stream, subj, cons string, cmd endpoint.Endpoint) SubRec

	Close() error
}