scheduler

Documentation

Overview

TODO: refactor me, 把这个文件中的所有逻辑都去掉，只有 http 处理和 检查 参数合法性

Index

• func GetDCOSTokenAuthPeriodically()
• type HTTPResponse
• type Responser
• type Scheduler
  • func NewScheduler(instanceinfoImpl instanceinfo.InstanceInfo, ...) *Scheduler
  • func (s *Scheduler) CancelServiceGroup(namespace, name string) (interface{}, error)
  • func (s *Scheduler) EpGetRuntimeStatus(ctx context.Context, vars map[string]string) (*apistructs.MultiLevelStatus, error)

Functions

func GetDCOSTokenAuthPeriodically

func GetDCOSTokenAuthPeriodically()

call this in form of goroutine

Types

type HTTPResponse

type HTTPResponse = httpserver.HTTPResponse

type Responser

type Responser = httpserver.Responser

type Scheduler

type Scheduler struct {
	Httpendpoints *endpoints.HTTPEndpoints
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler(instanceinfoImpl instanceinfo.InstanceInfo, clusterSvc clusterpb.ClusterServiceServer) *Scheduler

NewSched, p.ClusterSvc, p.ClusterSvculer creates a scheduler instance, it be used to handle servicegroup create/update/delete actions.

func (*Scheduler) CancelServiceGroup

func (s *Scheduler) CancelServiceGroup(namespace, name string) (interface{}, error)

func (*Scheduler) EpGetRuntimeStatus

func (s *Scheduler) EpGetRuntimeStatus(ctx context.Context, vars map[string]string) (*apistructs.MultiLevelStatus, error)