kubernetes: k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher Index | Files | Directories

package pluginwatcher

import "k8s.io/kubernetes/pkg/kubelet/pluginmanager/pluginwatcher"


Package Files

example_handler.go example_plugin.go plugin_watcher.go

func GetPluginInfo Uses

func GetPluginInfo(plugin *examplePlugin, foundInDeprecatedDir bool) cache.PluginInfo

GetPluginInfo returns a PluginInfo object

func NewExampleHandler Uses

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

NewExampleHandler provide a example handler

func NewExamplePlugin Uses

func NewExamplePlugin() *examplePlugin

NewExamplePlugin returns an initialized examplePlugin instance

func NewTestExamplePlugin Uses

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

NewTestExamplePlugin returns an initialized examplePlugin instance for testing

type Watcher Uses

type Watcher struct {
    // contains filtered or unexported fields

Watcher is the plugin watcher

func NewWatcher Uses

func NewWatcher(sockDir string, deprecatedSockDir string, desiredStateOfWorld cache.DesiredStateOfWorld) *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) Start Uses

func (w *Watcher) Start(stopCh <-chan struct{}) error

Start watches for the creation and deletion of plugin sockets at the path



Package pluginwatcher imports 20 packages (graph) and is imported by 1 packages. Updated 2019-09-20. Refresh now. Tools for package owners.