summaryrefslogtreecommitdiffstats
path: root/src/go/collectors/go.d.plugin/agent/jobmgr/di.go
diff options
context:
space:
mode:
Diffstat (limited to 'src/go/collectors/go.d.plugin/agent/jobmgr/di.go')
-rw-r--r--src/go/collectors/go.d.plugin/agent/jobmgr/di.go29
1 files changed, 18 insertions, 11 deletions
diff --git a/src/go/collectors/go.d.plugin/agent/jobmgr/di.go b/src/go/collectors/go.d.plugin/agent/jobmgr/di.go
index 746ef8588e..844e10c113 100644
--- a/src/go/collectors/go.d.plugin/agent/jobmgr/di.go
+++ b/src/go/collectors/go.d.plugin/agent/jobmgr/di.go
@@ -4,29 +4,36 @@ package jobmgr
import (
"github.com/netdata/netdata/go/go.d.plugin/agent/confgroup"
+ "github.com/netdata/netdata/go/go.d.plugin/agent/functions"
"github.com/netdata/netdata/go/go.d.plugin/agent/vnodes"
)
type FileLocker interface {
Lock(name string) (bool, error)
- Unlock(name string) error
+ Unlock(name string)
}
-type Vnodes interface {
- Lookup(key string) (*vnodes.VirtualNode, bool)
-}
-
-type StatusSaver interface {
+type FileStatus interface {
Save(cfg confgroup.Config, state string)
Remove(cfg confgroup.Config)
}
-type StatusStore interface {
+type FileStatusStore interface {
Contains(cfg confgroup.Config, states ...string) bool
}
-type Dyncfg interface {
- Register(cfg confgroup.Config)
- Unregister(cfg confgroup.Config)
- UpdateStatus(cfg confgroup.Config, status, payload string)
+type Vnodes interface {
+ Lookup(key string) (*vnodes.VirtualNode, bool)
+}
+
+type FunctionRegistry interface {
+ Register(name string, reg func(functions.Function))
+ Unregister(name string)
+}
+
+type dyncfgAPI interface {
+ CONFIGCREATE(id, status, configType, path, sourceType, source, supportedCommands string)
+ CONFIGDELETE(id string)
+ CONFIGSTATUS(id, status string)
+ FUNCRESULT(uid, contentType, payload, code, expireTimestamp string)
}