write

Documentation

Index

• type Loki
  • func NewWriteLoki(opMetrics *operational.Metrics, params config.StageParam) (*Loki, error)
  • func (l *Loki) ProcessRecord(in config.GenericMap) error
  • func (l *Loki) Write(entry config.GenericMap)
• type WriteFake
  • func (w *WriteFake) AllRecords() []config.GenericMap
  • func (w *WriteFake) Write(in config.GenericMap)
• type WriteNone
  • func (t *WriteNone) PrevRecords() []config.GenericMap
  • func (t *WriteNone) Write(in config.GenericMap)
• type Writer
  • func NewWriteFake(_ config.StageParam) (Writer, error)
  • 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(opMetrics *operational.Metrics, params config.StageParam) (*Loki, error)

NewWriteLoki creates a Loki writer from configuration

func (*Loki) ProcessRecord

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

func (*Loki) Write

func (l *Loki) Write(entry config.GenericMap)

Write writes a flow before being stored

type WriteFake

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

func (*WriteFake) AllRecords

func (w *WriteFake) AllRecords() []config.GenericMap

func (*WriteFake) Write

func (w *WriteFake) Write(in config.GenericMap)

Write stores in memory all records.

type WriteNone

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

func (*WriteNone) PrevRecords

func (t *WriteNone) 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 NewWriteFake

func NewWriteFake(_ config.StageParam) (Writer, error)

NewWriteFake creates a new write.

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