plugin

Documentation

Index

• type Manager
  • func NewManager(cfg *config.Config) *Manager
  • func (m *Manager) Events() <-chan kplugin.Event
  • func (m *Manager) GetPluginNames() []string
  • func (m *Manager) GetPluginStatus(name string) PluginStatus
  • func (m *Manager) PluginStatusChanges() <-chan PluginStatusChange
  • func (m *Manager) Start(ctx context.Context)
  • func (m *Manager) Stop()
• type PluginStatus
• type PluginStatusChange

Types

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager(cfg *config.Config) *Manager

NewManager add plugins which is enabled

func (*Manager) Events

func (m *Manager) Events() <-chan kplugin.Event

func (*Manager) GetPluginNames

func (m *Manager) GetPluginNames() []string

func (*Manager) GetPluginStatus

func (m *Manager) GetPluginStatus(name string) PluginStatus

func (*Manager) PluginStatusChanges

func (m *Manager) PluginStatusChanges() <-chan PluginStatusChange

func (*Manager) Start

func (m *Manager) Start(ctx context.Context)

Start method run plugins in m.plugins

func (*Manager) Stop

func (m *Manager) Stop()

type PluginStatus

type PluginStatus string

const (
	StatusStopped PluginStatus = "stopped"
	StatusRunning PluginStatus = "running"
	StatusError   PluginStatus = "error"
	StatusUnknown PluginStatus = "unknown"
)

type PluginStatusChange

type PluginStatusChange struct {
	Name   string
	Status PluginStatus
	Time   time.Time
}