pubsub

Documentation

Index

• type AtomBool
  • func (b *AtomBool) IsTrue() bool
  • func (b *AtomBool) Set(value bool)
• type Context
  • func New(config map[string]string) *Context
  • func (ctx *Context) Close()
  • func (ctx *Context) Connect(username string, register, subscribe []string) error
  • func (ctx *Context) Payload(msg *server.Msg) []byte
  • func (ctx *Context) Publish(channel string, message []byte) error
  • func (ctx *Context) PublishStr(channel string, message string) error
  • func (ctx *Context) PublishTTL(channel string, message []byte, ttl int) error
  • func (ctx *Context) PublishTTLStr(channel string, message string, ttl int) error
  • func (ctx *Context) Register(channel string) error
  • func (ctx *Context) Subscribe(channel string) (err error)
  • func (ctx *Context) Topic(msg *server.Msg) string

Types

type AtomBool

type AtomBool int32

func (*AtomBool) IsTrue

func (b *AtomBool) IsTrue() bool

func (*AtomBool) Set

func (b *AtomBool) Set(value bool)

type Context

type Context struct {
	Config        map[string]string
	InMsgs        chan *server.Msg
	SubToIndex    map[string]int
	Subscriptions []*server.Subscription
	SubChannels   []string
	Client        *server.Conn
	Connected     *AtomBool
	Tick          *server.Msg
}

Context contains the necessary information to run the Nats client

func New

func New(config map[string]string) *Context

func (*Context) Close

func (ctx *Context) Close()

func (*Context) Connect

func (ctx *Context) Connect(username string, register, subscribe []string) error

func (*Context) Payload

func (ctx *Context) Payload(msg *server.Msg) []byte

func (*Context) Publish

func (ctx *Context) Publish(channel string, message []byte) error

func (*Context) PublishStr

func (ctx *Context) PublishStr(channel string, message string) error

func (*Context) PublishTTL

func (ctx *Context) PublishTTL(channel string, message []byte, ttl int) error

func (*Context) PublishTTLStr

func (ctx *Context) PublishTTLStr(channel string, message string, ttl int) error

func (*Context) Register

func (ctx *Context) Register(channel string) error

func (*Context) Subscribe

func (ctx *Context) Subscribe(channel string) (err error)

func (*Context) Topic

func (ctx *Context) Topic(msg *server.Msg) string