jobmgr

type Dyncfg interface {
	Register(cfg confgroup.Config)
	Unregister(cfg confgroup.Config)
	UpdateStatus(cfg confgroup.Config, status, payload string)
}

type FileLocker interface {
	Lock(name string) (bool, error)
	Unlock(name string) error
}

type Job interface {
	Name() string
	ModuleName() string
	FullName() string
	AutoDetection() bool
	AutoDetectionEvery() int
	RetryAutoDetection() bool
	Tick(clock int)
	Start()
	Stop()
	Cleanup()
}

type Manager struct {
	*logger.Logger

	PluginName string
	Out        io.Writer
	Modules    module.Registry

	FileLock    FileLocker
	StatusSaver StatusSaver
	StatusStore StatusStore
	Vnodes      Vnodes
	Dyncfg      Dyncfg
	// contains filtered or unexported fields
}

type StatusSaver interface {
	Save(cfg confgroup.Config, state string)
	Remove(cfg confgroup.Config)
}

type StatusStore interface {
	Contains(cfg confgroup.Config, states ...string) bool
}

type Vnodes interface {
	Lookup(key string) (*vnodes.VirtualNode, bool)
}