Versions in this module Expand all Collapse all v1 v1.19.1 Oct 25, 2022 Changes in this version + type DeleteAppOpeParam struct + type DeleteTaskGroupOpeParam struct + TaskGroupId string + type DeleteTaskGroupsOpeParam struct + type FetchVersionOpeParam struct + VersionId string + type OperateItem struct + ModuleId string + Name string + RunAs string + SetId string + type RollbackOpeParam struct + type ScaleOpeParam struct + Instance uint64 + type Scheduler struct + func NewScheduler() *Scheduler + func (s *Scheduler) Actions() []*httpserver.Action + func (s *Scheduler) CreateAdmissionWebhook(body []byte) (string, error) + func (s *Scheduler) CreateAdmissionwebhookHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) CreateApplication(body []byte) (string, error) + func (s *Scheduler) CreateApplicationHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) CreateConfigMap(body []byte) (string, error) + func (s *Scheduler) CreateConfigMapHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) CreateCustomResource(ns, kind string, body []byte) (string, error) + func (s *Scheduler) CreateDaemonset(body []byte) (string, error) + func (s *Scheduler) CreateDeployment(body []byte) (string, error) + func (s *Scheduler) CreateProcessHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) CreateSecret(body []byte) (string, error) + func (s *Scheduler) CreateSecretHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) CreateService(body []byte) (string, error) + func (s *Scheduler) CreateServiceHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteAdmissionWebhook(ns string, name string) (string, error) + func (s *Scheduler) DeleteAdmissionwebhookHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteApplication(ns, name, enforce string, kind bcstype.BcsDataType) (string, error) + func (s *Scheduler) DeleteApplicationHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteApplicationTaskGroup(body []byte) (string, error) + func (s *Scheduler) DeleteApplicationTaskGroupHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteApplicationTaskGroups(body []byte) (string, error) + func (s *Scheduler) DeleteApplicationTaskGroupsHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteConfigMap(ns string, name string) (string, error) + func (s *Scheduler) DeleteConfigMapHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteCustomResource(ns, kind, name string) (string, error) + func (s *Scheduler) DeleteProcessHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteSecret(ns string, name string) (string, error) + func (s *Scheduler) DeleteSecretHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) DeleteService(ns string, name string) (string, error) + func (s *Scheduler) DeleteServiceHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) FetchAdmissionWebhook(ns string, name string) (string, error) + func (s *Scheduler) FetchAdmissionwebhookHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) FetchAllAdmissionWebhooks() (string, error) + func (s *Scheduler) FetchAllAdmissionwebhooksHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) FetchApplication(ns, name string, kind bcstype.BcsDataType) (string, error) + func (s *Scheduler) FetchApplicationHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) FetchApplicationVersion(ns, name, versionID string) (string, error) + func (s *Scheduler) FetchApplicationVersionHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) FetchProcessHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) GetClusterCurrentOffersHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) GetClusterEndpointsHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) GetClusterResourcesHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) GetCustomResource(ns, kind, name string) (string, error) + func (s *Scheduler) GetHost() string + func (s *Scheduler) GetHttpClient() *httpclient.HttpClient + func (s *Scheduler) InitConfig(conf *config.MesosDriverConfig) + func (s *Scheduler) ListAllCustomResource(kind string) (string, error) + func (s *Scheduler) ListApplicationTaskGroups(ns, name string) (string, error) + func (s *Scheduler) ListApplicationTaskGroupsHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) ListApplicationTasks(ns, name string) (string, error) + func (s *Scheduler) ListApplicationTasksHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) ListApplicationVersions(ns, name string) (string, error) + func (s *Scheduler) ListApplicationVersionsHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) ListApplications(ns string, kind bcstype.BcsDataType) (string, error) + func (s *Scheduler) ListApplicationsHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) ListCustomResource(ns, kind string) (string, error) + func (s *Scheduler) ListProcessesHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) RegisterCustomResource(body []byte) (string, error) + func (s *Scheduler) ReloadTaskGroup(taskGroupID string) (string, error) + func (s *Scheduler) RescheduleTaskgroup(taskgroupId, hostRetainTime string) (string, error) + func (s *Scheduler) RestartTaskGroup(taskGroupID string) (string, error) + func (s *Scheduler) RollbackApplication(body []byte, kind bcstype.BcsDataType) (string, error) + func (s *Scheduler) RollbackApplicationHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) RollbackProcessHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) ScaleApplication(ns, name, instances string, kind bcstype.BcsDataType) (string, error) + func (s *Scheduler) ScaleApplicationHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) ScaleProcessHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) SendMessageApplication(ns, name, taskgroupId string, body []byte) (string, error) + func (s *Scheduler) SendMessageApplicationHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) SendMessageTaskgroupHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) SetHost(hosts []string) + func (s *Scheduler) UpdateAdmissionWebhook(body []byte) (string, error) + func (s *Scheduler) UpdateAdmissionwebhookHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) UpdateApplication(body []byte, instances, args string) (string, error) + func (s *Scheduler) UpdateApplicationHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) UpdateConfigMap(body []byte) (string, error) + func (s *Scheduler) UpdateConfigMapHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) UpdateCustomResource(ns, kind string, body []byte) (string, error) + func (s *Scheduler) UpdateDeployment(body []byte) (string, error) + func (s *Scheduler) UpdateProcessHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) UpdateSecret(body []byte) (string, error) + func (s *Scheduler) UpdateSecretHandler(req *restful.Request, resp *restful.Response) + func (s *Scheduler) UpdateService(body []byte) (string, error) + func (s *Scheduler) UpdateServiceHandler(req *restful.Request, resp *restful.Response) + type SendMsgOpeParam struct + MsgData interface{} + MsgType string + TaskGroupId string