controller

package
v1.12.0 Latest Latest
Warning

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

Go to latest
Published: Apr 17, 2024 License: LGPL-3.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddVolume

func AddVolume(w http.ResponseWriter, r *http.Request)

AddVolume AddVolume

func AddVolumeDependency

func AddVolumeDependency(w http.ResponseWriter, r *http.Request)

AddVolumeDependency add volume dependency

func BackupCopy

func BackupCopy(w http.ResponseWriter, r *http.Request)

BackupCopy backup copy

func Backups

func Backups(w http.ResponseWriter, r *http.Request)

Backups list all backup history by group app

func BatchOperation

func BatchOperation(w http.ResponseWriter, r *http.Request)
	// // append every create event result to re and then return
	// httputil.ReturnSuccess(r, w, map[string]interface{}{
	// 	"batch_result": res,
	// })
}

BatchOperation batch operation for tenant support operation is : start,build,stop,update

func Check

func Check(w http.ResponseWriter, r *http.Request)

Check service check swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/servicecheck v2 serviceCheck

应用构建源检测,支持docker run ,docker compose, source code

service check

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func CheckLabel

func CheckLabel(serviceID string) bool

CheckLabel check label

func CheckMapKey

func CheckMapKey(rebody map[string]interface{}, key string, defaultValue interface{}) map[string]interface{}

CheckMapKey CheckMapKey

func CreateV2RouterManager

func CreateV2RouterManager(conf option.Config, statusCli *client.AppRuntimeSyncClient) (err error)

CreateV2RouterManager 创建manager

func DeleteBackup

func DeleteBackup(w http.ResponseWriter, r *http.Request)

DeleteBackup delete backup

func DeleteVolume

func DeleteVolume(w http.ResponseWriter, r *http.Request)

DeleteVolume DeleteVolume

func DeleteVolumeDependency

func DeleteVolumeDependency(w http.ResponseWriter, r *http.Request)

DeleteVolumeDependency delete volume dependency

func DeleteVolumeType

func DeleteVolumeType(w http.ResponseWriter, r *http.Request)

DeleteVolumeType delete volume option

func DirectRequest

func DirectRequest(w http.ResponseWriter, r *http.Request, endpoint string)

DirectRequest direct request

func Display

func Display(i interface{}, j interface{})

Display 遍历结构体

func FileServer

func FileServer(r chi.Router, path string, root http.FileSystem)

FileServer conveniently sets up a http.FileServer handler to serve static files from a http.FileSystem.

func GetBackup

func GetBackup(w http.ResponseWriter, r *http.Request)

GetBackup get one backup status

func GetDepVolume

func GetDepVolume(w http.ResponseWriter, r *http.Request)

GetDepVolume 获取应用所有依赖的存储

func GetGatewayIPs

func GetGatewayIPs(w http.ResponseWriter, r *http.Request)

GetGatewayIPs get gateway ips

func GetMonitorMetrics

func GetMonitorMetrics(w http.ResponseWriter, r *http.Request)

GetMonitorMetrics get monitor metrics

func GetNotificationEvent

func GetNotificationEvent(w http.ResponseWriter, r *http.Request)

GetNotificationEvent GetNotificationEvent swagger:operation GET /v2/notificationEvent/{hash} v2/notificationEvent getevents

获取通知事件

get events

--- produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func GetNotificationEvents

func GetNotificationEvents(w http.ResponseWriter, r *http.Request)

GetNotificationEvents GetNotificationEvent support query from start and end time or all swagger:operation GET /v2/notificationEvent v2/notificationEvent getevents

获取数据中心通知事件

get events

--- produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func GetRunningServices

func GetRunningServices(w http.ResponseWriter, r *http.Request)

GetRunningServices list all running service ids

func GetServiceAliasID

func GetServiceAliasID(ServiceID string) string

GetServiceAliasID get service alias id python: new_word = str(ord(string[10])) + string + str(ord(string[3])) + 'log' + str(ord(string[2]) / 7) new_id = hashlib.sha224(new_word).hexdigest()[0:16]

func GetServiceCheckInfo

func GetServiceCheckInfo(w http.ResponseWriter, r *http.Request)

GetServiceCheckInfo get service check info swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/servicecheck/{uuid} v2 getServiceCheckInfo

获取构建检测信息

get service check info

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func GetServiceDeployInfo

func GetServiceDeployInfo(w http.ResponseWriter, r *http.Request)

GetServiceDeployInfo get service deploy info

func GetServicesStatus added in v1.1.0

func GetServicesStatus(w http.ResponseWriter, r *http.Request)

func GetVolume

func GetVolume(w http.ResponseWriter, r *http.Request)

GetVolume 获取应用全部存储,包括依赖的存储

func HTTPRequest

func HTTPRequest(w http.ResponseWriter, r *http.Request, endpoint string)

HTTPRequest public http request

func HandleNotificationEvent

func HandleNotificationEvent(w http.ResponseWriter, r *http.Request)

HandleNotificationEvent HandleNotificationEvent swagger:operation PUT /v2/notificationEvent/{hash} v2/notificationEvent handlenotify

处理通知事件

get events

--- produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func ListVolumeType

func ListVolumeType(w http.ResponseWriter, r *http.Request)

ListVolumeType list volume type list

func NewBackups

func NewBackups(w http.ResponseWriter, r *http.Request)

NewBackups new group app backup

func PodNums

func PodNums(w http.ResponseWriter, r *http.Request)

PodNums reutrns the number of pods for components.

func Pods

func Pods(w http.ResponseWriter, r *http.Request)

Pods get some service pods swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/pods v2/tenants/{tenant_name}/envs pods

获取一些应用的Pod信息

get some service pods

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: get some service pods

func RestInfo

func RestInfo(code int, others ...string) []byte

RestInfo rest info

func Restore

func Restore(w http.ResponseWriter, r *http.Request)

Restore restore group app

func RestoreResult

func RestoreResult(w http.ResponseWriter, r *http.Request)

RestoreResult restore group app result

func TestFunc

func TestFunc(w http.ResponseWriter)

TestFunc test func

func TransBody

func TransBody(r *http.Request) (map[string]interface{}, error)

TransBody transfer body to map

func TransStatus

func TransStatus(eStatus string) string

TransStatus trans service status

func UpdateVolumeType

func UpdateVolumeType(w http.ResponseWriter, r *http.Request)

UpdateVolumeType delete volume option

func VolumeOptions

func VolumeOptions(w http.ResponseWriter, r *http.Request)

VolumeOptions list volume option

func VolumeSetVar

func VolumeSetVar(w http.ResponseWriter, r *http.Request)

VolumeSetVar set volume option

Types

type AppRestoreController

type AppRestoreController struct {
}

AppRestoreController is an implementation of AppRestoreInterface

func (*AppRestoreController) RestoreDepVols

func (a *AppRestoreController) RestoreDepVols(w http.ResponseWriter, r *http.Request)

RestoreDepVols restores service dependent volumes. delete the existing dependent volumes first, then create the ones in the request body.

func (*AppRestoreController) RestoreDeps

func (a *AppRestoreController) RestoreDeps(w http.ResponseWriter, r *http.Request)

RestoreDeps restores service dependencies. delete the existing dependencies first, then create the ones in the request body.

func (*AppRestoreController) RestoreEnvs

func (a *AppRestoreController) RestoreEnvs(w http.ResponseWriter, r *http.Request)

