kubernetes/test/integration/scheduler/rescheduling_test.go

var _ …

var _ …

var _ …

var _ …

type ReservePlugin …

func (rp *ReservePlugin) Name() string { … }

func (rp *ReservePlugin) Reserve(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) *framework.Status { … }

func (rp *ReservePlugin) Unreserve(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) { … }

func (rp *ReservePlugin) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … }

type PermitPlugin …

func (pp *PermitPlugin) Name() string { … }

func (pp *PermitPlugin) Permit(ctx context.Context, state *framework.CycleState, p *v1.Pod, nodeName string) (*framework.Status, time.Duration) { … }

func (pp *PermitPlugin) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … }

func TestReScheduling(t *testing.T) { … }