We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent c20046c commit 50ef4daCopy full SHA for 50ef4da
internal/plugin/server.go
@@ -59,7 +59,7 @@ type nvidiaDevicePlugin struct {
59
60
socket string
61
server *grpc.Server
62
- health chan *rm.Device
+ health chan *rm.DeviceEvent
63
stop chan interface{}
64
65
imexChannels imex.Channels
@@ -105,7 +105,7 @@ func getPluginSocketPath(resource spec.ResourceName) string {
105
106
func (plugin *nvidiaDevicePlugin) initialize() {
107
plugin.server = grpc.NewServer([]grpc.ServerOption{}...)
108
- plugin.health = make(chan *rm.Device)
+ plugin.health = make(chan *rm.DeviceEvent, 10)
109
plugin.stop = make(chan interface{})
110
}
111
0 commit comments