mesos

Documentation

Index

• Constants
• func IsTerminalState(state string) bool
• type EventCallback
• type FrameworkIDStore
• type Resources
• type Scheduler
  • func NewScheduler(frameworkId FrameworkIDStore, conf SchedulerConfig) (Scheduler, error)
• type SchedulerConfig

Constants

const EXECUTOR_CPU = 0.01

const EXECUTOR_DISK = 1

const EXECUTOR_MEM = 32

Functions

func IsTerminalState

func IsTerminalState(state string) bool

Types

type EventCallback

type EventCallback func(Scheduler, msg.Event)

type FrameworkIDStore

type FrameworkIDStore interface {
	FrameworkID() (string, error)
	SetFrameworkID(string) error
}

type Resources

type Resources struct {
	CPU  float64 `json:"cpu"`
	Mem  float64 `json:"mem"`
	Disk float64 `json:"disk"`
}

type Scheduler

type Scheduler interface {
	HeartbeatInterval() time.Duration
	IsSubscribed() bool

	Subscribe() error
	Teardown() error
	Disconnect()

	Accept(msg.Offer, Resources, []msg.TaskInfo) error
	Decline([]string) error

	Suppress([]string) error
	Revive(string) error
	// Shutdown()
	Kill(string, string) error

	Acknowledge(string, string, string) error
	AcknowledgeOperationStatus(string, string, string, string) error

	Reconcile([]string) error
}

func NewScheduler

func NewScheduler(frameworkId FrameworkIDStore, conf SchedulerConfig) (Scheduler, error)

type SchedulerConfig

type SchedulerConfig struct {
	Name            string
	User            string
	Roles           []string
	Hostname        string
	WebUI           string
	MesosMaster     string
	Callbacks       []EventCallback
	FrameworkID     FrameworkIDStore
	FailoverTimeout time.Duration
}