nats

Documentation

Index

• Constants
• func Setup(bs json.RawMessage) (types.OutputPlugin, error)
• type Nats
  • func (f *Nats) Close()
  • func (f *Nats) Open() error
  • func (f *Nats) Publish(data []byte) error
  • func (f *Nats) Write(dm *types.DnstapMessage) error

Constants

const DefaultMaxPayloadSize = 1024 * 1024

const DnstapFstrmControlHeaderSize = 42

const DnstapFstrmMsgHeaderSize = 4

Functions

func Setup

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

Types

type Nats

type Nats struct {
	plugin.PluginCommon
	sync.Mutex

	*output.DnstapOutput

	// config
	Hosts   []string
	Subject string

	User     string
	Password string
	Token    string

	MaxSize     int
	IntervalSec uint
	Format      pub.Format
	// contains filtered or unexported fields
}

func (*Nats) Close

func (f *Nats) Close()

func (*Nats) Open

func (f *Nats) Open() error

func (*Nats) Publish

func (f *Nats) Publish(data []byte) error

func (*Nats) Write

func (f *Nats) Write(dm *types.DnstapMessage) error