blob: f2fa661c18c417ed46630fb146e04602a0a33b0e (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
// SPDX-License-Identifier: GPL-3.0-or-later
package module
import "fmt"
const (
UpdateEvery = 1
AutoDetectionRetry = 0
Priority = 70000
)
// Defaults is a set of module default parameters.
type Defaults struct {
UpdateEvery int
AutoDetectionRetry int
Priority int
Disabled bool
}
type (
// Creator is a Job builder.
Creator struct {
Defaults
Create func() Module
JobConfigSchema string
}
// Registry is a collection of Creators.
Registry map[string]Creator
)
// DefaultRegistry DefaultRegistry.
var DefaultRegistry = Registry{}
// Register registers a module in the DefaultRegistry.
func Register(name string, creator Creator) {
DefaultRegistry.Register(name, creator)
}
// Register registers a module.
func (r Registry) Register(name string, creator Creator) {
if _, ok := r[name]; ok {
panic(fmt.Sprintf("%s is already in registry", name))
}
r[name] = creator
}
func (r Registry) Lookup(name string) (Creator, bool) {
v, ok := r[name]
return v, ok
}
|
