v4http

package
v1.30.0-alpha.25 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2024 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
}

DeleteAppOpeParam xxx

type DeleteTaskGroupOpeParam

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

DeleteTaskGroupOpeParam xxx

type DeleteTaskGroupsOpeParam

type DeleteTaskGroupsOpeParam struct {
	OperateItem
}

DeleteTaskGroupsOpeParam xxx

type FetchVersionOpeParam

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

FetchVersionOpeParam xxx

type OperateItem

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

OperateItem xxx

type RollbackOpeParam

type RollbackOpeParam struct {
	OperateItem
}

RollbackOpeParam xxx

type ScaleOpeParam

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

ScaleOpeParam xxx

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)

CreateAdmissionWebhook xxx

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)

CreateApplicationHandler xxx

func (*Scheduler) CreateConfigMap

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

CreateConfigMap xxx

func (*Scheduler) CreateConfigMapHandler

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

CreateConfigMapHandler xxx

func (*Scheduler) CreateCustomResource

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

CreateCustomResource xxx

func (*Scheduler) CreateDaemonset

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

CreateDaemonset xxx

func (*Scheduler) CreateDeployment

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

CreateDeployment create deployment, call scheduler create deployment api

func (*Scheduler) CreateProcessHandler

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

CreateProcessHandler xxx

func (*Scheduler) CreateSecret

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

CreateSecret xxx

func (*Scheduler) CreateSecretHandler

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

CreateSecretHandler xxx

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)

CreateServiceHandler xxx

func (*Scheduler) DeleteAdmissionWebhook

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

DeleteAdmissionWebhook xxx

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)

DeleteApplication xxx

func (*Scheduler) DeleteApplicationHandler

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

DeleteApplicationHandler xxx

func (*Scheduler) DeleteApplicationTaskGroup

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

DeleteApplicationTaskGroup xxx

func (*Scheduler) DeleteApplicationTaskGroupHandler

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

DeleteApplicationTaskGroupHandler xxx

func (*Scheduler) DeleteApplicationTaskGroups

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

DeleteApplicationTaskGroups xxx

func (*Scheduler) DeleteApplicationTaskGroupsHandler

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

DeleteApplicationTaskGroupsHandler xxx

func (*Scheduler) DeleteConfigMap

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

DeleteConfigMap xxx

func (*Scheduler) DeleteConfigMapHandler

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

DeleteConfigMapHandler xxx

func (*Scheduler) DeleteCustomResource

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

DeleteCustomResource xxx

func (*Scheduler) DeleteProcessHandler

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

DeleteProcessHandler xxx

func (*Scheduler) DeleteSecret

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

DeleteSecret xxx

func (*Scheduler) DeleteSecretHandler

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

DeleteSecretHandler xxx

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)

DeleteServiceHandler xxx

func (*Scheduler) FetchAdmissionWebhook

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

FetchAdmissionWebhook xxx

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)

FetchAllAdmissionWebhooks xxx

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)

FetchApplication xxx

func (*Scheduler) FetchApplicationHandler

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

FetchApplicationHandler xxx

func (*Scheduler) FetchApplicationVersion

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

FetchApplicationVersion xxx

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)

FetchProcessHandler xxx

func (*Scheduler) GetClusterCurrentOffersHandler

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

GetClusterCurrentOffersHandler xxx

func (*Scheduler) GetClusterEndpointsHandler

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

GetClusterEndpointsHandler xxx

func (*Scheduler) GetClusterResourcesHandler

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

GetClusterResourcesHandler xxx

func (*Scheduler) GetCustomResource

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

GetCustomResource xxx

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)

ListAllCustomResource xxx

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)

ListApplicationTaskGroupsHandler xxx

func (*Scheduler) ListApplicationTasks

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

ListApplicationTasks xxx

func (*Scheduler) ListApplicationTasksHandler

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

ListApplicationTasksHandler xxx

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)

ListApplicationVersionsHandler xxx

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)

ListApplicationsHandler xxx

func (*Scheduler) ListCustomResource

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

ListCustomResource xxx

func (*Scheduler) ListProcessesHandler

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

ListProcessesHandler xxx

func (*Scheduler) RegisterCustomResource

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

RegisterCustomResource xxx

func (*Scheduler) ReloadTaskGroup

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

ReloadTaskGroup xxx

func (*Scheduler) RescheduleTaskgroup

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

RescheduleTaskgroup xxx

func (*Scheduler) RestartTaskGroup

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

RestartTaskGroup xxx

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)

RollbackApplicationHandler xxx

func (*Scheduler) RollbackProcessHandler

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

RollbackProcessHandler xxx

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)

ScaleApplicationHandler xxx

func (*Scheduler) ScaleProcessHandler

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

ScaleProcessHandler xxx

func (*Scheduler) SendMessageApplication

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

SendMessageApplication xxx

func (*Scheduler) SendMessageApplicationHandler

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

SendMessageApplicationHandler xxx

func (*Scheduler) SendMessageTaskgroupHandler

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

SendMessageTaskgroupHandler xxx

func (*Scheduler) SetHost

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

SetHost scheduler implementation

func (*Scheduler) UpdateAdmissionWebhook

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

UpdateAdmissionWebhook xxx

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)

UpdateApplicationHandler xxx

func (*Scheduler) UpdateConfigMap

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

UpdateConfigMap xxx

func (*Scheduler) UpdateConfigMapHandler

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

UpdateConfigMapHandler xxx

func (*Scheduler) UpdateCustomResource

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

UpdateCustomResource xxx

func (*Scheduler) UpdateDeployment

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

UpdateDeployment do update deployment, call scheduler update deployment api

func (*Scheduler) UpdateProcessHandler

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

UpdateProcessHandler xxx

func (*Scheduler) UpdateSecret

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

UpdateSecret xxx

func (*Scheduler) UpdateSecretHandler

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

UpdateSecretHandler xxx

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)

UpdateServiceHandler xxx

type SendMsgOpeParam

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

SendMsgOpeParam xxx

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL