scheduler

Documentation

Index

• type DbBench
  • func NewDbBench() *DbBench
  • func (s *DbBench) AssignNode(nodes []pb.Node, specs []pb.NodeAssignmentSpec) ([]pb.AssignedNode, error)
  • func (s *DbBench) GetLogger() *dlog.Logger
  • func (s *DbBench) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity
  • func (s *DbBench) SetLogger(logger *dlog.Logger)
• type Error
  • func (e *Error) Error() string
• type Scheduler

Types

type DbBench

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

func NewDbBench

func NewDbBench() *DbBench

func (*DbBench) AssignNode

func (s *DbBench) AssignNode(nodes []pb.Node, specs []pb.NodeAssignmentSpec) ([]pb.AssignedNode, error)

func (*DbBench) GetLogger

func (s *DbBench) GetLogger() *dlog.Logger

func (*DbBench) LoggerIdentity

func (s *DbBench) LoggerIdentity(justCallMe func() *dlog.Identity) *dlog.Identity

func (*DbBench) SetLogger

func (s *DbBench) SetLogger(logger *dlog.Logger)

type Error

type Error struct {
	Code pb.ScheduleFail
}

Error is reason for failed to schedule a spec to one node

func (*Error) Error

func (e *Error) Error() string

type Scheduler

type Scheduler interface {
	AssignNode(nodes []pb.Node, specs []pb.NodeAssignmentSpec) ([]pb.AssignedNode, error)
}