mesos

type EventCallback func(Scheduler, msg.Event)

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

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

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
}

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