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) 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, desiredStateOfWorld cache.DesiredStateOfWorld) *Watcher

NewWatcher provides a new watcher for socket registration

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 19 packages (graph) and is imported by 1 packages. Updated 2020-09-04. Refresh now. Tools for package owners.