build

Documentation

Index

• type Manager
  • func NewManager() *Manager
  • func (m *Manager) Run(ctx context.Context, in chan []*confgroup.Group)
• type Registry
• type Runner
• type State
• type StateSaver
• type VNodeRegistry

Types

type Manager

type Manager struct {
	PluginName string
	Out        io.Writer
	Modules    module.Registry
	*logger.Logger

	Runner        Runner
	CurState      StateSaver
	PrevState     State
	Registry      Registry
	VNodeRegistry VNodeRegistry
	// 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 Registry

type Registry interface {
	Register(name string) (bool, error)
	Unregister(name string) error
}

type Runner

type Runner interface {
	Start(job jobpkg.Job)
	Stop(fullName string)
}

type State

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

type StateSaver

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

type VNodeRegistry

type VNodeRegistry interface {
	Lookup(key string) (*vnode.VirtualNode, bool)
}