nats

Documentation

Index

• type Commander
  • func NewCommander(opts *options.Options, metricsCollector *metrics.Collector, ...) *Commander
  • func (c *Commander) Init() error
  • func (c *Commander) Start() error
  • func (c *Commander) Stop() error

Types

type Commander

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

Commander implements the Commander interface.

func NewCommander

func NewCommander(opts *options.Options, metricsCollector *metrics.Collector, logger *logrus.Logger) *Commander

NewCommander creates the Commander for publisher to NATS.

func (*Commander) Init

func (c *Commander) Init() error

Init implements the Commander interface and initializes the publisher to NATS.

func (*Commander) Start

func (c *Commander) Start() error

Start implements the Commander interface and starts the publisher.

func (*Commander) Stop

func (c *Commander) Stop() error

Stop implements the Commander interface and stops the publisher.