scheduler

package

v0.1.11 Latest Latest Go to latest Published: May 3, 2017 License: Apache-2.0 Imports: 25 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 ¶

Constants
func AckUpdateEvent(taskStatus *mesos.TaskStatus)
func DummyHandler(s *Scheduler, ev event.Event) error
func FailureHandler(s *Scheduler, ev event.Event) error
func HeartbeatHandler(s *Scheduler, ev event.Event) error
func InvalidAppHandler(s *Scheduler, ev event.Event) error
func LaunchTaskInfos(offer *mesos.Offer, taskInfos []*mesos.TaskInfo)
func LoggerHandler(s *Scheduler, ev event.Event) error
func MetricsHandler(s *Scheduler, ev event.Event) error
func NewMemoryStore() *memoryStore
func OfferHandler(s *Scheduler, ev event.Event) error
func RecindHandler(s *Scheduler, ev event.Event) error
func RejectOffer(offer *mesos.Offer)
func SubscribedHandler(s *Scheduler, ev event.Event) error
func UpdateHandler(s *Scheduler, ev event.Event) error
type HandlerFunc
- func (hf HandlerFunc) Name() string
type HandlerManager
- func NewHandlerManager(SchedulerRef *Scheduler) *HandlerManager
- func (m *HandlerManager) Handle(e event.Event)
- func (m *HandlerManager) HandlerFuncs(eType string) []HandlerFunc
- func (m *HandlerManager) Process(timeoutCtx context.Context, e event.Event)
- func (m *HandlerManager) Register(eType string, funcs ...HandlerFunc)
type Scheduler
- func NewScheduler(mConfig config.ManagerConfig) *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) 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, newWeights map[string]float64) 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) UpdateApp(appId string, version *types.Version) error

Constants ¶

View Source

const (
	CONNECTOR_DEFAULT_BACKOFF = 2 * time.Second
)

Variables ¶

This section is empty.

Functions ¶

func AckUpdateEvent ¶

func AckUpdateEvent(taskStatus *mesos.TaskStatus)

func DummyHandler ¶

func DummyHandler(s *Scheduler, ev event.Event) error

func FailureHandler ¶

func FailureHandler(s *Scheduler, ev event.Event) error

func HeartbeatHandler ¶

func HeartbeatHandler(s *Scheduler, ev event.Event) error

func InvalidAppHandler ¶

func InvalidAppHandler(s *Scheduler, ev event.Event) error

func LaunchTaskInfos ¶

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

func LoggerHandler ¶

func LoggerHandler(s *Scheduler, ev event.Event) error

func MetricsHandler ¶

func MetricsHandler(s *Scheduler, ev event.Event) error

func NewMemoryStore ¶

func NewMemoryStore() *memoryStore

NewMemoryStore initializes a new memory store.

func OfferHandler ¶

func OfferHandler(s *Scheduler, ev event.Event) error

func RecindHandler ¶

func RecindHandler(s *Scheduler, ev event.Event) error

func RejectOffer ¶

func RejectOffer(offer *mesos.Offer)

func SubscribedHandler ¶

func SubscribedHandler(s *Scheduler, ev event.Event) error

func UpdateHandler ¶

func UpdateHandler(s *Scheduler, ev event.Event) error

Types ¶

type HandlerFunc ¶

type HandlerFunc func(s *Scheduler, e event.Event) error

func (HandlerFunc) Name ¶

func (hf HandlerFunc) Name() string

type HandlerManager ¶

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

func NewHandlerManager ¶

func NewHandlerManager(SchedulerRef *Scheduler) *HandlerManager

func (*HandlerManager) Handle ¶

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

func (*HandlerManager) HandlerFuncs ¶

func (m *HandlerManager) HandlerFuncs(eType string) []HandlerFunc

func (*HandlerManager) Process ¶

func (m *HandlerManager) Process(timeoutCtx context.Context, e event.Event)

func (*HandlerManager) Register ¶

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

type Scheduler ¶

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

func NewScheduler ¶

func NewScheduler(mConfig config.ManagerConfig) *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) 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, newWeights map[string]float64) error

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

shutdown main scheduler and related revive from crash or rotate from leader change

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