natsbroker

Documentation

Overview

Package natsbroker defines custom Nats Broker for Centrifuge library.

Index

• type Config
• type NatsBroker
  • func New(n *centrifuge.Node, conf Config) (*NatsBroker, error)
  • func (b *NatsBroker) Close(_ context.Context) error
  • func (b *NatsBroker) History(_ string, _ centrifuge.HistoryOptions) ([]*centrifuge.Publication, centrifuge.StreamPosition, error)
  • func (b *NatsBroker) Publish(ch string, data []byte, opts centrifuge.PublishOptions) (centrifuge.StreamPosition, bool, error)
  • func (b *NatsBroker) PublishControl(data []byte, nodeID, _ string) error
  • func (b *NatsBroker) PublishJoin(ch string, info *centrifuge.ClientInfo) error
  • func (b *NatsBroker) PublishLeave(ch string, info *centrifuge.ClientInfo) error
  • func (b *NatsBroker) RemoveHistory(_ string) error
  • func (b *NatsBroker) Run(h centrifuge.BrokerEventHandler) error
  • func (b *NatsBroker) Subscribe(ch string) error
  • func (b *NatsBroker) Unsubscribe(ch string) error

Types

type Config

type Config struct {
	Servers string
	Prefix  string
}

Config of NatsEngine.

type NatsBroker

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

NatsBroker is a broker on top of Nats messaging system.

func New

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

New creates NatsBroker.

func (*NatsBroker) Close

func (b *NatsBroker) Close(_ context.Context) error

Close is not implemented.

func (*NatsBroker) History

func (b *NatsBroker) History(_ string, _ centrifuge.HistoryOptions) ([]*centrifuge.Publication, centrifuge.StreamPosition, error)

History ...

func (*NatsBroker) Publish

func (b *NatsBroker) Publish(ch string, data []byte, opts centrifuge.PublishOptions) (centrifuge.StreamPosition, bool, error)

Publish - see centrifuge.Broker interface description.

func (*NatsBroker) PublishControl

func (b *NatsBroker) PublishControl(data []byte, nodeID, _ string) error

PublishControl - see centrifuge.Broker interface description.

func (*NatsBroker) PublishJoin

func (b *NatsBroker) PublishJoin(ch string, info *centrifuge.ClientInfo) error

PublishJoin - see centrifuge.Broker interface description.

func (*NatsBroker) PublishLeave

func (b *NatsBroker) PublishLeave(ch string, info *centrifuge.ClientInfo) error

PublishLeave - see centrifuge.Broker interface description.

func (*NatsBroker) RemoveHistory

func (b *NatsBroker) RemoveHistory(_ string) error

RemoveHistory ...

func (*NatsBroker) Run

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

Run runs broker after node initialized.

func (*NatsBroker) Subscribe

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

Subscribe - see centrifuge.Broker interface description.

func (*NatsBroker) Unsubscribe

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

Unsubscribe - see centrifuge.Broker interface description.