in pkg/client/apifactory_mock.go [65:100]
func NewMockedAPIProvider(showError bool) *MockedAPIProvider {
return &MockedAPIProvider{
clients: &Clients{
conf: &conf.SchedulerConf{
ClusterID: "yk-test-cluster",
ClusterVersion: "0.1",
PolicyGroup: "queues",
Interval: 0,
KubeConfig: "",
VolumeBindTimeout: 0,
TestMode: true,
EventChannelCapacity: 0,
DispatchTimeout: 0,
KubeQPS: 0,
KubeBurst: 0,
Namespace: "yunikorn",
},
KubeClient: NewKubeClientMock(showError),
SchedulerAPI: test.NewSchedulerAPIMock(),
PodInformer: test.NewMockedPodInformer(),
NodeInformer: test.NewMockedNodeInformer(),
ConfigMapInformer: test.NewMockedConfigMapInformer(),
PVInformer: &MockedPersistentVolumeInformer{},
PVCInformer: &MockedPersistentVolumeClaimInformer{},
StorageInformer: &MockedStorageClassInformer{},
VolumeBinder: nil,
NamespaceInformer: test.NewMockNamespaceInformer(false),
PriorityClassInformer: test.NewMockPriorityClassInformer(),
InformerFactory: informers.NewSharedInformerFactory(k8fake.NewSimpleClientset(), time.Second*60),
},
events: make(chan informerEvent),
eventHandler: make(chan *ResourceEventHandlers),
stop: make(chan struct{}),
running: false,
}
}