Versions in this module Expand all Collapse all v0 v0.27.0 Apr 19, 2017 Changes in this version type Scheduler + func (s *Scheduler) Kill(taskId string) error v0.26.0 Oct 4, 2016 Changes in this version + func RegisterMetrics(r prometheus.Registerer) error v0.25.0 Sep 28, 2016 Changes in this version + var QueueSize = prometheus.NewGauge(prometheus.GaugeOpts{ ... }) + var TasksCreated = prometheus.NewCounter(prometheus.CounterOpts{ ... }) + var TasksDelayed = prometheus.NewCounter(prometheus.CounterOpts{ ... }) + var TasksLaunched = prometheus.NewCounter(prometheus.CounterOpts{ ... }) + var TasksRunning = prometheus.NewGauge(prometheus.GaugeOpts{ ... }) + var TasksTerminated = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... }) + func AttributeMatch(slaveConstraints []eremetic.SlaveConstraint) ogle.Matcher + func CPUAvailable(v float64) ogle.Matcher + func MemoryAvailable(v float64) ogle.Matcher + type Reconcile struct + func ReconcileTasks(driver mesossched.SchedulerDriver, database eremetic.TaskDB) *Reconcile + func (r *Reconcile) Cancel() + type Scheduler struct + func NewScheduler(queueSize int, db eremetic.TaskDB) *Scheduler + func (s *Scheduler) Disconnected(mesossched.SchedulerDriver) + func (s *Scheduler) Error(_ mesossched.SchedulerDriver, err string) + func (s *Scheduler) ExecutorLost(_ mesossched.SchedulerDriver, executorID *mesosproto.ExecutorID, ...) + func (s *Scheduler) FrameworkMessage(driver mesossched.SchedulerDriver, executorID *mesosproto.ExecutorID, ...) + func (s *Scheduler) OfferRescinded(_ mesossched.SchedulerDriver, offerID *mesosproto.OfferID) + func (s *Scheduler) Reconcile(driver mesossched.SchedulerDriver) + func (s *Scheduler) Registered(driver mesossched.SchedulerDriver, frameworkID *mesosproto.FrameworkID, ...) + func (s *Scheduler) Reregistered(driver mesossched.SchedulerDriver, masterInfo *mesosproto.MasterInfo) + func (s *Scheduler) ResourceOffers(driver mesossched.SchedulerDriver, offers []*mesosproto.Offer) + func (s *Scheduler) Run(settings *Settings) + func (s *Scheduler) ScheduleTask(request eremetic.Request) (string, error) + func (s *Scheduler) SlaveLost(_ mesossched.SchedulerDriver, slaveID *mesosproto.SlaveID) + func (s *Scheduler) StatusUpdate(driver mesossched.SchedulerDriver, status *mesosproto.TaskStatus) + func (s *Scheduler) Stop() + type Settings struct + Checkpoint bool + CredentialFile string + FailoverTimeout float64 + FrameworkID string + Master string + MaxQueueSize int + MessengerAddress string + MessengerPort uint16 + Name string + User string
Go to main page