v4http

package
v0.20.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 22, 2021 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type DeleteAppOpeParam 

type DeleteAppOpeParam struct {
	OperateItem
}

type DeleteTaskGroupOpeParam 

type DeleteTaskGroupOpeParam struct {
	OperateItem
	TaskGroupId string `json:"taskgroupid"`
}

type DeleteTaskGroupsOpeParam 

type DeleteTaskGroupsOpeParam struct {
	OperateItem
}

type FetchVersionOpeParam 

type FetchVersionOpeParam struct {
	OperateItem
	VersionId string `json:"versionid"`
}

type OperateItem 

type OperateItem struct {
	Name     string `json:"name"`
	RunAs    string `json:"namespace"`
	SetId    string `json:"setid"`
	ModuleId string `json:"moduleid"`
}

type RollbackOpeParam 

type RollbackOpeParam struct {
	OperateItem
}

type ScaleOpeParam 

type ScaleOpeParam struct {
	OperateItem
	Instance uint64 `json:"instance"`
}

type Scheduler 

type Scheduler struct {
	// contains filtered or unexported fields
}

Scheduler is data struct of mesos scheduler

func NewScheduler 

func NewScheduler() *Scheduler

NewScheduler create a scheduler

func (*Scheduler) Actions 

func (s *Scheduler) Actions() []*httpserver.Action

Actions all http action implementation

func (*Scheduler) CreateAdmissionWebhook 

func (s *Scheduler) CreateAdmissionWebhook(body []byte) (string, error)

func (*Scheduler) CreateAdmissionwebhookHandler 

func (s *Scheduler) CreateAdmissionwebhookHandler(req *restful.Request, resp *restful.Response)

CreateAdmissionwebhookHandler create Admissionwebhook implementation

func (*Scheduler) CreateApplication 

func (s *Scheduler) CreateApplication(body []byte) (string, error)

CreateApplication create application implementation

func (*Scheduler) CreateApplicationHandler 

func (s *Scheduler) CreateApplicationHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) CreateConfigMap 

func (s *Scheduler) CreateConfigMap(body []byte) (string, error)

func (*Scheduler) CreateConfigMapHandler 

func (s *Scheduler) CreateConfigMapHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) CreateCustomResource 

func (s *Scheduler) CreateCustomResource(ns, kind string, body []byte) (string, error)

func (*Scheduler) CreateDaemonset 

func (s *Scheduler) CreateDaemonset(body []byte) (string, error)

func (*Scheduler) CreateDeployment 

func (s *Scheduler) CreateDeployment(body []byte) (string, error)

func (*Scheduler) CreateProcessHandler 

func (s *Scheduler) CreateProcessHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) CreateSecret 

func (s *Scheduler) CreateSecret(body []byte) (string, error)

func (*Scheduler) CreateSecretHandler 

func (s *Scheduler) CreateSecretHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) CreateService 

func (s *Scheduler) CreateService(body []byte) (string, error)

CreateService create service request forwarding

func (*Scheduler) CreateServiceHandler 

func (s *Scheduler) CreateServiceHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) DeleteAdmissionWebhook 

func (s *Scheduler) DeleteAdmissionWebhook(ns string, name string) (string, error)

func (*Scheduler) DeleteAdmissionwebhookHandler 

func (s *Scheduler) DeleteAdmissionwebhookHandler(req *restful.Request, resp *restful.Response)

DeleteAdmissionwebhookHandler delete Admissionwebhook implementation

func (*Scheduler) DeleteApplication 

func (s *Scheduler) DeleteApplication(ns, name, enforce string, kind bcstype.BcsDataType) (string, error)

func (*Scheduler) DeleteApplicationHandler 

func (s *Scheduler) DeleteApplicationHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) DeleteApplicationTaskGroup 

func (s *Scheduler) DeleteApplicationTaskGroup(body []byte) (string, error)

func (*Scheduler) DeleteApplicationTaskGroupHandler 

func (s *Scheduler) DeleteApplicationTaskGroupHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) DeleteApplicationTaskGroups 

func (s *Scheduler) DeleteApplicationTaskGroups(body []byte) (string, error)

func (*Scheduler) DeleteApplicationTaskGroupsHandler 

