message

package

v0.0.0-...-b07ed38 Latest Latest Go to latest Published: Mar 20, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kckecheng/goflow_exporter

Links

Open Source Insights

Documentation ¶

Index ¶

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

message.go

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