Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 WriteFake ¶ added in v0.1.3
type WriteFake struct {
AllRecords []config.GenericMap
// contains filtered or unexported fields
}
func (*WriteFake) ResetWait ¶ added in v0.1.3
func (w *WriteFake) ResetWait()
ResetWait resets the wait channel to allow waiters to block on Wait() for the next Write(). It should be invoked after Write() is done and all waiters are released.
func (*WriteFake) Wait ¶ added in v0.1.3
func (w *WriteFake) Wait()
Wait waits until Write() is done processing all the records.
func (*WriteFake) Write ¶ added in v0.1.3
func (w *WriteFake) Write(in []config.GenericMap)
Write stores in memory all records.
type WriteNone ¶
type WriteNone struct {
PrevRecords []config.GenericMap
}
type Writer ¶
type Writer interface {
Write(in []config.GenericMap)
}
func NewWriteFake ¶ added in v0.1.3
func NewWriteFake(params config.StageParam) (Writer, error)
NewWriteFake creates a new write.
func NewWriteStdout ¶
func NewWriteStdout(params config.StageParam) (Writer, error)
NewWriteStdout create a new write
Source Files
Click to show internal directories.
Click to hide internal directories.