collector

Documentation

Index

• func CurrentTimeGetter() func() time.Time
• type Collector
  • func New(cfg Config, log logrus.FieldLogger, kubeWatcher kube.Watcher, ...) *Collector
  • func (a *Collector) GetMetricsChan() <-chan PodNetworkMetric
  • func (a *Collector) Start(ctx context.Context) error
• type Config
• type PodNetworkMetric

Functions

func CurrentTimeGetter

func CurrentTimeGetter() func() time.Time

Types

type Collector

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

func New

func New(
	cfg Config,
	log logrus.FieldLogger,
	kubeWatcher kube.Watcher,
	conntracker conntrack.Client,
	currentTimeGetter func() time.Time,
) *Collector

func (*Collector) GetMetricsChan

func (a *Collector) GetMetricsChan() <-chan PodNetworkMetric

func (*Collector) Start

func (a *Collector) Start(ctx context.Context) error

type Config

type Config struct {
	ReadInterval      time.Duration
	FlushInterval     time.Duration
	NodeName          string
	ExcludeNamespaces string
	CacheItems        int
	MetricBufferSize  int
}

type PodNetworkMetric

type PodNetworkMetric struct {
	SrcIP        string `json:"src_ip"`
	SrcPod       string `json:"src_pod,omitempty"`
	SrcNamespace string `json:"src_namespace,omitempty"`
	SrcNode      string `json:"src_node,omitempty"`
	SrcZone      string `json:"src_zone,omitempty"`
	DstIP        string `json:"dst_ip"`
	DstIPType    string `json:"dst_ip_type"`
	DstPod       string `json:"dst_pod,omitempty"`
	DstNamespace string `json:"dst_namespace,omitempty"`
	DstNode      string `json:"dst_node,omitempty"`
	DstZone      string `json:"dst_zone,omitempty"`
	TxBytes      uint64 `json:"tx_bytes"`
	TxPackets    uint64 `json:"tx_packets"`
	RxBytes      uint64 `json:"rx_bytes"`
	RxPackets    uint64 `json:"rx_packets"`
	Proto        string `json:"proto"`
	TS           uint64 `json:"ts"`
}