exporter

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(hostPort string) (*GRPCProto, error)

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

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 (kp *KafkaProto) ExportFlows(input <-chan []*flow.Record)