jobmgr

Documentation

Index

• type Dyncfg
• type FileLocker
• type Job
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Run(ctx context.Context, in chan []*confgroup.Group)
• type StatusSaver
• type StatusStore
• type Vnodes

Types

type Dyncfg

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

type FileLocker

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

type Job

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

type Manager

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
}

func NewManager

func NewManager() *Manager

func (*Manager) Run

func (m *Manager) Run(ctx context.Context, in chan []*confgroup.Group)

type StatusSaver

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

type StatusStore

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

type Vnodes

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