loki

Documentation

Index

• Constants
• func Setup(bs json.RawMessage) (types.OutputPlugin, error)
• func ToLabelSet(dm *types.DnstapMessage) model.LabelSet
• type Loki
  • func (f *Loki) Close()
  • func (f *Loki) Open() error
  • func (f *Loki) SetOutputContext(oc *types.OutputContext)
  • func (f *Loki) 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)

func ToLabelSet

func ToLabelSet(dm *types.DnstapMessage) model.LabelSet

Types

type Loki

type Loki struct {
	plugin.PluginCommon
	sync.Mutex

	MaxStream   int
	MaxLineSize int
	client.Config
	client.Client

	*output.DnstapOutput
	// contains filtered or unexported fields
}

The loki plugin outputs messages to the loki server.

func (*Loki) Close

func (f *Loki) Close()

func (*Loki) Open

func (f *Loki) Open() error

func (*Loki) SetOutputContext

func (f *Loki) SetOutputContext(oc *types.OutputContext)

func (*Loki) Write

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