collector

Documentation

Index

• func CurrentTimeGetter() func() time.Time
• type Collector
  • func New(cfg Config, log logrus.FieldLogger, podsWatcher podsWatcher, ...) *Collector
  • func (c *Collector) GetRawNetworkMetricsHandler(w http.ResponseWriter, req *http.Request)
  • func (c *Collector) Start(ctx context.Context) error
• type Config

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,
	podsWatcher podsWatcher,
	conntracker conntrack.Client,
	ip2dns dnsRecorder,
	currentTimeGetter func() time.Time,
) *Collector

func (*Collector) GetRawNetworkMetricsHandler

func (c *Collector) GetRawNetworkMetricsHandler(w http.ResponseWriter, req *http.Request)

func (*Collector) Start

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

type Config

type Config struct {
	// ReadInterval used for conntrack records scrape.
	ReadInterval time.Duration
	// CleanupInterval used to remove expired conntrack and pod metrics records.
	CleanupInterval time.Duration
	// NodeName is current node name on which egressd is running.
	NodeName string
	// ExcludeNamespaces allows to exclude namespaces. Input is comma separated string.
	ExcludeNamespaces string
	// GroupPublicIPs will group all public destinations under single 0.0.0.0 IP.
	GroupPublicIPs bool
	// SendTrafficDelta used to determines if traffic should be sent as delta of 2 consecutive conntrack entries
	// or as the constantly growing counter value
	SendTrafficDelta bool
}