Plugin Registration Service

This folder contains a utility, pluginwatcher, for Kubelet to register different types of node-level plugins such as device plugins or CSI plugins. It discovers plugins by monitoring inotify events under the directory returned by kubelet.getPluginsDir(). We will refer to this directory as PluginsDir.

Plugins are expected to implement the gRPC registration service specified in pkg/kubelet/apis/pluginregistration/v*/api.proto.

Plugin Discovery

The pluginwatcher service will discover plugins in the PluginDir when they place a socket in that directory or, at Kubelet start if the socket is already there.

This socket filename should not start with a '.' as it will be ignored.

gRPC Service Lifecycle

For any discovered plugin, kubelet will issue a Registration.GetInfo gRPC call to get plugin type, name, endpoint and supported service API versions.

Kubelet will then go through a plugin initialization phase where it will issue Plugin specific calls (e.g: DevicePlugin::GetDevicePluginOptions).

Once Kubelet determines that it is ready to use your plugin it will issue a Registration.NotifyRegistrationStatus gRPC call.

If the plugin removes its socket from the PluginDir this will be interpreted as a plugin Deregistration

gRPC Service Overview

Here are the general rules that Kubelet plugin developers should follow:

  • Run plugin as 'root' user. Currently creating socket under PluginsDir, a root owned directory, requires plugin process to be running as 'root'.

  • The plugin name sent during Registration.GetInfo grpc should be unique for the given plugin type (CSIPlugin or DevicePlugin).

  • The socket path needs to be unique within one directory, in normal case, each plugin type has its own sub directory, but the design does support socket file under any sub directory of PluginSockDir.

  • A plugin should clean up its own socket upon exiting or when a new instance comes up. A plugin should NOT remove any sockets belonging to other plugins.

  • A plugin should make sure it has service ready for any supported service API version listed in the PluginInfo.

  • For an example plugin implementation, take a look at example_plugin.go included in this directory.

Kubelet Interface

For any kubelet components using the pluginwatcher module, you will need to implement the PluginHandler interface defined in the types.go file.

The interface is documented and the implementations are registered with the pluginwatcher module in kubelet.go by calling AddHandler(pluginType, handler).

The lifecycle follows a simple state machine:

           Validate -> Register -> DeRegister
              ^          +
              |          |
              +--------- +

The pluginwatcher calls the functions with the received plugin name, supported service API versions and the endpoint to call the plugin on.

The Kubelet component that receives this callback can acknowledge or reject the plugin according to its own logic, and use the socket path to establish its service communication with any API version supported by the plugin.




This section is empty.


This section is empty.


func NewExampleHandler

func NewExampleHandler(supportedVersions []string, permitDeprecatedDir bool) *exampleHandler

    NewExampleHandler provide a example handler

    func NewExamplePlugin

    func NewExamplePlugin() *examplePlugin

      NewExamplePlugin returns an initialized examplePlugin instance

      func NewTestExamplePlugin

      func NewTestExamplePlugin(pluginName string, pluginType string, endpoint string, advertisedVersions ...string) *examplePlugin

        NewTestExamplePlugin returns an initialized examplePlugin instance for testing


        type PluginHandler

        type PluginHandler interface {
        	// Validate returns an error if the information provided by
        	// the potential plugin is erroneous (unsupported version, ...)
        	ValidatePlugin(pluginName string, endpoint string, versions []string, foundInDeprecatedDir bool) error
        	// RegisterPlugin is called so that the plugin can be register by any
        	// plugin consumer
        	// Error encountered here can still be Notified to the plugin.
        	RegisterPlugin(pluginName, endpoint string, versions []string) error
        	// DeRegister is called once the pluginwatcher observes that the socket has
        	// been deleted.
        	DeRegisterPlugin(pluginName string)

        type Watcher

        type Watcher struct {
        	// contains filtered or unexported fields

          Watcher is the plugin watcher

          func NewWatcher

          func NewWatcher(sockDir string, deprecatedSockDir string) *Watcher

            NewWatcher provides a new watcher deprecatedSockDir refers to a pre-GA directory that was used by older plugins for socket registration. New plugins should not use this directory.

            func (*Watcher) AddHandler

            func (w *Watcher) AddHandler(pluginType string, handler PluginHandler)

            func (*Watcher) Start

            func (w *Watcher) Start() error

              Start watches for the creation of plugin sockets at the path

              func (*Watcher) Stop

              func (w *Watcher) Stop() error

                Stop stops probing the creation of plugin sockets at the path


                Path Synopsis
                Package v1beta1 is a generated protocol buffer package.
                Package v1beta1 is a generated protocol buffer package.
                Package v1beta2 is a generated protocol buffer package.
                Package v1beta2 is a generated protocol buffer package.