job

Documentation

Index

• type Executor
  • func NewExecutor() *Executor
  • func (exc *Executor) GetLogger() *dlog.Logger
  • func (exc *Executor) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity
  • func (exc *Executor) SetLogger(logger *dlog.Logger)
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) GetLogger() *dlog.Logger
  • func (m *Manager) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity
  • func (m *Manager) SetLogger(logger *dlog.Logger)

Types

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

Executor on local node execute plan received from central, one stage at a time

func NewExecutor

func NewExecutor() *Executor

func (*Executor) GetLogger

func (exc *Executor) GetLogger() *dlog.Logger

func (*Executor) LoggerIdentity

func (exc *Executor) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (*Executor) SetLogger

func (exc *Executor) SetLogger(logger *dlog.Logger)

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func NewManager

func NewManager() *Manager

func (*Manager) GetLogger

func (m *Manager) GetLogger() *dlog.Logger

func (*Manager) LoggerIdentity

func (m *Manager) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (*Manager) SetLogger

func (m *Manager) SetLogger(logger *dlog.Logger)