Documentation ¶
Index ¶
- func NewMockNamespaceInformer(errIfNotFound bool) informersV1.NamespaceInformer
- func NewMockNamespaceLister(errIfNotFound bool) listersV1.NamespaceLister
- func NewMockPriorityClassInformer() informersV1.PriorityClassInformer
- func NewMockPriorityClassLister() listersV1.PriorityClassLister
- type ConfigMapInformerMock
- type ConfigMapListerMock
- type MockNamespaceInformer
- type MockNamespaceLister
- type MockPriorityClassInformer
- type MockPriorityClassLister
- type MockedNodeInformer
- type MockedPodInformer
- type MockedRecoverableAppManager
- type NodeListerMock
- type PodListerMock
- func (n *PodListerMock) AddPod(pod *v1.Pod)
- func (n *PodListerMock) DeletePod(pod *v1.Pod)
- func (n *PodListerMock) Get(name string) (*v1.Pod, error)
- func (n *PodListerMock) List(selector labels.Selector) (ret []*v1.Pod, err error)
- func (n *PodListerMock) Pods(namespace string) clientv1.PodNamespaceLister
- type SchedulerAPIMock
- func (api *SchedulerAPIMock) GetRegisterCount() int32
- func (api *SchedulerAPIMock) GetUpdateAllocationCount() int32
- func (api *SchedulerAPIMock) GetUpdateApplicationCount() int32
- func (api *SchedulerAPIMock) GetUpdateNodeCount() int32
- func (api *SchedulerAPIMock) RegisterFunction(...) *SchedulerAPIMock
- func (api *SchedulerAPIMock) RegisterResourceManager(request *si.RegisterResourceManagerRequest, ...) (*si.RegisterResourceManagerResponse, error)
- func (api *SchedulerAPIMock) ResetAllCounters()
- func (api *SchedulerAPIMock) UpdateAllocation(request *si.AllocationRequest) error
- func (api *SchedulerAPIMock) UpdateAllocationFunction(ufn func(request *si.AllocationRequest) error) *SchedulerAPIMock
- func (api *SchedulerAPIMock) UpdateApplication(request *si.ApplicationRequest) error
- func (api *SchedulerAPIMock) UpdateApplicationFunction(ufn func(request *si.ApplicationRequest) error) *SchedulerAPIMock
- func (api *SchedulerAPIMock) UpdateConfiguration(request *si.UpdateConfigurationRequest) error
- func (api *SchedulerAPIMock) UpdateNode(request *si.NodeRequest) error
- func (api *SchedulerAPIMock) UpdateNodeFunction(ufn func(request *si.NodeRequest) error) *SchedulerAPIMock
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMockNamespaceInformer ¶
func NewMockNamespaceInformer(errIfNotFound bool) informersV1.NamespaceInformer
func NewMockNamespaceLister ¶
func NewMockNamespaceLister(errIfNotFound bool) listersV1.NamespaceLister
func NewMockPriorityClassInformer ¶ added in v1.2.0
func NewMockPriorityClassInformer() informersV1.PriorityClassInformer
func NewMockPriorityClassLister ¶ added in v1.2.0
func NewMockPriorityClassLister() listersV1.PriorityClassLister
Types ¶
type ConfigMapInformerMock ¶
type ConfigMapInformerMock struct {
// contains filtered or unexported fields
}
func NewMockedConfigMapInformer ¶
func NewMockedConfigMapInformer() *ConfigMapInformerMock
func (ConfigMapInformerMock) Informer ¶
func (c ConfigMapInformerMock) Informer() cache.SharedIndexInformer
func (ConfigMapInformerMock) Lister ¶
func (c ConfigMapInformerMock) Lister() v1.ConfigMapLister
type ConfigMapListerMock ¶
type ConfigMapListerMock struct {
// contains filtered or unexported fields
}
func NewConfigMapListerMock ¶
func NewConfigMapListerMock() *ConfigMapListerMock
func (ConfigMapListerMock) ConfigMaps ¶
func (c ConfigMapListerMock) ConfigMaps(namespace string) listers.ConfigMapNamespaceLister
type MockNamespaceInformer ¶
type MockNamespaceInformer struct {
// contains filtered or unexported fields
}
func (*MockNamespaceInformer) Informer ¶
func (nsi *MockNamespaceInformer) Informer() cache.SharedIndexInformer
func (*MockNamespaceInformer) Lister ¶
func (nsi *MockNamespaceInformer) Lister() listersV1.NamespaceLister
type MockNamespaceLister ¶
type MockNamespaceLister struct {
// contains filtered or unexported fields
}
func (*MockNamespaceLister) Add ¶
func (nsl *MockNamespaceLister) Add(ns *v1.Namespace)
type MockPriorityClassInformer ¶ added in v1.2.0
type MockPriorityClassInformer struct {
// contains filtered or unexported fields
}
func (*MockPriorityClassInformer) Informer ¶ added in v1.2.0
func (nsi *MockPriorityClassInformer) Informer() cache.SharedIndexInformer
func (*MockPriorityClassInformer) Lister ¶ added in v1.2.0
func (nsi *MockPriorityClassInformer) Lister() listersV1.PriorityClassLister
type MockPriorityClassLister ¶ added in v1.2.0
type MockPriorityClassLister struct {
// contains filtered or unexported fields
}
func (*MockPriorityClassLister) Add ¶ added in v1.2.0
func (nsl *MockPriorityClassLister) Add(ns *v1.PriorityClass)
func (*MockPriorityClassLister) Get ¶ added in v1.2.0
func (nsl *MockPriorityClassLister) Get(name string) (*v1.PriorityClass, error)
func (*MockPriorityClassLister) List ¶ added in v1.2.0
func (nsl *MockPriorityClassLister) List(labels.Selector) (ret []*v1.PriorityClass, err error)
type MockedNodeInformer ¶
type MockedNodeInformer struct {
// contains filtered or unexported fields
}
func NewMockedNodeInformer ¶
func NewMockedNodeInformer() *MockedNodeInformer
func (*MockedNodeInformer) Informer ¶
func (m *MockedNodeInformer) Informer() cache.SharedIndexInformer
func (*MockedNodeInformer) Lister ¶
func (m *MockedNodeInformer) Lister() v1.NodeLister
func (*MockedNodeInformer) SetLister ¶
func (m *MockedNodeInformer) SetLister(lister v1.NodeLister)
type MockedPodInformer ¶
type MockedPodInformer struct {
// contains filtered or unexported fields
}
func NewMockedPodInformer ¶
func NewMockedPodInformer() *MockedPodInformer
func (*MockedPodInformer) Informer ¶
func (m *MockedPodInformer) Informer() cache.SharedIndexInformer
func (*MockedPodInformer) Lister ¶
func (m *MockedPodInformer) Lister() v1.PodLister
func (*MockedPodInformer) SetLister ¶
func (m *MockedPodInformer) SetLister(lister v1.PodLister)
type MockedRecoverableAppManager ¶
type MockedRecoverableAppManager struct { }
func NewMockedRecoverableAppManager ¶
func NewMockedRecoverableAppManager() *MockedRecoverableAppManager
func (*MockedRecoverableAppManager) GetExistingAllocation ¶
func (m *MockedRecoverableAppManager) GetExistingAllocation(pod *v1.Pod) *si.Allocation
type NodeListerMock ¶
type NodeListerMock struct {
// contains filtered or unexported fields
}
func NewNodeListerMock ¶
func NewNodeListerMock() *NodeListerMock
func (*NodeListerMock) AddNode ¶
func (n *NodeListerMock) AddNode(node *v1.Node)
func (*NodeListerMock) RemoveNode ¶ added in v1.4.0
func (n *NodeListerMock) RemoveNode(node *v1.Node)
type PodListerMock ¶
type PodListerMock struct {
// contains filtered or unexported fields
}
func NewPodListerMock ¶
func NewPodListerMock() *PodListerMock
func (*PodListerMock) AddPod ¶
func (n *PodListerMock) AddPod(pod *v1.Pod)
func (*PodListerMock) DeletePod ¶ added in v1.4.0
func (n *PodListerMock) DeletePod(pod *v1.Pod)
func (*PodListerMock) Pods ¶
func (n *PodListerMock) Pods(namespace string) clientv1.PodNamespaceLister
type SchedulerAPIMock ¶
type SchedulerAPIMock struct { UpdateAllocationCount int32 UpdateApplicationCount int32 UpdateNodeCount int32 UpdateAllocationFn func(request *si.AllocationRequest) error UpdateApplicationFn func(request *si.ApplicationRequest) error UpdateNodeFn func(request *si.NodeRequest) error // contains filtered or unexported fields }
func NewSchedulerAPIMock ¶
func NewSchedulerAPIMock() *SchedulerAPIMock
func (*SchedulerAPIMock) GetRegisterCount ¶
func (api *SchedulerAPIMock) GetRegisterCount() int32
func (*SchedulerAPIMock) GetUpdateAllocationCount ¶
func (api *SchedulerAPIMock) GetUpdateAllocationCount() int32
func (*SchedulerAPIMock) GetUpdateApplicationCount ¶
func (api *SchedulerAPIMock) GetUpdateApplicationCount() int32
func (*SchedulerAPIMock) GetUpdateNodeCount ¶
func (api *SchedulerAPIMock) GetUpdateNodeCount() int32
func (*SchedulerAPIMock) RegisterFunction ¶
func (api *SchedulerAPIMock) RegisterFunction(rfn func(request *si.RegisterResourceManagerRequest, callback api.ResourceManagerCallback) (*si.RegisterResourceManagerResponse, error)) *SchedulerAPIMock
func (*SchedulerAPIMock) RegisterResourceManager ¶
func (api *SchedulerAPIMock) RegisterResourceManager(request *si.RegisterResourceManagerRequest, callback api.ResourceManagerCallback) (*si.RegisterResourceManagerResponse, error)
func (*SchedulerAPIMock) ResetAllCounters ¶
func (api *SchedulerAPIMock) ResetAllCounters()
func (*SchedulerAPIMock) UpdateAllocation ¶
func (api *SchedulerAPIMock) UpdateAllocation(request *si.AllocationRequest) error
func (*SchedulerAPIMock) UpdateAllocationFunction ¶
func (api *SchedulerAPIMock) UpdateAllocationFunction(ufn func(request *si.AllocationRequest) error) *SchedulerAPIMock
func (*SchedulerAPIMock) UpdateApplication ¶
func (api *SchedulerAPIMock) UpdateApplication(request *si.ApplicationRequest) error
func (*SchedulerAPIMock) UpdateApplicationFunction ¶
func (api *SchedulerAPIMock) UpdateApplicationFunction(ufn func(request *si.ApplicationRequest) error) *SchedulerAPIMock
func (*SchedulerAPIMock) UpdateConfiguration ¶
func (api *SchedulerAPIMock) UpdateConfiguration(request *si.UpdateConfigurationRequest) error
func (*SchedulerAPIMock) UpdateNode ¶
func (api *SchedulerAPIMock) UpdateNode(request *si.NodeRequest) error
func (*SchedulerAPIMock) UpdateNodeFunction ¶
func (api *SchedulerAPIMock) UpdateNodeFunction(ufn func(request *si.NodeRequest) error) *SchedulerAPIMock
Source Files ¶
Click to show internal directories.
Click to hide internal directories.