exporter

package

v0.2.4-rc0 Latest Latest Go to latest Published: Jan 23, 2023 License: Apache-2.0 Imports: 13 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/netobserv/netobserv-ebpf-agent

Links

Open Source Insights

Documentation ¶

Index ¶

func AddRecordValuesToTemplate(log *logrus.Entry, elements *[]entities.InfoElementWithValue) error
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 GRPCProto
- func StartGRPCProto(hostPort string, maxFlowsPerMessage int) (*GRPCProto, error)
- func (g *GRPCProto) ExportFlows(input <-chan []*flow.Record)
type IPFIX
- func StartIPFIXExporter(hostPort string, transportProto string) (*IPFIX, error)
- func (ipf *IPFIX) ExportFlows(input <-chan []*flow.Record)
type JSONRecord
type KafkaProto
- func (kp *KafkaProto) ExportFlows(input <-chan []*flow.Record)

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 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(hostPort string, 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 ¶ added in v0.2.3

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

func StartIPFIXExporter ¶ added in v0.2.3

func StartIPFIXExporter(hostPort string, 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 []*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 ¶ added in v0.1.1

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

type KafkaProto ¶ added in v0.2.1

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 ¶ added in v0.2.1

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL