Skip to content

Commit e30aebd

Browse files
committed
provider recorder to attach detach controller
Signed-off-by: Huamin Chen <[email protected]>
1 parent 9e1c93e commit e30aebd

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

pkg/cmd/server/kubernetes/master.go

+4-1
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,9 @@ func (c *MasterConfig) RunPersistentVolumeController(client *kclientset.Clientse
109109

110110
func (c *MasterConfig) RunPersistentVolumeAttachDetachController(client *kclientset.Clientset) {
111111
s := c.ControllerManager
112+
eventBroadcaster := record.NewBroadcaster()
113+
eventBroadcaster.StartRecordingToSink((&kcoreclient.EventSinkImpl{Interface: c.KubeClient.Core().Events("")}))
114+
recorder := eventBroadcaster.NewRecorder(kapi.EventSource{Component: "controller-manager"})
112115
attachDetachController, err :=
113116
attachdetachcontroller.NewAttachDetachController(
114117
client,
@@ -118,7 +121,7 @@ func (c *MasterConfig) RunPersistentVolumeAttachDetachController(client *kclient
118121
c.Informers.KubernetesInformers().PersistentVolumes().Informer(),
119122
c.CloudProvider,
120123
kctrlmgr.ProbeAttachableVolumePlugins(s.VolumeConfiguration),
121-
nil,
124+
recorder,
122125
s.DisableAttachDetachReconcilerSync,
123126
s.ReconcilerSyncLoopPeriod.Duration,
124127
)

0 commit comments

Comments
 (0)