RestoreEnvs restores environment variables. delete the existing environment variables first, then create the ones in the request body.

func (*AppRestoreController) RestorePlugins

func (a *AppRestoreController) RestorePlugins(w http.ResponseWriter, r *http.Request)

RestorePlugins restores service plugins. delete the existing service plugins first, then create the ones in the request body.

func (*AppRestoreController) RestorePorts

func (a *AppRestoreController) RestorePorts(w http.ResponseWriter, r *http.Request)

RestorePorts restores service ports. delete the existing ports first, then create the ones in the request body.

func (*AppRestoreController) RestoreProbe

func (a *AppRestoreController) RestoreProbe(w http.ResponseWriter, r *http.Request)

RestoreProbe restores service probe. delete the existing probe first, then create the one in the request body.

func (*AppRestoreController) RestoreVolumes

func (a *AppRestoreController) RestoreVolumes(w http.ResponseWriter, r *http.Request)

RestoreVolumes restores service volumes. delete the existing volumes first, then create the ones in the request body.

type AppStruct

type AppStruct struct{}

AppStruct -

func (*AppStruct) Download

func (a *AppStruct) Download(w http.ResponseWriter, r *http.Request)

Download -

func (*AppStruct) ExportApp

func (a *AppStruct) ExportApp(w http.ResponseWriter, r *http.Request)

ExportApp -

func (*AppStruct) ImportApp

func (a *AppStruct) ImportApp(w http.ResponseWriter, r *http.Request)

ImportApp -

func (*AppStruct) ImportID

func (a *AppStruct) ImportID(w http.ResponseWriter, r *http.Request)

ImportID -

func (*AppStruct) NewUpload

func (a *AppStruct) NewUpload(w http.ResponseWriter, r *http.Request)

NewUpload -

func (*AppStruct) Upload

func (a *AppStruct) Upload(w http.ResponseWriter, r *http.Request)

Upload -

type ApplicationController

type ApplicationController struct{}

ApplicationController -

func (*ApplicationController) AddConfigGroup

func (a *ApplicationController) AddConfigGroup(w http.ResponseWriter, r *http.Request)

AddConfigGroup -

func (*ApplicationController) BatchBindService

func (a *ApplicationController) BatchBindService(w http.ResponseWriter, r *http.Request)

BatchBindService -

func (*ApplicationController) BatchCreateApp

func (a *ApplicationController) BatchCreateApp(w http.ResponseWriter, r *http.Request)

BatchCreateApp -

func (*ApplicationController) BatchUpdateComponentPorts

func (a *ApplicationController) BatchUpdateComponentPorts(w http.ResponseWriter, r *http.Request)

BatchUpdateComponentPorts update component ports in batch.

func (*ApplicationController) ChangeVolumes

func (a *ApplicationController) ChangeVolumes(w http.ResponseWriter, r *http.Request)

ChangeVolumes Since the component name supports modification, the storage directory of stateful components will change. This interface is used to modify the original directory name to the storage directory that will actually be used.

func (*ApplicationController) CheckGovernanceMode

func (a *ApplicationController) CheckGovernanceMode(w http.ResponseWriter, r *http.Request)

CheckGovernanceMode check governance mode.

func (*ApplicationController) CreateApp

CreateApp -

func (*ApplicationController) DeleteApp

DeleteApp -

func (*ApplicationController) DeleteConfigGroup

func (a *ApplicationController) DeleteConfigGroup(w http.ResponseWriter, r *http.Request)

DeleteConfigGroup -

func (*ApplicationController) GetAppStatus

func (a *ApplicationController) GetAppStatus(w http.ResponseWriter, r *http.Request)

GetAppStatus returns the status of the application.

func (*ApplicationController) Install

Install installs the application.

func (*ApplicationController) ListAppStatuses

func (a *ApplicationController) ListAppStatuses(w http.ResponseWriter, r *http.Request)

ListAppStatuses returns the status of the applications.

func (*ApplicationController) ListApps

ListApps -

func (*ApplicationController) ListComponents

func (a *ApplicationController) ListComponents(w http.ResponseWriter, r *http.Request)

ListComponents -

func (*ApplicationController) ListConfigGroups

func (a *ApplicationController) ListConfigGroups(w http.ResponseWriter, r *http.Request)

ListConfigGroups -

func (*ApplicationController) ListHelmAppReleases

func (a *ApplicationController) ListHelmAppReleases(w http.ResponseWriter, r *http.Request)

ListHelmAppReleases returns the list of helm releases.

func (*ApplicationController) ListServices

func (a *ApplicationController) ListServices(w http.ResponseWriter, r *http.Request)

ListServices returns the list fo the application.

func (*ApplicationController) SyncAppConfigGroups

func (a *ApplicationController) SyncAppConfigGroups(w http.ResponseWriter, r *http.Request)

SyncAppConfigGroups -

func (*ApplicationController) SyncComponents

func (a *ApplicationController) SyncComponents(w http.ResponseWriter, r *http.Request)

SyncComponents -

func (*ApplicationController) UpdateApp

UpdateApp -

func (*ApplicationController) UpdateConfigGroup

func (a *ApplicationController) UpdateConfigGroup(w http.ResponseWriter, r *http.Request)

UpdateConfigGroup -

type ClusterController

type ClusterController struct {
}

ClusterController -

func (*ClusterController) Features added in v1.9.0

func (t *ClusterController) Features(w http.ResponseWriter, r *http.Request)

Features

func (*ClusterController) GetClusterEvents added in v1.1.0

func (t *ClusterController) GetClusterEvents(w http.ResponseWriter, r *http.Request)

GetClusterEvents

func (*ClusterController) GetClusterInfo

func (t *ClusterController) GetClusterInfo(w http.ResponseWriter, r *http.Request)

GetClusterInfo -

func (*ClusterController) ListStorageClasses added in v1.11.0

func (t *ClusterController) ListStorageClasses(w http.ResponseWriter, r *http.Request)

func (*ClusterController) MavenSettingAdd

func (t *ClusterController) MavenSettingAdd(w http.ResponseWriter, r *http.Request)

MavenSettingAdd maven setting add

func (*ClusterController) MavenSettingDelete

func (t *ClusterController) MavenSettingDelete(w http.ResponseWriter, r *http.Request)

MavenSettingDelete maven setting file delete

func (*ClusterController) MavenSettingDetail

func (t *ClusterController) MavenSettingDetail(w http.ResponseWriter, r *http.Request)

MavenSettingDetail maven setting file delete

func (*ClusterController) MavenSettingList

func (t *ClusterController) MavenSettingList(w http.ResponseWriter, r *http.Request)

MavenSettingList maven setting list

func (*ClusterController) MavenSettingUpdate

func (t *ClusterController) MavenSettingUpdate(w http.ResponseWriter, r *http.Request)

MavenSettingUpdate maven setting file update

type DockerConsole

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

DockerConsole docker console

func GetDockerConsole

func GetDockerConsole() *DockerConsole

GetDockerConsole get Docker console

func (DockerConsole) Get

Get get

type DockerLog

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

DockerLog docker log

func GetDockerLog

func GetDockerLog() *DockerLog

GetDockerLog get docker log

func (DockerLog) Get

func (d DockerLog) Get(w http.ResponseWriter, r *http.Request)

Get get

type EventLog

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

EventLog event log

func GetEventLog

func GetEventLog() *EventLog

GetEventLog get event log

func (EventLog) Get

