natsinput

Documentation

Index

• Variables
• func MustNewNatsConnection(c config.NatsConf) *nats.Conn
• func NewNatsConnection(c config.NatsConf) (*nats.Conn, error)
• type ConsumeHandler
• type Nats
  • func NewNats(c config.NatsConf, handler ConsumeHandler) *Nats
  • func (n *Nats) Start()
  • func (n *Nats) Stop()

Variables

var (
	InvalidFormatError    = errors.New("invalid format")
	EmptyAuthContentError = errors.New("empty auth content")
)

Functions

func MustNewNatsConnection

func MustNewNatsConnection(c config.NatsConf) *nats.Conn

func NewNatsConnection

func NewNatsConnection(c config.NatsConf) (*nats.Conn, error)

Types

type ConsumeHandler

type ConsumeHandler interface {
	Consume(key string, value string) error
}

type Nats

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

func NewNats

func NewNats(c config.NatsConf, handler ConsumeHandler) *Nats

func (*Nats) Start

func (n *Nats) Start()

func (*Nats) Stop

func (n *Nats) Stop()