Versions in this module Expand all Collapse all v0 v0.20.0 Jun 24, 2015 Changes in this version + func FCFSScheduleFunc(r offers.Registry, unused SlaveIndex, task *podtask.T) (offers.Perishable, error) + type Config struct + Client *client.Client + EtcdClient tools.EtcdGetSet + Executor *mesos.ExecutorInfo + FailoverTimeout float64 + ReconcileCooldown time.Duration + ReconcileInterval int64 + Schedcfg schedcfg.Config + ScheduleFunc PodScheduleFunc + type KubernetesScheduler struct + func New(config Config) *KubernetesScheduler + func (k *KubernetesScheduler) Disconnected(driver bindings.SchedulerDriver) + func (k *KubernetesScheduler) Error(driver bindings.SchedulerDriver, message string) + func (k *KubernetesScheduler) ExecutorLost(driver bindings.SchedulerDriver, executorId *mesos.ExecutorID, ...) + func (k *KubernetesScheduler) FrameworkMessage(driver bindings.SchedulerDriver, executorId *mesos.ExecutorID, ...) + func (k *KubernetesScheduler) Init(electedMaster proc.Process, pl PluginInterface, mux *http.ServeMux) error + func (k *KubernetesScheduler) InstallDebugHandlers(mux *http.ServeMux) + func (k *KubernetesScheduler) NewDefaultPluginConfig(terminate <-chan struct{}, mux *http.ServeMux) *PluginConfig + func (k *KubernetesScheduler) NewPluginConfig(terminate <-chan struct{}, mux *http.ServeMux, podsWatcher *cache.ListWatch) *PluginConfig + func (k *KubernetesScheduler) OfferRescinded(driver bindings.SchedulerDriver, offerId *mesos.OfferID) + func (k *KubernetesScheduler) Registered(drv bindings.SchedulerDriver, fid *mesos.FrameworkID, mi *mesos.MasterInfo) + func (k *KubernetesScheduler) Registration() <-chan struct{} + func (k *KubernetesScheduler) Reregistered(drv bindings.SchedulerDriver, mi *mesos.MasterInfo) + func (k *KubernetesScheduler) ResourceOffers(driver bindings.SchedulerDriver, offers []*mesos.Offer) + func (k *KubernetesScheduler) SlaveLost(driver bindings.SchedulerDriver, slaveId *mesos.SlaveID) + func (k *KubernetesScheduler) StatusUpdate(driver bindings.SchedulerDriver, taskStatus *mesos.TaskStatus) + type PluginConfig struct + type PluginInterface interface + Run func(<-chan struct{}) + func NewPlugin(c *PluginConfig) PluginInterface + type Pod struct + func (dp *Pod) Deadline() (time.Time, bool) + func (dp *Pod) GetDelay() time.Duration + func (p *Pod) Breaker() queue.BreakChan + func (p *Pod) Copy() queue.Copyable + func (p *Pod) GetUID() string + func (p *Pod) String() string + type PodScheduleFunc func(r offers.Registry, slaves SlaveIndex, task *podtask.T) (offers.Perishable, error) + type Reconciler struct + Action ReconcilerAction + func (r *Reconciler) RequestExplicit() + func (r *Reconciler) RequestImplicit() + func (r *Reconciler) Run(driver bindings.SchedulerDriver) + type ReconcilerAction func(driver bindings.SchedulerDriver, cancel <-chan struct{}) <-chan error + type Slave struct + HostName string + type SlaveIndex interface