func (d EventLog) Get(w http.ResponseWriter, r *http.Request)

Get get

type EventLogStruct

type EventLogStruct struct {
	EventlogServerProxy proxy.Proxy
}

EventLogStruct eventlog struct

func (*EventLogStruct) EventLog

func (e *EventLogStruct) EventLog(w http.ResponseWriter, r *http.Request)

EventLog get event log by eventID

func (*EventLogStruct) Events

func (e *EventLogStruct) Events(w http.ResponseWriter, r *http.Request)

Events get log by target

func (*EventLogStruct) HistoryLogs

func (e *EventLogStruct) HistoryLogs(w http.ResponseWriter, r *http.Request)

HistoryLogs get service history logs proxy

func (*EventLogStruct) LogByAction

func (e *EventLogStruct) LogByAction(w http.ResponseWriter, r *http.Request)

LogByAction GetLogByAction

func (*EventLogStruct) LogFile

func (e *EventLogStruct) LogFile(w http.ResponseWriter, r *http.Request)

LogFile GetLogFile

func (*EventLogStruct) LogList

func (e *EventLogStruct) LogList(w http.ResponseWriter, r *http.Request)

LogList GetLogList

func (*EventLogStruct) LogSocket

func (e *EventLogStruct) LogSocket(w http.ResponseWriter, r *http.Request)

LogSocket GetLogSocket

func (*EventLogStruct) TenantEnvLogByAction added in v1.1.0

func (e *EventLogStruct) TenantEnvLogByAction(w http.ResponseWriter, r *http.Request)

TenantEnvLogByAction GetTenantEnvLogByAction swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/event-log v2 tenantEnvLogByAction

获取指定操作的操作日志

get tenant envlog by level

--- produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

type GatewayStruct

type GatewayStruct struct {
	MQClient client.MQClient
	// contains filtered or unexported fields
}

GatewayStruct -

func (*GatewayStruct) AddTCPRule

func (g *GatewayStruct) AddTCPRule(w http.ResponseWriter, r *http.Request)

AddTCPRule adds a tcp rule

func (*GatewayStruct) Certificate

func (g *GatewayStruct) Certificate(w http.ResponseWriter, r *http.Request)

Certificate -

func (*GatewayStruct) GetAvailablePort

func (g *GatewayStruct) GetAvailablePort(w http.ResponseWriter, r *http.Request)

GetAvailablePort returns a available port

func (*GatewayStruct) HTTPRule

func (g *GatewayStruct) HTTPRule(w http.ResponseWriter, r *http.Request)

HTTPRule is used to add, update or delete http rule which enables external traffic to access applications through the gateway

func (*GatewayStruct) RuleConfig

func (g *GatewayStruct) RuleConfig(w http.ResponseWriter, r *http.Request)

RuleConfig is used to add, update or delete rule config.

func (*GatewayStruct) TCPRule

func (g *GatewayStruct) TCPRule(w http.ResponseWriter, r *http.Request)

TCPRule is used to add, update or delete tcp rule which enables external traffic to access applications through the gateway

func (*GatewayStruct) TCPRuleConfig added in v1.1.0

func (g *GatewayStruct) TCPRuleConfig(w http.ResponseWriter, r *http.Request)

TCPRuleConfig is used to add, update or delete tcp rule config.

type Handle

type Handle struct {
	Body struct {
		//in: body
		//handle message
		HandleMessage string `json:"handle_message" validate:"handle_message"`
	}
}

Handle Handle swagger:parameters handlenotify

type HelmAppsController added in v1.1.0

type HelmAppsController struct{}

HelmAppsController is an implementation of HelmAppsInterface

func (*HelmAppsController) ListHelmAppResources added in v1.1.0

func (c *HelmAppsController) ListHelmAppResources(w http.ResponseWriter, r *http.Request)

ListHelmAppResources - list helm resources

func (*HelmAppsController) ListHelmApps added in v1.1.0

func (c *HelmAppsController) ListHelmApps(w http.ResponseWriter, r *http.Request)

ListHelmApps - get helm apps

type LabelController

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

LabelController implements Labeler.

func (*LabelController) Labels

func (l *LabelController) Labels(w http.ResponseWriter, r *http.Request)

Labels - get -> list labels

type LicenseManager

type LicenseManager struct{}

LicenseManager license manager

func GetLicenseManager

func GetLicenseManager() *LicenseManager

GetLicenseManager get license Manager

func (*LicenseManager) GetlicenseFeature

func (l *LicenseManager) GetlicenseFeature(w http.ResponseWriter, r *http.Request)

type LogFile

type LogFile struct {
	Root string
}

LogFile log file down server

func GetLogFile

func GetLogFile() *LogFile

GetLogFile get log file

func (LogFile) Get

func (d LogFile) Get(w http.ResponseWriter, r *http.Request)

Get get

func (LogFile) GetInstallLog

func (d LogFile) GetInstallLog(w http.ResponseWriter, r *http.Request)

GetInstallLog get

type MonitorMessage

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

MonitorMessage monitor message

func GetMonitorMessage

func GetMonitorMessage() *MonitorMessage

GetMonitorMessage get MonitorMessage

func (MonitorMessage) Get

Get get

type NodeController added in v1.9.0

type NodeController struct {
}

NodeController -

func (*NodeController) CordonNode added in v1.10.0

func (*NodeController) CordonNode(w http.ResponseWriter, r *http.Request)

func (*NodeController) DeleteNodeAnnotation added in v1.10.0

func (t *NodeController) DeleteNodeAnnotation(w http.ResponseWriter, r *http.Request)

func (*NodeController) DeleteNodeLabel added in v1.10.0

func (t *NodeController) DeleteNodeLabel(w http.ResponseWriter, r *http.Request)

func (*NodeController) DeleteTaintNode added in v1.10.0

func (*NodeController) DeleteTaintNode(w http.ResponseWriter, r *http.Request)

func (*NodeController) DeleteVMSchedulingLabel added in v1.10.0

func (t *NodeController) DeleteVMSchedulingLabel(w http.ResponseWriter, r *http.Request)

func (*NodeController) GetCommonLabels added in v1.11.0

func (t *NodeController) GetCommonLabels(w http.ResponseWriter, r *http.Request)

func (*NodeController) GetNode added in v1.10.0

func (t *NodeController) GetNode(w http.ResponseWriter, r *http.Request)

func (*NodeController) GetNodeAnnotations added in v1.11.0

func (t *NodeController) GetNodeAnnotations(w http.ResponseWriter, r *http.Request)

func (*NodeController) GetNodeLabels added in v1.11.0

func (t *NodeController) GetNodeLabels(w http.ResponseWriter, r *http.Request)

func (*NodeController) GetNodeTaints added in v1.11.0

func (t *NodeController) GetNodeTaints(w http.ResponseWriter, r *http.Request)

func (*NodeController) GetVMSchedulingLabels added in v1.11.0

func (t *NodeController) GetVMSchedulingLabels(w http.ResponseWriter, r *http.Request)

func (*NodeController) ListNodes added in v1.10.0

func (t *NodeController) ListNodes(w http.ResponseWriter, r *http.Request)

func (*NodeController) ListSchedulingLabels added in v1.10.0

func (t *NodeController) ListSchedulingLabels(w http.ResponseWriter, r *http.Request)

func (*NodeController) ListSchedulingNodes added in v1.10.0

func (t *NodeController) ListSchedulingNodes(w http.ResponseWriter, r *http.Request)

