stream

Documentation

Index

• type Client
  • func NewNATS(url, group string, options ...nats.Option) Client
• type NATS
  • func (n *NATS) Close()
  • func (n *NATS) SendMessage(topic string, value []byte) error
  • func (n *NATS) Subscribe(topic string, f func([]byte)) error

Types

type Client

type Client interface {
	SendMessage(topic string, value []byte) error
	Subscribe(topic string, f func([]byte)) error
	Close()
}

Client provides the interface for streaming messages

func NewNATS

func NewNATS(url, group string, options ...nats.Option) Client

NewNATS returns a new stream Client instance

type NATS

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

NATS implements the stream Client interface

func (*NATS) Close

func (n *NATS) Close()

Close drains the NATS subscriptions and connection

func (*NATS) SendMessage

func (n *NATS) SendMessage(topic string, value []byte) error

SendMessage sends a stream message to NATS

func (*NATS) Subscribe

func (n *NATS) Subscribe(topic string, f func([]byte)) error

Subscribe listens to messages on a NATS stream