natsbroker

Mar 13, 2019

Changes in this version

+ type Config struct

+ Prefix string

+ Servers string

+ type NatsBroker struct

+ func New(n *centrifuge.Node, conf Config) (*NatsBroker, error)

+ func (b *NatsBroker) Channels() ([]string, error)

+ func (b *NatsBroker) Close(ctx context.Context) error

+ func (b *NatsBroker) Publish(ch string, pub *centrifuge.Publication, opts *centrifuge.ChannelOptions) error

+ func (b *NatsBroker) PublishControl(data []byte) error

+ func (b *NatsBroker) PublishJoin(ch string, join *centrifuge.Join, opts *centrifuge.ChannelOptions) error

+ func (b *NatsBroker) PublishLeave(ch string, leave *centrifuge.Leave, opts *centrifuge.ChannelOptions) error

+ func (b *NatsBroker) Run(h centrifuge.BrokerEventHandler) error

+ func (b *NatsBroker) Subscribe(ch string) error

+ func (b *NatsBroker) Unsubscribe(ch string) error