func (*NodeController) ListSchedulingTaints added in v1.10.0

func (t *NodeController) ListSchedulingTaints(w http.ResponseWriter, r *http.Request)

func (*NodeController) ListVMSchedulingLabels added in v1.10.0

func (t *NodeController) ListVMSchedulingLabels(w http.ResponseWriter, r *http.Request)

func (*NodeController) SetNodeAnnotation added in v1.10.0

func (t *NodeController) SetNodeAnnotation(w http.ResponseWriter, r *http.Request)

func (*NodeController) SetNodeLabel added in v1.10.0

func (t *NodeController) SetNodeLabel(w http.ResponseWriter, r *http.Request)

func (*NodeController) SetVMSchedulingLabel added in v1.10.0

func (t *NodeController) SetVMSchedulingLabel(w http.ResponseWriter, r *http.Request)

func (*NodeController) TaintNode added in v1.10.0

func (*NodeController) TaintNode(w http.ResponseWriter, r *http.Request)

func (*NodeController) UncordonNode added in v1.10.0

func (*NodeController) UncordonNode(w http.ResponseWriter, r *http.Request)

type PodController

type PodController struct{}

PodController is an implementation of PodInterface

func (*PodController) PodDetail

func (p *PodController) PodDetail(w http.ResponseWriter, r *http.Request)

PodDetail -

type PubSubControll

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

PubSubControll service pub sub

func GetPubSubControll

func GetPubSubControll() *PubSubControll

GetPubSubControll get service pub sub controller

func (PubSubControll) Get

Get pubsub controller

func (PubSubControll) GetHistoryLog

func (d PubSubControll) GetHistoryLog(w http.ResponseWriter, r *http.Request)

GetHistoryLog get service docker logs

type RegistryAuthSecretStruct added in v1.1.0

type RegistryAuthSecretStruct struct {
	MQClient client.MQClient
	// contains filtered or unexported fields
}

RegistryAuthSecretStruct -

func (*RegistryAuthSecretStruct) RegistryAuthSecret added in v1.1.0

func (g *RegistryAuthSecretStruct) RegistryAuthSecret(w http.ResponseWriter, r *http.Request)

HTTPRule is used to add, update or delete http rule which enables external traffic to access applications through the gateway

type RootFuncManager

type RootFuncManager struct{}

RootFuncManager root function manager

func GetRootFuncManager

func GetRootFuncManager() *RootFuncManager

GetRootFuncManager get root function Manager

type SchedulingController added in v1.10.0

type SchedulingController struct{}

type SourcesInfo

type SourcesInfo struct {
	TenantEnvID     string `json:"tenant_env_id"`
	AvailableMemory int    `json:"available_memory"`
	Status          bool   `json:"status"`
	MemTotal        int    `json:"mem_total"`
	MemUsed         int    `json:"mem_used"`
	CPUTotal        int    `json:"cpu_total"`
	CPUUsed         int    `json:"cpu_used"`
}

SourcesInfo -

type TenantEnvStruct added in v1.1.0

type TenantEnvStruct struct {
	StatusCli *client.AppRuntimeSyncClient
	MQClient  mqclient.MQClient
}

TenantEnvStruct tenant env struct

func (*TenantEnvStruct) AddDefatultENV added in v1.1.0

func (t *TenantEnvStruct) AddDefatultENV(w http.ResponseWriter, r *http.Request)

AddDefatultENV AddDefatultENV

func (*TenantEnvStruct) AddDependency added in v1.1.0

func (t *TenantEnvStruct) AddDependency(w http.ResponseWriter, r *http.Request)

AddDependency AddDependency swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/dependency v2 addDependency

增加应用依赖关系

add dependency

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) AddEnv added in v1.1.0

func (t *TenantEnvStruct) AddEnv(w http.ResponseWriter, r *http.Request)

AddEnv AddEnv swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/env v2 addEnv

增加环境变量

add env var

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) AddLabel added in v1.1.0

AddLabel adds label

func (*TenantEnvStruct) AddPort added in v1.1.0

func (t *TenantEnvStruct) AddPort(w http.ResponseWriter, r *http.Request)

AddPort add port

func (*TenantEnvStruct) AddProbe added in v1.1.0

func (t *TenantEnvStruct) AddProbe(w http.ResponseWriter, r *http.Request)

AddProbe add probe swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/probe v2 addProbe

增加应用探针

add probe

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) AddServiceMonitors added in v1.1.0

func (t *TenantEnvStruct) AddServiceMonitors(w http.ResponseWriter, r *http.Request)

AddServiceMonitors add service monitor

func (*TenantEnvStruct) AddServiceSchedulingLabel added in v1.10.0

func (t *TenantEnvStruct) AddServiceSchedulingLabel(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) AddServiceSchedulingToleration added in v1.10.0

func (t *TenantEnvStruct) AddServiceSchedulingToleration(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) AddTenantEnv added in v1.1.0

func (t *TenantEnvStruct) AddTenantEnv(w http.ResponseWriter, r *http.Request)

AddTenantEnv AddTenantEnv

func (*TenantEnvStruct) AddVMPort added in v1.7.0

func (t *TenantEnvStruct) AddVMPort(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) AddVMVolume added in v1.10.0

func (t *TenantEnvStruct) AddVMVolume(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) AddVolume added in v1.1.0

func (t *TenantEnvStruct) AddVolume(w http.ResponseWriter, r *http.Request)

AddVolume AddVolume

func (*TenantEnvStruct) AddVolumeDependency added in v1.1.0

func (t *TenantEnvStruct) AddVolumeDependency(w http.ResponseWriter, r *http.Request)

AddVolumeDependency add volume dependency

func (*TenantEnvStruct) AllTenantEnvResources added in v1.1.0

func (t *TenantEnvStruct) AllTenantEnvResources(w http.ResponseWriter, r *http.Request)

AllTenantEnvResources GetResources

func (*TenantEnvStruct) AutoscalerRules added in v1.1.0

func (t *TenantEnvStruct) AutoscalerRules(w http.ResponseWriter, r *http.Request)

AutoscalerRules -

func (*TenantEnvStruct) BackupRecords added in v1.6.0

func (t *TenantEnvStruct) BackupRecords(w http.ResponseWriter, r *http.Request)

BackupRecords get backup histories

func (*TenantEnvStruct) BatchBuildPlugins added in v1.1.0

func (t *TenantEnvStruct) BatchBuildPlugins(w http.ResponseWriter, r *http.Request)

BatchBuildPlugins -

func (*TenantEnvStruct) BatchInstallPlugins added in v1.1.0

func (t *TenantEnvStruct) BatchInstallPlugins(w http.ResponseWriter, r *http.Request)

BatchInstallPlugins -

func (*TenantEnvStruct) BuildList added in v1.1.0

func (t *TenantEnvStruct) BuildList(w http.ResponseWriter, r *http.Request)

BuildList BuildList

func (*TenantEnvStruct) BuildService added in v1.1.0

func (t *TenantEnvStruct) BuildService(w http.ResponseWriter, r *http.Request)

BuildService BuildService swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/build v2 serviceBuild

应用构建

service build

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) BuildVersionInfo added in v1.1.0

func (t *TenantEnvStruct) BuildVersionInfo(w http.ResponseWriter, r *http.Request)

BuildVersionInfo -

func (*TenantEnvStruct) BuildVersionIsExist added in v1.1.0

