message

Documentation

Index

• func GetRecords(brokers []string, topic string) (<-chan *FlowRecord, <-chan *kafka.ConsumerError)
• type FlowRecord

Functions

func GetRecords

func GetRecords(brokers []string, topic string) (<-chan *FlowRecord, <-chan *kafka.ConsumerError)

GetRecords get sflow records and errors

Types

type FlowRecord

type FlowRecord struct {
	Type          string
	TimeRecvd     time.Time
	SamplingRate  uint64
	SequenceNum   uint32
	TimeFlow      time.Time
	SrcIP         string
	DstIP         string
	Bytes         uint64
	Packets       uint64
	RouterAddr    string
	SrcIf         uint32
	DstIf         uint32
	Proto         uint32
	SrcPort       uint32
	DstPort       uint32
	IPTTL         uint32
	TCPFlags      uint32
	SrcMac        uint64
	DstMac        uint64
	Etype         uint32
	IPv6FlowLabel uint32
	IngressVrfID  uint32
}

FlowRecord human readable representation for sflow message