throttle · pkg.go.dev

Documentation

const MB uint64 = 1024 * 1024

This section is empty.

This section is empty.

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

func NewEnforcer(cpuCgroupPath string) CPUCgroupEnforcer

func (c CPUCgroupEnforcer) Punish(logger lager.Logger, handle string) error

func (c CPUCgroupEnforcer) Release(logger lager.Logger, handle string) error

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

func NewCompositeRunnable(runnables ...Runnable) CompositeRunnable

func (r CompositeRunnable) Run(logger lager.Logger) error

type ContainerManager interface {
	Handles() ([]string, error)
	Metrics(log lager.Logger, handle string) (gardener.ActualContainerMetrics, error)
}

go:generate counterfeiter . ContainerManager

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

func (c ContainerMetricsSource) CollectMetrics(logger lager.Logger) (map[string]gardener.ActualContainerMetrics, error)

type Enforcer interface {
	Punish(logger lager.Logger, handle string) error
	Release(logger lager.Logger, handle string) error
}

go:generate counterfeiter . Enforcer

type MemoryProvider interface {
	TotalMemory() (uint64, error)
}

go:generate counterfeiter . MemoryProvider

type MetricsSource interface {
	CollectMetrics(logger lager.Logger) (map[string]gardener.ActualContainerMetrics, error)
}

go:generate counterfeiter . MetricsSource

func NewContainerMetricsSource(containerManager ContainerManager) MetricsSource

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

func NewPollingService(
	logger lager.Logger,
	runnable Runnable,
	ticker <-chan time.Time,
) *PollingService

func (s PollingService) Start()

func (s PollingService) Stop()

type Runnable interface {
	Run(logger lager.Logger) error
}

go:generate counterfeiter . Runnable

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

func NewSharesBalancer(cpuCgroupPath string, memoryProvider MemoryProvider, multiplier float64) SharesBalancer

func (b SharesBalancer) Run(logger lager.Logger) error

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

func NewThrottler(metricsSource MetricsSource, enforcer Enforcer) Throttler

func (t Throttler) Run(logger lager.Logger) error

View all

Path	Synopsis
throttlefakes	Code generated by counterfeiter.