bandwidth

Documentation

Overview

Package bandwidth provides efficient EDT-based rate-limiting.

Index

• Constants
• Variables
• func GetBytesPerSec(bandwidth string) (uint64, error)
• type Config
  • func (def Config) Flags(flags *pflag.FlagSet)

Constants

const (
	// EgressBandwidth is the K8s Pod annotation.
	EgressBandwidth = "kubernetes.io/egress-bandwidth"
	// IngressBandwidth is the K8s Pod annotation.
	IngressBandwidth = "kubernetes.io/ingress-bandwidth"

	EnableBBR = "enable-bbr"

	// FqDefaultHorizon represents maximum allowed departure
	// time delta in future. Given applications can set SO_TXTIME
	// from user space this is a limit to prevent buggy applications
	// to fill the FQ qdisc.
	FqDefaultHorizon = bwmap.DefaultDropHorizon
	// FqDefaultBuckets is the default 32k (2^15) bucket limit for bwm.
	// Too low bucket limit can cause scalability issue.
	FqDefaultBuckets = 15
)

Variables

var Cell = cell.Module(
	"bandwidth-manager",
	"Linux Bandwidth Manager for EDT-based pacing",

	cell.Config(Config{false, false}),
	cell.Provide(newBandwidthManager),

	cell.ProvidePrivate(
		tables.NewBandwidthQDiscTable,
		newReconcilerConfig,
	),
	cell.Invoke(registerReconciler),
)

Functions

func GetBytesPerSec

func GetBytesPerSec(bandwidth string) (uint64, error)

Types

type Config

type Config struct {
	// EnableBandwidthManager enables EDT-based pacing
	EnableBandwidthManager bool

	// EnableBBR enables BBR TCP congestion control for the node including Pods
	EnableBBR bool
}

func (Config) Flags

func (def Config) Flags(flags *pflag.FlagSet)