scheduler_plugin

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
  • func DecodePluginArgs(configuration runtime.Object) (*KubeThrottlerPluginArgs, error)

Constants

const (
	// PluginName of the plugin used in the plugin registry and configurations.
	PluginName = "kube-throttler"
)

Variables

var (
	DefaultReconcileTemporaryThresholdInterval = 15 * time.Second
)

Functions

func NewPlugin

func NewPlugin(configuration runtime.Object, fh framework.Handle) (framework.Plugin, error)

NewPlugin initializes a new plugin and returns it.

Types

type KubeThrottler

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

func (*KubeThrottler) EventsToRegister

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)