kubernetes/pkg/kubelet/pluginmanager/pluginwatcher/example_handler.go

type exampleHandler …

type examplePluginEvent …

const exampleEventValidate …

const exampleEventRegister …

const exampleEventDeRegister …

// NewExampleHandler provide a example handler
func NewExampleHandler(supportedVersions []string, permitDeprecatedDir bool) *exampleHandler { … }

func (p *exampleHandler) ValidatePlugin(pluginName string, endpoint string, versions []string) error { … }

func (p *exampleHandler) RegisterPlugin(pluginName, endpoint string, versions []string) error { … }

func (p *exampleHandler) DeRegisterPlugin(pluginName string) { … }

func (p *exampleHandler) SendEvent(pluginName string, event examplePluginEvent) { … }

func (p *exampleHandler) DecreasePluginCount(pluginName string) (old int, ok bool) { … }

// Dial establishes the gRPC communication with the picked up plugin socket. https://godoc.org/google.golang.org/grpc#Dial
func dial(unixSocketPath string, timeout time.Duration) (registerapi.RegistrationClient, *grpc.ClientConn, error) { … }