endpoints

func (*Endpoints) CreateCluster ¶

func (e *Endpoints) CreateCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

CreateCluster 创建集群

func (*Endpoints) DBClient ¶

func (e *Endpoints) DBClient() *dao.DBClient

DBClient 获取db client

func (*Endpoints) DealTaskEvent ¶

func (e *Endpoints) DealTaskEvent(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

DealTaskEvent 接收任务的事件

func (*Endpoints) DeleteCluster ¶

func (e *Endpoints) DeleteCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

DeleteCluster 删除集群

func (*Endpoints) GetCluster ¶

func (e *Endpoints) GetCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

GetCluster 获取集群详情

func (*Endpoints) GetHost ¶

func (e *Endpoints) GetHost(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

GetHost 获取指定集群下某个host的信息

func (*Endpoints) GetLocale ¶

func (e *Endpoints) GetLocale(request *http.Request) *i18n.LocaleResource

GetLocale 获取本地化资源

func (*Endpoints) Health ¶

func (e *Endpoints) Health(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

Component health check interface

func (*Endpoints) Info ¶

func (e *Endpoints) Info(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

Info 用于健康检查

func (*Endpoints) ListCluster ¶

func (e *Endpoints) ListCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

ListCluster 获取集群列表(可按orgID过滤)

func (*Endpoints) ListEdasContainers ¶

func (e *Endpoints) ListEdasContainers(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

ListEdasContainers 获取 edas 实例列表 (内部调用)

func (*Endpoints) ListOrgRunningTasks ¶

func (e *Endpoints) ListOrgRunningTasks(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

ListOrgRunningTasks 指定企业获取服务或者job列表

func (*Endpoints) Routes ¶

func (e *Endpoints) Routes() []httpserver.Endpoint

Routes 返回 endpoints 的所有 endpoint 方法，也就是 route.

func (*Endpoints) SyncHostResource ¶

func (e *Endpoints) SyncHostResource(interval time.Duration)

SyncHostResource 定时同步主机实际使用资源

func (*Endpoints) SyncTaskStatus ¶

func (e *Endpoints) SyncTaskStatus(interval time.Duration)

SyncTaskStatus 定时同步主机实际使用资源

func (*Endpoints) TaskClean ¶

func (e *Endpoints) TaskClean(interval time.Duration)

TaskClean 定时清理任务(job/deployment)资源

func (*Endpoints) UCClient ¶

func (e *Endpoints) UCClient() *ucauth.UCClient

func (*Endpoints) UpdateCluster ¶

func (e *Endpoints) UpdateCluster(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)

UpdateCluster 更新集群

func (*Endpoints) UpdateInstanceBySchedulerEvent ¶

func (e *Endpoints) UpdateInstanceBySchedulerEvent(ctx context.Context, r *http.Request, vars map[string]string) (httpserver.Responser, error)