exporter

Documentation

Index

• func AddRecordValuesToTemplate(log *logrus.Entry, elements *[]entities.InfoElementWithValue) error
• func ConvertToFLP(fr *flow.Record) config.GenericMap
• func SendTemplateRecordv4(log *logrus.Entry, exporter *ipfixExporter.ExportingProcess) (uint16, []entities.InfoElementWithValue, error)
• func SendTemplateRecordv6(log *logrus.Entry, exporter *ipfixExporter.ExportingProcess) (uint16, []entities.InfoElementWithValue, error)
• type DirectFLP
  • func StartDirectFLP(jsonConfig string, bufLen int) (*DirectFLP, error)
  • func (d *DirectFLP) Close()
  • func (d *DirectFLP) ExportFlows(input <-chan []*flow.Record)
• type GRPCProto
  • func StartGRPCProto(hostIP string, hostPort int, maxFlowsPerMessage int) (*GRPCProto, error)
  • func (g *GRPCProto) ExportFlows(input <-chan []*flow.Record)
• type IPFIX
  • func StartIPFIXExporter(hostIP string, hostPort int, transportProto string) (*IPFIX, error)
  • func (ipf *IPFIX) ExportFlows(input <-chan []*flow.Record)
• type JSONRecord
• type KafkaProto
  • func (kp *KafkaProto) ExportFlows(input <-chan []*flow.Record)
• type PCAPStream
  • func StartPCAPSend(hostPort string) (*PCAPStream, error)
  • func (p *PCAPStream) ExportFlows(in <-chan []*flow.PacketRecord)

Functions

func AddRecordValuesToTemplate

func AddRecordValuesToTemplate(log *logrus.Entry, elements *[]entities.InfoElementWithValue) error

func ConvertToFLP

func ConvertToFLP(fr *flow.Record) config.GenericMap

ConvertToFLP converts the flow from Agent inner model into FLP GenericMap model

func SendTemplateRecordv4

func SendTemplateRecordv4(log *logrus.Entry, exporter *ipfixExporter.ExportingProcess) (uint16, []entities.InfoElementWithValue, error)

func SendTemplateRecordv6

func SendTemplateRecordv6(log *logrus.Entry, exporter *ipfixExporter.ExportingProcess) (uint16, []entities.InfoElementWithValue, error)

Types

type DirectFLP

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

DirectFLP flow exporter

func StartDirectFLP

func StartDirectFLP(jsonConfig string, bufLen int) (*DirectFLP, error)

func (*DirectFLP) Close

func (d *DirectFLP) Close()

func (*DirectFLP) ExportFlows

func (d *DirectFLP) ExportFlows(input <-chan []*flow.Record)

ExportFlows accepts slices of *flow.Record by its input channel, converts them to *pbflow.Records instances, and submits them to the collector.

type GRPCProto

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

GRPCProto flow exporter. Its ExportFlows method accepts slices of *flow.Record by its input channel, converts them to *pbflow.Records instances, and submits them to the collector.

func StartGRPCProto

func StartGRPCProto(hostIP string, hostPort int, maxFlowsPerMessage int) (*GRPCProto, error)

func (*GRPCProto) ExportFlows

func (g *GRPCProto) ExportFlows(input <-chan []*flow.Record)

ExportFlows accepts slices of *flow.Record by its input channel, converts them to *pbflow.Records instances, and submits them to the collector.

type IPFIX

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

func StartIPFIXExporter

func StartIPFIXExporter(hostIP string, hostPort int, transportProto string) (*IPFIX, error)

Sends out Template record to the IPFIX collector

func (*IPFIX) ExportFlows

func (ipf *IPFIX) ExportFlows(input <-chan []*flow.Record)

ExportFlows accepts slices of *flow.Record by its input channel, converts them to IPFIX Records, and submits them to the collector.

type JSONRecord

type JSONRecord struct {
	*flow.Record
	TimeFlowStart   int64
	TimeFlowEnd     int64
	TimeFlowStartMs int64
	TimeFlowEndMs   int64
}

type KafkaProto

type KafkaProto struct {
	Writer kafkaWriter
}

KafkaProto exports flows over Kafka, encoded as a protobuf that is understandable by the Flowlogs-Pipeline collector

func (*KafkaProto) ExportFlows

func (kp *KafkaProto) ExportFlows(input <-chan []*flow.Record)

type PCAPStream

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

func StartPCAPSend

func StartPCAPSend(hostPort string) (*PCAPStream, error)

FIXME: Only after client connects to it, the agent starts collecting and sending packets. This behavior needs to be fixed.

func (*PCAPStream) ExportFlows

func (p *PCAPStream) ExportFlows(in <-chan []*flow.PacketRecord)