mocks

Documentation

Index

• type MockFrameworkHandle
  • func (f *MockFrameworkHandle) AddNominatedPod(logger logr.Logger, pod *framework.PodInfo, ...)
  • func (f *MockFrameworkHandle) AddWaitingPod(uid types.UID, wp framework.WaitingPod)
  • func (f *MockFrameworkHandle) ClientSet() clientset.Interface
  • func (f *MockFrameworkHandle) DeleteNominatedPodIfExists(pod *v1.Pod)
  • func (f *MockFrameworkHandle) EventRecorder() events.EventRecorder
  • func (f *MockFrameworkHandle) Extenders() []framework.Extender
  • func (f *MockFrameworkHandle) GetWaitingPod(uid types.UID) framework.WaitingPod
  • func (f *MockFrameworkHandle) IterateOverWaitingPods(callback func(framework.WaitingPod))
  • func (f *MockFrameworkHandle) KubeConfig() *restclient.Config
  • func (f *MockFrameworkHandle) NominatedPodsForNode(nodeName string) []*framework.PodInfo
  • func (f *MockFrameworkHandle) Parallelizer() parallelize.Parallelizer
  • func (f *MockFrameworkHandle) RejectWaitingPod(uid types.UID) bool
  • func (f *MockFrameworkHandle) RemoveWaitingPod(uid types.UID)
  • func (f *MockFrameworkHandle) RunFilterPlugins(context.Context, *framework.CycleState, *v1.Pod, *framework.NodeInfo) *framework.Status
  • func (f *MockFrameworkHandle) RunFilterPluginsWithNominatedPods(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (f *MockFrameworkHandle) RunPreFilterExtensionAddPod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (f *MockFrameworkHandle) RunPreFilterExtensionRemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (f *MockFrameworkHandle) RunPreScorePlugins(context.Context, *framework.CycleState, *v1.Pod, []*v1.Node) *framework.Status
  • func (f *MockFrameworkHandle) RunScorePlugins(context.Context, *framework.CycleState, *v1.Pod, []*v1.Node) ([]framework.NodePluginScores, *framework.Status)
  • func (f *MockFrameworkHandle) SharedInformerFactory() informers.SharedInformerFactory
  • func (f *MockFrameworkHandle) SnapshotSharedLister() framework.SharedLister
  • func (f *MockFrameworkHandle) UpdateNominatedPod(logger logr.Logger, oldPod *v1.Pod, newPodInfo *framework.PodInfo)
• type MockWaitingPod
  • func (w *MockWaitingPod) Allow(pluginName string)
  • func (w *MockWaitingPod) GetPendingPlugins() []string
  • func (w *MockWaitingPod) GetPod() *v1.Pod
  • func (w *MockWaitingPod) Reject(plugin, msg string)

Types

type MockFrameworkHandle

type MockFrameworkHandle struct {
	WaitingPods map[types.UID]framework.WaitingPod
	// contains filtered or unexported fields
}

Implements framework.Handle

func (*MockFrameworkHandle) AddNominatedPod

func (f *MockFrameworkHandle) AddNominatedPod(logger logr.Logger, pod *framework.PodInfo, nominatingInfo *framework.NominatingInfo)

framework.PodNominator

func (*MockFrameworkHandle) AddWaitingPod

func (f *MockFrameworkHandle) AddWaitingPod(uid types.UID, wp framework.WaitingPod)

func (*MockFrameworkHandle) ClientSet

func (f *MockFrameworkHandle) ClientSet() clientset.Interface

func (*MockFrameworkHandle) DeleteNominatedPodIfExists

func (f *MockFrameworkHandle) DeleteNominatedPodIfExists(pod *v1.Pod)

func (*MockFrameworkHandle) EventRecorder

func (f *MockFrameworkHandle) EventRecorder() events.EventRecorder

func (*MockFrameworkHandle) Extenders

func (f *MockFrameworkHandle) Extenders() []framework.Extender

func (*MockFrameworkHandle) GetWaitingPod

func (f *MockFrameworkHandle) GetWaitingPod(uid types.UID) framework.WaitingPod

func (*MockFrameworkHandle) IterateOverWaitingPods

func (f *MockFrameworkHandle) IterateOverWaitingPods(callback func(framework.WaitingPod))

func (*MockFrameworkHandle) KubeConfig

func (f *MockFrameworkHandle) KubeConfig() *restclient.Config

framework.Handle

func (*MockFrameworkHandle) NominatedPodsForNode

func (f *MockFrameworkHandle) NominatedPodsForNode(nodeName string) []*framework.PodInfo

func (*MockFrameworkHandle) Parallelizer

func (f *MockFrameworkHandle) Parallelizer() parallelize.Parallelizer

func (*MockFrameworkHandle) RejectWaitingPod

func (f *MockFrameworkHandle) RejectWaitingPod(uid types.UID) bool

func (*MockFrameworkHandle) RemoveWaitingPod

func (f *MockFrameworkHandle) RemoveWaitingPod(uid types.UID)

func (*MockFrameworkHandle) RunFilterPlugins

func (f *MockFrameworkHandle) RunFilterPlugins(context.Context, *framework.CycleState, *v1.Pod, *framework.NodeInfo) *framework.Status

func (*MockFrameworkHandle) RunFilterPluginsWithNominatedPods

func (f *MockFrameworkHandle) RunFilterPluginsWithNominatedPods(ctx context.Context, state *framework.CycleState, pod *v1.Pod, info *framework.NodeInfo) *framework.Status

func (*MockFrameworkHandle) RunPreFilterExtensionAddPod

func (f *MockFrameworkHandle) RunPreFilterExtensionAddPod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status

func (*MockFrameworkHandle) RunPreFilterExtensionRemovePod

func (f *MockFrameworkHandle) RunPreFilterExtensionRemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status

func (*MockFrameworkHandle) RunPreScorePlugins

func (f *MockFrameworkHandle) RunPreScorePlugins(context.Context, *framework.CycleState, *v1.Pod, []*v1.Node) *framework.Status

framework.PluginsRunner

func (*MockFrameworkHandle) RunScorePlugins

func (f *MockFrameworkHandle) RunScorePlugins(context.Context, *framework.CycleState, *v1.Pod, []*v1.Node) ([]framework.NodePluginScores, *framework.Status)

func (*MockFrameworkHandle) SharedInformerFactory

func (f *MockFrameworkHandle) SharedInformerFactory() informers.SharedInformerFactory

func (*MockFrameworkHandle) SnapshotSharedLister

func (f *MockFrameworkHandle) SnapshotSharedLister() framework.SharedLister

func (*MockFrameworkHandle) UpdateNominatedPod

func (f *MockFrameworkHandle) UpdateNominatedPod(logger logr.Logger, oldPod *v1.Pod, newPodInfo *framework.PodInfo)

type MockWaitingPod

type MockWaitingPod struct {
	Pod *v1.Pod
}

Implements framework.WaitingPod

func (*MockWaitingPod) Allow

func (w *MockWaitingPod) Allow(pluginName string)

func (*MockWaitingPod) GetPendingPlugins

func (w *MockWaitingPod) GetPendingPlugins() []string

func (*MockWaitingPod) GetPod

func (w *MockWaitingPod) GetPod() *v1.Pod

func (*MockWaitingPod) Reject

func (w *MockWaitingPod) Reject(plugin, msg string)