func (t *TenantEnvStruct) BuildVersionIsExist(w http.ResponseWriter, r *http.Request)

BuildVersionIsExist -

func (*TenantEnvStruct) CheckCode added in v1.1.0

func (t *TenantEnvStruct) CheckCode(w http.ResponseWriter, r *http.Request)

CheckCode CheckCode swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/code-check v2 checkCode

应用代码检测

check code

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) CheckResourceName added in v1.1.0

func (t *TenantEnvStruct) CheckResourceName(w http.ResponseWriter, r *http.Request)

CheckResourceName checks the resource name.

func (*TenantEnvStruct) CreateBackup added in v1.6.0

func (t *TenantEnvStruct) CreateBackup(w http.ResponseWriter, r *http.Request)

CreateBackup create backup for service resource and data

func (*TenantEnvStruct) CreateBackupSchedule added in v1.6.0

func (t *TenantEnvStruct) CreateBackupSchedule(w http.ResponseWriter, r *http.Request)

CreateBackupSchedule create backup schedule for service resource and data

func (*TenantEnvStruct) CreatePlugin added in v1.1.0

func (t *TenantEnvStruct) CreatePlugin(w http.ResponseWriter, r *http.Request)

CreatePlugin add plugin

func (*TenantEnvStruct) CreateRestore added in v1.6.0

func (t *TenantEnvStruct) CreateRestore(w http.ResponseWriter, r *http.Request)

CreateRestore create restore for service resource and data

func (*TenantEnvStruct) CreateService added in v1.1.0

func (t *TenantEnvStruct) CreateService(w http.ResponseWriter, r *http.Request)

CreateService create Service

func (*TenantEnvStruct) CreateVM added in v1.7.0

func (t *TenantEnvStruct) CreateVM(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) CreateVMPortGateway added in v1.7.0

func (t *TenantEnvStruct) CreateVMPortGateway(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DeleteBackup added in v1.6.0

func (t *TenantEnvStruct) DeleteBackup(w http.ResponseWriter, r *http.Request)

DeleteBackup delete backup for service resource and data

func (*TenantEnvStruct) DeleteBackupSchedule added in v1.6.0

func (t *TenantEnvStruct) DeleteBackupSchedule(w http.ResponseWriter, r *http.Request)

DeleteBackupSchedule delete backup schedule for service resource and data

func (*TenantEnvStruct) DeleteBuildVersion added in v1.1.0

func (t *TenantEnvStruct) DeleteBuildVersion(w http.ResponseWriter, r *http.Request)

DeleteBuildVersion -

func (*TenantEnvStruct) DeleteDefaultENV added in v1.1.0

func (t *TenantEnvStruct) DeleteDefaultENV(w http.ResponseWriter, r *http.Request)

DeleteDefaultENV DeleteDefaultENV

func (*TenantEnvStruct) DeleteDependency added in v1.1.0

func (t *TenantEnvStruct) DeleteDependency(w http.ResponseWriter, r *http.Request)

DeleteDependency DeleteDependency swagger:operation DELETE /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/dependency v2 deleteDependency

删除应用依赖关系

delete dependency

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) DeleteDownStreamRule added in v1.1.0

func (t *TenantEnvStruct) DeleteDownStreamRule(w http.ResponseWriter, r *http.Request)

DeleteDownStreamRule 删除下游规则

func (*TenantEnvStruct) DeleteEnv added in v1.1.0

func (t *TenantEnvStruct) DeleteEnv(w http.ResponseWriter, r *http.Request)

DeleteEnv DeleteEnv swagger:operation DELETE /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/env v2 deleteEnv

删除环境变量

delete env var

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) DeleteLabel added in v1.1.0

func (t *TenantEnvStruct) DeleteLabel(w http.ResponseWriter, r *http.Request, labels *api_model.LabelsStruct)

DeleteLabel deletes labels

func (*TenantEnvStruct) DeletePlugin added in v1.1.0

func (t *TenantEnvStruct) DeletePlugin(w http.ResponseWriter, r *http.Request)

DeletePlugin DeletePlugin

func (*TenantEnvStruct) DeletePluginBuildVersion added in v1.1.0

func (t *TenantEnvStruct) DeletePluginBuildVersion(w http.ResponseWriter, r *http.Request)

DeletePluginBuildVersion DeletePluginBuildVersion swagger:operation DELETE /v2/tenants/{tenant_name}/envs/{tenant_env_name}/plugin/{plugin_id}/build-version/{version_id} v2 deletePluginVersion

删除某个构建版本信息

delete plugin version

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) DeletePluginRelation added in v1.1.0

func (t *TenantEnvStruct) DeletePluginRelation(w http.ResponseWriter, r *http.Request)

DeletePluginRelation DeletePluginRelation swagger:operation DELETE /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/plugin/{plugin_id} v2 deletePluginRelation

删除插件依赖

delete plugin relation

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) DeletePort added in v1.1.0

func (t *TenantEnvStruct) DeletePort(w http.ResponseWriter, r *http.Request)

DeletePort delete port

func (*TenantEnvStruct) DeleteProbe added in v1.1.0

func (t *TenantEnvStruct) DeleteProbe(w http.ResponseWriter, r *http.Request)

DeleteProbe delete probe swagger:operation DELETE /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/probe v2 deleteProbe

删除应用探针

delete probe

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) DeleteRestore added in v1.6.0

func (t *TenantEnvStruct) DeleteRestore(w http.ResponseWriter, r *http.Request)

DeleteRestore delete restore for service resource and data

func (*TenantEnvStruct) DeleteServiceMonitors added in v1.1.0

func (t *TenantEnvStruct) DeleteServiceMonitors(w http.ResponseWriter, r *http.Request)

DeleteServiceMonitors delete service monitor

func (*TenantEnvStruct) DeleteServiceSchedulingLabel added in v1.10.0

func (t *TenantEnvStruct) DeleteServiceSchedulingLabel(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DeleteServiceSchedulingToleration added in v1.10.0

func (t *TenantEnvStruct) DeleteServiceSchedulingToleration(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DeleteSingleServiceInfo added in v1.1.0

func (t *TenantEnvStruct) DeleteSingleServiceInfo(w http.ResponseWriter, r *http.Request)

DeleteSingleServiceInfo DeleteService swagger:operation DELETE /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias} v2 deleteService

删除应用

delete service

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) DeleteTenantEnv added in v1.1.0

func (t *TenantEnvStruct) DeleteTenantEnv(w http.ResponseWriter, r *http.Request)

DeleteTenantEnv DeleteTenantEnv

func (*TenantEnvStruct) DeleteVM added in v1.7.0

