package scheduler

import "k8s.io/kubernetes/contrib/mesos/pkg/scheduler"

Package scheduler implements the Kubernetes Mesos scheduler.

Index ¶

• type MockScheduler
• func (m *MockScheduler) KillTask(taskId string) error
• func (m *MockScheduler) LaunchTask(task *podtask.T) error
• func (m *MockScheduler) Offers() (f offers.Registry)
• func (m *MockScheduler) Reconcile(task *podtask.T)
• func (m *MockScheduler) Run(done <-chan struct{})
• func (m *MockScheduler) Tasks() (f podtask.Registry)
• type Scheduler

Types ¶

type MockScheduler ¶

type MockScheduler struct {
	sync.RWMutex
	mock.Mock
}

MockScheduler implements SchedulerApi

func (*MockScheduler) KillTask ¶

func (m *MockScheduler) KillTask(taskId string) error

func (*MockScheduler) LaunchTask ¶

func (m *MockScheduler) LaunchTask(task *podtask.T) error

func (*MockScheduler) Offers ¶

func (m *MockScheduler) Offers() (f offers.Registry)

func (*MockScheduler) Reconcile ¶

func (m *MockScheduler) Reconcile(task *podtask.T)

func (*MockScheduler) Run ¶

func (m *MockScheduler) Run(done <-chan struct{})

func (*MockScheduler) Tasks ¶

func (m *MockScheduler) Tasks() (f podtask.Registry)

type Scheduler ¶

type Scheduler interface {
	Tasks() podtask.Registry
	sync.Locker // synchronize changes to tasks, i.e. lock, get task, change task, store task, unlock

	Offers() offers.Registry
	Reconcile(t *podtask.T)
	KillTask(id string) error
	LaunchTask(t *podtask.T) error
	Run(done <-chan struct{})
}

Scheduler abstracts everything other components of the scheduler need to access from eachother

Source Files ¶

doc.go scheduler.go scheduler_mock.go

Directories ¶