plugins

Documentation

Index

• func Flush(plugin string) map[string]interface{}
• func Initialize() error
• func Inventory() ([]byte, error)
• func IsInternal(plugin string) bool
• func IsValid(plugin string) bool
• func Run(plugin string) error
• func Scan() error
• type Metric
• type Metrics
• type Plugin
• type PluginList

Functions

func Flush

func Flush(plugin string) map[string]interface{}

Flush plugin metrics

func Initialize

func Initialize() error

Initialize the plugin manager

func Inventory

func Inventory() ([]byte, error)

Inventory returns list of active plugins

func IsInternal

func IsInternal(plugin string) bool

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

func IsValid

func IsValid(plugin string) bool

IsValid determines if a specific plugin is valid

func Run

func Run(plugin string) error

Run one or all plugins

func Scan

func Scan() error

Scan the plugin directory for new/updated plugins

Types

type Metric

type Metric struct {
	Type  string      `json:"_type"`
	Value interface{} `json:"_value"`
}

Metric defines an individual metric sample or array of samples (histogram)

type Metrics

type Metrics map[string]Metric

Metrics defines the list of metrics for a given plugin

type Plugin

type Plugin struct {
	sync.RWMutex

	ID           string
	InstanceID   string
	Name         string
	InstanceArgs []string
	Command      string
	Generation   uint64
	Running      bool
	// contains filtered or unexported fields
}

Plugin defines a specific plugin

type PluginList

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

PluginList all active plugins