write

Documentation

Index

• type Loki
  • func NewWriteLoki(params config.StageParam) (*Loki, error)
  • func (l *Loki) ProcessRecord(record config.GenericMap) error
  • func (l *Loki) Write(entries []config.GenericMap)
• type WriteNone
  • func (t *WriteNone) Write(in []config.GenericMap)
• type Writer
  • func NewWriteNone() (Writer, error)
  • func NewWriteStdout(params config.StageParam) (Writer, error)

Types

type Loki

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

Loki record writer

func NewWriteLoki

func NewWriteLoki(params config.StageParam) (*Loki, error)

NewWriteLoki creates a Loki writer from configuration

func (*Loki) ProcessRecord

func (l *Loki) ProcessRecord(record config.GenericMap) error

func (*Loki) Write

func (l *Loki) Write(entries []config.GenericMap)

Write writes a flow before being stored

type WriteNone

type WriteNone struct {
	PrevRecords []config.GenericMap
}

func (*WriteNone) Write

func (t *WriteNone) Write(in []config.GenericMap)

Write writes entries

type Writer

type Writer interface {
	Write(in []config.GenericMap)
}

func NewWriteNone

func NewWriteNone() (Writer, error)

NewWriteNone create a new write

func NewWriteStdout

func NewWriteStdout(params config.StageParam) (Writer, error)

NewWriteStdout create a new write