plugins

Documentation

Index

• Variables
• func AddNewPlugins(newPlugins map[string]*Plugin)
• func ClearAllPlugins()
• func DelNoUsePlugins(newPlugins map[string]*Plugin)
• func GetCurrGitRepo() (str string, err error)
• func GetCurrPluginVersion() (str string, err error)
• func GitLsRemote(gitRepo string, refs string) (string, error)
• func ListPlugins(relativePath string) map[string]*Plugin
• func PluginRun(plugin *Plugin)
• func SetCurrGitRepo(gitRepo string) error
• func UpdatePlugin(ver string, repo string) error
• type Plugin
• type PluginScheduler
  • func NewPluginScheduler(p *Plugin) *PluginScheduler
  • func (this *PluginScheduler) Schedule()
  • func (this *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 GetCurrGitRepo

func GetCurrGitRepo() (str string, err error)

func GetCurrPluginVersion

func GetCurrPluginVersion() (str string, err error)

func GitLsRemote

func GitLsRemote(gitRepo string, refs string) (string, error)

func ListPlugins

func ListPlugins(relativePath string) map[string]*Plugin

key: sys/ntp/60_ntp.py

func PluginRun

func PluginRun(plugin *Plugin)

func SetCurrGitRepo

func SetCurrGitRepo(gitRepo string) error

func UpdatePlugin

func UpdatePlugin(ver string, repo string) error

Types

type Plugin

type Plugin struct {
	FilePath 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 (this *PluginScheduler) Schedule()

func (*PluginScheduler) Stop

func (this *PluginScheduler) Stop()