plugins

Documentation

Index

• Variables
• func ForceResetPlugin() error
• func GetCurrentPluginVersion() (string, error)
• func RunPlugins(dirs []string, metrics []model.PluginParam)
• func SyncConfig(pluginVer string, pluginDirs []string, pluginMetrics []model.PluginParam)
• func UpdatePlugin(ver string) error
• type Plugin
  • func (this *Plugin) Kill()
  • func (this *Plugin) Run()
  • func (this *Plugin) RunOnce()

Variables

var (
	PluginsLock = new(sync.RWMutex)
	Plugins     = make([]*Plugin, 0)
)

Functions

func ForceResetPlugin

func ForceResetPlugin() error

func GetCurrentPluginVersion

func GetCurrentPluginVersion() (string, error)

func RunPlugins

func RunPlugins(dirs []string, metrics []model.PluginParam)

func SyncConfig

func SyncConfig(pluginVer string, pluginDirs []string, pluginMetrics []model.PluginParam)

func UpdatePlugin

func UpdatePlugin(ver string) error

Types

type Plugin

type Plugin struct {
	FilePath string
	Step     int
	Params   []model.PluginParam
	// contains filtered or unexported fields
}

func (*Plugin) Kill

func (this *Plugin) Kill()

func (*Plugin) Run

func (this *Plugin) Run()

func (*Plugin) RunOnce

func (this *Plugin) RunOnce()