Documentation
¶
Index ¶
- Constants
- Variables
- func NewPlugin(configuration runtime.Object, fh framework.Handle) (framework.Plugin, error)
- type KubeThrottler
- func (p *KubeThrottler) EventsToRegister() []framework.ClusterEvent
- func (p *KubeThrottler) Name() string
- func (pl *KubeThrottler) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)
- func (p *KubeThrottler) PreFilterExtensions() framework.PreFilterExtensions
- func (pl *KubeThrottler) Reserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, node string) *framework.Status
- func (pl *KubeThrottler) Unreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, node string)
- type KubeThrottlerPluginArgs
Constants ¶
View Source
const (
// PluginName of the plugin used in the plugin registry and configurations.
PluginName = "kube-throttler"
)
Variables ¶
View Source
var (
DefaultReconcileTemporaryThresholdInterval = 15 * time.Second
)
Functions ¶
Types ¶
type KubeThrottler ¶
type KubeThrottler struct {
// contains filtered or unexported fields
}
func (*KubeThrottler) EventsToRegister ¶ added in v1.3.1
func (p *KubeThrottler) EventsToRegister() []framework.ClusterEvent
func (*KubeThrottler) Name ¶
func (p *KubeThrottler) Name() string
func (*KubeThrottler) PreFilter ¶
func (pl *KubeThrottler) PreFilter( ctx context.Context, state *framework.CycleState, pod *v1.Pod, ) (*framework.PreFilterResult, *framework.Status)
func (*KubeThrottler) PreFilterExtensions ¶
func (p *KubeThrottler) PreFilterExtensions() framework.PreFilterExtensions
func (*KubeThrottler) Reserve ¶
func (pl *KubeThrottler) Reserve( ctx context.Context, state *framework.CycleState, pod *v1.Pod, node string, ) *framework.Status
func (*KubeThrottler) Unreserve ¶
func (pl *KubeThrottler) Unreserve( ctx context.Context, state *framework.CycleState, pod *v1.Pod, node string, )
type KubeThrottlerPluginArgs ¶
type KubeThrottlerPluginArgs struct {
Name string `json:"name"`
KubeConifg string `json:"kubeconfig"`
ReconcileTemporaryThresholdInterval time.Duration `json:"reconcileTemporaryThresholdInterval"`
TargetSchedulerName string `json:"targetSchedulerName"`
ControllerThrediness int `json:"controllerThrediness"`
NumKeyMutex int `json:"numKeyMutex"`
}
func DecodePluginArgs ¶
func DecodePluginArgs(configuration runtime.Object) (*KubeThrottlerPluginArgs, error)
Source Files
Click to show internal directories.
Click to hide internal directories.