scheduler

package

v0.1.0-alpha-target-23... Latest Latest Go to latest Published: Oct 22, 2015 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/bluepeppers/etcd-mesos

Documentation ¶

Index ¶

func ServeExecutorArtifact(path, address string, artifactPort int) (*string, error)
type EtcdScheduler
- func NewEtcdScheduler(desiredInstanceCount int, chillSeconds int, reseedTimeout int, autoReseed bool, ...) *EtcdScheduler
type OfferResources
type State
type Stats

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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"`
}

Source Files ¶

View all Source files

scheduler.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL