plugins

Documentation

Index

• type Plugins
  • func New(ctx context.Context, defaultPluginPath string) (*Plugins, error)
  • func (p *Plugins) Flush(pluginName string) *cgm.Metrics
  • func (p *Plugins) Inventory() []byte
  • func (p *Plugins) IsInternal(pluginName string) bool
  • func (p *Plugins) IsValid(pluginName string) bool
  • func (p *Plugins) Run(pluginName string) error
  • func (p *Plugins) Scan(b *builtins.Builtins) error
  • func (p *Plugins) Stop() error

Types

type Plugins

type Plugins struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Plugins defines plugin manager

func New

func New(ctx context.Context, defaultPluginPath string) (*Plugins, error)

New returns a new instance of the plugins manager

func (*Plugins) Flush

func (p *Plugins) Flush(pluginName string) *cgm.Metrics

Flush plugin metrics

func (*Plugins) Inventory

func (p *Plugins) Inventory() []byte

Inventory returns list of active plugins

func (*Plugins) IsInternal

func (p *Plugins) IsInternal(pluginName string) bool

IsInternal checks to see if the plugin is one of the internal plugins (write|statsd)

func (*Plugins) IsValid

func (p *Plugins) IsValid(pluginName string) bool

IsValid determines if a specific plugin is valid

func (*Plugins) Run

func (p *Plugins) Run(pluginName string) error

Run one or all plugins

func (*Plugins) Scan

func (p *Plugins) Scan(b *builtins.Builtins) error

Scan the plugin directory for new/updated plugins

func (*Plugins) Stop

func (p *Plugins) Stop() error

Stop any long running plugins