controller

Documentation

Index

• func AddVolume(w http.ResponseWriter, r *http.Request)
• func AddVolumeDependency(w http.ResponseWriter, r *http.Request)
• func BackupCopy(w http.ResponseWriter, r *http.Request)
• func Backups(w http.ResponseWriter, r *http.Request)
• func BatchOperation(w http.ResponseWriter, r *http.Request)
• func Check(w http.ResponseWriter, r *http.Request)
• func CheckLabel(serviceID string) bool
• func CheckMapKey(rebody map[string]interface{}, key string, defaultValue interface{}) map[string]interface{}
• func CreateV2RouterManager(conf option.Config, statusCli *client.AppRuntimeSyncClient) (err error)
• func DeleteBackup(w http.ResponseWriter, r *http.Request)
• func DeleteVolume(w http.ResponseWriter, r *http.Request)
• func DeleteVolumeDependency(w http.ResponseWriter, r *http.Request)
• func DeleteVolumeType(w http.ResponseWriter, r *http.Request)
• func DirectRequest(w http.ResponseWriter, r *http.Request, endpoint string)
• func Display(i interface{}, j interface{})
• func FileServer(r chi.Router, path string, root http.FileSystem)
• func GetBackup(w http.ResponseWriter, r *http.Request)
• func GetDepVolume(w http.ResponseWriter, r *http.Request)
• func GetGatewayIPs(w http.ResponseWriter, r *http.Request)
• func GetMonitorMetrics(w http.ResponseWriter, r *http.Request)
• func GetNotificationEvent(w http.ResponseWriter, r *http.Request)
• func GetNotificationEvents(w http.ResponseWriter, r *http.Request)
• func GetRunningServices(w http.ResponseWriter, r *http.Request)
• func GetServiceAliasID(ServiceID string) string
• func GetServiceCheckInfo(w http.ResponseWriter, r *http.Request)
• func GetServiceDeployInfo(w http.ResponseWriter, r *http.Request)
• func GetServicesStatus(w http.ResponseWriter, r *http.Request)
• func GetVolume(w http.ResponseWriter, r *http.Request)
• func HTTPRequest(w http.ResponseWriter, r *http.Request, endpoint string)
• func HandleNotificationEvent(w http.ResponseWriter, r *http.Request)
• func ListVolumeType(w http.ResponseWriter, r *http.Request)
• func NewBackups(w http.ResponseWriter, r *http.Request)
• func PodNums(w http.ResponseWriter, r *http.Request)
• func Pods(w http.ResponseWriter, r *http.Request)
• func RestInfo(code int, others ...string) []byte
• func Restore(w http.ResponseWriter, r *http.Request)
• func RestoreResult(w http.ResponseWriter, r *http.Request)
• func TestFunc(w http.ResponseWriter)
• func TransBody(r *http.Request) (map[string]interface{}, error)
• func TransStatus(eStatus string) string
• func UpdateVolumeType(w http.ResponseWriter, r *http.Request)
• func VolumeOptions(w http.ResponseWriter, r *http.Request)
• func VolumeSetVar(w http.ResponseWriter, r *http.Request)
• type AppRestoreController
  • func (a *AppRestoreController) RestoreDepVols(w http.ResponseWriter, r *http.Request)
  • func (a *AppRestoreController) RestoreDeps(w http.ResponseWriter, r *http.Request)
  • func (a *AppRestoreController) RestoreEnvs(w http.ResponseWriter, r *http.Request)
  • func (a *AppRestoreController) RestorePlugins(w http.ResponseWriter, r *http.Request)
  • func (a *AppRestoreController) RestorePorts(w http.ResponseWriter, r *http.Request)
  • func (a *AppRestoreController) RestoreProbe(w http.ResponseWriter, r *http.Request)
  • func (a *AppRestoreController) RestoreVolumes(w http.ResponseWriter, r *http.Request)
• type AppStruct
  • func (a *AppStruct) Download(w http.ResponseWriter, r *http.Request)
  • func (a *AppStruct) ExportApp(w http.ResponseWriter, r *http.Request)
  • func (a *AppStruct) ImportApp(w http.ResponseWriter, r *http.Request)
  • func (a *AppStruct) ImportID(w http.ResponseWriter, r *http.Request)
  • func (a *AppStruct) NewUpload(w http.ResponseWriter, r *http.Request)
  • func (a *AppStruct) Upload(w http.ResponseWriter, r *http.Request)
