metacacheplugin

Documentation

Index

• Constants
• func NewMetaCachePlugin(pluginName string, conf *config.Configuration, _ interface{}, ...) (plugin.SysAdvisorPlugin, error)
• type MetaCachePlugin
  • func (mcp *MetaCachePlugin) Init() error
  • func (mcp *MetaCachePlugin) Name() string
  • func (mcp *MetaCachePlugin) Run(ctx context.Context)

Constants

const (
	// MetricsNamePlugMetaCacheHeartbeat is the heartbeat metrics of metacache plugin
	MetricsNamePlugMetaCacheHeartbeat = "plugin_metacache_heartbeat"
)

Functions

func NewMetaCachePlugin

func NewMetaCachePlugin(pluginName string, conf *config.Configuration, _ interface{}, emitterPool metricspool.MetricsEmitterPool,
	metaServer *metaserver.MetaServer, metaCache metacache.MetaCache,
) (plugin.SysAdvisorPlugin, error)

NewMetaCachePlugin creates a metacache plugin with the specified config

Types

type MetaCachePlugin

type MetaCachePlugin struct {
	MetaWriter metacache.MetaWriter
	// contains filtered or unexported fields
}

MetaCachePlugin collects pod info from kubelet

func (*MetaCachePlugin) Init

func (mcp *MetaCachePlugin) Init() error

Init initializes the metacache plugin

func (*MetaCachePlugin) Name

func (mcp *MetaCachePlugin) Name() string

Name returns the name of metacache

func (*MetaCachePlugin) Run

func (mcp *MetaCachePlugin) Run(ctx context.Context)

Run starts the metacache plugin