scheduler

Documentation

Index

• func ServeExecutorArtifact(path, address string, artifactPort int) (*string, error)
• type EtcdScheduler
  • func NewEtcdScheduler(desiredInstanceCount int, chillSeconds int, reseedTimeout int, autoReseed bool, ...) *EtcdScheduler
  • func (s *EtcdScheduler) AdminHTTP(port int, driver scheduler.SchedulerDriver)
  • func (s *EtcdScheduler) Disconnected(scheduler.SchedulerDriver)
  • func (s *EtcdScheduler) Error(driver scheduler.SchedulerDriver, err string)
  • func (s *EtcdScheduler) ExecutorLost(scheduler.SchedulerDriver, *mesos.ExecutorID, *mesos.SlaveID, int)
  • func (s *EtcdScheduler) FrameworkMessage(driver scheduler.SchedulerDriver, exec *mesos.ExecutorID, slave *mesos.SlaveID, ...)
  • func (s *EtcdScheduler) Initialize(driver scheduler.SchedulerDriver, masterInfo *mesos.MasterInfo)
  • func (s *EtcdScheduler) OfferRescinded(driver scheduler.SchedulerDriver, offerID *mesos.OfferID)
  • func (s *EtcdScheduler) PeriodicHealthChecker()
  • func (s *EtcdScheduler) PeriodicLaunchRequestor()
  • func (s *EtcdScheduler) PeriodicReconciler(driver scheduler.SchedulerDriver)
  • func (s *EtcdScheduler) Prune() error
  • func (s *EtcdScheduler) PumpTheBrakes()
  • func (s *EtcdScheduler) QueueLaunchAttempt()
  • func (s *EtcdScheduler) Registered(driver scheduler.SchedulerDriver, frameworkID *mesos.FrameworkID, ...)
  • func (s *EtcdScheduler) Reregistered(driver scheduler.SchedulerDriver, masterInfo *mesos.MasterInfo)
  • func (s *EtcdScheduler) ResourceOffers(driver scheduler.SchedulerDriver, offers []*mesos.Offer)
  • func (s *EtcdScheduler) RunningCopy() map[string]*config.Node
  • func (s *EtcdScheduler) SerialLauncher(driver scheduler.SchedulerDriver)
  • func (s *EtcdScheduler) SlaveLost(scheduler.SchedulerDriver, *mesos.SlaveID)
  • func (s *EtcdScheduler) StatusUpdate(driver scheduler.SchedulerDriver, status *mesos.TaskStatus)
• type OfferResources
• type State
• type Stats

Functions

func ServeExecutorArtifact

func ServeExecutorArtifact(path, address string, artifactPort int) (*string, error)

Types

type EtcdScheduler

type EtcdScheduler struct {
	Stats         Stats
	Master        string
	ExecutorPath  string
	EtcdPath      string
	FrameworkName string
	ZkConnect     string
	ZkChroot      string
	ZkServers     []string
	// contains filtered or unexported fields
}

func NewEtcdScheduler

func NewEtcdScheduler(
	desiredInstanceCount int,
	chillSeconds int,
	reseedTimeout int,
	autoReseed bool,
	executorUris []*mesos.CommandInfo_URI,
	singleInstancePerSlave bool,
	diskPerTask float64,
	cpusPerTask float64,
	memPerTask float64,
) *EtcdScheduler

func (*EtcdScheduler) AdminHTTP

func (s *EtcdScheduler) AdminHTTP(port int, driver scheduler.SchedulerDriver)

func (*EtcdScheduler) Disconnected

func (s *EtcdScheduler) Disconnected(scheduler.SchedulerDriver)

func (*EtcdScheduler) Error

func (s *EtcdScheduler) Error(driver scheduler.SchedulerDriver, err string)

func (*EtcdScheduler) ExecutorLost

func (s *EtcdScheduler) ExecutorLost(
	scheduler.SchedulerDriver,
	*mesos.ExecutorID,
	*mesos.SlaveID,
	int,
)

