scheduler

Documentation

Index

• type Framework
  • func NewFramework(t mockConstructorTestingTNewFramework) *Framework
  • func (_m *Framework) AddNominatedPod(pod *framework.PodInfo, nominatingInfo *framework.NominatingInfo)
  • func (_m *Framework) ClientSet() kubernetes.Interface
  • func (_m *Framework) DeleteNominatedPodIfExists(pod *v1.Pod)
  • func (_m *Framework) EventRecorder() events.EventRecorder
  • func (_m *Framework) Extenders() []framework.Extender
  • func (_m *Framework) GetWaitingPod(uid types.UID) framework.WaitingPod
  • func (_m *Framework) HasFilterPlugins() bool
  • func (_m *Framework) HasPostFilterPlugins() bool
  • func (_m *Framework) HasScorePlugins() bool
  • func (_m *Framework) IterateOverWaitingPods(callback func(framework.WaitingPod))
  • func (_m *Framework) KubeConfig() *rest.Config
  • func (_m *Framework) ListPlugins() *config.Plugins
  • func (_m *Framework) NominatedPodsForNode(nodeName string) []*framework.PodInfo
  • func (_m *Framework) Parallelizer() parallelize.Parallelizer
  • func (_m *Framework) ProfileName() string
  • func (_m *Framework) QueueSortFunc() framework.LessFunc
  • func (_m *Framework) RejectWaitingPod(uid types.UID) bool
  • func (_m *Framework) RunBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status
  • func (_m *Framework) RunFilterPlugins(_a0 context.Context, _a1 *framework.CycleState, _a2 *v1.Pod, ...) framework.PluginToStatus
  • func (_m *Framework) RunFilterPluginsWithNominatedPods(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) *framework.Status
  • func (_m *Framework) RunPermitPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status
  • func (_m *Framework) RunPostBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
  • func (_m *Framework) RunPostFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, ...) (*framework.PostFilterResult, *framework.Status)
  • func (_m *Framework) RunPreBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status
  • func (_m *Framework) RunPreFilterExtensionAddPod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (_m *Framework) RunPreFilterExtensionRemovePod(ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, ...) *framework.Status
  • func (_m *Framework) RunPreFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)
  • func (_m *Framework) RunPreScorePlugins(_a0 context.Context, _a1 *framework.CycleState, _a2 *v1.Pod, _a3 []*v1.Node) *framework.Status
  • func (_m *Framework) RunReservePluginsReserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status
  • func (_m *Framework) RunReservePluginsUnreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)
  • func (_m *Framework) RunScorePlugins(_a0 context.Context, _a1 *framework.CycleState, _a2 *v1.Pod, _a3 []*v1.Node) (framework.PluginToNodeScores, *framework.Status)
  • func (_m *Framework) SharedInformerFactory() informers.SharedInformerFactory
  • func (_m *Framework) SnapshotSharedLister() framework.SharedLister
  • func (_m *Framework) UpdateNominatedPod(oldPod *v1.Pod, newPodInfo *framework.PodInfo)
  • func (_m *Framework) WaitOnPermit(ctx context.Context, pod *v1.Pod) *framework.Status

Types

type Framework

type Framework struct {
	mock.Mock
}

Framework is an autogenerated mock type for the Framework type

func NewFramework

func NewFramework(t mockConstructorTestingTNewFramework) *Framework

NewFramework creates a new instance of Framework. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*Framework) AddNominatedPod

func (_m *Framework) AddNominatedPod(pod *framework.PodInfo, nominatingInfo *framework.NominatingInfo)

AddNominatedPod provides a mock function with given fields: pod, nominatingInfo

func (*Framework) ClientSet

func (_m *Framework) ClientSet() kubernetes.Interface

ClientSet provides a mock function with given fields:

func (*Framework) DeleteNominatedPodIfExists

func (_m *Framework) DeleteNominatedPodIfExists(pod *v1.Pod)

DeleteNominatedPodIfExists provides a mock function with given fields: pod

func (*Framework) EventRecorder

func (_m *Framework) EventRecorder() events.EventRecorder

EventRecorder provides a mock function with given fields:

func (*Framework) Extenders

func (_m *Framework) Extenders() []framework.Extender

Extenders provides a mock function with given fields:

func (*Framework) GetWaitingPod

func (_m *Framework) GetWaitingPod(uid types.UID) framework.WaitingPod

GetWaitingPod provides a mock function with given fields: uid

func (*Framework) HasFilterPlugins

func (_m *Framework) HasFilterPlugins() bool

HasFilterPlugins provides a mock function with given fields:

func (*Framework) HasPostFilterPlugins

func (_m *Framework) HasPostFilterPlugins() bool

HasPostFilterPlugins provides a mock function with given fields:

func (*Framework) HasScorePlugins

func (_m *Framework) HasScorePlugins() bool

HasScorePlugins provides a mock function with given fields:

func (*Framework) IterateOverWaitingPods

func (_m *Framework) IterateOverWaitingPods(callback func(framework.WaitingPod))