• type ApplicationController
  • func (a *ApplicationController) AddConfigGroup(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) BatchBindService(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) BatchCreateApp(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) BatchUpdateComponentPorts(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) ChangeVolumes(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) CheckGovernanceMode(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) CreateApp(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) DeleteApp(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) DeleteConfigGroup(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) GetAppStatus(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) Install(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) ListAppStatuses(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) ListApps(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) ListComponents(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) ListConfigGroups(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) ListHelmAppReleases(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) ListServices(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) SyncAppConfigGroups(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) SyncComponents(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) UpdateApp(w http.ResponseWriter, r *http.Request)
  • func (a *ApplicationController) UpdateConfigGroup(w http.ResponseWriter, r *http.Request)
• type ClusterController
  • func (t *ClusterController) Features(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) GetClusterEvents(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) GetClusterInfo(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) ListVMNodeSelectorLabels(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) MavenSettingAdd(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) MavenSettingDelete(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) MavenSettingDetail(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) MavenSettingList(w http.ResponseWriter, r *http.Request)
  • func (t *ClusterController) MavenSettingUpdate(w http.ResponseWriter, r *http.Request)
• type DockerConsole
  • func GetDockerConsole() *DockerConsole
  • func (d DockerConsole) Get(w http.ResponseWriter, r *http.Request)
• type DockerLog
  • func GetDockerLog() *DockerLog
  • func (d DockerLog) Get(w http.ResponseWriter, r *http.Request)
• type EventLog
  • func GetEventLog() *EventLog
  • func (d EventLog) Get(w http.ResponseWriter, r *http.Request)
• type EventLogStruct
  • func (e *EventLogStruct) EventLog(w http.ResponseWriter, r *http.Request)
  • func (e *EventLogStruct) Events(w http.ResponseWriter, r *http.Request)
  • func (e *EventLogStruct) HistoryLogs(w http.ResponseWriter, r *http.Request)
  • func (e *EventLogStruct) LogByAction(w http.ResponseWriter, r *http.Request)
  • func (e *EventLogStruct) LogFile(w http.ResponseWriter, r *http.Request)
  • func (e *EventLogStruct) LogList(w http.ResponseWriter, r *http.Request)
  • func (e *EventLogStruct) LogSocket(w http.ResponseWriter, r *http.Request)
  • func (e *EventLogStruct) TenantEnvLogByAction(w http.ResponseWriter, r *http.Request)
• type GatewayStruct
  • func (g *GatewayStruct) AddTCPRule(w http.ResponseWriter, r *http.Request)
  • func (g *GatewayStruct) Certificate(w http.ResponseWriter, r *http.Request)
  • func (g *GatewayStruct) GetAvailablePort(w http.ResponseWriter, r *http.Request)
  • func (g *GatewayStruct) HTTPRule(w http.ResponseWriter, r *http.Request)
  • func (g *GatewayStruct) RuleConfig(w http.ResponseWriter, r *http.Request)
  • func (g *GatewayStruct) TCPRule(w http.ResponseWriter, r *http.Request)
  • func (g *GatewayStruct) TCPRuleConfig(w http.ResponseWriter, r *http.Request)
• type Handle
• type HelmAppsController
  • func (c *HelmAppsController) ListHelmAppResources(w http.ResponseWriter, r *http.Request)
  • func (c *HelmAppsController) ListHelmApps(w http.ResponseWriter, r *http.Request)
• type LabelController
  • func (l *LabelController) Labels(w http.ResponseWriter, r *http.Request)
• type LicenseManager
  • func GetLicenseManager() *LicenseManager
  • func (l *LicenseManager) GetlicenseFeature(w http.ResponseWriter, r *http.Request)
• type LogFile
  • func GetLogFile() *LogFile
  • func (d LogFile) Get(w http.ResponseWriter, r *http.Request)
  • func (d LogFile) GetInstallLog(w http.ResponseWriter, r *http.Request)
• type MonitorMessage
  • func GetMonitorMessage() *MonitorMessage
  • func (d MonitorMessage) Get(w http.ResponseWriter, r *http.Request)
• type NodeController
• type PodController
  • func (p *PodController) PodDetail(w http.ResponseWriter, r *http.Request)
• type PubSubControll
  • func GetPubSubControll() *PubSubControll
  • func (d PubSubControll) Get(w http.ResponseWriter, r *http.Request)
  • func (d PubSubControll) GetHistoryLog(w http.ResponseWriter, r *http.Request)
