convertor

Documentation

Index

• type IPFIXToKafkaConvertor

Types

type IPFIXToKafkaConvertor

type IPFIXToKafkaConvertor interface {
	// ConvertIPFIXMsgToFlowMsgs converts multiple data records in the IPFIX message
	// to flow messages for any given proto schema.
	ConvertIPFIXMsgToFlowMsgs(msg *entities.Message) []protoreflect.Message
	// ConvertIPFIXRecordToFlowMsg converts a single IPFIX record to a kafka flow
	// message for any given proto schema. Some times producers are interacting
	// with the intermediate process instead of the collector process, where only
	// the record is available.
	ConvertIPFIXRecordToFlowMsg(record entities.Record) protoreflect.Message
}

IPFIXToKafkaConvertor is an interface to support multiple proto schema for Kafka producer.