func (*EtcdScheduler) FrameworkMessage

func (s *EtcdScheduler) FrameworkMessage(
	driver scheduler.SchedulerDriver,
	exec *mesos.ExecutorID,
	slave *mesos.SlaveID,
	msg string,
)

func (*EtcdScheduler) Initialize

func (s *EtcdScheduler) Initialize(
	driver scheduler.SchedulerDriver,
	masterInfo *mesos.MasterInfo,
)

func (*EtcdScheduler) OfferRescinded

func (s *EtcdScheduler) OfferRescinded(
	driver scheduler.SchedulerDriver,
	offerID *mesos.OfferID,
)

func (*EtcdScheduler) PeriodicHealthChecker

func (s *EtcdScheduler) PeriodicHealthChecker()

func (*EtcdScheduler) PeriodicLaunchRequestor

func (s *EtcdScheduler) PeriodicLaunchRequestor()

func (*EtcdScheduler) PeriodicReconciler

func (s *EtcdScheduler) PeriodicReconciler(driver scheduler.SchedulerDriver)

Perform implicit reconciliation every 5 minutes

func (*EtcdScheduler) Prune

func (s *EtcdScheduler) Prune() error

func (*EtcdScheduler) PumpTheBrakes

func (s *EtcdScheduler) PumpTheBrakes()

func (*EtcdScheduler) QueueLaunchAttempt

func (s *EtcdScheduler) QueueLaunchAttempt()

func (*EtcdScheduler) Registered

func (s *EtcdScheduler) Registered(
	driver scheduler.SchedulerDriver,
	frameworkID *mesos.FrameworkID,
	masterInfo *mesos.MasterInfo,
)

func (*EtcdScheduler) Reregistered

func (s *EtcdScheduler) Reregistered(
	driver scheduler.SchedulerDriver,
	masterInfo *mesos.MasterInfo,
)

func (*EtcdScheduler) ResourceOffers

func (s *EtcdScheduler) ResourceOffers(
	driver scheduler.SchedulerDriver,
	offers []*mesos.Offer,
)

func (*EtcdScheduler) RunningCopy

func (s *EtcdScheduler) RunningCopy() map[string]*config.Node

RunningCopy makes a copy of the running map to minimize time spent with the scheduler lock is minimized.

func (*EtcdScheduler) SerialLauncher

func (s *EtcdScheduler) SerialLauncher(driver scheduler.SchedulerDriver)

SerialLauncher performs the launching of all tasks in a time-limited way. This helps to prevent misconfiguration by allowing time for state to propagate.

func (*EtcdScheduler) SlaveLost

func (s *EtcdScheduler) SlaveLost(
	scheduler.SchedulerDriver,
	*mesos.SlaveID,
)

func (*EtcdScheduler) StatusUpdate

func (s *EtcdScheduler) StatusUpdate(
	driver scheduler.SchedulerDriver,
	status *mesos.TaskStatus,
)

type OfferResources

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

type State

type State int32

State represents the mutability of the scheduler.

const (
	// Mutable scheduler state occurs during:
	// * starting up for the first time
	// * growing (recovering) from 1 to N nodes
	// * pruning dead nodes
	// * exiting
	Mutable State = iota
	// Immutable scheduler state occurs during:
	// * waiting for state to settle during initialization
	// * disconnection from the Mesos master
	// * performing a backup with the intention of seeding a new cluster
	Immutable
)

type Stats

type Stats struct {
	RunningServers   uint32 `json:"running_servers"`
	LaunchedServers  uint32 `json:"launched_servers"`
	FailedServers    uint32 `json:"failed_servers"`
	ClusterLivelocks uint32 `json:"cluster_livelocks"`
	ClusterReseeds   uint32 `json:"cluster_reseeds"`
	IsHealthy        uint32 `json:"healthy"`
}