scheduler

Documentation

Index

• type Scheduler
  • func Subscribe(cfg *cfg.Config, frm *cfg.FrameworkConfig) *Scheduler
  • func (e *Scheduler) EventLoop()
  • func (e *Scheduler) HandleOffers(offers *mesosproto.Event_Offers) error
  • func (e *Scheduler) HandleUpdate(event *mesosproto.Event)
  • func (e *Scheduler) Heartbeat()
  • func (e *Scheduler) HeartbeatLoop()
  • func (e *Scheduler) PrepareTaskInfoExecuteContainer(agent *mesosproto.AgentID, cmd *cfg.Command) []*mesosproto.TaskInfo
  • func (e *Scheduler) ReconcileLoop()

Types

type Scheduler

type Scheduler struct {
	Config          *cfg.Config
	Framework       *cfg.FrameworkConfig
	Mesos           mesos.Mesos
	Client          *http.Client
	Req             *http.Request
	API             *api.API
	Vault           *vault.Vault
	Redis           *redis.Redis
	ConnectionError bool
}

Scheduler include all the current vars and global config

func Subscribe

func Subscribe(cfg *cfg.Config, frm *cfg.FrameworkConfig) *Scheduler

Subscribe to the mesos backend

func (*Scheduler) EventLoop

func (e *Scheduler) EventLoop()

EventLoop is the main loop for the mesos events.

func (*Scheduler) HandleOffers

func (e *Scheduler) HandleOffers(offers *mesosproto.Event_Offers) error

HandleOffers will handle the offers event of mesos

func (*Scheduler) HandleUpdate

func (e *Scheduler) HandleUpdate(event *mesosproto.Event)

HandleUpdate will handle the offers event of mesos

func (*Scheduler) Heartbeat

func (e *Scheduler) Heartbeat()

Heartbeat - The Apache Mesos heatbeat function nolint:gocyclo

func (*Scheduler) HeartbeatLoop

func (e *Scheduler) HeartbeatLoop()

HeartbeatLoop - The main loop for the hearbeat

func (*Scheduler) PrepareTaskInfoExecuteContainer

func (e *Scheduler) PrepareTaskInfoExecuteContainer(agent *mesosproto.AgentID, cmd *cfg.Command) []*mesosproto.TaskInfo

PrepareTaskInfoExecuteContainer will create the TaskInfo Protobuf for Mesos nolint: gocyclo

func (*Scheduler) ReconcileLoop

func (e *Scheduler) ReconcileLoop()

ReconcileLoop - The reconcile loop to check periodicly the task state