bandwidth_manager

Documentation

Index

• Variables
• type BandwidthManager
• type ContainerBandwidthManager
  • func New(containerPath, containerID string, runner command_runner.CommandRunner) *ContainerBandwidthManager
  • func (m *ContainerBandwidthManager) GetLimits(logger lager.Logger) (garden.ContainerBandwidthStat, error)
  • func (m *ContainerBandwidthManager) SetLimits(logger lager.Logger, limits garden.BandwidthLimits) error

Variables

var IN_RATE_PATTERN = regexp.MustCompile(`qdisc tbf [0-9a-f]+: root refcnt \d+ rate (\d+)([KMG]?)bit burst (\d+)([KMG]?)b`)

var OUT_RATE_PATTERN = regexp.MustCompile(`police 0x[0-9a-f]+ rate (\d+)([KMG]?)bit burst (\d+)([KMG]?)b`)

Types

type BandwidthManager

type BandwidthManager interface {
	SetLimits(lager.Logger, garden.BandwidthLimits) error
	GetLimits(lager.Logger) (garden.ContainerBandwidthStat, error)
}

type ContainerBandwidthManager

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

func New

func New(containerPath, containerID string, runner command_runner.CommandRunner) *ContainerBandwidthManager

func (*ContainerBandwidthManager) GetLimits

func (m *ContainerBandwidthManager) GetLimits(logger lager.Logger) (garden.ContainerBandwidthStat, error)

func (*ContainerBandwidthManager) SetLimits

func (m *ContainerBandwidthManager) SetLimits(
	logger lager.Logger,
	limits garden.BandwidthLimits,
) error