bwmap

Documentation

Overview

Package bwmap represents the BPF map used to enforce Pod bandwidth limitations via EDT (Earliest Departure Time) + BPF. +groupName=maps

Index

• Constants
• func Delete(Id uint16) error
• func SilentDelete(Id uint16) error
• func ThrottleMap() *bpf.Map
• func Update(Id uint16, Bps uint64) error
• type EdtId
  • func (k *EdtId) New() bpf.MapKey
  • func (k *EdtId) String() string
• type EdtInfo
  • func (v *EdtInfo) New() bpf.MapValue
  • func (v *EdtInfo) String() string

Constants

const (
	MapName = "cilium_throttle"
	// Flow aggregate is per Pod, so same size as Endpoint map.
	MapSize = lxcmap.MaxEntries

	// DefaultDropHorizon 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.
	DefaultDropHorizon = 2 * time.Second
)

Functions

func Delete

func Delete(Id uint16) error

func SilentDelete

func SilentDelete(Id uint16) error

func ThrottleMap

func ThrottleMap() *bpf.Map

func Update

func Update(Id uint16, Bps uint64) error

Types

type EdtId

type EdtId struct {
	Id uint64 `align:"id"`
}

func (*EdtId) New

func (k *EdtId) New() bpf.MapKey

func (*EdtId) String

func (k *EdtId) String() string

type EdtInfo

type EdtInfo struct {
	Bps             uint64    `align:"bps"`
	TimeLast        uint64    `align:"t_last"`
	TimeHorizonDrop uint64    `align:"t_horizon_drop"`
	Pad             [4]uint64 `align:"pad"`
}

func (*EdtInfo) New

func (v *EdtInfo) New() bpf.MapValue

func (*EdtInfo) String

func (v *EdtInfo) String() string