func (t *TenantEnvStruct) DeleteVM(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DeleteVMPort added in v1.7.0

func (t *TenantEnvStruct) DeleteVMPort(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DeleteVMPortGateway added in v1.7.0

func (t *TenantEnvStruct) DeleteVMPortGateway(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DeleteVMVolume added in v1.10.0

func (t *TenantEnvStruct) DeleteVMVolume(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DeleteVolume added in v1.1.0

func (t *TenantEnvStruct) DeleteVolume(w http.ResponseWriter, r *http.Request)

DeleteVolume DeleteVolume

func (*TenantEnvStruct) DeleteVolumeDependency added in v1.1.0

func (t *TenantEnvStruct) DeleteVolumeDependency(w http.ResponseWriter, r *http.Request)

DeleteVolumeDependency delete volume dependency

func (*TenantEnvStruct) Dependency added in v1.1.0

func (t *TenantEnvStruct) Dependency(w http.ResponseWriter, r *http.Request)

Dependency Dependency

func (*TenantEnvStruct) DeployService added in v1.1.0

func (t *TenantEnvStruct) DeployService(w http.ResponseWriter, r *http.Request)

DeployService DeployService

func (*TenantEnvStruct) DisableVMPort added in v1.9.0

func (t *TenantEnvStruct) DisableVMPort(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) DownloadBackup added in v1.6.0

func (t *TenantEnvStruct) DownloadBackup(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) EnableVMPort added in v1.9.0

func (t *TenantEnvStruct) EnableVMPort(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) Env added in v1.1.0

Env Env

func (*TenantEnvStruct) Event added in v1.1.0

Event GetLogs

func (*TenantEnvStruct) GePluginEnvWhichCanBeSet added in v1.1.0

func (t *TenantEnvStruct) GePluginEnvWhichCanBeSet(w http.ResponseWriter, r *http.Request)

GePluginEnvWhichCanBeSet GePluginEnvWhichCanBeSet swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/plugin/{plugin_id}/envs v2 getVersionEnvs

获取可配置的env; 从service plugin对应中取, 若不存在则返回默认可修改的变量

get version env

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) GetAllPluginBuildVersions added in v1.1.0

func (t *TenantEnvStruct) GetAllPluginBuildVersions(w http.ResponseWriter, r *http.Request)

GetAllPluginBuildVersions 获取该插件所有的构建版本 swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/plugin/{plugin_id}/build-version v2 allPluginVersions

获取所有的构建版本信息

all plugin versions

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) GetAllTenantEnvs added in v1.1.0

func (t *TenantEnvStruct) GetAllTenantEnvs(w http.ResponseWriter, r *http.Request)

GetAllTenantEnvs GetAllTenantEnvs

func (*TenantEnvStruct) GetApplicationKubeResources added in v1.1.0

func (t *TenantEnvStruct) GetApplicationKubeResources(w http.ResponseWriter, r *http.Request)

GetApplicationKubeResources get kube resources for application

func (*TenantEnvStruct) GetBackupSchedule added in v1.6.0

func (t *TenantEnvStruct) GetBackupSchedule(w http.ResponseWriter, r *http.Request)

GetBackupSchedule get backup schedule

func (*TenantEnvStruct) GetDeployVersion added in v1.1.0

func (t *TenantEnvStruct) GetDeployVersion(w http.ResponseWriter, r *http.Request)

GetDeployVersion GetDeployVersion by service

func (*TenantEnvStruct) GetDownStreamRule added in v1.1.0

func (t *TenantEnvStruct) GetDownStreamRule(w http.ResponseWriter, r *http.Request)

GetDownStreamRule 获取下游规则 swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/net-rule/downstream/{dest_service_alias}/{port} v2 getNetDownStreamRuleStruct

获取下游网络规则

set NetDownStreamRuleStruct

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) GetKubeConfig added in v1.1.0

func (t *TenantEnvStruct) GetKubeConfig(w http.ResponseWriter, r *http.Request)

GetKubeConfig get kube config for developer

func (*TenantEnvStruct) GetManyDeployVersion added in v1.1.0

func (t *TenantEnvStruct) GetManyDeployVersion(w http.ResponseWriter, r *http.Request)

GetManyDeployVersion GetDeployVersion by some service id

func (*TenantEnvStruct) GetPluginBuildVersion added in v1.1.0

func (t *TenantEnvStruct) GetPluginBuildVersion(w http.ResponseWriter, r *http.Request)

GetPluginBuildVersion 获取某构建版本信息 swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/plugin/{plugin_id}/build-version/{version_id} v2 pluginVersion

获取某个构建版本信息

plugin version

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) GetPluginDefaultEnvs added in v1.1.0

func (t *TenantEnvStruct) GetPluginDefaultEnvs(w http.ResponseWriter, r *http.Request)

GetPluginDefaultEnvs GetPluginDefaultEnvs

func (*TenantEnvStruct) GetPlugins added in v1.1.0

func (t *TenantEnvStruct) GetPlugins(w http.ResponseWriter, r *http.Request)

GetPlugins GetPlugins

func (*TenantEnvStruct) GetServiceKubeResources added in v1.1.0

func (t *TenantEnvStruct) GetServiceKubeResources(w http.ResponseWriter, r *http.Request)

GetServiceKubeResources get kube resources for component

func (*TenantEnvStruct) GetServiceSchedulingDetails added in v1.10.0

func (t *TenantEnvStruct) GetServiceSchedulingDetails(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) GetSingleServiceInfo added in v1.1.0

func (t *TenantEnvStruct) GetSingleServiceInfo(w http.ResponseWriter, r *http.Request)

GetSingleServiceInfo GetSingleServiceInfo

func (*TenantEnvStruct) GetSupportProtocols added in v1.1.0

func (t *TenantEnvStruct) GetSupportProtocols(w http.ResponseWriter, r *http.Request)

GetSupportProtocols GetSupportProtocols swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/protocols v2 getSupportProtocols

获取当前数据中心支持的protocols

get region protocols

--- produces: - application/json - application/xml parameters:

  • name: tenant_env_name in: path description: tenant env name required: true type: string

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) GetTenantEnv added in v1.1.0

func (t *TenantEnvStruct) GetTenantEnv(w http.ResponseWriter, r *http.Request)

GetTenantEnv get one tenant env

func (*TenantEnvStruct) GetTenantEnvKubeResources added in v1.1.0

func (t *TenantEnvStruct) GetTenantEnvKubeResources(w http.ResponseWriter, r *http.Request)

GetTenantEnvKubeResources get kube resources for tenantEnv

func (*TenantEnvStruct) GetTenantEnvs added in v1.1.0

func (t *TenantEnvStruct) GetTenantEnvs(w http.ResponseWriter, r *http.Request)

GetTenantEnvs GetTenantEnvs

func (*TenantEnvStruct) GetVM added in v1.7.0

func (*TenantEnvStruct) GetVMConditions added in v1.11.0

func (t *TenantEnvStruct) GetVMConditions(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) GetVMPorts added in v1.7.0

func (t *TenantEnvStruct) GetVMPorts(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) HorizontalService added in v1.1.0

func (t *TenantEnvStruct) HorizontalService(w http.ResponseWriter, r *http.Request)

HorizontalService HorizontalService swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/horizontal v2 horizontalService

应用水平伸缩

service horizontal

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) Label added in v1.1.0

Label -

func (*TenantEnvStruct) LimitTenantEnvMemory added in v1.1.0

func (t *TenantEnvStruct) LimitTenantEnvMemory(w http.ResponseWriter, r *http.Request)

LimitTenantEnvMemory -

func (*TenantEnvStruct) ListVMVolumes added in v1.10.0

func (t *TenantEnvStruct) ListVMVolumes(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) ListVMs added in v1.7.0

func (t *TenantEnvStruct) ListVMs(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) Log added in v1.1.0

Log -

func (*TenantEnvStruct) PluginAction added in v1.1.0

func (t *TenantEnvStruct) PluginAction(w http.ResponseWriter, r *http.Request)

PluginAction plugin action

func (*TenantEnvStruct) PluginBuild added in v1.1.0

func (t *TenantEnvStruct) PluginBuild(w http.ResponseWriter, r *http.Request)

PluginBuild PluginBuild swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/plugin/{plugin_id}/build v2 buildPlugin

