exporter

package
v1.8.1-crc0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 11, 2025 License: Apache-2.0 Imports: 25 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddRecordValuesToTemplate added in v0.2.4 

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

func SendTemplateRecordv4 added in v0.2.3 

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

func SendTemplateRecordv6 added in v0.2.3 

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

Types

type DirectFLP added in v0.3.3 

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

DirectFLP flow exporter

func StartDirectFLP added in v0.3.3 

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

func (*DirectFLP) Close added in v0.3.3 

func (d *DirectFLP) Close()

func (*DirectFLP) ExportFlows added in v0.3.3 

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

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

func (*DirectFLP) ExportPackets 

func (d *DirectFLP) ExportPackets(input <-chan []*model.PacketRecord)

ExportPackets accepts slices of *model.PacketRecord by its input channel, converts them to *pbflow.Records instances, and submits them to the collector.

type GRPCPacketProto 

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

func StartGRPCPacketSend 

func StartGRPCPacketSend(hostIP string, hostPort int) (*GRPCPacketProto, error)

func (*GRPCPacketProto) ExportGRPCPackets 

func (p *GRPCPacketProto) ExportGRPCPackets(in <-chan []*model.PacketRecord)

type GRPCProto 

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

GRPCProto flow exporter. Its ExportFlows method accepts slices of *model.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, m *metrics.Metrics) (*GRPCProto, error)

func (*GRPCProto) ExportFlows 

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

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

type IPFIX added in v0.2.3 

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

func StartIPFIXExporter added in v0.2.3 

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

Sends out Template record to the IPFIX collector

func (*IPFIX) ExportFlows added in v0.2.3 

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

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

type JSONRecord added in v0.1.1 

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

type KafkaProto added in v0.2.1 

type KafkaProto struct {
	Writer  kafkaWriter
	Metrics *metrics.Metrics
}

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

func (*KafkaProto) ExportFlows added in v0.2.1 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.