package pluginwatcher

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

Index ¶

• func GetPluginInfo(plugin *examplePlugin) cache.PluginInfo
• func NewExampleHandler(supportedVersions []string, permitDeprecatedDir bool) *exampleHandler
• func NewExamplePlugin() *examplePlugin
• func NewTestExamplePlugin(pluginName string, pluginType string, endpoint string, advertisedVersions ...string) *examplePlugin
• type Watcher
• func NewWatcher(sockDir string, desiredStateOfWorld cache.DesiredStateOfWorld) *Watcher
• func (w *Watcher) Start(stopCh <-chan struct{}) error

Functions ¶

func GetPluginInfo ¶

func GetPluginInfo(plugin *examplePlugin) cache.PluginInfo

GetPluginInfo returns a PluginInfo object

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

Types ¶

type Watcher ¶

type Watcher struct {
	// contains filtered or unexported fields
}

Watcher is the plugin watcher

func NewWatcher ¶

func NewWatcher(sockDir string, desiredStateOfWorld cache.DesiredStateOfWorld) *Watcher

NewWatcher provides a new watcher for socket registration

func (*Watcher) Start ¶

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

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

Source Files ¶

example_handler.go example_plugin.go plugin_watcher.go plugin_watcher_others.go

Directories ¶