构建plugin

build plugin

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) PluginDefaultENV added in v1.1.0

func (t *TenantEnvStruct) PluginDefaultENV(w http.ResponseWriter, r *http.Request)

PluginDefaultENV PluginDefaultENV

func (*TenantEnvStruct) PluginSet added in v1.1.0

func (t *TenantEnvStruct) PluginSet(w http.ResponseWriter, r *http.Request)

PluginSet PluginSet

func (*TenantEnvStruct) Pods added in v1.1.0

Pods pods swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/pods v2 getPodsInfo

获取pods信息

get pods info

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) Port added in v1.1.0

Port Port

func (*TenantEnvStruct) PortInnerController added in v1.1.0

func (t *TenantEnvStruct) PortInnerController(w http.ResponseWriter, r *http.Request)

PortInnerController 开关端口对内服务 swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/ports/{port}/inner v2 PortInnerController

开关对内服务,应用无需重启,自动生效

add port

--- Consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) PortOuterController added in v1.1.0

func (t *TenantEnvStruct) PortOuterController(w http.ResponseWriter, r *http.Request)

PortOuterController 开关端口对外服务 swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/ports/{port}/outer v2 PortOuterController

开关端口对外服务,应用无需重启自动生效

add port

--- Consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) Ports added in v1.1.0

Ports 应用端口控制器

func (*TenantEnvStruct) PostStatusService added in v1.1.0

func (t *TenantEnvStruct) PostStatusService(w http.ResponseWriter, r *http.Request)

PostStatusService PostStatusService

func (*TenantEnvStruct) Probe added in v1.1.0

Probe probe

func (*TenantEnvStruct) PutPorts added in v1.1.0

func (t *TenantEnvStruct) PutPorts(w http.ResponseWriter, r *http.Request)

PutPorts PortVar swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/ports v2 updatePort

更新应用端口信息(旧)

update port

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) RestartService added in v1.1.0

func (t *TenantEnvStruct) RestartService(w http.ResponseWriter, r *http.Request)

RestartService RestartService swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/restart v2 restartService

重启应用

restart service

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) RestartVM added in v1.7.0

func (t *TenantEnvStruct) RestartVM(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) RestoreRecords added in v1.6.0

func (t *TenantEnvStruct) RestoreRecords(w http.ResponseWriter, r *http.Request)

RestoreRecords get restore histories

func (*TenantEnvStruct) RollBack added in v1.1.0

func (t *TenantEnvStruct) RollBack(w http.ResponseWriter, r *http.Request)

RollBack RollBack swagger:operation Post /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/rollback v2 rollback

应用版本回滚

service rollback

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) ScalingRecords added in v1.1.0

func (t *TenantEnvStruct) ScalingRecords(w http.ResponseWriter, r *http.Request)

ScalingRecords -

func (*TenantEnvStruct) ServiceResources added in v1.1.0

func (t *TenantEnvStruct) ServiceResources(w http.ResponseWriter, r *http.Request)

ServiceResources ServiceResources

func (*TenantEnvStruct) ServicesCount added in v1.1.0

func (t *TenantEnvStruct) ServicesCount(w http.ResponseWriter, r *http.Request)

ServicesCount Get all apps and status

func (*TenantEnvStruct) ServicesInfo added in v1.1.0

func (t *TenantEnvStruct) ServicesInfo(w http.ResponseWriter, r *http.Request)

ServicesInfo GetServiceInfo

func (*TenantEnvStruct) SetDownStreamRule added in v1.1.0

func (t *TenantEnvStruct) SetDownStreamRule(w http.ResponseWriter, r *http.Request)

SetDownStreamRule 设置下游规则 swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/net-rule/downstream v2 setNetDownStreamRuleStruct

设置下游网络规则

set NetDownStreamRuleStruct

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) SetLanguage added in v1.1.0

func (t *TenantEnvStruct) SetLanguage(w http.ResponseWriter, r *http.Request)

SetLanguage SetLanguage

func (*TenantEnvStruct) SetServiceSchedulingNode added in v1.10.0

func (t *TenantEnvStruct) SetServiceSchedulingNode(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) Share added in v1.1.0

Share 应用分享

func (*TenantEnvStruct) SharePlugin added in v1.1.0

func (t *TenantEnvStruct) SharePlugin(w http.ResponseWriter, r *http.Request)

SharePlugin share tenantEnvs plugin

func (*TenantEnvStruct) SharePluginResult added in v1.1.0

func (t *TenantEnvStruct) SharePluginResult(w http.ResponseWriter, r *http.Request)

SharePluginResult SharePluginResult

func (*TenantEnvStruct) ShareResult added in v1.1.0

func (t *TenantEnvStruct) ShareResult(w http.ResponseWriter, r *http.Request)

ShareResult 获取分享结果

func (*TenantEnvStruct) SingleServiceInfo added in v1.1.0

func (t *TenantEnvStruct) SingleServiceInfo(w http.ResponseWriter, r *http.Request)

SingleServiceInfo SingleServiceInfo

func (*TenantEnvStruct) SingleTenantEnvResources added in v1.1.0

func (t *TenantEnvStruct) SingleTenantEnvResources(w http.ResponseWriter, r *http.Request)

SingleTenantEnvResources SingleTenantEnvResources swagger:operation GET /v2/tenants/{tenant_name}/envs/{tenant_env_name}/resources v2 singletenantEnvResources

指定租户资源使用情况

get tenant env resources

--- produces: - application/json - application/xml parameters:

  • name: tenant_env_name in: path description: tenant env name required: true type: string

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) StartService added in v1.1.0

func (t *TenantEnvStruct) StartService(w http.ResponseWriter, r *http.Request)

StartService StartService swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/start v2 startService

启动应用

start service

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) StartVM added in v1.7.0

func (t *TenantEnvStruct) StartVM(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) StatusContainerID added in v1.1.0

func (t *TenantEnvStruct) StatusContainerID(w http.ResponseWriter, r *http.Request)

StatusContainerID StatusContainerID

func (*TenantEnvStruct) StatusService added in v1.1.0

func (t *TenantEnvStruct) StatusService(w http.ResponseWriter, r *http.Request)

StatusService StatusService

func (*TenantEnvStruct) StatusServiceList added in v1.1.0

func (t *TenantEnvStruct) StatusServiceList(w http.ResponseWriter, r *http.Request)

StatusServiceList service list status

func (*TenantEnvStruct) StopService added in v1.1.0

func (t *TenantEnvStruct) StopService(w http.ResponseWriter, r *http.Request)

StopService StopService swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/stop v2 stopService

关闭应用

stop service

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) StopVM added in v1.7.0

func (t *TenantEnvStruct) StopVM(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) SumTenantEnvs added in v1.1.0

func (t *TenantEnvStruct) SumTenantEnvs(w http.ResponseWriter, r *http.Request)

SumTenantEnvs 统计租户数量

func (*TenantEnvStruct) TenantEnv added in v1.1.0

func (t *TenantEnvStruct) TenantEnv(w http.ResponseWriter, r *http.Request)

TenantEnv one tenant env controller

func (*TenantEnvStruct) TenantEnvResources added in v1.1.0

func (t *TenantEnvStruct) TenantEnvResources(w http.ResponseWriter, r *http.Request)

TenantEnvResources TenantEnvResources

func (*TenantEnvStruct) TenantEnvResourcesStatus added in v1.1.0

