natsbridge

Documentation

Index

• type Bridge
  • func New(url string) (*Bridge, error)
  • func (b *Bridge) Receive(hubID string, fn func(string, []byte)) error
  • func (b *Bridge) ReceiveHeartbeat(hubID string, fn func(string, []string)) error
  • func (b *Bridge) Send(hubID, topic string, msg []byte) error
  • func (b *Bridge) SendHeartbeat(hubID, userID string, topics []string) error

Types

type Bridge

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

func New

func New(url string) (*Bridge, error)

TODO drain, ctx

func (*Bridge) Receive

func (b *Bridge) Receive(hubID string, fn func(string, []byte)) error

func (*Bridge) ReceiveHeartbeat

func (b *Bridge) ReceiveHeartbeat(hubID string, fn func(string, []string)) error

func (*Bridge) Send

func (b *Bridge) Send(hubID, topic string, msg []byte) error

func (*Bridge) SendHeartbeat

func (b *Bridge) SendHeartbeat(hubID, userID string, topics []string) error