func (s *Scheduler) DeleteApplicationTaskGroupsHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) DeleteConfigMap 

func (s *Scheduler) DeleteConfigMap(ns string, name string) (string, error)

func (*Scheduler) DeleteConfigMapHandler 

func (s *Scheduler) DeleteConfigMapHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) DeleteCustomResource 

func (s *Scheduler) DeleteCustomResource(ns, kind, name string) (string, error)

func (*Scheduler) DeleteProcessHandler 

func (s *Scheduler) DeleteProcessHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) DeleteSecret 

func (s *Scheduler) DeleteSecret(ns string, name string) (string, error)

func (*Scheduler) DeleteSecretHandler 

func (s *Scheduler) DeleteSecretHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) DeleteService 

func (s *Scheduler) DeleteService(ns string, name string) (string, error)

DeleteService delete service request forwarding

func (*Scheduler) DeleteServiceHandler 

func (s *Scheduler) DeleteServiceHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) FetchAdmissionWebhook 

func (s *Scheduler) FetchAdmissionWebhook(ns string, name string) (string, error)

func (*Scheduler) FetchAdmissionwebhookHandler 

func (s *Scheduler) FetchAdmissionwebhookHandler(req *restful.Request, resp *restful.Response)

FetchAdmissionwebhookHandler get specified admission webhook

func (*Scheduler) FetchAllAdmissionWebhooks 

func (s *Scheduler) FetchAllAdmissionWebhooks() (string, error)

func (*Scheduler) FetchAllAdmissionwebhooksHandler 

func (s *Scheduler) FetchAllAdmissionwebhooksHandler(req *restful.Request, resp *restful.Response)

FetchAllAdmissionwebhooksHandler get all admission webhook request

func (*Scheduler) FetchApplication 

func (s *Scheduler) FetchApplication(ns, name string, kind bcstype.BcsDataType) (string, error)

func (*Scheduler) FetchApplicationHandler 

func (s *Scheduler) FetchApplicationHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) FetchApplicationVersion 

func (s *Scheduler) FetchApplicationVersion(ns, name, versionID string) (string, error)

func (*Scheduler) FetchApplicationVersionHandler 

func (s *Scheduler) FetchApplicationVersionHandler(req *restful.Request, resp *restful.Response)

FetchApplicationVersionHandler get Application information

func (*Scheduler) FetchProcessHandler 

func (s *Scheduler) FetchProcessHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) GetClusterCurrentOffersHandler 

func (s *Scheduler) GetClusterCurrentOffersHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) GetClusterEndpointsHandler 

func (s *Scheduler) GetClusterEndpointsHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) GetClusterResourcesHandler 

func (s *Scheduler) GetClusterResourcesHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) GetCustomResource 

func (s *Scheduler) GetCustomResource(ns, kind, name string) (string, error)

func (*Scheduler) GetHost 

func (s *Scheduler) GetHost() string

GetHost scheduler implementation

func (*Scheduler) GetHttpClient 

func (s *Scheduler) GetHttpClient() *httpclient.HttpClient

GetHttpClient get scheudler specified http client implementation

func (*Scheduler) InitConfig 

func (s *Scheduler) InitConfig(conf *config.MesosDriverConfig)

InitConfig scheduler init configuration

func (*Scheduler) ListAllCustomResource 

func (s *Scheduler) ListAllCustomResource(kind string) (string, error)

func (*Scheduler) ListApplicationTaskGroups 

func (s *Scheduler) ListApplicationTaskGroups(ns, name string) (string, error)

ListApplicationTaskGroups list all taskgroup under application

func (*Scheduler) ListApplicationTaskGroupsHandler 

func (s *Scheduler) ListApplicationTaskGroupsHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) ListApplicationTasks 

func (s *Scheduler) ListApplicationTasks(ns, name string) (string, error)

func (*Scheduler) ListApplicationTasksHandler 

func (s *Scheduler) ListApplicationTasksHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) ListApplicationVersions 

func (s *Scheduler) ListApplicationVersions(ns, name string) (string, error)

ListApplicationVersions list application inner definition

func (*Scheduler) ListApplicationVersionsHandler 

func (s *Scheduler) ListApplicationVersionsHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) ListApplications 

