scheduler

Documentation

Index

• Constants
• func AckUpdateEvent(h *Handler, taskStatus *mesos.TaskStatus)
• func LaunchTaskInfos(h *Handler, offer *mesos.Offer, taskInfos []*mesos.TaskInfo)
• func NewMemoryStore() *memoryStore
• func RejectOffer(h *Handler, offer *mesos.Offer)
• type Handler
  • func DummyHandler(h *Handler) (*Handler, error)
  • func FailureHandler(h *Handler) (*Handler, error)
  • func HeartbeatHandler(h *Handler) (*Handler, error)
  • func InvalidAppHandler(h *Handler) (*Handler, error)
  • func LoggerHandler(h *Handler) (*Handler, error)
  • func MetricsHandler(h *Handler) (*Handler, error)
  • func NewHandler(id string, manager *HandlerManager, e event.Event) *Handler
  • func OfferHandler(h *Handler) (*Handler, error)
  • func RecindHandler(h *Handler) (*Handler, error)
  • func SubscribedHandler(h *Handler) (*Handler, error)
  • func UpdateHandler(h *Handler) (*Handler, error)
  • func (h *Handler) Process(timeoutCtx context.Context)
• type HandlerFunc
• type HandlerFuncs
• type HandlerManager
  • func NewHandlerManager(scheduler *Scheduler, installHandler func(*HandlerManager)) *HandlerManager
  • func (m *HandlerManager) Handle(e event.Event) *Handler
  • func (m *HandlerManager) HandlerFuncs(eType string) HandlerFuncs
  • func (m *HandlerManager) Register(eType string, funcs ...HandlerFunc)
  • func (m *HandlerManager) RemoveHandler(handlerId string)
• type Response
  • func NewResponse() *Response
• type Scheduler
  • func NewScheduler(store store.Store) *Scheduler
  • func (scheduler *Scheduler) CancelUpdate(appId string) error
  • func (scheduler *Scheduler) CreateApp(version *types.Version) (*state.App, error)
  • func (scheduler *Scheduler) DeleteApp(appId string) error
  • func (scheduler *Scheduler) EmitEvent(e *eventbus.Event)
  • func (scheduler *Scheduler) HealthyTaskEvents() []*eventbus.Event
  • func (scheduler *Scheduler) InspectApp(appId string) (*state.App, error)
  • func (scheduler *Scheduler) ListApps(appFilterOptions types.AppFilterOptions) []*state.App
  • func (scheduler *Scheduler) ProceedUpdate(appId string, instances int) error
  • func (scheduler *Scheduler) Run(ctx context.Context) error
  • func (scheduler *Scheduler) ScaleDown(appId string, removeInstances int) error
  • func (scheduler *Scheduler) ScaleUp(appId string, newInstances int, newIps []string) error
  • func (scheduler *Scheduler) Start(ctx context.Context) error
  • func (scheduler *Scheduler) Stop()
  • func (scheduler *Scheduler) UpdateApp(appId string, version *types.Version) error

Constants

const (
	CONNECTOR_DEFAULT_BACKOFF = 2 * time.Second
)

Functions

func AckUpdateEvent

func AckUpdateEvent(h *Handler, taskStatus *mesos.TaskStatus)

func LaunchTaskInfos

func LaunchTaskInfos(h *Handler, offer *mesos.Offer, taskInfos []*mesos.TaskInfo)

func NewMemoryStore

func NewMemoryStore() *memoryStore

NewMemoryStore initializes a new memory store.

func RejectOffer

func RejectOffer(h *Handler, offer *mesos.Offer)

Types

type Handler

type Handler struct {
	Id       string
	Manager  *HandlerManager
	Response *Response
	Event    event.Event
}

func DummyHandler

func DummyHandler(h *Handler) (*Handler, error)

func FailureHandler

func FailureHandler(h *Handler) (*Handler, error)

func HeartbeatHandler

func HeartbeatHandler(h *Handler) (*Handler, error)

func InvalidAppHandler

func InvalidAppHandler(h *Handler) (*Handler, error)

func LoggerHandler

func LoggerHandler(h *Handler) (*Handler, error)

func MetricsHandler

func MetricsHandler(h *Handler) (*Handler, error)

func NewHandler

func NewHandler(id string, manager *HandlerManager, e event.Event) *Handler

func OfferHandler

func OfferHandler(h *Handler) (*Handler, error)

func RecindHandler

func RecindHandler(h *Handler) (*Handler, error)

func SubscribedHandler

func SubscribedHandler(h *Handler) (*Handler, error)

func UpdateHandler

func UpdateHandler(h *Handler) (*Handler, error)

func (*Handler) Process

func (h *Handler) Process(timeoutCtx context.Context)

type HandlerFunc

type HandlerFunc func(s *Handler) (*Handler, error)

type HandlerFuncs

type HandlerFuncs []HandlerFunc

type HandlerManager

type HandlerManager struct {
	SchedulerRef *Scheduler
	// contains filtered or unexported fields
}

func NewHandlerManager

func NewHandlerManager(scheduler *Scheduler, installHandler func(*HandlerManager)) *HandlerManager

func (*HandlerManager) Handle

func (m *HandlerManager) Handle(e event.Event) *Handler

func (*HandlerManager) HandlerFuncs

func (m *HandlerManager) HandlerFuncs(eType string) HandlerFuncs

func (*HandlerManager) Register

func (m *HandlerManager) Register(eType string, funcs ...HandlerFunc)

func (*HandlerManager) RemoveHandler

func (m *HandlerManager) RemoveHandler(handlerId string)

type Response

type Response struct {
	Calls []*sched.Call
}

func NewResponse

func NewResponse() *Response

type Scheduler

type Scheduler struct {
	AppStorage     *memoryStore
	UserEventChan  chan *event.UserEvent
	MesosConnector *connector.Connector
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(store store.Store) *Scheduler

func (*Scheduler) CancelUpdate

func (scheduler *Scheduler) CancelUpdate(appId string) error

func (*Scheduler) CreateApp

func (scheduler *Scheduler) CreateApp(version *types.Version) (*state.App, error)

func (*Scheduler) DeleteApp

func (scheduler *Scheduler) DeleteApp(appId string) error

func (*Scheduler) EmitEvent

func (scheduler *Scheduler) EmitEvent(e *eventbus.Event)

func (*Scheduler) HealthyTaskEvents

func (scheduler *Scheduler) HealthyTaskEvents() []*eventbus.Event

func (*Scheduler) InspectApp

func (scheduler *Scheduler) InspectApp(appId string) (*state.App, error)

func (*Scheduler) ListApps

func (scheduler *Scheduler) ListApps(appFilterOptions types.AppFilterOptions) []*state.App

func (*Scheduler) ProceedUpdate

func (scheduler *Scheduler) ProceedUpdate(appId string, instances int) error

func (*Scheduler) Run

func (scheduler *Scheduler) Run(ctx context.Context) error

main loop

func (*Scheduler) ScaleDown

func (scheduler *Scheduler) ScaleDown(appId string, removeInstances int) error

func (*Scheduler) ScaleUp

func (scheduler *Scheduler) ScaleUp(appId string, newInstances int, newIps []string) error

func (*Scheduler) Start

func (scheduler *Scheduler) Start(ctx context.Context) error

revive from crash or rotate from leader change

func (*Scheduler) Stop

func (scheduler *Scheduler) Stop()

shutdown main scheduler and related

func (*Scheduler) UpdateApp

func (scheduler *Scheduler) UpdateApp(appId string, version *types.Version) error