bandwidth

Documentation

Index

• Constants
• func GetPodBandwidth(podAnnotation map[string]string, cniDriver string) (*ccev2.BindwidthOption, error)
• func InitBandwidthManager()
• func ProbeBandwidthManager()
• func SetupTBFQdisc(dev netlink.Link, bandwidthInBytes uint64) error
• type BandwidthManager
  • func (*BandwidthManager) AcceptType() event.EndpointProbeEventType
  • func (manager *BandwidthManager) Handle(event *event.EndpointProbeEvent) (*ccev2.ExtFeatureStatus, error)

Constants

const (
	AnnotaionPodIngressBandwidth = "kubernetes.io/ingress-bandwidth"
	AnnotaionPodEgressBandwidth  = "kubernetes.io/egress-bandwidth"
	AnnotaionPodBindwidthMode    = "kubernetes.io/bindwidth-mode"
)

const (
	BYTE = 1 << (10 * iota)
	KILOBYTE
	MEGABYTE
	GIGABYTE
	TERABYTE
)

bandwidth limit unit

Functions

func GetPodBandwidth

func GetPodBandwidth(podAnnotation map[string]string, cniDriver string) (*ccev2.BindwidthOption, error)

func InitBandwidthManager

func InitBandwidthManager()

func ProbeBandwidthManager

func ProbeBandwidthManager()

func SetupTBFQdisc

func SetupTBFQdisc(dev netlink.Link, bandwidthInBytes uint64) error

Types

type BandwidthManager

type BandwidthManager struct {
	Mode ccev2.BindwidthMode
}

var (
	GlobalManager *BandwidthManager
)

func (*BandwidthManager) AcceptType

func (*BandwidthManager) AcceptType() event.EndpointProbeEventType

AcceptType implements event.EndpointProbeEventHandler.

func (*BandwidthManager) Handle

func (manager *BandwidthManager) Handle(event *event.EndpointProbeEvent) (*ccev2.ExtFeatureStatus, error)

Handle implements event.EndpointProbeEventHandler.