type examplePlugin … type pluginServiceV1Beta1 … func (s *pluginServiceV1Beta1) GetExampleInfo(ctx context.Context, rqt *v1beta1.ExampleRequest) (*v1beta1.ExampleResponse, error) { … } func (s *pluginServiceV1Beta1) RegisterService() { … } type pluginServiceV1Beta2 … func (s *pluginServiceV1Beta2) GetExampleInfo(ctx context.Context, rqt *v1beta2.ExampleRequest) (*v1beta2.ExampleResponse, error) { … } func (s *pluginServiceV1Beta2) RegisterService() { … } // NewExamplePlugin returns an initialized examplePlugin instance func NewExamplePlugin() *examplePlugin { … } // NewTestExamplePlugin returns an initialized examplePlugin instance for testing func NewTestExamplePlugin(pluginName string, pluginType string, endpoint string, advertisedVersions ...string) *examplePlugin { … } // GetPluginInfo returns a PluginInfo object func GetPluginInfo(plugin *examplePlugin) cache.PluginInfo { … } // GetInfo is the RPC invoked by plugin watcher func (e *examplePlugin) GetInfo(ctx context.Context, req *registerapi.InfoRequest) (*registerapi.PluginInfo, error) { … } func (e *examplePlugin) NotifyRegistrationStatus(ctx context.Context, status *registerapi.RegistrationStatus) (*registerapi.RegistrationStatusResponse, error) { … } // Serve starts a pluginwatcher server and one or more of the plugin services func (e *examplePlugin) Serve(services ...string) error { … } func (e *examplePlugin) Stop() error { … }
Codebase Browser
kubernetes