scheduler

package

v0.1.9 Latest Latest Go to latest Published: Mar 20, 2017 License: Apache-2.0 Imports: 22 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/bbklab/swan

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

Constants ¶

View Source

const (
	CONNECTOR_DEFAULT_BACKOFF = 2 * time.Second
)

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 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 ¶ added in v0.1.3

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 ¶ added in v0.1.3

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

Source Files ¶

View all Source files

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