controllers

Documentation

Index

• type ClusterThrottleController
  • func NewClusterThrottleController(throttlerName, targetSchedulerName string, ...) *ClusterThrottleController
  • func (c *ClusterThrottleController) CheckThrottled(pod *corev1.Pod, isThrottledOnEqual bool) ([]schedulev1alpha1.ClusterThrottle, []schedulev1alpha1.ClusterThrottle, ...)
  • func (c *ClusterThrottleController) Reserve(pod *corev1.Pod) error
  • func (c *ClusterThrottleController) ReserveOnClusterThrottle(pod *corev1.Pod, thr *schedulev1alpha1.ClusterThrottle) bool
  • func (c *ClusterThrottleController) UnReserve(pod *corev1.Pod) error
  • func (c *ClusterThrottleController) UnReserveOnClusterThrottle(pod *corev1.Pod, thr *schedulev1alpha1.ClusterThrottle) bool
• type ClusterThrottleMetricsRecorder
  • func NewClusterThrottleMetricsRecorder() *ClusterThrottleMetricsRecorder
• type ControllerBase
  • func (c *ControllerBase) Start(stopCh <-chan struct{}) error
• type MetricsRecorder
• type ThrottleController
  • func NewThrottleController(throttlerName, targetSchedulerName string, ...) *ThrottleController
  • func (c *ThrottleController) CheckThrottled(pod *corev1.Pod, isThrottledOnEqual bool) ([]schedulev1alpha1.Throttle, []schedulev1alpha1.Throttle, ...)
  • func (c *ThrottleController) Reserve(pod *corev1.Pod) error
  • func (c *ThrottleController) ReserveOnThrottle(pod *corev1.Pod, thr *schedulev1alpha1.Throttle) bool
  • func (c *ThrottleController) UnReserve(pod *corev1.Pod) error
  • func (c *ThrottleController) UnReserveOnThrottle(pod *corev1.Pod, thr *schedulev1alpha1.Throttle) bool
• type ThrottleMetricsRecorder
  • func NewThrottleMetricsRecorder() *ThrottleMetricsRecorder

Types

type ClusterThrottleController

type ClusterThrottleController struct {
	ControllerBase
	// contains filtered or unexported fields
}

func NewClusterThrottleController

func NewClusterThrottleController(
	throttlerName, targetSchedulerName string,
	reconcileTemporaryThresholdInterval time.Duration,
	scheduleClient scheduleclientset.Clientset,
	clusterthrottleInformer scheduleinformer.ClusterThrottleInformer,
	podInformer corev1informer.PodInformer,
	namespaceInformer corev1informer.NamespaceInformer,
	clock clock.Clock,
	thrediness int,
	numKeyMutex int,
) *ClusterThrottleController

func (*ClusterThrottleController) CheckThrottled

func (c *ClusterThrottleController) CheckThrottled(
	pod *corev1.Pod,
	isThrottledOnEqual bool,
) (
	[]schedulev1alpha1.ClusterThrottle,
	[]schedulev1alpha1.ClusterThrottle,
	[]schedulev1alpha1.ClusterThrottle,
	[]schedulev1alpha1.ClusterThrottle,
	error,
)

func (*ClusterThrottleController) Reserve

func (c *ClusterThrottleController) Reserve(pod *corev1.Pod) error

func (*ClusterThrottleController) ReserveOnClusterThrottle

func (c *ClusterThrottleController) ReserveOnClusterThrottle(pod *corev1.Pod, thr *schedulev1alpha1.ClusterThrottle) bool

func (*ClusterThrottleController) UnReserve

func (c *ClusterThrottleController) UnReserve(pod *corev1.Pod) error

func (*ClusterThrottleController) UnReserveOnClusterThrottle

func (c *ClusterThrottleController) UnReserveOnClusterThrottle(pod *corev1.Pod, thr *schedulev1alpha1.ClusterThrottle) bool

type ClusterThrottleMetricsRecorder

type ClusterThrottleMetricsRecorder struct {
	MetricsRecorder
	// contains filtered or unexported fields
}

func NewClusterThrottleMetricsRecorder

func NewClusterThrottleMetricsRecorder() *ClusterThrottleMetricsRecorder

type ControllerBase

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

func (*ControllerBase) Start

func (c *ControllerBase) Start(stopCh <-chan struct{}) error

type MetricsRecorder

type MetricsRecorder struct {
}

type ThrottleController

type ThrottleController struct {
	ControllerBase
	// contains filtered or unexported fields
}

func NewThrottleController

func NewThrottleController(
	throttlerName, targetSchedulerName string,
	reconcileTemporaryThresholdInterval time.Duration,
	scheduleClient scheduleclientset.Clientset,
	throttleInformer scheduleinformer.ThrottleInformer,
	podInformer corev1informer.PodInformer,
	clock clock.Clock,
	thrediness int,
	numKeyMutex int,
) *ThrottleController

func (*ThrottleController) CheckThrottled

func (c *ThrottleController) CheckThrottled(
	pod *corev1.Pod,
	isThrottledOnEqual bool,
) (
	[]schedulev1alpha1.Throttle,
	[]schedulev1alpha1.Throttle,
	[]schedulev1alpha1.Throttle,
	[]schedulev1alpha1.Throttle,
	error,
)

func (*ThrottleController) Reserve

func (c *ThrottleController) Reserve(pod *corev1.Pod) error

func (*ThrottleController) ReserveOnThrottle

func (c *ThrottleController) ReserveOnThrottle(pod *corev1.Pod, thr *schedulev1alpha1.Throttle) bool

func (*ThrottleController) UnReserve

func (c *ThrottleController) UnReserve(pod *corev1.Pod) error

func (*ThrottleController) UnReserveOnThrottle

func (c *ThrottleController) UnReserveOnThrottle(pod *corev1.Pod, thr *schedulev1alpha1.Throttle) bool

type ThrottleMetricsRecorder

type ThrottleMetricsRecorder struct {
	MetricsRecorder
	// contains filtered or unexported fields
}

func NewThrottleMetricsRecorder

func NewThrottleMetricsRecorder() *ThrottleMetricsRecorder