client

Documentation

Index

• Constants
• func SendMessage(message *ipfix.Message, conn *net.UDPConn)
• type ClientError
  • func New(ingressIfName string, raddr *net.UDPAddr, interval int) ClientError
• type Exporter
  • func NewExporter() *Exporter
  • func (e *Exporter) Run(raddr *net.UDPAddr, flowChan chan []ipfix.FieldValue) error
• type Meter
  • func NewMeter(ingressIfName string) *Meter
  • func (m *Meter) Close() error
  • func (m *Meter) Read(ctx context.Context) error
  • func (m *Meter) Run(flowChan chan []ipfix.FieldValue, interval time.Duration) error
  • func (m *Meter) Send(ctx context.Context, flowChan chan []ipfix.FieldValue, interval time.Duration) error
• type Stats
• type StatsMap

Constants

const OBSERVATION_ID uint32 = 61166

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

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

func NewMeter

func NewMeter(ingressIfName string) *Meter

func (*Meter) Close

func (m *Meter) Close() error

func (*Meter) Read

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

func (*Meter) Run

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

func (*Meter) Send

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

type Stats

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

type StatsMap

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