exporter

Documentation

Index

• type Exporter
  • func (exporter *Exporter) Increment(flow *flow.FlowMessage)
  • func (exporter *Exporter) IncrementCtrl(topic string, partition int32, offset int64)
  • func (exporter *Exporter) RemoveTopHost(topHostType TopHostType, cid uint32, ipSrc string, ipDst string, peer string)
  • func (exporter *Exporter) TopHost(topHostType TopHostType, cid uint32, ipSrc string, ipDst string, peer string, ...)
• type TopHostType

Types

type Exporter

type Exporter struct {
}

func (*Exporter) Increment

func (exporter *Exporter) Increment(flow *flow.FlowMessage)

Increment updates the counters by one flow

func (*Exporter) IncrementCtrl

func (exporter *Exporter) IncrementCtrl(topic string, partition int32, offset int64)

IncrementCtrl updates the kafka offset counters

func (*Exporter) RemoveTopHost

func (exporter *Exporter) RemoveTopHost(topHostType TopHostType, cid uint32, ipSrc string, ipDst string, peer string)

RemoveTopHost removes the host from the counter vector

func (*Exporter) TopHost

func (exporter *Exporter) TopHost(topHostType TopHostType, cid uint32, ipSrc string, ipDst string, peer string, value uint64)

TopHost updates one entry for Top Hosts

type TopHostType

type TopHostType int32

TopHostType defines whether the top host is bytes or connections

const (
	// TopHostTypeBytes defines type byte of TopHostType
	TopHostTypeBytes TopHostType = 0
	// TopHostTypeConnections defines type connections of TopHostType
	TopHostTypeConnections TopHostType = 1
)