traffic

Documentation

Index

• type Collector
  • func NewCollector() *Collector
  • func (c *Collector) Add(source, destination serviceidentity.ServiceIdentity, bytes, flows int)
  • func (c *Collector) PeriodicUpload(ctx context.Context, interval time.Duration)
  • func (c *Collector) RegisterNotifyTraffic(callback TrafficLevelCallbackFunc)
• type TrafficLevelCallbackFunc
• type TrafficLevelCounter
• type TrafficLevelData
• type TrafficLevelKey
• type TrafficLevelMap

Types

type Collector

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

func NewCollector

func NewCollector() *Collector

func (*Collector) Add

func (c *Collector) Add(source, destination serviceidentity.ServiceIdentity, bytes, flows int)

func (*Collector) PeriodicUpload

func (c *Collector) PeriodicUpload(ctx context.Context, interval time.Duration)

func (*Collector) RegisterNotifyTraffic

func (c *Collector) RegisterNotifyTraffic(callback TrafficLevelCallbackFunc)

type TrafficLevelCallbackFunc

type TrafficLevelCallbackFunc func(context.Context, TrafficLevelMap)

type TrafficLevelCounter

type TrafficLevelCounter map[TrafficLevelKey][]TrafficLevelData

type TrafficLevelData

type TrafficLevelData struct {
	Bytes int
	Flows int
	// contains filtered or unexported fields
}

type TrafficLevelKey

type TrafficLevelKey struct {
	SourceName           string
	SourceNamespace      string
	DestinationName      string
	DestinationNamespace string
}

type TrafficLevelMap

type TrafficLevelMap map[TrafficLevelKey]TrafficLevelData