update test function calls
This commit is contained in:
parent
6d59906884
commit
3466fab857
@ -98,7 +98,7 @@ func TestInitialPendingVolumesForPodAndGetVolumesInUse(t *testing.T) {
|
|||||||
t.Fatalf("can't make a temp dir: %v", err)
|
t.Fatalf("can't make a temp dir: %v", err)
|
||||||
}
|
}
|
||||||
defer os.RemoveAll(tmpDir)
|
defer os.RemoveAll(tmpDir)
|
||||||
podManager := kubepod.NewBasicPodManager(podtest.NewFakeMirrorClient(), secret.NewFakeManager())
|
podManager := kubepod.NewBasicPodManager(podtest.NewFakeMirrorClient(), secret.NewFakeManager(), configmap.NewFakeManager())
|
||||||
|
|
||||||
node, pod, pv, claim := createObjects()
|
node, pod, pv, claim := createObjects()
|
||||||
claim.Status = v1.PersistentVolumeClaimStatus{
|
claim.Status = v1.PersistentVolumeClaimStatus{
|
||||||
@ -107,10 +107,7 @@ func TestInitialPendingVolumesForPodAndGetVolumesInUse(t *testing.T) {
|
|||||||
|
|
||||||
kubeClient := fake.NewSimpleClientset(node, pod, pv, claim)
|
kubeClient := fake.NewSimpleClientset(node, pod, pv, claim)
|
||||||
|
|
||||||
manager, err := newTestVolumeManager(tmpDir, podManager, kubeClient)
|
manager := newTestVolumeManager(tmpDir, podManager, kubeClient)
|
||||||
if err != nil {
|
|
||||||
t.Fatalf("Failed to initialize volume manager: %v", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
stopCh := runVolumeManager(manager)
|
stopCh := runVolumeManager(manager)
|
||||||
defer close(stopCh)
|
defer close(stopCh)
|
||||||
|
Loading…
Reference in New Issue
Block a user