mesosrunners

Documentation

Index

• type RunOnceApplicationContext
  • func NewRunOnceApplicationContext() *RunOnceApplicationContext
  • func (ctx *RunOnceApplicationContext) CheckConstraints(offer *mesos.Offer) string
  • func (ctx *RunOnceApplicationContext) LaunchTask(driver scheduler.SchedulerDriver, offer *mesos.Offer) error
  • func (ctx *RunOnceApplicationContext) Matches(offer *mesos.Offer) string
  • func (ctx *RunOnceApplicationContext) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus) bool
• type RunOnceRunner
  • func NewRunOnceRunner() *RunOnceRunner
  • func (r *RunOnceRunner) DeleteSchedule(id int64, cronScheduler framework.CronScheduler)
  • func (r *RunOnceRunner) ResourceOffer(driver scheduler.SchedulerDriver, offer *mesos.Offer) (string, error)
  • func (r *RunOnceRunner) ScheduleApplication(application *framework.Application, state framework.MesosState, ...) (int64, <-chan *framework.ApplicationRunStatus)
  • func (r *RunOnceRunner) ScheduleOnly(application *framework.Application, state framework.MesosState, ...) int64
  • func (r *RunOnceRunner) StageApplication(application *framework.Application, state framework.MesosState) <-chan *framework.ApplicationRunStatus
  • func (r *RunOnceRunner) StartOnly(application *framework.Application, state framework.MesosState, ...) int64
  • func (r *RunOnceRunner) StartWithSchedule(application *framework.Application, state framework.MesosState, ...) int64
  • func (r *RunOnceRunner) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus) bool

Types

type RunOnceApplicationContext

type RunOnceApplicationContext struct {
	Application *framework.Application
	StatusChan  chan *framework.ApplicationRunStatus

	InstancesLeftToRun int
	// contains filtered or unexported fields
}

func NewRunOnceApplicationContext

func NewRunOnceApplicationContext() *RunOnceApplicationContext

func (*RunOnceApplicationContext) CheckConstraints

func (ctx *RunOnceApplicationContext) CheckConstraints(offer *mesos.Offer) string

func (*RunOnceApplicationContext) LaunchTask

func (ctx *RunOnceApplicationContext) LaunchTask(driver scheduler.SchedulerDriver, offer *mesos.Offer) error

func (*RunOnceApplicationContext) Matches

func (ctx *RunOnceApplicationContext) Matches(offer *mesos.Offer) string

func (*RunOnceApplicationContext) StatusUpdate

func (ctx *RunOnceApplicationContext) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus) bool

type RunOnceRunner

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

func NewRunOnceRunner

func NewRunOnceRunner() *RunOnceRunner

func (*RunOnceRunner) DeleteSchedule

func (r *RunOnceRunner) DeleteSchedule(id int64, cronScheduler framework.CronScheduler)

func (*RunOnceRunner) ResourceOffer

func (r *RunOnceRunner) ResourceOffer(driver scheduler.SchedulerDriver, offer *mesos.Offer) (string, error)

func (*RunOnceRunner) ScheduleApplication

func (r *RunOnceRunner) ScheduleApplication(application *framework.Application, state framework.MesosState, cronScheduler framework.CronScheduler) (int64, <-chan *framework.ApplicationRunStatus)

func (*RunOnceRunner) ScheduleOnly

func (r *RunOnceRunner) ScheduleOnly(application *framework.Application, state framework.MesosState, cronScheduler framework.CronScheduler) int64

func (*RunOnceRunner) StageApplication

func (r *RunOnceRunner) StageApplication(application *framework.Application, state framework.MesosState) <-chan *framework.ApplicationRunStatus

func (*RunOnceRunner) StartOnly

func (r *RunOnceRunner) StartOnly(application *framework.Application, state framework.MesosState, cronScheduler framework.CronScheduler) int64

func (*RunOnceRunner) StartWithSchedule

func (r *RunOnceRunner) StartWithSchedule(application *framework.Application, state framework.MesosState, cronScheduler framework.CronScheduler) int64

func (*RunOnceRunner) StatusUpdate

func (r *RunOnceRunner) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus) bool