scheduler

package

v0.1.1 Latest Latest Go to latest Published: Jan 17, 2017 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/2lambda123/dataman-cloud-swan

Links

Open Source Insights

Documentation ¶

Index ¶

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 AppFilterOptions
type Handler
- func (h *Handler) Process(timeoutCtx context.Context)
type HandlerFunc
type HandlerFuncs
type HandlerManager
- func NewHanlderManager(scheduler *Scheduler, installFun func(*HandlerManager)) *HandlerManager
type Response
- func NewResponse() *Response
type Scheduler
- func NewScheduler(store store.Store) *Scheduler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 AppFilterOptions ¶

type AppFilterOptions struct {
	LabelsSelector labels.Selector
	FieldsSelector fields.Selector
}

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 NewHanlderManager ¶

func NewHanlderManager(scheduler *Scheduler, installFun 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

	MesosConnector *mesos_connector.MesosConnector

	UserEventChan chan *event.UserEvent
	// contains filtered or unexported fields
}

func NewScheduler ¶

func NewScheduler(store store.Store) *Scheduler

func (*Scheduler) BuildHealthyTaskEvent ¶

func (scheduler *Scheduler) BuildHealthyTaskEvent() []*swanevent.Event

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(swanEvent *swanevent.Event)

func (*Scheduler) InspectApp ¶

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

func (*Scheduler) InvalidateApps ¶

func (scheduler *Scheduler) InvalidateApps()

reevaluation of apps state, clean up stale apps

func (*Scheduler) ListApps ¶

func (scheduler *Scheduler) ListApps(appFilterOptions 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

Source Files ¶

View all Source files

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