plugins

Documentation

Index

• Variables
• func AddNewPlugins(newPlugins map[string]*Plugin)
• func ClearAllPlugins()
• func DelNoUsePlugins(newPlugins map[string]*Plugin)
• func Detect()
• func ListPlugins() map[string]*Plugin
• func ListPluginsFromLocal() map[string]*Plugin
• func ListPluginsFromMonapi() map[string]*Plugin
• func PluginRun(plugin *Plugin)
• type Plugin
• type PluginScheduler
  • func NewPluginScheduler(p *Plugin) *PluginScheduler
  • func (p *PluginScheduler) Schedule()
  • func (p *PluginScheduler) Stop()

Variables

var (
	Plugins              = make(map[string]*Plugin)
	PluginsWithScheduler = make(map[string]*PluginScheduler)
)

Functions

func AddNewPlugins

func AddNewPlugins(newPlugins map[string]*Plugin)

func ClearAllPlugins

func ClearAllPlugins()

func DelNoUsePlugins

func DelNoUsePlugins(newPlugins map[string]*Plugin)

func Detect

func Detect()

func ListPlugins

func ListPlugins() map[string]*Plugin

key: 60_ntp.py

func ListPluginsFromLocal

func ListPluginsFromLocal() map[string]*Plugin

func ListPluginsFromMonapi

func ListPluginsFromMonapi() map[string]*Plugin

func PluginRun

func PluginRun(plugin *Plugin)

Types

type Plugin

type Plugin struct {
	FilePath string
	Params   string
	Env      string
	Stdin    string
	MTime    int64
	Cycle    int
}

type PluginScheduler

type PluginScheduler struct {
	Ticker *time.Ticker
	Plugin *Plugin
	Quit   chan struct{}
}

func NewPluginScheduler

func NewPluginScheduler(p *Plugin) *PluginScheduler

func (*PluginScheduler) Schedule

func (p *PluginScheduler) Schedule()

func (*PluginScheduler) Stop

func (p *PluginScheduler) Stop()