impl

Documentation

Index

• Variables
• func New(scheduler *scheduler.Scheduler, frameworkName string, master string, ...) (manager, error)
• type NodeRegistry
  • func NewNodeRegistry() *NodeRegistry
  • func (nodeRegistry *NodeRegistry) Delete(id string)
  • func (nodeRegistry *NodeRegistry) Exists(id string) bool
  • func (nodeRegistry *NodeRegistry) Fetch(id string) (*managerInterface.Node, error)
  • func (nodeRegistry *NodeRegistry) Nodes() []*managerInterface.Node
  • func (nodeRegistry *NodeRegistry) Register(id string, node *managerInterface.Node)
  • func (nodeRegistry *NodeRegistry) Update(id string, node *managerInterface.Node)
  • func (nodeRegistry *NodeRegistry) UpdateTimeOfLastOffer(id string)
• type TaskRegistry
  • func NewTaskRegistry() *TaskRegistry
  • func (taskRegistry *TaskRegistry) Delete(id string)
  • func (taskRegistry *TaskRegistry) Fetch(id string) (*managerInterface.Task, error)
  • func (taskRegistry *TaskRegistry) OpenTaskRequests() []*managerInterface.Task
  • func (taskRegistry *TaskRegistry) OpenTaskRequestsNoSla() []*managerInterface.Task
  • func (taskRegistry *TaskRegistry) Register(id string, task *managerInterface.Task)
  • func (taskRegistry *TaskRegistry) RunningTasks() []*managerInterface.Task
  • func (taskRegistry *TaskRegistry) Tasks() []*managerInterface.Task
  • func (taskRegistry *TaskRegistry) TimeOfLastOffer(id string, task *managerInterface.Task)

Variables

var ErrNodeNotExists = errors.New("node does not exist")

var ErrTaskNotExists = errors.New("task does not exist")

Functions

func New

func New(
	scheduler *scheduler.Scheduler,
	frameworkName string,
	master string,
	listening string,
	redis string) (manager, error)

Types

type NodeRegistry

type NodeRegistry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNodeRegistry

func NewNodeRegistry() *NodeRegistry

func (*NodeRegistry) Delete

func (nodeRegistry *NodeRegistry) Delete(id string)

func (*NodeRegistry) Exists

func (nodeRegistry *NodeRegistry) Exists(id string) bool

func (*NodeRegistry) Fetch

func (nodeRegistry *NodeRegistry) Fetch(id string) (*managerInterface.Node, error)

func (*NodeRegistry) Nodes

func (nodeRegistry *NodeRegistry) Nodes() []*managerInterface.Node

func (*NodeRegistry) Register

func (nodeRegistry *NodeRegistry) Register(id string, node *managerInterface.Node)

func (*NodeRegistry) Update

func (nodeRegistry *NodeRegistry) Update(id string, node *managerInterface.Node)

func (*NodeRegistry) UpdateTimeOfLastOffer

func (nodeRegistry *NodeRegistry) UpdateTimeOfLastOffer(id string)

type TaskRegistry

type TaskRegistry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewTaskRegistry

func NewTaskRegistry() *TaskRegistry

func (*TaskRegistry) Delete

func (taskRegistry *TaskRegistry) Delete(id string)

func (*TaskRegistry) Fetch

func (taskRegistry *TaskRegistry) Fetch(id string) (*managerInterface.Task, error)

func (*TaskRegistry) OpenTaskRequests

func (taskRegistry *TaskRegistry) OpenTaskRequests() []*managerInterface.Task

func (*TaskRegistry) OpenTaskRequestsNoSla

func (taskRegistry *TaskRegistry) OpenTaskRequestsNoSla() []*managerInterface.Task

func (*TaskRegistry) Register

func (taskRegistry *TaskRegistry) Register(id string, task *managerInterface.Task)

func (*TaskRegistry) RunningTasks

func (taskRegistry *TaskRegistry) RunningTasks() []*managerInterface.Task

func (*TaskRegistry) Tasks

func (taskRegistry *TaskRegistry) Tasks() []*managerInterface.Task

func (*TaskRegistry) TimeOfLastOffer

func (taskRegistry *TaskRegistry) TimeOfLastOffer(id string, task *managerInterface.Task)