Documentation
¶
Index ¶
- Constants
- type Informer
- type JobsStat
- type Named
- type Plugin
- func (p *Plugin) AddWorker(plugin string) error
- func (p *Plugin) Collects() []*dep.In
- func (p *Plugin) Init() error
- func (p *Plugin) Jobs(name string) []*jobs.State
- func (p *Plugin) Name() string
- func (p *Plugin) RPC() any
- func (p *Plugin) RemoveWorker(plugin string) error
- func (p *Plugin) Workers(name string) []*process.State
- type WorkerList
- type WorkerManager
Constants ¶
View Source
const PluginName = "informer"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobsStat ¶
type JobsStat interface { Named // JobsState returns slice with the attached drivers information JobsState(ctx context.Context) ([]*jobs.State, error) }
JobsStat interface provides statistic for the job plugin
type Named ¶ added in v4.3.4
type Named interface { // Name returns user-friendly name of the plugin Name() string }
type Plugin ¶
type Plugin struct {
// contains filtered or unexported fields
}
func (*Plugin) RemoveWorker ¶ added in v4.3.1
type WorkerList ¶
type WorkerList struct { // Workers are list of workers. Workers []*process.State `json:"workers"` }
WorkerList contains a list of workers.
func (*WorkerList) Len ¶
func (w *WorkerList) Len() int
func (*WorkerList) Less ¶
func (w *WorkerList) Less(i, j int) bool
func (*WorkerList) Swap ¶
func (w *WorkerList) Swap(i, j int)
Click to show internal directories.
Click to hide internal directories.