Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 (*GRPCProto) ExportFlows ¶
ExportFlows accepts slices of *flow.Record by its input channel, converts them to *pbflow.Records instances, and submits them to the collector.
type JSONRecord ¶ added in v0.1.1
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)
Click to show internal directories.
Click to hide internal directories.