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, w types.Writer) error
  • func (f *Nats) Subscribe(ctx context.Context, w types.Writer) error

Functions

func Setup

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

Types

type Nats

type Nats struct {
	plugin.PluginCommon
	sync.Mutex

	*output.DnstapOutput

	// config
	Hosts     []string
	Subject   string
	QueueName string
	QueueLen  int

	User     string
	Password string
	Token    string

	Format input.Format
}

func (*Nats) Open

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

func (*Nats) Start

func (f *Nats) Start(ctx context.Context, w types.Writer) error

func (*Nats) Subscribe

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