Documentation ¶
Index ¶
- func NewMockNamespaceInformer() informersV1.NamespaceInformer
- func NewMockNamespaceLister() listersV1.NamespaceLister
- type ConfigMapInformerMock
- type ConfigMapListerMock
- type MockNamespaceInformer
- type MockNamespaceLister
- type MockedAppInformer
- type MockedAppLister
- type MockedNodeInformer
- type MockedPodInformer
- type MockedRecoverableAppManager
- type NodeListerMock
- type PodListerMock
- 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(rmID string) 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() informersV1.NamespaceInformer
func NewMockNamespaceLister ¶
func NewMockNamespaceLister() listersV1.NamespaceLister
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 MockedAppInformer ¶
type MockedAppInformer struct {
// contains filtered or unexported fields
}
func NewAppInformerMock ¶
func NewAppInformerMock() *MockedAppInformer
func (MockedAppInformer) Informer ¶
func (m MockedAppInformer) Informer() cache.SharedIndexInformer
func (MockedAppInformer) Lister ¶
func (m MockedAppInformer) Lister() lister.ApplicationLister
type MockedAppLister ¶
type MockedAppLister struct { }
func (MockedAppLister) Applications ¶
func (m MockedAppLister) Applications(namespace string) lister.ApplicationNamespaceLister
func (MockedAppLister) Get ¶
func (m MockedAppLister) Get(name string) (*v1alpha1.Application, error)
func (MockedAppLister) List ¶
func (m MockedAppLister) List(selector labels.Selector) (ret []*v1alpha1.Application, 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
func (*MockedRecoverableAppManager) ListApplications ¶
func (m *MockedRecoverableAppManager) ListApplications() (map[string]interfaces.ApplicationMetadata, error)
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)
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) 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(rmID string) 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
Click to show internal directories.
Click to hide internal directories.