Documentation
¶
Index ¶
- type 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
- type ControllerBase
- type MetricsRecorder
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v1.0.1
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 ¶ added in v1.1.0
type ControllerBase struct {
// contains filtered or unexported fields
}
func (*ControllerBase) Start ¶ added in v1.1.0
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) ReserveOnThrottle ¶ added in v1.0.1
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
Source Files
Click to show internal directories.
Click to hide internal directories.