nats

Documentation

Index

• func Setup(bs json.RawMessage) (types.InputPlugin, error)
• type Nats
  • func (f *Nats) Open() (*nats.Conn, error)
  • func (f *Nats) Start(ctx context.Context, ic *types.InputContext) error
  • func (f *Nats) Subscribe(ctx context.Context, w types.Writer, ic *types.InputContext) error

Functions

func Setup

func Setup(bs json.RawMessage) (types.InputPlugin, error)

Types

type Nats

type Nats struct {
	plugin.PluginCommon
	// Nats message format
	input.FormatMeta

	sync.Mutex

	// Hosts is the URL of the nats servers. Must not be empty.
	Hosts []string
	// Nats subject. Must not be empty.
	Subject string
	// Nats queue name.
	QueueName string
	// QueueLen is nats subscriber queue length.
	QueueLen int

	// Nats user, If a token is given, it is not used.
	User string
	// Nats password, If a token is given, it is not used.
	Password string
	// Nats token
	Token string
	// contains filtered or unexported fields
}

The nats plugin retrieves messages from the nats server.

func (*Nats) Open

func (f *Nats) Open() (*nats.Conn, error)

func (*Nats) Start

func (f *Nats) Start(ctx context.Context, ic *types.InputContext) error

func (*Nats) Subscribe

func (f *Nats) Subscribe(ctx context.Context, w types.Writer, ic *types.InputContext) error