fetcher

Documentation

Overview

Package fetcher is a framework to collect resources from multiple plugins (both in-tree and out-of-tree implementations) and push contents to reporter manager to assemble and update thrugh APIServer.

Index

• type ReporterPluginManager
  • func NewReporterPluginManager(reporterMgr reporter.Manager, emitter metrics.MetricEmitter, ...) (*ReporterPluginManager, error)
  • func (m *ReporterPluginManager) DeRegisterPlugin(pluginName string)
  • func (m *ReporterPluginManager) GetHandlerType() string
  • func (m *ReporterPluginManager) RegisterPlugin(pluginName, endpoint string, versions []string) error
  • func (m *ReporterPluginManager) Run(ctx context.Context)
  • func (m *ReporterPluginManager) ValidatePlugin(pluginName string, endpoint string, versions []string) error

Types

type ReporterPluginManager

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

ReporterPluginManager is used to manage in-tree or out-tree reporter plugin registrations and get report content from these plugins to aggregate them into the Reporter Manager

func NewReporterPluginManager

func NewReporterPluginManager(reporterMgr reporter.Manager, emitter metrics.MetricEmitter,
	metaServer *metaserver.MetaServer, conf *config.Configuration) (*ReporterPluginManager, error)

NewReporterPluginManager creates a new reporter plugin manager.

func (*ReporterPluginManager) DeRegisterPlugin

func (m *ReporterPluginManager) DeRegisterPlugin(pluginName string)

DeRegisterPlugin is to handler plugin de-register event

func (*ReporterPluginManager) GetHandlerType

func (m *ReporterPluginManager) GetHandlerType() string

GetHandlerType get manage plugin type

func (*ReporterPluginManager) RegisterPlugin

func (m *ReporterPluginManager) RegisterPlugin(pluginName, endpoint string, versions []string) error

RegisterPlugin is to handle plugin register event

func (*ReporterPluginManager) Run

func (m *ReporterPluginManager) Run(ctx context.Context)

Run start the reporter plugin manager

func (*ReporterPluginManager) ValidatePlugin

func (m *ReporterPluginManager) ValidatePlugin(pluginName string, endpoint string, versions []string) error

ValidatePlugin is to validate the plugin info is supported