• type RegistryAuthSecretStruct
  • func (g *RegistryAuthSecretStruct) RegistryAuthSecret(w http.ResponseWriter, r *http.Request)
• type RootFuncManager
  • func GetRootFuncManager() *RootFuncManager
• type SourcesInfo
• type TenantEnvStruct
  • func (t *TenantEnvStruct) AddDefatultENV(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddDependency(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddLabel(w http.ResponseWriter, r *http.Request, labels *api_model.LabelsStruct)
  • func (t *TenantEnvStruct) AddPort(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddProbe(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddServiceMonitors(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddTenantEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddVMPort(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddVolume(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AddVolumeDependency(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AllTenantEnvResources(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) AutoscalerRules(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) BackupRecords(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) BatchBuildPlugins(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) BatchInstallPlugins(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) BuildList(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) BuildService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) BuildVersionInfo(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) BuildVersionIsExist(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CheckCode(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CheckResourceName(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CreateBackup(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CreateBackupSchedule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CreatePlugin(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CreateRestore(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CreateService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CreateVM(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) CreateVMPortGateway(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteBackup(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteBackupSchedule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteBuildVersion(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteDefaultENV(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteDependency(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteDownStreamRule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteLabel(w http.ResponseWriter, r *http.Request, labels *api_model.LabelsStruct)
  • func (t *TenantEnvStruct) DeletePlugin(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeletePluginBuildVersion(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeletePluginRelation(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeletePort(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteProbe(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteRestore(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteServiceMonitors(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteSingleServiceInfo(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteTenantEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteVM(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteVMPort(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteVMPortGateway(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteVolume(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeleteVolumeDependency(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Dependency(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DeployService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DisableVMPort(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) DownloadBackup(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) EnableVMPort(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Env(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Event(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GePluginEnvWhichCanBeSet(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetAllPluginBuildVersions(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetAllTenantEnvs(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetApplicationKubeResources(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetBackupSchedule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetDeployVersion(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetDownStreamRule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetKubeConfig(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetManyDeployVersion(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetPluginBuildVersion(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetPluginDefaultEnvs(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetPlugins(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetServiceKubeResources(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetSingleServiceInfo(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetSupportProtocols(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetTenantEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetTenantEnvKubeResources(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetTenantEnvs(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetVM(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) GetVMPorts(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) HorizontalService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Label(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) LimitTenantEnvMemory(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) ListVMs(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Log(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PluginAction(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PluginBuild(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PluginDefaultENV(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PluginSet(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Pods(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Port(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PortInnerController(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PortOuterController(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Ports(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PostStatusService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Probe(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) PutPorts(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) RestartService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) RestartVM(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) RestoreRecords(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) RollBack(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) ScalingRecords(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) ServiceResources(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) ServicesCount(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) ServicesInfo(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) SetDownStreamRule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) SetLanguage(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) Share(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) SharePlugin(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) SharePluginResult(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) ShareResult(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) SingleServiceInfo(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) SingleTenantEnvResources(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) StartService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) StartVM(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) StatusContainerID(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) StatusService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) StatusServiceList(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) StopService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) StopVM(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) SumTenantEnvs(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) TenantEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) TenantEnvResources(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) TenantEnvResourcesStatus(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) TenantEnvsGetByName(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) TenantEnvsQuery(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) TenantEnvsWithResource(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) TransPlugins(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdVolume(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateBackupSchedule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateBuildVersion(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateDefaultENV(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateDownStreamRule(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateLabel(w http.ResponseWriter, r *http.Request, labels *api_model.LabelsStruct)
  • func (t *TenantEnvStruct) UpdatePlugin(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdatePort(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateProbe(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateServiceMonitors(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateTenantEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateVM(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateVMPortGateway(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpdateVersionEnv(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) UpgradeService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) VerticalService(w http.ResponseWriter, r *http.Request)
  • func (t *TenantEnvStruct) VolumeDependency(w http.ResponseWriter, r *http.Request)
• type ThirdPartyServiceController
  • func (t *ThirdPartyServiceController) Endpoints(w http.ResponseWriter, r *http.Request)
• type V2Manager
  • func GetManager() V2Manager
• type V2Routes
  • func NewManager(conf option.Config, statusCli *client.AppRuntimeSyncClient) (*V2Routes, error)
  • func (v2 *V2Routes) AlertManagerWebHook(w http.ResponseWriter, r *http.Request)
  • func (v2 *V2Routes) Health(w http.ResponseWriter, r *http.Request)
  • func (v2 *V2Routes) Show(w http.ResponseWriter, r *http.Request)
  • func (v2 *V2Routes) Version(w http.ResponseWriter, r *http.Request)

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

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

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

CreateApp -

func (*ApplicationController) DeleteApp

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

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

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

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

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

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

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

UpdateApp -

func (*ApplicationController) UpdateConfigGroup

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

UpdateConfigGroup -

type ClusterController

type ClusterController struct {
}

ClusterController -

func (*ClusterController) Features

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

Features

func (*ClusterController) GetClusterEvents

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) ListVMNodeSelectorLabels

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

GetClusterInfo -

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

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

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

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

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

type HelmAppsController struct{}

HelmAppsController is an implementation of HelmAppsInterface

func (*HelmAppsController) ListHelmAppResources

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

ListHelmAppResources - list helm resources

func (*HelmAppsController) ListHelmApps

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

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

Get get

type NodeController

type NodeController struct {
}

NodeController -

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

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

Get pubsub controller

func (PubSubControll) GetHistoryLog

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

GetHistoryLog get service docker logs

type RegistryAuthSecretStruct

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

RegistryAuthSecretStruct -

func (*RegistryAuthSecretStruct) RegistryAuthSecret

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 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

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

TenantEnvStruct tenant env struct

func (*TenantEnvStruct) AddDefatultENV

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

AddDefatultENV AddDefatultENV

func (*TenantEnvStruct) AddDependency

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

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

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

AddLabel adds label

func (*TenantEnvStruct) AddPort

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

AddPort add port

func (*TenantEnvStruct) AddProbe

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

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

AddServiceMonitors add service monitor

func (*TenantEnvStruct) AddTenantEnv

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

AddTenantEnv AddTenantEnv

func (*TenantEnvStruct) AddVMPort

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

func (*TenantEnvStruct) AddVolume

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

AddVolume AddVolume

func (*TenantEnvStruct) AddVolumeDependency

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

AddVolumeDependency add volume dependency

func (*TenantEnvStruct) AllTenantEnvResources

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

AllTenantEnvResources GetResources

func (*TenantEnvStruct) AutoscalerRules

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

AutoscalerRules -

func (*TenantEnvStruct) BackupRecords

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

BackupRecords get backup histories

func (*TenantEnvStruct) BatchBuildPlugins

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

BatchBuildPlugins -

func (*TenantEnvStruct) BatchInstallPlugins

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

BatchInstallPlugins -

func (*TenantEnvStruct) BuildList

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

BuildList BuildList

func (*TenantEnvStruct) BuildService

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

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

BuildVersionInfo -

func (*TenantEnvStruct) BuildVersionIsExist

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

BuildVersionIsExist -

func (*TenantEnvStruct) CheckCode

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

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

CheckResourceName checks the resource name.

func (*TenantEnvStruct) CreateBackup

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

CreateBackup create backup for service resource and data

func (*TenantEnvStruct) CreateBackupSchedule

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

CreateBackupSchedule create backup schedule for service resource and data

func (*TenantEnvStruct) CreatePlugin

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

CreatePlugin add plugin

func (*TenantEnvStruct) CreateRestore

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

CreateRestore create restore for service resource and data

func (*TenantEnvStruct) CreateService

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

CreateService create Service

func (*TenantEnvStruct) CreateVM

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

func (*TenantEnvStruct) CreateVMPortGateway

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

func (*TenantEnvStruct) DeleteBackup

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

DeleteBackup delete backup for service resource and data

func (*TenantEnvStruct) DeleteBackupSchedule

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

DeleteBackupSchedule delete backup schedule for service resource and data

func (*TenantEnvStruct) DeleteBuildVersion

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

DeleteBuildVersion -

func (*TenantEnvStruct) DeleteDefaultENV

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

DeleteDefaultENV DeleteDefaultENV

func (*TenantEnvStruct) DeleteDependency

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

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

DeleteDownStreamRule 删除下游规则

func (*TenantEnvStruct) DeleteEnv

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

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

DeleteLabel deletes labels

func (*TenantEnvStruct) DeletePlugin

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

DeletePlugin DeletePlugin

func (*TenantEnvStruct) DeletePluginBuildVersion

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

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

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

DeletePort delete port

func (*TenantEnvStruct) DeleteProbe

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

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

DeleteRestore delete restore for service resource and data

func (*TenantEnvStruct) DeleteServiceMonitors

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

DeleteServiceMonitors delete service monitor

func (*TenantEnvStruct) DeleteSingleServiceInfo

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

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

DeleteTenantEnv DeleteTenantEnv

func (*TenantEnvStruct) DeleteVM

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

func (*TenantEnvStruct) DeleteVMPort

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

func (*TenantEnvStruct) DeleteVMPortGateway

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

func (*TenantEnvStruct) DeleteVolume

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

DeleteVolume DeleteVolume

func (*TenantEnvStruct) DeleteVolumeDependency

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

DeleteVolumeDependency delete volume dependency

func (*TenantEnvStruct) Dependency

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

Dependency Dependency

func (*TenantEnvStruct) DeployService

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

DeployService DeployService

func (*TenantEnvStruct) DisableVMPort

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

func (*TenantEnvStruct) DownloadBackup

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

func (*TenantEnvStruct) EnableVMPort

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

func (*TenantEnvStruct) Env

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

Env Env

func (*TenantEnvStruct) Event

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

Event GetLogs

func (*TenantEnvStruct) GePluginEnvWhichCanBeSet

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

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

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

GetAllTenantEnvs GetAllTenantEnvs

func (*TenantEnvStruct) GetApplicationKubeResources

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

GetApplicationKubeResources get kube resources for application

func (*TenantEnvStruct) GetBackupSchedule

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

GetBackupSchedule get backup schedule

func (*TenantEnvStruct) GetDeployVersion

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

GetDeployVersion GetDeployVersion by service

func (*TenantEnvStruct) GetDownStreamRule

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

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

GetKubeConfig get kube config for developer

func (*TenantEnvStruct) GetManyDeployVersion

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

GetManyDeployVersion GetDeployVersion by some service id

func (*TenantEnvStruct) GetPluginBuildVersion

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

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

GetPluginDefaultEnvs GetPluginDefaultEnvs

func (*TenantEnvStruct) GetPlugins

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

GetPlugins GetPlugins

func (*TenantEnvStruct) GetServiceKubeResources

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

GetServiceKubeResources get kube resources for component

func (*TenantEnvStruct) GetSingleServiceInfo

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

GetSingleServiceInfo GetSingleServiceInfo

func (*TenantEnvStruct) GetSupportProtocols

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

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

GetTenantEnv get one tenant env

func (*TenantEnvStruct) GetTenantEnvKubeResources

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

GetTenantEnvKubeResources get kube resources for tenantEnv

func (*TenantEnvStruct) GetTenantEnvs

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

GetTenantEnvs GetTenantEnvs

func (*TenantEnvStruct) GetVM

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

func (*TenantEnvStruct) GetVMPorts

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

func (*TenantEnvStruct) HorizontalService

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

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

Label -

func (*TenantEnvStruct) LimitTenantEnvMemory

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

LimitTenantEnvMemory -

func (*TenantEnvStruct) ListVMs

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

func (*TenantEnvStruct) Log

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

Log -

func (*TenantEnvStruct) PluginAction

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

PluginAction plugin action

func (*TenantEnvStruct) PluginBuild

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

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

PluginDefaultENV PluginDefaultENV

func (*TenantEnvStruct) PluginSet

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

PluginSet PluginSet

func (*TenantEnvStruct) Pods

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

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

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

Port Port

func (*TenantEnvStruct) PortInnerController

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

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

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

Ports 应用端口控制器

func (*TenantEnvStruct) PostStatusService

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

PostStatusService PostStatusService

func (*TenantEnvStruct) Probe

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

Probe probe

func (*TenantEnvStruct) PutPorts

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

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

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

func (*TenantEnvStruct) RestoreRecords

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

RestoreRecords get restore histories

func (*TenantEnvStruct) RollBack

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

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

ScalingRecords -

func (*TenantEnvStruct) ServiceResources

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

ServiceResources ServiceResources

func (*TenantEnvStruct) ServicesCount

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

ServicesCount Get all apps and status

func (*TenantEnvStruct) ServicesInfo

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

ServicesInfo GetServiceInfo

func (*TenantEnvStruct) SetDownStreamRule

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

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

SetLanguage SetLanguage

func (*TenantEnvStruct) Share

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

Share 应用分享

func (*TenantEnvStruct) SharePlugin

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

SharePlugin share tenantEnvs plugin

func (*TenantEnvStruct) SharePluginResult

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

SharePluginResult SharePluginResult

func (*TenantEnvStruct) ShareResult

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

ShareResult 获取分享结果

func (*TenantEnvStruct) SingleServiceInfo

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

SingleServiceInfo SingleServiceInfo

func (*TenantEnvStruct) SingleTenantEnvResources

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

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

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

func (*TenantEnvStruct) StatusContainerID

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

StatusContainerID StatusContainerID

func (*TenantEnvStruct) StatusService

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

StatusService StatusService

func (*TenantEnvStruct) StatusServiceList

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

StatusServiceList service list status

func (*TenantEnvStruct) StopService

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

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

func (*TenantEnvStruct) SumTenantEnvs

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

SumTenantEnvs 统计租户数量

func (*TenantEnvStruct) TenantEnv

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

TenantEnv one tenant env controller

func (*TenantEnvStruct) TenantEnvResources

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

TenantEnvResources TenantEnvResources

func (*TenantEnvStruct) TenantEnvResourcesStatus

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

TenantEnvResourcesStatus tenant env resources status

func (*TenantEnvStruct) TenantEnvsGetByName

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

TenantEnvsGetByName TenantEnvsGetByName

func (*TenantEnvStruct) TenantEnvsQuery

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

TenantEnvsQuery TenantEnvsQuery

func (*TenantEnvStruct) TenantEnvsWithResource

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

TenantEnvsWithResource TenantEnvsWithResource

func (*TenantEnvStruct) TransPlugins

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

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

UpdVolume updates service volume.

func (*TenantEnvStruct) UpdateBackupSchedule

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

UpdateBackupSchedule update backup schedule for service resource and data

func (*TenantEnvStruct) UpdateBuildVersion

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

UpdateBuildVersion -

func (*TenantEnvStruct) UpdateDefaultENV

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

UpdateDefaultENV UpdateDefaultENV

func (*TenantEnvStruct) UpdateDownStreamRule

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

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

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

UpdateLabel Update updates labels

func (*TenantEnvStruct) UpdatePlugin

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

UpdatePlugin UpdatePlugin

func (*TenantEnvStruct) UpdatePort

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

UpdatePort Update port

func (*TenantEnvStruct) UpdateProbe

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

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

UpdateService create Service

func (*TenantEnvStruct) UpdateServiceMonitors

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

UpdateServiceMonitors update service monitor

func (*TenantEnvStruct) UpdateTenantEnv

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

UpdateTenantEnv UpdateTenantEnv support update tenant env limit memory

func (*TenantEnvStruct) UpdateVM

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

func (*TenantEnvStruct) UpdateVMPortGateway

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

func (*TenantEnvStruct) UpdateVersionEnv

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

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

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

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

VolumeDependency VolumeDependency

type ThirdPartyServiceController

type ThirdPartyServiceController struct{}

ThirdPartyServiceController implements ThirdPartyServicer

func (*ThirdPartyServiceController) Endpoints

func (t *ThirdPartyServiceController) Endpoints(w http.ResponseWriter, r *http.Request)

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

type V2Manager

type V2Manager interface {
	Show(w http.ResponseWriter, r *http.Request)
	Health(w http.ResponseWriter, r *http.Request)
	AlertManagerWebHook(w http.ResponseWriter, r *http.Request)
	Version(w http.ResponseWriter, r *http.Request)
	api.ClusterInterface
	api.NodeInterface
	api.TenantEnvInterface
	api.ServiceInterface
	api.LogInterface
	api.PluginInterface
	api.RulesInterface
	api.AppInterface
	api.Gatewayer
	api.ThirdPartyServicer
	api.Labeler
	api.AppRestoreInterface
	api.PodInterface
	api.ApplicationInterface
	api.HelmAppsInterface
	api.RegistryAuthSecretInterface
}

V2Manager v2 manager

func GetManager

func GetManager() V2Manager

GetManager 获取管理器

type V2Routes

type V2Routes struct {
	ClusterController
	TenantEnvStruct
	EventLogStruct
	AppStruct
	GatewayStruct
	ThirdPartyServiceController
	LabelController
	AppRestoreController
	PodController
	ApplicationController
	HelmAppsController
	RegistryAuthSecretStruct
}

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 -