IterateOverWaitingPods provides a mock function with given fields: callback

func (*Framework) KubeConfig

func (_m *Framework) KubeConfig() *rest.Config

KubeConfig provides a mock function with given fields:

func (*Framework) ListPlugins

func (_m *Framework) ListPlugins() *config.Plugins

ListPlugins provides a mock function with given fields:

func (*Framework) NominatedPodsForNode

func (_m *Framework) NominatedPodsForNode(nodeName string) []*framework.PodInfo

NominatedPodsForNode provides a mock function with given fields: nodeName

func (*Framework) Parallelizer

func (_m *Framework) Parallelizer() parallelize.Parallelizer

Parallelizer provides a mock function with given fields:

func (*Framework) ProfileName

func (_m *Framework) ProfileName() string

ProfileName provides a mock function with given fields:

func (*Framework) QueueSortFunc

func (_m *Framework) QueueSortFunc() framework.LessFunc

QueueSortFunc provides a mock function with given fields:

func (*Framework) RejectWaitingPod

func (_m *Framework) RejectWaitingPod(uid types.UID) bool

RejectWaitingPod provides a mock function with given fields: uid

func (*Framework) RunBindPlugins

func (_m *Framework) RunBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status

RunBindPlugins provides a mock function with given fields: ctx, state, pod, nodeName

func (*Framework) RunFilterPlugins

func (_m *Framework) RunFilterPlugins(_a0 context.Context, _a1 *framework.CycleState, _a2 *v1.Pod, _a3 *framework.NodeInfo) framework.PluginToStatus

RunFilterPlugins provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Framework) RunFilterPluginsWithNominatedPods

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

RunFilterPluginsWithNominatedPods provides a mock function with given fields: ctx, state, pod, info

func (*Framework) RunPermitPlugins

func (_m *Framework) RunPermitPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status

RunPermitPlugins provides a mock function with given fields: ctx, state, pod, nodeName

func (*Framework) RunPostBindPlugins

func (_m *Framework) RunPostBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)

RunPostBindPlugins provides a mock function with given fields: ctx, state, pod, nodeName

func (*Framework) RunPostFilterPlugins

func (_m *Framework) RunPostFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, filteredNodeStatusMap framework.NodeToStatusMap) (*framework.PostFilterResult, *framework.Status)

RunPostFilterPlugins provides a mock function with given fields: ctx, state, pod, filteredNodeStatusMap

func (*Framework) RunPreBindPlugins

func (_m *Framework) RunPreBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status

RunPreBindPlugins provides a mock function with given fields: ctx, state, pod, nodeName

func (*Framework) RunPreFilterExtensionAddPod

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

RunPreFilterExtensionAddPod provides a mock function with given fields: ctx, state, podToSchedule, podInfoToAdd, nodeInfo

func (*Framework) RunPreFilterExtensionRemovePod

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

RunPreFilterExtensionRemovePod provides a mock function with given fields: ctx, state, podToSchedule, podInfoToRemove, nodeInfo

func (*Framework) RunPreFilterPlugins

func (_m *Framework) RunPreFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status)

RunPreFilterPlugins provides a mock function with given fields: ctx, state, pod

func (*Framework) RunPreScorePlugins

func (_m *Framework) RunPreScorePlugins(_a0 context.Context, _a1 *framework.CycleState, _a2 *v1.Pod, _a3 []*v1.Node) *framework.Status

RunPreScorePlugins provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Framework) RunReservePluginsReserve

func (_m *Framework) RunReservePluginsReserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status

RunReservePluginsReserve provides a mock function with given fields: ctx, state, pod, nodeName

func (*Framework) RunReservePluginsUnreserve

func (_m *Framework) RunReservePluginsUnreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string)

RunReservePluginsUnreserve provides a mock function with given fields: ctx, state, pod, nodeName

func (*Framework) RunScorePlugins

func (_m *Framework) RunScorePlugins(_a0 context.Context, _a1 *framework.CycleState, _a2 *v1.Pod, _a3 []*v1.Node) (framework.PluginToNodeScores, *framework.Status)

RunScorePlugins provides a mock function with given fields: _a0, _a1, _a2, _a3

func (*Framework) SharedInformerFactory

func (_m *Framework) SharedInformerFactory() informers.SharedInformerFactory

SharedInformerFactory provides a mock function with given fields:

func (*Framework) SnapshotSharedLister

func (_m *Framework) SnapshotSharedLister() framework.SharedLister

SnapshotSharedLister provides a mock function with given fields:

func (*Framework) UpdateNominatedPod

func (_m *Framework) UpdateNominatedPod(oldPod *v1.Pod, newPodInfo *framework.PodInfo)

UpdateNominatedPod provides a mock function with given fields: oldPod, newPodInfo

func (*Framework) WaitOnPermit

func (_m *Framework) WaitOnPermit(ctx context.Context, pod *v1.Pod) *framework.Status

WaitOnPermit provides a mock function with given fields: ctx, pod