registration

Documentation

Index

• Constants
• func NewRegistrationHandler(pluginType, pluginName string, supportedVersions []string) watcherapi.RegistrationServer
• type AgentPluginHandler
• type RegistrationHandler
  • func (handler *RegistrationHandler) GetInfo(ctx context.Context, req *watcherapi.InfoRequest) (*watcherapi.PluginInfo, error)
  • func (handler *RegistrationHandler) NotifyRegistrationStatus(ctx context.Context, status *watcherapi.RegistrationStatus) (*watcherapi.RegistrationStatusResponse, error)

Constants

const (
	EvictionPlugin    = "EvictionPlugin"
	ReporterPlugin    = "ReporterPlugin"
	QoSResourcePlugin = "QoSResourcePlugin"

	BaseVersion = "v1alpha1"
)

Functions

func NewRegistrationHandler

func NewRegistrationHandler(pluginType, pluginName string, supportedVersions []string) watcherapi.RegistrationServer

Types

type AgentPluginHandler

type AgentPluginHandler interface {
	GetHandlerType() string
	plugincache.PluginHandler
}

type RegistrationHandler

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

func (*RegistrationHandler) GetInfo

func (handler *RegistrationHandler) GetInfo(ctx context.Context, req *watcherapi.InfoRequest) (*watcherapi.PluginInfo, error)

GetInfo is the RPC which return pluginInfo

func (*RegistrationHandler) NotifyRegistrationStatus

func (handler *RegistrationHandler) NotifyRegistrationStatus(ctx context.Context, status *watcherapi.RegistrationStatus) (*watcherapi.RegistrationStatusResponse, error)

NotifyRegistrationStatus receives the registration notification from watcher