nats

Documentation

Index

• type PubSub
  • func (ps *PubSub) Pub(topic string, data []byte) error
  • func (ps *PubSub) Sub(topic string, cb func(data []byte)) (unsub func() error, err error)

Types

type PubSub

type PubSub struct {
	Conn *nats.Conn
}

PubSub implementation using NATS server.

func (*PubSub) Pub

func (ps *PubSub) Pub(topic string, data []byte) error

Pub publishes some data to the given topic.

func (*PubSub) Sub

func (ps *PubSub) Sub(topic string, cb func(data []byte)) (unsub func() error, err error)

Sub subscribes the given callback function to the interested topic.