package framework

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

Package framework implements the Mesos scheduler.

Index ¶

• type Config
• type Framework
• func New(config Config) Framework
• type JoinableDriver
• func (m *JoinableDriver) Join() (mesos.Status, error)
• func (m *JoinableDriver) Upon() <-chan struct{}
• type MockSchedulerDriver
• func (m *MockSchedulerDriver) Abort() (mesos.Status, error)
• func (m *MockSchedulerDriver) AcceptOffers(ids []*mesos.OfferID, ops []*mesos.Offer_Operation, f *mesos.Filters) (mesos.Status, error)
• func (m *MockSchedulerDriver) DeclineOffer(oid *mesos.OfferID, f *mesos.Filters) (mesos.Status, error)
• func (m *MockSchedulerDriver) Destroy()
• func (m *MockSchedulerDriver) Init() error
• func (m *MockSchedulerDriver) Join() (mesos.Status, error)
• func (m *MockSchedulerDriver) KillTask(tid *mesos.TaskID) (mesos.Status, error)
• func (m *MockSchedulerDriver) LaunchTasks(offerIds []*mesos.OfferID, ti []*mesos.TaskInfo, f *mesos.Filters) (mesos.Status, error)
• func (m *MockSchedulerDriver) ReconcileTasks(statuses []*mesos.TaskStatus) (mesos.Status, error)
• func (m *MockSchedulerDriver) RequestResources(r []*mesos.Request) (mesos.Status, error)
• func (m *MockSchedulerDriver) ReviveOffers() (mesos.Status, error)
• func (m *MockSchedulerDriver) Run() (mesos.Status, error)
• func (m *MockSchedulerDriver) SendFrameworkMessage(eid *mesos.ExecutorID, sid *mesos.SlaveID, s string) (mesos.Status, error)
• func (m *MockSchedulerDriver) Start() (mesos.Status, error)
• func (m *MockSchedulerDriver) Stop(b bool) (mesos.Status, error)
• func (m *MockSchedulerDriver) Upon() <-chan struct{}
• func (m *MockSchedulerDriver) Wait()

Types ¶

type Config ¶

type Config struct {
	SchedulerConfig   schedcfg.Config
	ExecutorId        *mesos.ExecutorID
	Client            *clientset.Clientset
	StoreFrameworkId  frameworkid.StoreFunc
	FailoverTimeout   float64
	ReconcileInterval int64
	ReconcileCooldown time.Duration
	LookupNode        node.LookupFunc
}

type Framework ¶

type Framework interface {
	bindings.Scheduler

	Init(sched scheduler.Scheduler, electedMaster proc.Process, mux *http.ServeMux) error
	Registration() <-chan struct{}
	Offers() offers.Registry
	LaunchTask(t *podtask.T) error
	KillTask(id string) error
}

func New ¶

func New(config Config) Framework

New creates a new Framework

type JoinableDriver ¶

type JoinableDriver struct {
	MockSchedulerDriver
	// contains filtered or unexported fields
}

func (*JoinableDriver) Join ¶

func (m *JoinableDriver) Join() (mesos.Status, error)

Join invokes joinFunc if it has been set, otherwise blocks forever

func (*JoinableDriver) Upon ¶

func (m *JoinableDriver) Upon() <-chan struct{}

Upon returns a chan that closes upon the execution of the most recently registered call.

type MockSchedulerDriver ¶

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

func (*MockSchedulerDriver) Abort ¶

func (m *MockSchedulerDriver) Abort() (mesos.Status, error)

func (*MockSchedulerDriver) AcceptOffers ¶

func (m *MockSchedulerDriver) AcceptOffers(ids []*mesos.OfferID, ops []*mesos.Offer_Operation, f *mesos.Filters) (mesos.Status, error)

func (*MockSchedulerDriver) DeclineOffer ¶

func (m *MockSchedulerDriver) DeclineOffer(oid *mesos.OfferID, f *mesos.Filters) (mesos.Status, error)

func (*MockSchedulerDriver) Destroy ¶

func (m *MockSchedulerDriver) Destroy()

func (*MockSchedulerDriver) Init ¶

func (m *MockSchedulerDriver) Init() error

func (*MockSchedulerDriver) Join ¶

func (m *MockSchedulerDriver) Join() (mesos.Status, error)

func (*MockSchedulerDriver) KillTask ¶

func (m *MockSchedulerDriver) KillTask(tid *mesos.TaskID) (mesos.Status, error)

func (*MockSchedulerDriver) LaunchTasks ¶

func (m *MockSchedulerDriver) LaunchTasks(offerIds []*mesos.OfferID, ti []*mesos.TaskInfo, f *mesos.Filters) (mesos.Status, error)

func (*MockSchedulerDriver) ReconcileTasks ¶

func (m *MockSchedulerDriver) ReconcileTasks(statuses []*mesos.TaskStatus) (mesos.Status, error)

func (*MockSchedulerDriver) RequestResources ¶

func (m *MockSchedulerDriver) RequestResources(r []*mesos.Request) (mesos.Status, error)

func (*MockSchedulerDriver) ReviveOffers ¶

func (m *MockSchedulerDriver) ReviveOffers() (mesos.Status, error)

func (*MockSchedulerDriver) Run ¶

func (m *MockSchedulerDriver) Run() (mesos.Status, error)

func (*MockSchedulerDriver) SendFrameworkMessage ¶

func (m *MockSchedulerDriver) SendFrameworkMessage(eid *mesos.ExecutorID, sid *mesos.SlaveID, s string) (mesos.Status, error)

func (*MockSchedulerDriver) Start ¶

func (m *MockSchedulerDriver) Start() (mesos.Status, error)

func (*MockSchedulerDriver) Stop ¶

func (m *MockSchedulerDriver) Stop(b bool) (mesos.Status, error)

func (*MockSchedulerDriver) Upon ¶

func (m *MockSchedulerDriver) Upon() <-chan struct{}

Upon returns a chan that closes upon the execution of the most recently registered call.

func (*MockSchedulerDriver) Wait ¶

func (m *MockSchedulerDriver) Wait()

Source Files ¶

doc.go driver_mock.go framework.go slaveregistry.go

Directories ¶