...
1
16
17 package flexvolume
18
19 import (
20 "testing"
21
22 "k8s.io/kubernetes/test/utils/harness"
23 "k8s.io/utils/exec/testing"
24 )
25
26 func TestInit(tt *testing.T) {
27 t := harness.For(tt)
28 defer t.Close()
29
30 plugin, _ := testPlugin(t)
31 plugin.runner = fakeRunner(
32 assertDriverCall(t, successOutput(), "init"),
33 )
34 plugin.Init(plugin.host)
35 }
36
37 func fakeVolumeNameOutput(name string) testingexec.FakeAction {
38 return fakeResultOutput(&DriverStatus{
39 Status: StatusSuccess,
40 VolumeName: name,
41 })
42 }
43
44 func TestGetVolumeName(tt *testing.T) {
45 t := harness.For(tt)
46 defer t.Close()
47
48 spec := fakeVolumeSpec()
49 plugin, _ := testPlugin(t)
50 plugin.runner = fakeRunner(
51 assertDriverCall(t, fakeVolumeNameOutput(spec.Name()), getVolumeNameCmd,
52 specJSON(plugin, spec, nil)),
53 )
54
55 name, err := plugin.GetVolumeName(spec)
56 if err != nil {
57 t.Errorf("GetVolumeName() failed: %v", err)
58 }
59 expectedName := spec.Name()
60 if name != expectedName {
61 t.Errorf("GetVolumeName() returned %v instead of %v", name, expectedName)
62 }
63 }
64
View as plain text