@@ -33,9 +33,27 @@ import (
33
33
kubetypes "k8s.io/kubernetes/pkg/kubelet/types"
34
34
"k8s.io/kubernetes/pkg/util/mount"
35
35
"k8s.io/kubernetes/pkg/util/oom"
36
+ "k8s.io/kubernetes/pkg/volume"
37
+ "k8s.io/kubernetes/pkg/volume/cephfs"
38
+ "k8s.io/kubernetes/pkg/volume/configmap"
39
+ "k8s.io/kubernetes/pkg/volume/csi"
40
+ "k8s.io/kubernetes/pkg/volume/downwardapi"
36
41
"k8s.io/kubernetes/pkg/volume/emptydir"
42
+ "k8s.io/kubernetes/pkg/volume/fc"
43
+ "k8s.io/kubernetes/pkg/volume/flocker"
44
+ "k8s.io/kubernetes/pkg/volume/git_repo"
45
+ "k8s.io/kubernetes/pkg/volume/glusterfs"
46
+ "k8s.io/kubernetes/pkg/volume/hostpath"
47
+ "k8s.io/kubernetes/pkg/volume/iscsi"
48
+ "k8s.io/kubernetes/pkg/volume/local"
49
+ "k8s.io/kubernetes/pkg/volume/nfs"
50
+ "k8s.io/kubernetes/pkg/volume/portworx"
37
51
"k8s.io/kubernetes/pkg/volume/projected"
52
+ "k8s.io/kubernetes/pkg/volume/quobyte"
53
+ "k8s.io/kubernetes/pkg/volume/rbd"
54
+ "k8s.io/kubernetes/pkg/volume/scaleio"
38
55
"k8s.io/kubernetes/pkg/volume/secret"
56
+ "k8s.io/kubernetes/pkg/volume/storageos"
39
57
"k8s.io/kubernetes/pkg/volume/util/hostutil"
40
58
"k8s.io/kubernetes/pkg/volume/util/subpath"
41
59
"k8s.io/kubernetes/test/utils"
@@ -49,6 +67,31 @@ type HollowKubelet struct {
49
67
KubeletDeps * kubelet.Dependencies
50
68
}
51
69
70
+ func volumePlugins () []volume.VolumePlugin {
71
+ allPlugins := []volume.VolumePlugin {}
72
+ allPlugins = append (allPlugins , emptydir .ProbeVolumePlugins ()... )
73
+ allPlugins = append (allPlugins , git_repo .ProbeVolumePlugins ()... )
74
+ allPlugins = append (allPlugins , hostpath .ProbeVolumePlugins (volume.VolumeConfig {})... )
75
+ allPlugins = append (allPlugins , nfs .ProbeVolumePlugins (volume.VolumeConfig {})... )
76
+ allPlugins = append (allPlugins , secret .ProbeVolumePlugins ()... )
77
+ allPlugins = append (allPlugins , iscsi .ProbeVolumePlugins ()... )
78
+ allPlugins = append (allPlugins , glusterfs .ProbeVolumePlugins ()... )
79
+ allPlugins = append (allPlugins , rbd .ProbeVolumePlugins ()... )
80
+ allPlugins = append (allPlugins , quobyte .ProbeVolumePlugins ()... )
81
+ allPlugins = append (allPlugins , cephfs .ProbeVolumePlugins ()... )
82
+ allPlugins = append (allPlugins , downwardapi .ProbeVolumePlugins ()... )
83
+ allPlugins = append (allPlugins , fc .ProbeVolumePlugins ()... )
84
+ allPlugins = append (allPlugins , flocker .ProbeVolumePlugins ()... )
85
+ allPlugins = append (allPlugins , configmap .ProbeVolumePlugins ()... )
86
+ allPlugins = append (allPlugins , projected .ProbeVolumePlugins ()... )
87
+ allPlugins = append (allPlugins , portworx .ProbeVolumePlugins ()... )
88
+ allPlugins = append (allPlugins , scaleio .ProbeVolumePlugins ()... )
89
+ allPlugins = append (allPlugins , local .ProbeVolumePlugins ()... )
90
+ allPlugins = append (allPlugins , storageos .ProbeVolumePlugins ()... )
91
+ allPlugins = append (allPlugins , csi .ProbeVolumePlugins ()... )
92
+ return allPlugins
93
+ }
94
+
52
95
func NewHollowKubelet (
53
96
flags * options.KubeletFlags ,
54
97
config * kubeletconfig.KubeletConfiguration ,
@@ -57,12 +100,6 @@ func NewHollowKubelet(
57
100
cadvisorInterface cadvisor.Interface ,
58
101
dockerClientConfig * dockershim.ClientConfig ,
59
102
containerManager cm.ContainerManager ) * HollowKubelet {
60
- // -----------------
61
- // Injected objects
62
- // -----------------
63
- volumePlugins := emptydir .ProbeVolumePlugins ()
64
- volumePlugins = append (volumePlugins , secret .ProbeVolumePlugins ()... )
65
- volumePlugins = append (volumePlugins , projected .ProbeVolumePlugins ()... )
66
103
d := & kubelet.Dependencies {
67
104
KubeClient : client ,
68
105
HeartbeatClient : heartbeatClient ,
@@ -71,7 +108,7 @@ func NewHollowKubelet(
71
108
Cloud : nil ,
72
109
OSInterface : & containertest.FakeOS {},
73
110
ContainerManager : containerManager ,
74
- VolumePlugins : volumePlugins ,
111
+ VolumePlugins : volumePlugins () ,
75
112
TLSOptions : nil ,
76
113
OOMAdjuster : oom .NewFakeOOMAdjuster (),
77
114
Mounter : mount .New ("" /* default mount path */ ),
0 commit comments