func (t *TenantEnvStruct) TenantEnvResourcesStatus(w http.ResponseWriter, r *http.Request)

TenantEnvResourcesStatus tenant env resources status

func (*TenantEnvStruct) TenantEnvsGetByName added in v1.1.0

func (t *TenantEnvStruct) TenantEnvsGetByName(w http.ResponseWriter, r *http.Request)

TenantEnvsGetByName TenantEnvsGetByName

func (*TenantEnvStruct) TenantEnvsQuery added in v1.1.0

func (t *TenantEnvStruct) TenantEnvsQuery(w http.ResponseWriter, r *http.Request)

TenantEnvsQuery TenantEnvsQuery

func (*TenantEnvStruct) TenantEnvsWithResource added in v1.1.0

func (t *TenantEnvStruct) TenantEnvsWithResource(w http.ResponseWriter, r *http.Request)

TenantEnvsWithResource TenantEnvsWithResource

func (*TenantEnvStruct) TransPlugins added in v1.1.0

func (t *TenantEnvStruct) TransPlugins(w http.ResponseWriter, r *http.Request)

TransPlugins transPlugins swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/transplugins v2 transPlugins

安装云帮默认plugins

trans plugins

--- produces: - application/json - application/xml parameters:

  • name: tenant_env_name in: path description: tenant env name required: true type: string

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) UpdVolume added in v1.1.0

func (t *TenantEnvStruct) UpdVolume(w http.ResponseWriter, r *http.Request)

UpdVolume updates service volume.

func (*TenantEnvStruct) UpdateBackupSchedule added in v1.7.0

func (t *TenantEnvStruct) UpdateBackupSchedule(w http.ResponseWriter, r *http.Request)

UpdateBackupSchedule update backup schedule for service resource and data

func (*TenantEnvStruct) UpdateBuildVersion added in v1.1.0

func (t *TenantEnvStruct) UpdateBuildVersion(w http.ResponseWriter, r *http.Request)

UpdateBuildVersion -

func (*TenantEnvStruct) UpdateDefaultENV added in v1.1.0

func (t *TenantEnvStruct) UpdateDefaultENV(w http.ResponseWriter, r *http.Request)

UpdateDefaultENV UpdateDefaultENV

func (*TenantEnvStruct) UpdateDownStreamRule added in v1.1.0

func (t *TenantEnvStruct) UpdateDownStreamRule(w http.ResponseWriter, r *http.Request)

UpdateDownStreamRule 更新下游规则 swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/net-rule/downstream/{dest_service_alias}/{port} v2 updateNetDownStreamRuleStruct

更新下游网络规则

update NetDownStreamRuleStruct

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) UpdateEnv added in v1.1.0

func (t *TenantEnvStruct) UpdateEnv(w http.ResponseWriter, r *http.Request)

UpdateEnv UpdateEnv swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/env v2 update Env

修改环境变量

update env var

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) UpdateLabel added in v1.1.0

func (t *TenantEnvStruct) UpdateLabel(w http.ResponseWriter, r *http.Request, labels *api_model.LabelsStruct)

UpdateLabel Update updates labels

func (*TenantEnvStruct) UpdatePlugin added in v1.1.0

func (t *TenantEnvStruct) UpdatePlugin(w http.ResponseWriter, r *http.Request)

UpdatePlugin UpdatePlugin

func (*TenantEnvStruct) UpdatePort added in v1.1.0

func (t *TenantEnvStruct) UpdatePort(w http.ResponseWriter, r *http.Request)

UpdatePort Update port

func (*TenantEnvStruct) UpdateProbe added in v1.1.0

func (t *TenantEnvStruct) UpdateProbe(w http.ResponseWriter, r *http.Request)

UpdateProbe update probe swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/probe v2 updateProbe

更新应用探针信息, *注意此处为全量更新

update probe

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) UpdateService added in v1.1.0

func (t *TenantEnvStruct) UpdateService(w http.ResponseWriter, r *http.Request)

UpdateService create Service

func (*TenantEnvStruct) UpdateServiceMonitors added in v1.1.0

func (t *TenantEnvStruct) UpdateServiceMonitors(w http.ResponseWriter, r *http.Request)

UpdateServiceMonitors update service monitor

func (*TenantEnvStruct) UpdateServiceSchedulingLabel added in v1.10.0

func (t *TenantEnvStruct) UpdateServiceSchedulingLabel(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) UpdateServiceSchedulingToleration added in v1.10.0

func (t *TenantEnvStruct) UpdateServiceSchedulingToleration(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) UpdateTenantEnv added in v1.1.0

func (t *TenantEnvStruct) UpdateTenantEnv(w http.ResponseWriter, r *http.Request)

UpdateTenantEnv UpdateTenantEnv support update tenant env limit memory

func (*TenantEnvStruct) UpdateVM added in v1.7.0

func (t *TenantEnvStruct) UpdateVM(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) UpdateVMPortGateway added in v1.7.0

func (t *TenantEnvStruct) UpdateVMPortGateway(w http.ResponseWriter, r *http.Request)

func (*TenantEnvStruct) UpdateVersionEnv added in v1.1.0

func (t *TenantEnvStruct) UpdateVersionEnv(w http.ResponseWriter, r *http.Request)

UpdateVersionEnv UpdateVersionEnv swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/plugin/{plugin_id}/upenv v2 updateVersionEnv

modify the app plugin config info. it will Thermal effect

update version env

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) UpgradeService added in v1.1.0

func (t *TenantEnvStruct) UpgradeService(w http.ResponseWriter, r *http.Request)

UpgradeService UpgradeService swagger:operation POST /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/upgrade v2 upgradeService

升级应用

upgrade service

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) VerticalService added in v1.1.0

func (t *TenantEnvStruct) VerticalService(w http.ResponseWriter, r *http.Request)

VerticalService VerticalService swagger:operation PUT /v2/tenants/{tenant_name}/envs/{tenant_env_name}/services/{service_alias}/vertical v2 verticalService

应用垂直伸缩

service vertical

--- consumes: - application/json - application/x-protobuf

produces: - application/json - application/xml

responses:

default:
  schema:
    "$ref": "#/responses/commandResponse"
  description: 统一返回格式

func (*TenantEnvStruct) VolumeDependency added in v1.1.0

func (t *TenantEnvStruct) VolumeDependency(w http.ResponseWriter, r *http.Request)

VolumeDependency VolumeDependency

type ThirdPartyServiceController

type ThirdPartyServiceController struct{}

ThirdPartyServiceController implements ThirdPartyServicer

func (*ThirdPartyServiceController) Endpoints

Endpoints POST->add endpoints, PUT->update endpoints, DELETE->delete endpoints

type V2Routes

V2Routes v2Routes

func NewManager

func NewManager(conf option.Config, statusCli *client.AppRuntimeSyncClient) (*V2Routes, error)

NewManager new manager

func (*V2Routes) AlertManagerWebHook

func (v2 *V2Routes) AlertManagerWebHook(w http.ResponseWriter, r *http.Request)

AlertManagerWebHook -

func (*V2Routes) Health

func (v2 *V2Routes) Health(w http.ResponseWriter, r *http.Request)

Health show health status

func (*V2Routes) Show

func (v2 *V2Routes) Show(w http.ResponseWriter, r *http.Request)

Show test

func (*V2Routes) Version

func (v2 *V2Routes) Version(w http.ResponseWriter, r *http.Request)

Version -

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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