Documentation
¶
Index ¶
- Constants
- func SendTemplateRecordv4(exporter *ipfixExporter.ExportingProcess, enrichEnterpriseID uint32) (uint16, []entities.InfoElementWithValue, error)
- func SendTemplateRecordv6(exporter *ipfixExporter.ExportingProcess, enrichEnterpriseID uint32) (uint16, []entities.InfoElementWithValue, error)
- type Loki
- type WriteFake
- type WriteNone
- type Writer
Constants ¶
View Source
const IPv6Type = 0x86DD
IPv6Type value as defined in IEEE 802: https://www.iana.org/assignments/ieee-802-numbers/ieee-802-numbers.xhtml
Variables ¶
This section is empty.
Functions ¶
func SendTemplateRecordv4 ¶ added in v0.1.8
func SendTemplateRecordv4(exporter *ipfixExporter.ExportingProcess, enrichEnterpriseID uint32) (uint16, []entities.InfoElementWithValue, error)
func SendTemplateRecordv6 ¶ added in v0.1.8
func SendTemplateRecordv6(exporter *ipfixExporter.ExportingProcess, enrichEnterpriseID uint32) (uint16, []entities.InfoElementWithValue, 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 ¶ added in v0.1.3
type WriteFake struct {
// contains filtered or unexported fields
}
func (*WriteFake) AllRecords ¶ added in v0.1.3
func (w *WriteFake) AllRecords() []config.GenericMap
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 {
// contains filtered or unexported fields
}
func (*WriteNone) PrevRecords ¶
func (t *WriteNone) PrevRecords() []config.GenericMap
type Writer ¶
type Writer interface {
Write(in config.GenericMap)
}
func NewWriteFake ¶ added in v0.1.3
func NewWriteFake(_ config.StageParam) (Writer, error)
NewWriteFake creates a new write.
func NewWriteIpfix ¶ added in v0.1.8
func NewWriteIpfix(params config.StageParam) (Writer, error)
NewWriteIpfix 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.