flows

Documentation

Index

• type ExportableValue
• type Metric
  • func NewMetric(samplingRate int64, computeRRPs bool, exportBufferSize uint) *Metric
  • func (m *Metric) ExportRoutine(directory string)
  • func (m *Metric) Flush()
  • func (m *Metric) OnTCPFlush(flow *flows.TCPFlow)
  • func (m *Metric) OnUDPFlush(flow *flows.UDPFlow)
  • func (m *Metric) Wait()
• type MetricFlowDuration
• type MetricFlowRate
• type MetricFlowSize
• type MetricPackets
• type MetricProtocol
• type MetricRRPs
• type ValueFlowDuration
• type ValueFlowRate
• type ValueFlowSize
• type ValuePackets
• type ValueProtocol
• type ValueRRPairs

Types

type ExportableValue

type ExportableValue interface {
	// contains filtered or unexported methods
}

type Metric

type Metric struct {
	// contains filtered or unexported fields
}

func NewMetric

func NewMetric(samplingRate int64, computeRRPs bool, exportBufferSize uint) *Metric

func (*Metric) ExportRoutine

func (m *Metric) ExportRoutine(directory string)

Should always be called as a goroutine. Writes serialized metrics directly to disk.

func (*Metric) Flush

func (m *Metric) Flush()

Closes the exportChannel, which causes all buffered metrics to be flushed.

func (*Metric) OnTCPFlush

func (m *Metric) OnTCPFlush(flow *flows.TCPFlow)

Callback that is called by the pools, once reconstruction for a flow is done. This means that this method runs concurrently.

func (*Metric) OnUDPFlush

func (m *Metric) OnUDPFlush(flow *flows.UDPFlow)

Callback that is called by the pools, once reconstruction for a flow is done. This means that this method runs concurrently.

func (*Metric) Wait

func (m *Metric) Wait()

Waits until all metrics have been written to file.

type MetricFlowDuration

type MetricFlowDuration struct{}

type MetricFlowRate

type MetricFlowRate struct {
	// contains filtered or unexported fields
}

type MetricFlowSize

type MetricFlowSize struct{}

type MetricPackets

type MetricPackets struct{}

type MetricProtocol

type MetricProtocol struct{}

type MetricRRPs

type MetricRRPs struct{}

type ValueFlowDuration

type ValueFlowDuration struct {
	// contains filtered or unexported fields
}

type ValueFlowRate

type ValueFlowRate struct {
	// contains filtered or unexported fields
}

type ValueFlowSize

type ValueFlowSize struct {
	// contains filtered or unexported fields
}

type ValuePackets

type ValuePackets struct {
	// contains filtered or unexported fields
}

type ValueProtocol

type ValueProtocol struct {
	// contains filtered or unexported fields
}

type ValueRRPairs

type ValueRRPairs struct {
	// contains filtered or unexported fields
}