client

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 14, 2023 License: MIT Imports: 17 Imported by: 2

Documentation

Index

Constants

View Source
const OBSERVATION_ID uint32 = 61166

Variables

This section is empty.

Functions

func SendMessage

func SendMessage(message *ipfix.Message, conn *net.UDPConn)

Types

type ClientError

type ClientError struct {
	Component string
	Error     error
}

func New

func New(ingressIfName string, raddr *net.UDPAddr, interval int) ClientError

type Exporter

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

func NewExporter

func NewExporter() *Exporter

func (*Exporter) Run

func (e *Exporter) Run(raddr *net.UDPAddr, flowChan chan []ipfix.FieldValue) error

type Meter added in v1.2.0

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

func NewMeter added in v1.1.0

func NewMeter(ingressIfName string) *Meter

func (*Meter) Close added in v1.2.0

func (m *Meter) Close() error

func (*Meter) Read added in v1.2.0

func (m *Meter) Read(ctx context.Context) error

func (*Meter) Run added in v1.2.0

func (m *Meter) Run(flowChan chan []ipfix.FieldValue, interval time.Duration) error

func (*Meter) Send added in v1.2.0

func (m *Meter) Send(ctx context.Context, flowChan chan []ipfix.FieldValue, intervalSec time.Duration) error

type Stats added in v1.2.0

type Stats struct {
	Count     int64
	DelayMean int64
	DelayMin  int64
	DelayMax  int64
	DelaySum  int64
}

type StatsMap added in v1.2.0

type StatsMap struct {
	Mu sync.RWMutex
	Db map[meter.ProbeData]*Stats
}

Jump to

Keyboard shortcuts

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