func (s *Scheduler) ListApplications(ns string, kind bcstype.BcsDataType) (string, error)

ListApplications list all apps

func (*Scheduler) ListApplicationsHandler 

func (s *Scheduler) ListApplicationsHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) ListCustomResource 

func (s *Scheduler) ListCustomResource(ns, kind string) (string, error)

func (*Scheduler) ListProcessesHandler 

func (s *Scheduler) ListProcessesHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) RegisterCustomResource 

func (s *Scheduler) RegisterCustomResource(body []byte) (string, error)

func (*Scheduler) ReloadTaskGroup 

func (s *Scheduler) ReloadTaskGroup(taskGroupID string) (string, error)

func (*Scheduler) RescheduleTaskgroup 

func (s *Scheduler) RescheduleTaskgroup(taskgroupId, hostRetainTime string) (string, error)

func (*Scheduler) RestartTaskGroup 

func (s *Scheduler) RestartTaskGroup(taskGroupID string) (string, error)

func (*Scheduler) RollbackApplication 

func (s *Scheduler) RollbackApplication(body []byte, kind bcstype.BcsDataType) (string, error)

RollbackApplication application rollback implementation

func (*Scheduler) RollbackApplicationHandler 

func (s *Scheduler) RollbackApplicationHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) RollbackProcessHandler 

func (s *Scheduler) RollbackProcessHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) ScaleApplication 

func (s *Scheduler) ScaleApplication(ns, name, instances string, kind bcstype.BcsDataType) (string, error)

ScaleApplication scale application transparent forwarding

func (*Scheduler) ScaleApplicationHandler 

func (s *Scheduler) ScaleApplicationHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) ScaleProcessHandler 

func (s *Scheduler) ScaleProcessHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) SendMessageApplication 

func (s *Scheduler) SendMessageApplication(ns, name, taskgroupId string, body []byte) (string, error)

func (*Scheduler) SendMessageApplicationHandler 

func (s *Scheduler) SendMessageApplicationHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) SendMessageTaskgroupHandler 

func (s *Scheduler) SendMessageTaskgroupHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) SetHost 

func (s *Scheduler) SetHost(hosts []string)

SetHost scheduler implementation

func (*Scheduler) UpdateAdmissionWebhook 

func (s *Scheduler) UpdateAdmissionWebhook(body []byte) (string, error)

func (*Scheduler) UpdateAdmissionwebhookHandler 

func (s *Scheduler) UpdateAdmissionwebhookHandler(req *restful.Request, resp *restful.Response)

UpdateAdmissionwebhookHandler update Admissionwebhook

func (*Scheduler) UpdateApplication 

func (s *Scheduler) UpdateApplication(body []byte, instances, args string) (string, error)

UpdateApplication update application forwarding

func (*Scheduler) UpdateApplicationHandler 

func (s *Scheduler) UpdateApplicationHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) UpdateConfigMap 

func (s *Scheduler) UpdateConfigMap(body []byte) (string, error)

func (*Scheduler) UpdateConfigMapHandler 

func (s *Scheduler) UpdateConfigMapHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) UpdateCustomResource 

func (s *Scheduler) UpdateCustomResource(ns, kind string, body []byte) (string, error)

func (*Scheduler) UpdateDeployment 

func (s *Scheduler) UpdateDeployment(body []byte) (string, error)

func (*Scheduler) UpdateProcessHandler 

func (s *Scheduler) UpdateProcessHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) UpdateSecret 

func (s *Scheduler) UpdateSecret(body []byte) (string, error)

func (*Scheduler) UpdateSecretHandler 

func (s *Scheduler) UpdateSecretHandler(req *restful.Request, resp *restful.Response)

func (*Scheduler) UpdateService 

func (s *Scheduler) UpdateService(body []byte) (string, error)

UpdateService update service request forwarding

func (*Scheduler) UpdateServiceHandler 

func (s *Scheduler) UpdateServiceHandler(req *restful.Request, resp *restful.Response)

type SendMsgOpeParam 

type SendMsgOpeParam struct {
	OperateItem
	MsgType     string      `json:"msgtype"`
	MsgData     interface{} `json:"msgdata"`
	TaskGroupId string      `json:"taskgroupid"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.