handler

package

Go to main page

Versions in this module

v1

v1.15.0

Sep 4, 2024

Changes in this version

type ClusterHandler

+ SetClusterInfo func(ctx context.Context, info *RegionInfo) error

+ type RegionInfo struct

+ RegionCode string

+ RegionID string

type ServiceAction

+ func (s *ServiceAction) ChangeServiceApp(serviceID string, req *api_model.ChangeServiceAppRequest) error

type ServiceHandler

+ ChangeServiceApp func(serviceID string, req *api_model.ChangeServiceAppRequest) error

v1.14.0

Jul 30, 2024

Changes in this version

type PluginAction

+ func (p *PluginAction) BuildSysPluginManual(bps *api_model.BuildSysPluginStruct) (*dbmodel.TenantEnvPluginBuildVersion, *util.APIHandleError)

+ func (p *PluginAction) CreateSysPluginAct(cps *api_model.CreateSysPluginStruct) *util.APIHandleError

+ func (p *PluginAction) DeleteSysPluginAct(pluginID string) *util.APIHandleError

+ func (p *PluginAction) UpdateSysPluginAct(pluginID string, cps *api_model.UpdateSysPluginStruct) *util.APIHandleError

type PluginHandler

+ BuildSysPluginManual func(bps *api_model.BuildSysPluginStruct) (*dbmodel.TenantEnvPluginBuildVersion, *util.APIHandleError)

+ CreateSysPluginAct func(cps *api_model.CreateSysPluginStruct) *util.APIHandleError

+ DeleteSysPluginAct func(pluginID string) *util.APIHandleError

+ UpdateSysPluginAct func(pluginID string, cps *api_model.UpdateSysPluginStruct) *util.APIHandleError

v1.13.0

Jun 18, 2024

Changes in this version

type ServiceAction

+ func (s *ServiceAction) DeleteAutoscalerRule(ruleID string) error

+ func (s *ServiceAction) RemoveBootDisk(tenantEnv *dbmodel.TenantEnvs, vmID string) error

type ServiceHandler

+ DeleteAutoscalerRule func(ruleID string) error

+ RemoveBootDisk func(tenantEnv *dbmodel.TenantEnvs, vmID string) error

+ type VirtVNCProxy struct

+ HTTPProxy proxy.Proxy

+ WebSocketProxy proxy.Proxy

+ func GetVirtVNCProxy(namespace, vm string) *VirtVNCProxy

v1.12.0

Apr 17, 2024

Changes in this version

+ func GetObsLokiProxy() proxy.Proxy

+ func GetObsTempoProxy() proxy.Proxy

v1.11.0

Feb 21, 2024

Changes in this version

+ func GetNodeDiskAvailable(nodeName, nodeIP string, prometheusCli prometheus.Interface) float64

+ func GetObsMimirProxy() proxy.Proxy

type ClusterHandler

+ ListStorageClasses func(ctx context.Context) []model.StorageClass

type NodeHandler

+ GetCommonLabels func(nodeName string) ([]model.Label, error)

+ GetNodeAnnotations func(nodeName string) ([]model.Annotation, error)

+ GetNodeLabels func(nodeName string) ([]model.Label, error)

+ GetNodeTaints func(nodeName string) ([]model.Taint, error)

+ GetVMSchedulingLabels func(nodeName string) ([]model.Label, error)

type ServiceAction

+ func (s *ServiceAction) GetVMConditions(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.GetVMConditionsResponse, error)

type ServiceHandler

+ GetVMConditions func(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.GetVMConditionsResponse, error)

v1.10.0

Jan 16, 2024

Changes in this version

+ const VolumeStatusBoundAndInUse

+ const VolumeStatusBoundButNotInUse

+ const VolumeStatusLost

+ const VolumeStatusPending

+ const VolumeStatusUnknown

type NodeHandler

+ CordonNode func(nodeName string, req *model.CordonNodeRequest) error

+ DeleteNodeAnnotation func(nodeName string, req *model.DeleteNodeAnnotationRequest) error

+ DeleteNodeLabel func(nodeName string, req *model.DeleteNodeLabelRequest) error

+ DeleteTaintNode func(nodeName string, req *model.DeleteTaintNodeRequest) error

+ DeleteVMSchedulingLabel func(nodeName string, req *model.DeleteVMSchedulingLabelRequest) error

+ GetNode func(nodeName string) (*model.GetNodeResponse, error)

+ ListNodes func() (*model.ListNodeResponse, error)

+ SetNodeAnnotation func(nodeName string, req *model.SetNodeAnnotationRequest) error

+ SetNodeLabel func(nodeName string, req *model.SetNodeLabelRequest) error

+ SetVMSchedulingLabel func(nodeName string, req *model.SetVMSchedulingLabelRequest) error

+ TaintNode func(nodeName string, req *model.TaintNodeRequest) error

+ UncordonNode func(nodeName string) error

+ type SchedulingHandler interface

+ ListSchedulingLabels func() (*model.ListSchedulingLabelsResponse, error)

+ ListSchedulingNodes func() (*model.ListSchedulingNodesResponse, error)

+ ListSchedulingTaints func() (*model.ListSchedulingTaintsResponse, error)

+ ListVMSchedulingLabels func() ([]string, error)

+ func GetSchedulingHandler() SchedulingHandler

+ func NewSchedulingHandler(clientset kubernetes.Interface) SchedulingHandler

type ServiceAction

+ func (s *ServiceAction) AddServiceSchedulingLabel(serviceID string, req *model.AddServiceSchedulingLabelRequest) error

+ func (s *ServiceAction) AddServiceSchedulingToleration(serviceID string, req *model.AddServiceSchedulingTolerationRequest) error

+ func (s *ServiceAction) AddVMVolume(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.AddVMVolumeRequest) error

+ func (s *ServiceAction) DeleteServiceSchedulingLabel(service string, req *model.DeleteServiceSchedulingLabelRequest) error

+ func (s *ServiceAction) DeleteServiceSchedulingToleration(service string, req *model.DeleteServiceSchedulingTolerationRequest) error

+ func (s *ServiceAction) DeleteVMVolume(tenantEnv *dbmodel.TenantEnvs, vmID, volumeName string) error

+ func (s *ServiceAction) GetServiceSchedulingDetails(serviceID string) (*model.GetServiceSchedulingDetailsResponse, error)

+ func (s *ServiceAction) ListVMVolumes(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.ListVMVolumesResponse, error)

+ func (s *ServiceAction) SetServiceSchedulingNode(serviceID string, req *model.SetServiceSchedulingNodeRequest) error

+ func (s *ServiceAction) UpdateServiceSchedulingLabel(serviceID string, req *model.UpdateServiceSchedulingLabelRequest) error

+ func (s *ServiceAction) UpdateServiceSchedulingToleration(serviceID string, req *model.UpdateServiceSchedulingTolerationRequest) error

type ServiceHandler

+ AddServiceSchedulingLabel func(serviceID string, req *api_model.AddServiceSchedulingLabelRequest) error

+ AddServiceSchedulingToleration func(serviceID string, req *api_model.AddServiceSchedulingTolerationRequest) error

+ AddVMVolume func(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.AddVMVolumeRequest) error

+ DeleteServiceSchedulingLabel func(serviceID string, req *api_model.DeleteServiceSchedulingLabelRequest) error

+ DeleteServiceSchedulingToleration func(serviceID string, req *api_model.DeleteServiceSchedulingTolerationRequest) error

+ DeleteVMVolume func(tenantEnv *dbmodel.TenantEnvs, vmID, volumeName string) error

+ GetServiceSchedulingDetails func(serviceID string) (*api_model.GetServiceSchedulingDetailsResponse, error)

+ ListVMVolumes func(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.ListVMVolumesResponse, error)

+ SetServiceSchedulingNode func(serviceID string, req *api_model.SetServiceSchedulingNodeRequest) error

+ UpdateServiceSchedulingLabel func(serviceID string, req *api_model.UpdateServiceSchedulingLabelRequest) error

+ UpdateServiceSchedulingToleration func(serviceID string, req *api_model.UpdateServiceSchedulingTolerationRequest) error

v1.9.0

Dec 18, 2023

Changes in this version

+ var ErrClusterLackOfMemory = errors.New("cluster_lack_of_memory")

+ var ErrTenantEnvLackOfMemory = errors.New("tenant_env_lack_of_memory")

type ClusterHandler

+ Features func(ctx context.Context) map[string]bool

+ type NodeHandler interface

+ ListVMNodeSelectorLabels func() ([]string, error)

+ func GetNodeHandler() NodeHandler

+ func NewNodeHandler(clientset kubernetes.Interface) NodeHandler

type ServiceAction

+ func (s *ServiceAction) DisableVMPort(tenantEnv *dbmodel.TenantEnvs, vmID string, ...) error

+ func (s *ServiceAction) DisableVMPortGateway(tenantEnv *dbmodel.TenantEnvs, vmID, gatewayID string) error

+ func (s *ServiceAction) EnableVMPort(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.EnableVMPortRequest) error

type ServiceHandler

+ DisableVMPort func(tenantEnv *dbmodel.TenantEnvs, vmID string, ...) error

+ EnableVMPort func(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.EnableVMPortRequest) error

v1.8.0

Nov 28, 2023

v1.7.0

Nov 27, 2023

Changes in this version

type GatewayAction

+ func (g *GatewayAction) IsPortAvailable(ip string, port int) bool

type GatewayHandler

+ IsPortAvailable func(ip string, port int) bool

type ServiceAction

+ func (s *ServiceAction) AddVMPort(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.AddVMPortRequest) error

+ func (s *ServiceAction) CreateVM(tenantEnv *dbmodel.TenantEnvs, req *api_model.CreateVMRequest) (*api_model.CreateVMResponse, error)

+ func (s *ServiceAction) CreateVMPortGateway(tenantEnv *dbmodel.TenantEnvs, vmID string, ...) error

+ func (s *ServiceAction) DeleteVM(tenantEnv *dbmodel.TenantEnvs, vmID string) error

+ func (s *ServiceAction) DeleteVMPort(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.DeleteVMPortRequest) error

+ func (s *ServiceAction) DeleteVMPortGateway(tenantEnv *dbmodel.TenantEnvs, vmID, gatewayID string) error

+ func (s *ServiceAction) GetVM(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.GetVMResponse, error)

+ func (s *ServiceAction) GetVMPorts(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.GetVMPortsResponse, error)

+ func (s *ServiceAction) ListVMs(tenantEnv *dbmodel.TenantEnvs) (*api_model.ListVMsResponse, error)

+ func (s *ServiceAction) RestartVM(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.RestartVMResponse, error)

+ func (s *ServiceAction) StartVM(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.StartVMResponse, error)

+ func (s *ServiceAction) StopVM(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.StopVMResponse, error)

+ func (s *ServiceAction) UpdateBackupSchedule(tenantEnvID, serviceID string, req api_model.UpdateBackupScheduleRequest) error

+ func (s *ServiceAction) UpdateVM(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.UpdateVMRequest) (*api_model.UpdateVMResponse, error)

+ func (s *ServiceAction) UpdateVMPortGateway(tenantEnv *dbmodel.TenantEnvs, vmID, gatewayID string, ...) error

type ServiceHandler

+ AddVMPort func(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.AddVMPortRequest) error

+ CreateVM func(tenantEnv *dbmodel.TenantEnvs, req *api_model.CreateVMRequest) (*api_model.CreateVMResponse, error)

+ CreateVMPortGateway func(tenantEnv *dbmodel.TenantEnvs, vmID string, ...) error

+ DeleteVM func(tenantEnv *dbmodel.TenantEnvs, vmID string) error

+ DeleteVMPort func(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.DeleteVMPortRequest) error

+ DeleteVMPortGateway func(tenantEnv *dbmodel.TenantEnvs, vmID, gatewayID string) error

+ GetVM func(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.GetVMResponse, error)

+ GetVMPorts func(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.GetVMPortsResponse, error)

+ ListVMs func(tenantEnv *dbmodel.TenantEnvs) (*api_model.ListVMsResponse, error)

+ RestartVM func(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.RestartVMResponse, error)

+ StartVM func(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.StartVMResponse, error)

+ StopVM func(tenantEnv *dbmodel.TenantEnvs, vmID string) (*api_model.StopVMResponse, error)

+ UpdateBackupSchedule func(tenantEnvID, serviceID string, req api_model.UpdateBackupScheduleRequest) error

+ UpdateVM func(tenantEnv *dbmodel.TenantEnvs, vmID string, req *api_model.UpdateVMRequest) (*api_model.UpdateVMResponse, error)

+ UpdateVMPortGateway func(tenantEnv *dbmodel.TenantEnvs, vmID, gatewayID string, ...) error

v1.6.0

Nov 1, 2023

Changes in this version

type ServiceAction

+ func (s *ServiceAction) BackupRecords(tenantEnvID, serviceID string) ([]*api_model.BackupRecord, error)

+ func (s *ServiceAction) CreateBackup(tenantEnvID, serviceID string) error

+ func (s *ServiceAction) CreateBackupSchedule(tenantEnvID, serviceID, cron string) error

+ func (s *ServiceAction) CreateRestore(tenantEnvID, serviceID, BackupID string) error

+ func (s *ServiceAction) DeleteBackup(serviceID, backupID string) error

+ func (s *ServiceAction) DeleteBackupSchedule(serviceID string) error

+ func (s *ServiceAction) DeleteRestore(serviceID, restoreID string) error

+ func (s *ServiceAction) DownloadBackup(serviceID, backupID string) ([]byte, error)

+ func (s *ServiceAction) GetBackupSchedule(tenantEnvID, serviceID string) (*api_model.BackupSchedule, bool)

+ func (s *ServiceAction) RestoreRecords(tenantEnvID, serviceID string) ([]*api_model.RestoreRecord, error)

type ServiceHandler

+ BackupRecords func(tenantEnvID, serviceID string) ([]*api_model.BackupRecord, error)

+ CreateBackup func(tenantEnvID, serviceID string) error

+ CreateBackupSchedule func(tenantEnvID, serviceID, cron string) error

+ CreateRestore func(tenantEnvID, serviceID, BackupID string) error

+ DeleteBackup func(serviceID, backupID string) error

+ DeleteBackupSchedule func(serviceID string) error

+ DeleteRestore func(serviceID, restoreID string) error

+ DownloadBackup func(serviceID, backupID string) ([]byte, error)

+ GetBackupSchedule func(tenantEnvID, serviceID string) (*api_model.BackupSchedule, bool)

+ RestoreRecords func(tenantEnvID, serviceID string) ([]*api_model.RestoreRecord, error)

v1.5.0

Aug 30, 2023

v1.4.0

Aug 8, 2023

v1.3.0

Jul 7, 2023

v1.2.0

Jul 7, 2023

v1.1.0

Jun 14, 2023

Changes in this version

+ const NodFreeStorageMetric

+ const NodeCapacityStorageMetric

+ var ErrTenantEnvStillHasPlugins = errors.New("tenant env still has plugins")

+ var ErrTenantEnvStillHasServices = errors.New("tenant env still has services")

+ func CheckTenantEnvResource(ctx context.Context, tenantEnv *dbmodel.TenantEnvs, needMemory int) error

+ func GetDbgateProxy(serviceID string) proxy.Proxy

+ func GetFileBrowserProxy(serviceID string) proxy.Proxy

+ func GetObsProxy() proxy.Proxy

type AppAction

+ func (a *AppAction) SetExportAppInfoParameter(appName, appVersion string, end bool)

type ApplicationAction

+ func (s *ApplicationAction) GetKubeResources(namespace string, servieAliases []string, ...) (string, error)

type ApplicationHandler

+ GetKubeResources func(namespace string, serviceAliases []string, ...) (string, error)

type ClusterHandler

+ GetClusterEvents func(ctx context.Context) ([]model.ClusterEvent, error)

type GatewayAction

+ func (g *GatewayAction) TCPRuleConfig(req *apimodel.TCPRuleConfigReq) error

type GatewayHandler

+ TCPRuleConfig func(req *apimodel.TCPRuleConfigReq) error

type Info

+ TenantEnv int64

type MonitorHandler

+ GetTenantEnvMonitorMetrics func(tenantEnvID string) []prometheus.Metadata

+ type NodeStorageMetric struct

+ CapacityStorage int64

+ NodeName string

+ UsedStorage int64

+ type NodeStorageMetricsResponse struct

+ Data NodeStorageMetricsResponseData

+ Status string

+ type NodeStorageMetricsResponseData struct

+ Result []NodeStorageMetricsResponseDataResult

+ type NodeStorageMetricsResponseDataResult struct

+ Metric NodeStorageMetricsResponseDataResultMetric

+ Value []interface{}

+ type NodeStorageMetricsResponseDataResultMetric struct

+ Instance string

+ Mountpoint string

+ type RegistryAuthSecretAction struct

+ func CreateRegistryAuthSecretManager(dbmanager db.Manager, mqclient client.MQClient, etcdCli *clientv3.Client) *RegistryAuthSecretAction

+ func (g *RegistryAuthSecretAction) AddOrUpdateRegistryAuthSecret(req *apimodel.AddOrUpdateRegistryAuthSecretStruct) error

+ func (g *RegistryAuthSecretAction) DeleteRegistryAuthSecret(req *apimodel.DeleteRegistryAuthSecretStruct) error

+ type RegistryAuthSecretHandler interface

+ AddOrUpdateRegistryAuthSecret func(req *apimodel.AddOrUpdateRegistryAuthSecretStruct) error

+ DeleteRegistryAuthSecret func(req *apimodel.DeleteRegistryAuthSecretStruct) error

+ func GetRegistryAuthSecretHandler() RegistryAuthSecretHandler

type ServiceAction

+ func (s *ServiceAction) CreateTenantEnv(t *dbmodel.TenantEnvs) error

+ func (s *ServiceAction) CreateTenantEnvIDAndName() (string, string, error)

+ func (s *ServiceAction) GetAllRunningServices() ([]string, *util.APIHandleError)

+ func (s *ServiceAction) GetAllServicesStatus() (*ServicesStatus, *util.APIHandleError)

+ func (s *ServiceAction) GetKubeResources(namespace, serviceID string, customSetting api_model.KubeResourceCustomSetting) (string, error)

+ func (s *ServiceAction) GetPagedTenantEnvRes(offset, len int) ([]*api_model.TenantEnvResource, int, error)

+ func (s *ServiceAction) GetPodContainerCPU(podNames []string) (map[string]map[string]string, error)

+ func (s *ServiceAction) GetTenantEnvRes(uuid string) (*api_model.TenantEnvResource, error)

+ func (s *ServiceAction) GetTenantEnvServicePluginRelation(serviceID string) ([]*dbmodel.TenantEnvServicePluginRelation, *util.APIHandleError)

+ func (s *ServiceAction) SetTenantEnvServicePluginRelation(tenantEnvID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantEnvServicePluginRelation, *util.APIHandleError)

+ func (s *ServiceAction) TenantEnvServiceDeletePluginRelation(tenantEnvID, serviceID, pluginID string) *util.APIHandleError

+ func (s *ServiceAction) UpdateTenantEnvServicePluginRelation(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantEnvServicePluginRelation, *util.APIHandleError)

type ServiceHandler

+ CreateTenantEnv func(*dbmodel.TenantEnvs) error

+ CreateTenantEnvIDAndName func() (string, string, error)

+ GetAllRunningServices func() ([]string, *util.APIHandleError)

+ GetAllServicesStatus func() (*ServicesStatus, *util.APIHandleError)

+ GetKubeResources func(namespace, serviceID string, customSetting api_model.KubeResourceCustomSetting) (string, error)

+ GetPagedTenantEnvRes func(offset, len int) ([]*api_model.TenantEnvResource, int, error)

+ GetTenantEnvRes func(uuid string) (*api_model.TenantEnvResource, error)

+ GetTenantEnvServicePluginRelation func(serviceID string) ([]*dbmodel.TenantEnvServicePluginRelation, *util.APIHandleError)

+ SetTenantEnvServicePluginRelation func(tenantEnvID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantEnvServicePluginRelation, *util.APIHandleError)

+ TenantEnvServiceDeletePluginRelation func(tenantEnvID, serviceID, pluginID string) *util.APIHandleError

+ UpdateTenantEnvServicePluginRelation func(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantEnvServicePluginRelation, *util.APIHandleError)

+ type ServicesStatus struct

+ AbnormalServices []string

+ RunningServices []string

+ UnRunningServices []string

+ type TenantEnvAction struct

+ MQClient mqclient.MQClient

+ OptCfg *option.Config

+ func CreateTenantEnvManager(mqc mqclient.MQClient, statusCli *client.AppRuntimeSyncClient, ...) *TenantEnvAction

+ func (s *TenantEnvAction) GetKubeResources(namespace, tenantEnvID string, customSetting model.KubeResourceCustomSetting) (string, error)

+ func (t *TenantEnvAction) BindTenantEnvsResource(source []*dbmodel.TenantEnvs) api_model.TenantEnvList

+ func (t *TenantEnvAction) CheckResourceName(ctx context.Context, namespace string, req *model.CheckResourceNameReq) (*model.CheckResourceNameResp, error)

+ func (t *TenantEnvAction) DeleteTenantEnv(ctx context.Context, tenantEnvID string) error

+ func (t *TenantEnvAction) GetAllTenantEnvs(query string) ([]*dbmodel.TenantEnvs, error)

+ func (t *TenantEnvAction) GetAllocatableResources(ctx context.Context) (*ClusterResourceStats, error)

+ func (t *TenantEnvAction) GetClusterResource(ctx context.Context) *ClusterResourceStats

+ func (t *TenantEnvAction) GetKubeConfig(namespace string) (string, error)

+ func (t *TenantEnvAction) GetProtocols() ([]*dbmodel.RegionProcotols, *util.APIHandleError)

+ func (t *TenantEnvAction) GetServicesResources(tr *api_model.ServicesResources) (re map[string]map[string]interface{}, err error)

+ func (t *TenantEnvAction) GetServicesStatus(ids string) map[string]string

+ func (t *TenantEnvAction) GetTenantEnvResource(tenantEnvID string) (ts TenantEnvResourceStats, err error)

+ func (t *TenantEnvAction) GetTenantEnvs(tenantName, query string) ([]*dbmodel.TenantEnvs, error)

+ func (t *TenantEnvAction) GetTenantEnvsByName(tenantName, tenantEnvName string) (*dbmodel.TenantEnvs, error)

+ func (t *TenantEnvAction) GetTenantEnvsByUUID(uuid string) (*dbmodel.TenantEnvs, error)

+ func (t *TenantEnvAction) GetTenantEnvsName(tenantName string) ([]string, error)

+ func (t *TenantEnvAction) GetTenantEnvsResources(ctx context.Context, tr *api_model.TenantEnvResources) (map[string]map[string]interface{}, error)

+ func (t *TenantEnvAction) IsClosedStatus(status string) bool

+ func (t *TenantEnvAction) StatsMemCPU(services []*dbmodel.TenantEnvServices) (*api_model.StatsInfo, error)

+ func (t *TenantEnvAction) TenantEnvsSum(tenantName string) (int, error)

+ func (t *TenantEnvAction) TotalMemCPU(services []*dbmodel.TenantEnvServices) (*api_model.StatsInfo, error)

+ func (t *TenantEnvAction) TransPlugins(tenantEnvID, tenantEnvName, fromTenantEnv string, pluginList []string) *util.APIHandleError

+ func (t *TenantEnvAction) UpdateTenantEnv(tenantEnv *dbmodel.TenantEnvs) error

+ type TenantEnvHandler interface

+ BindTenantEnvsResource func(source []*dbmodel.TenantEnvs) api_model.TenantEnvList

+ CheckResourceName func(ctx context.Context, namespace string, req *api_model.CheckResourceNameReq) (*api_model.CheckResourceNameResp, error)

+ DeleteTenantEnv func(ctx context.Context, tenantEnvID string) error

+ GetAllTenantEnvs func(query string) ([]*dbmodel.TenantEnvs, error)

+ GetAllocatableResources func(ctx context.Context) (*ClusterResourceStats, error)

+ GetClusterResource func(ctx context.Context) *ClusterResourceStats

+ GetKubeConfig func(namespace string) (string, error)

+ GetKubeResources func(namespace, tenantEnvID string, ...) (string, error)

+ GetProtocols func() ([]*dbmodel.RegionProcotols, *util.APIHandleError)

+ GetServicesResources func(tr *api_model.ServicesResources) (map[string]map[string]interface{}, error)

+ GetServicesStatus func(ids string) map[string]string

+ GetTenantEnvResource func(tenantEnvID string) (TenantEnvResourceStats, error)

+ GetTenantEnvs func(tenantName, query string) ([]*dbmodel.TenantEnvs, error)

+ GetTenantEnvsByName func(tenantName, tenantEnvName string) (*dbmodel.TenantEnvs, error)

+ GetTenantEnvsByUUID func(uuid string) (*dbmodel.TenantEnvs, error)

+ GetTenantEnvsName func(tenantName string) ([]string, error)

+ GetTenantEnvsResources func(ctx context.Context, tr *api_model.TenantEnvResources) (map[string]map[string]interface{}, error)

+ IsClosedStatus func(status string) bool

+ StatsMemCPU func(services []*dbmodel.TenantEnvServices) (*api_model.StatsInfo, error)

+ TenantEnvsSum func(tenantName string) (int, error)

+ TotalMemCPU func(services []*dbmodel.TenantEnvServices) (*api_model.StatsInfo, error)

+ TransPlugins func(tenantEnvID, tenantEnvName, fromTenantEnv string, pluginList []string) *util.APIHandleError

+ UpdateTenantEnv func(*dbmodel.TenantEnvs) error

+ func GetTenantEnvManager() TenantEnvHandler

+ type TenantEnvResourceStats struct

+ CPULimit int64

+ CPURequest int64

+ MemoryLimit int64

+ MemoryRequest int64

+ RunningAppNum int64

+ TenantEnvID string

+ UnscdCPULimit int64

+ UnscdCPUReq int64

+ UnscdMemoryLimit int64

+ UnscdMemoryReq int64

v1.0.1

Mar 23, 2022

v1.0.0

Mar 22, 2022

Changes in this version

+ var ErrServiceNotClosed = errors.New("Service has not been closed")

+ var ErrTenantStillHasPlugins = errors.New("tenant still has plugins")

+ var ErrTenantStillHasServices = errors.New("tenant still has services")

+ func BasePack(text []byte) (string, error)

+ func CheckTenantResource(ctx context.Context, tenant *dbmodel.Tenants, needMemory int) error

+ func ClusterAllocMemory(ctx context.Context) (int64, error)

+ func CreateDefaultTokenMap(conf option.Config)

+ func CreateLicenseManger() error

+ func CreateLicensesInfoManager() error

+ func CreateRootFuncHandler(conf option.Config) error

+ func CreateTokenIdenHandler(conf option.Config) error

+ func GetAPPBackupHandler() *group.BackupHandle

+ func GetBuilderProxy() proxy.Proxy

+ func GetDefaultSourceURI() map[string][]*dbmodel.RegionAPIClass

+ func GetDefaultTokenMap() map[string]*dbmodel.RegionUserInfo

+ func GetKubernetesDashboardProxy() proxy.Proxy

+ func GetMonitorProxy() proxy.Proxy

+ func GetNodeProxy() proxy.Proxy

+ func GetPluginShareHandle() *share.PluginShareHandle

+ func GetPrometheusProxy() proxy.Proxy

+ func GetServicesDiskDeprecated(ids []string, prometheusCli prometheus.Interface) map[string]float64

+ func GetShareHandle() *share.ServiceShareHandle

+ func InitHandle(conf option.Config, etcdClientArgs *etcdutil.ClientArgs, ...) error

+ func InitProxy(conf option.Config)

+ func ListLicense() (map[string]*api_model.LicenseInfo, error)

+ func SetTokenCache(info *dbmodel.RegionUserInfo)

+ func TransStatus(eStatus string) string

+ type AllocMemory struct

+ func NewAllocMemory(ctx context.Context, statusCli *client.AppRuntimeSyncClient, ...) (*AllocMemory, error)

+ func (a *AllocMemory) BadOpRequests() model.BatchOpRequesters

+ func (a *AllocMemory) BatchOpRequests() model.BatchOpRequesters

+ func (a *AllocMemory) BatchOpResult() model.BatchOpResult

+ type AppAction struct

+ MQClient client.MQClient

+ func CreateAppManager(mqClient client.MQClient) *AppAction

+ func GetAppHandler() *AppAction

+ func (a *AppAction) Complete(tr *model.ExportAppStruct) error

+ func (a *AppAction) ExportApp(tr *model.ExportAppStruct) error

+ func (a *AppAction) GetStaticDir() string

+ func (a *AppAction) ImportApp(importApp *model.ImportAppStruct) error

+ type AppRestoreAction struct

+ func (a *AppRestoreAction) RestoreDepVols(tenantID, serviceID string, req *apimodel.RestoreDepVolsReq) error

+ func (a *AppRestoreAction) RestoreDeps(tenantID, serviceID string, req *apimodel.RestoreDepsReq) error

+ func (a *AppRestoreAction) RestoreEnvs(tenantID, serviceID string, req *apimodel.RestoreEnvsReq) error

+ func (a *AppRestoreAction) RestorePlugins(tenantID, serviceID string, req *apimodel.RestorePluginsReq) error

+ func (a *AppRestoreAction) RestorePorts(tenantID, serviceID string, req *apimodel.RestorePortsReq) error

+ func (a *AppRestoreAction) RestoreProbe(serviceID string, req *apimodel.ServiceProbe) error

+ func (a *AppRestoreAction) RestoreVolumes(tenantID, serviceID string, req *apimodel.RestoreVolumesReq) error

+ type AppRestoreHandler interface

+ RestoreDepVols func(tenantID, serviceID string, req *apimodel.RestoreDepVolsReq) error

+ RestoreDeps func(tenantID, serviceID string, req *apimodel.RestoreDepsReq) error

+ RestoreEnvs func(tenantID, serviceID string, req *apimodel.RestoreEnvsReq) error

+ RestorePlugins func(tenantID, serviceID string, req *apimodel.RestorePluginsReq) error

+ RestorePorts func(tenantID, serviceID string, req *apimodel.RestorePortsReq) error

+ RestoreProbe func(serviceID string, req *apimodel.ServiceProbe) error

+ RestoreVolumes func(tenantID, serviceID string, req *apimodel.RestoreVolumesReq) error

+ func GetAppRestoreHandler() AppRestoreHandler

+ func NewAppRestoreHandler() AppRestoreHandler

+ type ApplicationAction struct

+ func (a *ApplicationAction) AddConfigGroup(appID string, req *model.ApplicationConfigGroup) (*model.ApplicationConfigGroupResp, error)

+ func (a *ApplicationAction) BatchBindService(appID string, req model.BindServiceRequest) error

+ func (a *ApplicationAction) BatchCreateApp(ctx context.Context, apps *model.CreateAppRequest, tenantID string) ([]model.CreateAppResponse, error)

+ func (a *ApplicationAction) BatchUpdateComponentPorts(appID string, ports []*model.AppPort) error

+ func (a *ApplicationAction) ChangeVolumes(app *dbmodel.Application) error

+ func (a *ApplicationAction) CheckGovernanceMode(ctx context.Context, governanceMode string) error

+ func (a *ApplicationAction) CreateApp(ctx context.Context, req *model.Application) (*model.Application, error)

+ func (a *ApplicationAction) DeleteApp(ctx context.Context, app *dbmodel.Application) error

+ func (a *ApplicationAction) DeleteConfigGroup(appID, configGroupName string) error

+ func (a *ApplicationAction) GetAppByID(appID string) (*dbmodel.Application, error)

+ func (a *ApplicationAction) GetStatus(ctx context.Context, app *dbmodel.Application) (*model.AppStatus, error)

+ func (a *ApplicationAction) Install(ctx context.Context, app *dbmodel.Application, overrides []string) error

+ func (a *ApplicationAction) ListAppStatuses(ctx context.Context, appIDs []string) ([]*model.AppStatus, error)

+ func (a *ApplicationAction) ListApps(tenantID, appName string, page, pageSize int) (*model.ListAppResponse, error)

+ func (a *ApplicationAction) ListConfigGroups(appID string, page, pageSize int) (*model.ListApplicationConfigGroupResp, error)

+ func (a *ApplicationAction) ListHelmAppReleases(ctx context.Context, app *dbmodel.Application) ([]*model.HelmAppRelease, error)

+ func (a *ApplicationAction) ListServices(ctx context.Context, app *dbmodel.Application) ([]*model.AppService, error)

+ func (a *ApplicationAction) SyncAppConfigGroups(app *dbmodel.Application, appConfigGroups []model.AppConfigGroup) error

+ func (a *ApplicationAction) SyncComponentConfigGroupRels(tx *gorm.DB, app *dbmodel.Application, components []*model.Component) error

+ func (a *ApplicationAction) SyncComponents(app *dbmodel.Application, components []*model.Component, ...) error

+ func (a *ApplicationAction) UpdateApp(ctx context.Context, app *dbmodel.Application, req model.UpdateAppRequest) (*dbmodel.Application, error)

+ func (a *ApplicationAction) UpdateConfigGroup(appID, configGroupName string, req *model.UpdateAppConfigGroupReq) (*model.ApplicationConfigGroupResp, error)

+ type ApplicationHandler interface

+ AddConfigGroup func(appID string, req *model.ApplicationConfigGroup) (*model.ApplicationConfigGroupResp, error)

+ BatchBindService func(appID string, req model.BindServiceRequest) error

+ BatchCreateApp func(ctx context.Context, req *model.CreateAppRequest, tenantID string) ([]model.CreateAppResponse, error)

+ BatchUpdateComponentPorts func(appID string, ports []*model.AppPort) error

+ ChangeVolumes func(app *dbmodel.Application) error

+ CheckGovernanceMode func(ctx context.Context, governanceMode string) error

+ CreateApp func(ctx context.Context, req *model.Application) (*model.Application, error)

+ DeleteApp func(ctx context.Context, app *dbmodel.Application) error

+ DeleteConfigGroup func(appID, configGroupName string) error

+ GetAppByID func(appID string) (*dbmodel.Application, error)

+ GetStatus func(ctx context.Context, app *dbmodel.Application) (*model.AppStatus, error)

+ Install func(ctx context.Context, app *dbmodel.Application, overrides []string) error

+ ListAppStatuses func(ctx context.Context, appIDs []string) ([]*model.AppStatus, error)

+ ListApps func(tenantID, appName string, page, pageSize int) (*model.ListAppResponse, error)

+ ListConfigGroups func(appID string, page, pageSize int) (*model.ListApplicationConfigGroupResp, error)

+ ListHelmAppReleases func(ctx context.Context, app *dbmodel.Application) ([]*model.HelmAppRelease, error)

+ ListServices func(ctx context.Context, app *dbmodel.Application) ([]*model.AppService, error)

+ SyncAppConfigGroups func(app *dbmodel.Application, appConfigGroups []model.AppConfigGroup) error

+ SyncComponentConfigGroupRels func(tx *gorm.DB, app *dbmodel.Application, components []*model.Component) error

+ SyncComponents func(app *dbmodel.Application, components []*model.Component, ...) error

+ UpdateApp func(ctx context.Context, app *dbmodel.Application, req model.UpdateAppRequest) (*dbmodel.Application, error)

+ UpdateConfigGroup func(appID, configGroupName string, req *model.UpdateAppConfigGroupReq) (*model.ApplicationConfigGroupResp, error)

+ func GetApplicationHandler() ApplicationHandler

+ func NewApplicationHandler(statusCli *client.AppRuntimeSyncClient, promClient prometheus.Interface, ...) ApplicationHandler

+ type BatchOperationHandler struct

+ func CreateBatchOperationHandler(mqCli gclient.MQClient, statusCli *client.AppRuntimeSyncClient, ...) *BatchOperationHandler

+ func GetBatchOperationHandler() *BatchOperationHandler

+ func (b *BatchOperationHandler) Build(ctx context.Context, tenant *dbmodel.Tenants, operator string, ...) (model.BatchOpResult, error)

+ func (b *BatchOperationHandler) Start(ctx context.Context, tenant *dbmodel.Tenants, operator string, ...) (model.BatchOpResult, error)

+ func (b *BatchOperationHandler) Stop(ctx context.Context, tenant *dbmodel.Tenants, operator string, ...) (model.BatchOpResult, error)

+ func (b *BatchOperationHandler) Upgrade(ctx context.Context, tenant *dbmodel.Tenants, operator string, ...) (model.BatchOpResult, error)

+ type BatchOperationResult struct

+ BatchResult []OperationResult

+ type CloudAction struct

+ APISSL bool

+ CAPath string

+ KeyPath string

+ RegionTag string

+ func CreateCloudManager(conf option.Config) *CloudAction

+ func (c *CloudAction) CertDispatcher(gt *api_model.GetUserToken) ([]byte, []byte, error)

+ func (c *CloudAction) GetTokenInfo(eid string) (*dbmodel.RegionUserInfo, *util.APIHandleError)

+ func (c *CloudAction) TokenDispatcher(gt *api_model.GetUserToken) (*api_model.TokenInfo, *util.APIHandleError)

+ func (c *CloudAction) UpdateTokenTime(eid string, vd int) *util.APIHandleError

+ type CloudHandler interface

+ GetTokenInfo func(eid string) (*dbmodel.RegionUserInfo, *util.APIHandleError)

+ TokenDispatcher func(gt *api_model.GetUserToken) (*api_model.TokenInfo, *util.APIHandleError)

+ UpdateTokenTime func(eid string, vd int) *util.APIHandleError

+ func GetCloudManager() CloudHandler

+ type ClusterHandler interface

+ GetClusterInfo func(ctx context.Context) (*model.ClusterResource, error)

+ MavenSettingAdd func(ctx context.Context, ms *MavenSetting) *util.APIHandleError

+ MavenSettingDelete func(ctx context.Context, name string) *util.APIHandleError

+ MavenSettingDetail func(ctx context.Context, name string) (*MavenSetting, *util.APIHandleError)

+ MavenSettingList func(ctx context.Context) (re []MavenSetting)

+ MavenSettingUpdate func(ctx context.Context, ms *MavenSetting) *util.APIHandleError

+ func GetClusterHandler() ClusterHandler

+ func NewClusterHandler(clientset *kubernetes.Clientset, WtNamespace string) ClusterHandler

+ type ClusterResourceStats struct

+ AllCPU int64

+ AllMemory int64

+ RequestCPU int64

+ RequestMemory int64

+ type ComponentIngressTask struct

+ Action string

+ ComponentID string

+ IsInner bool

+ Port int

+ type EtcdHandler struct

+ func GetEtcdHandler() *EtcdHandler

+ func NewEtcdHandler(etcdCli *clientv3.Client) *EtcdHandler

+ func (h *EtcdHandler) CleanAllServiceData(keys []string)

+ func (h *EtcdHandler) CleanServiceCheckData(key string)

+ type EtcdKeyType int

+ const BackupRestoreEtcdKey

+ const ServiceCheckEtcdKey

+ const ShareResultEtcdKey

+ type EventHandler interface

+ GetEvents func(target, targetID string, page, size int) ([]*dbmodel.ServiceEvent, int, error)

+ GetLevelLog func(eventID string, level string) (*api_model.DataLog, error)

+ GetLogFile func(serviceAlias, fileName string) (string, string, error)

+ GetLogInstance func(serviceID string) (string, error)

+ GetLogList func(serviceAlias string) ([]*model.HistoryLogFile, error)

+ func GetEventHandler() EventHandler

+ type GatewayAction struct

+ func CreateGatewayManager(dbmanager db.Manager, mqclient client.MQClient, etcdCli *clientv3.Client) *GatewayAction

+ func (g *GatewayAction) AddCertificate(req *apimodel.AddHTTPRuleStruct, tx *gorm.DB) error

+ func (g *GatewayAction) AddHTTPRule(req *apimodel.AddHTTPRuleStruct) error

+ func (g *GatewayAction) AddRuleExtensions(ruleID string, ruleExtensions []*apimodel.RuleExtensionStruct, tx *gorm.DB) error

+ func (g *GatewayAction) AddTCPRule(req *apimodel.AddTCPRuleStruct) error

+ func (g *GatewayAction) CreateHTTPRule(tx *gorm.DB, req *apimodel.AddHTTPRuleStruct) error

+ func (g *GatewayAction) CreateTCPRule(tx *gorm.DB, req *apimodel.AddTCPRuleStruct) error

+ func (g *GatewayAction) DeleteHTTPRule(req *apimodel.DeleteHTTPRuleStruct) error

+ func (g *GatewayAction) DeleteHTTPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error

+ func (g *GatewayAction) DeleteIngressRulesByComponentPort(tx *gorm.DB, componentID string, port int) error

+ func (g *GatewayAction) DeleteTCPRule(req *apimodel.DeleteTCPRuleStruct) error

+ func (g *GatewayAction) DeleteTCPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error

+ func (g *GatewayAction) GetAvailablePort(ip string, lock bool) (int, error)

+ func (g *GatewayAction) GetGatewayIPs() []IPAndAvailablePort

+ func (g *GatewayAction) ListHTTPRulesByCertID(certID string) ([]*model.HTTPRule, error)

+ func (g *GatewayAction) RuleConfig(req *apimodel.RuleConfigReq) error

+ func (g *GatewayAction) SendTask(task *ComponentIngressTask) error

+ func (g *GatewayAction) SendTaskDeprecated(in map[string]interface{}) error

+ func (g *GatewayAction) SyncHTTPRules(tx *gorm.DB, components []*apimodel.Component) error

+ func (g *GatewayAction) SyncRuleConfigs(tx *gorm.DB, components []*apimodel.Component) error

+ func (g *GatewayAction) SyncTCPRules(tx *gorm.DB, components []*apimodel.Component) error

+ func (g *GatewayAction) TCPIPPortExists(host string, port int) bool

+ func (g *GatewayAction) UpdCertificate(req *apimodel.UpdCertificateReq) error

+ func (g *GatewayAction) UpdateCertificate(req apimodel.AddHTTPRuleStruct, httpRule *model.HTTPRule, tx *gorm.DB) error

+ func (g *GatewayAction) UpdateHTTPRule(req *apimodel.UpdateHTTPRuleStruct) error

+ func (g *GatewayAction) UpdateTCPRule(req *apimodel.UpdateTCPRuleStruct, minPort int) error

+ type GatewayHandler interface

+ AddCertificate func(req *apimodel.AddHTTPRuleStruct, tx *gorm.DB) error

+ AddHTTPRule func(req *apimodel.AddHTTPRuleStruct) error

+ AddRuleExtensions func(ruleID string, ruleExtensions []*apimodel.RuleExtensionStruct, tx *gorm.DB) error

+ AddTCPRule func(req *apimodel.AddTCPRuleStruct) error

+ CreateHTTPRule func(tx *gorm.DB, req *apimodel.AddHTTPRuleStruct) error

+ CreateTCPRule func(tx *gorm.DB, req *apimodel.AddTCPRuleStruct) error

+ DeleteHTTPRule func(req *apimodel.DeleteHTTPRuleStruct) error

+ DeleteHTTPRuleByServiceIDWithTransaction func(sid string, tx *gorm.DB) error

+ DeleteIngressRulesByComponentPort func(tx *gorm.DB, componentID string, port int) error

+ DeleteTCPRule func(req *apimodel.DeleteTCPRuleStruct) error

+ DeleteTCPRuleByServiceIDWithTransaction func(sid string, tx *gorm.DB) error

+ GetAvailablePort func(ip string, lock bool) (int, error)

+ GetGatewayIPs func() []IPAndAvailablePort

+ ListHTTPRulesByCertID func(certID string) ([]*dbmodel.HTTPRule, error)

+ RuleConfig func(req *apimodel.RuleConfigReq) error

+ SendTask func(task *ComponentIngressTask) error

+ SendTaskDeprecated func(in map[string]interface{}) error

+ SyncHTTPRules func(tx *gorm.DB, components []*apimodel.Component) error

+ SyncRuleConfigs func(tx *gorm.DB, components []*apimodel.Component) error

+ SyncTCPRules func(tx *gorm.DB, components []*apimodel.Component) error

+ TCPIPPortExists func(ip string, port int) bool

+ UpdCertificate func(req *apimodel.UpdCertificateReq) error

+ UpdateCertificate func(req apimodel.AddHTTPRuleStruct, httpRule *dbmodel.HTTPRule, tx *gorm.DB) error

+ UpdateHTTPRule func(req *apimodel.UpdateHTTPRuleStruct) error

+ UpdateTCPRule func(req *apimodel.UpdateTCPRuleStruct, minPort int) error

+ func GetGatewayHandler() GatewayHandler

+ type IPAndAvailablePort struct

+ AvailablePort int

+ IP string

+ type Info struct

+ CPU int64

+ Code string

+ Company string

+ DataCenter int64

+ EndTime string

+ Memory int64

+ ModuleList []string

+ Node int64

+ StartTime string

+ Tenant int64

+ func ReadLicenseFromFile(licenseFile string) (Info, error)

+ type K8sPodInfo struct

+ Container map[string]map[string]string

+ PodIP string

+ PodName string

+ PodStatus string

+ ServiceID string

+ type K8sPodInfos struct

+ NewPods []*K8sPodInfo

+ OldPods []*K8sPodInfo

+ type LangInfo struct

+ Lang string

+ Major []*MajorInfo

+ type LicenseAction struct

+ func (l *LicenseAction) PackLicense(encrypted string) ([]byte, error)

+ func (l *LicenseAction) StoreLicense(license, token string) error

+ type LicenseHandler interface

+ PackLicense func(encrypted string) ([]byte, error)

+ StoreLicense func(license, token string) error

+ func GetLicenseHandler() LicenseHandler

+ type LicenseInfoHandler interface

+ ShowInfos func() (map[string]*api_model.LicenseInfo, error)

+ func GetLicensesInfosHandler() LicenseInfoHandler

+ type LicensesInfos struct

+ Infos map[string]*api_model.LicenseInfo

+ func (l *LicensesInfos) ShowInfos() (map[string]*api_model.LicenseInfo, error)

+ type LogAction struct

+ EtcdCli *clientv3.Client

+ func CreateLogManager(cli *clientv3.Client) *LogAction

+ func (l *LogAction) GetEvents(target, targetID string, page, size int) ([]*dbmodel.ServiceEvent, int, error)

+ func (l *LogAction) GetLevelLog(eventID string, level string) (*api_model.DataLog, error)

+ func (l *LogAction) GetLogFile(serviceAlias, fileName string) (string, string, error)

+ func (l *LogAction) GetLogInstance(serviceID string) (string, error)

+ func (l *LogAction) GetLogList(serviceAlias string) ([]*model.HistoryLogFile, error)

+ type MajorInfo struct

+ Major int

+ Minor []*MinorInfo

+ type MavenSetting struct

+ Content string

+ CreateTime string

+ IsDefault bool

+ Name string

+ UpdateTime string

+ type MinorInfo struct

+ Minor int

+ Patch []int

+ type MonitorHandler interface

+ GetAppMonitorMetrics func(tenantID, appID string) []prometheus.Metadata

+ GetComponentMonitorMetrics func(tenantID, componentID string) []prometheus.Metadata

+ GetTenantMonitorMetrics func(tenantID string) []prometheus.Metadata

+ func GetMonitorHandle() MonitorHandler

+ func NewMonitorHandler(cli prometheus.Interface) MonitorHandler

+ type NetRulesAction struct

+ func CreateNetRulesManager(etcdCli *clientv3.Client) *NetRulesAction

+ func (n *NetRulesAction) CreateDownStreamNetRules(tenantID string, rs *api_model.SetNetDownStreamRuleStruct) *util.APIHandleError

+ func (n *NetRulesAction) GetDownStreamNetRule(tenantID, serviceAlias, destServiceAlias, port string) (*api_model.NetRulesDownStreamBody, *util.APIHandleError)

+ func (n *NetRulesAction) UpdateDownStreamNetRule(tenantID string, urs *api_model.UpdateNetDownStreamRuleStruct) *util.APIHandleError

+ type NetRulesHandler interface

+ CreateDownStreamNetRules func(tenantID string, rs *api_model.SetNetDownStreamRuleStruct) *util.APIHandleError

+ GetDownStreamNetRule func(tenantID, serviceAlias, destServiceAlias, port string) (*api_model.NetRulesDownStreamBody, *util.APIHandleError)

+ UpdateDownStreamNetRule func(tenantID string, urs *api_model.UpdateNetDownStreamRuleStruct) *util.APIHandleError

+ func GetRulesManager() NetRulesHandler

+ type OperationHandler struct

+ func CreateOperationHandler(mqCli gclient.MQClient) *OperationHandler

+ func GetOperationHandler() *OperationHandler

+ func (o *OperationHandler) Build(batchOpReq model.ComponentOpReq) (*model.ComponentOpResult, error)

+ func (o *OperationHandler) RollBack(rollback model.RollbackInfoRequestStruct) (re OperationResult)

+ func (o *OperationHandler) Start(batchOpReq model.ComponentOpReq) error

+ func (o *OperationHandler) Stop(batchOpReq model.ComponentOpReq) error

+ func (o *OperationHandler) Upgrade(batchOpReq model.ComponentOpReq) (*model.ComponentOpResult, error)

+ type OperationResult struct

+ DeployVersion string

+ ErrMsg string

+ EventID string

+ Operation string

+ ServiceID string

+ Status string

+ type PluginAction struct

+ MQClient client.MQClient

+ func CreatePluginManager(mqClient client.MQClient) *PluginAction

+ func (p *PluginAction) AddDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError

+ func (p *PluginAction) BatchBuildPlugins(req *api_model.BatchBuildPlugins, tenantID string) *util.APIHandleError

+ func (p *PluginAction) BatchCreatePlugins(tenantID string, plugins []*api_model.Plugin) *util.APIHandleError

+ func (p *PluginAction) BuildPluginManual(bps *api_model.BuildPluginStruct) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

+ func (p *PluginAction) CreatePluginAct(cps *api_model.CreatePluginStruct) *util.APIHandleError

+ func (p *PluginAction) DeleteDefaultEnv(pluginID, versionID, name string) *util.APIHandleError

+ func (p *PluginAction) DeletePluginAct(pluginID, tenantID string) *util.APIHandleError

+ func (p *PluginAction) DeletePluginBuildVersion(pluginID, versionID string) *util.APIHandleError

+ func (p *PluginAction) GetAllPluginBuildVersions(pluginID string) ([]*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

+ func (p *PluginAction) GetDefaultEnv(pluginID, versionID string) ([]*dbmodel.TenantPluginDefaultENV, *util.APIHandleError)

+ func (p *PluginAction) GetEnvsWhichCanBeSet(serviceID, pluginID string) (interface{}, *util.APIHandleError)

+ func (p *PluginAction) GetPluginBuildVersion(pluginID, versionID string) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

+ func (p *PluginAction) GetPlugins(tenantID string) ([]*dbmodel.TenantPlugin, *util.APIHandleError)

+ func (p *PluginAction) UpdateDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError

+ func (p *PluginAction) UpdatePluginAct(pluginID, tenantID string, cps *api_model.UpdatePluginStruct) *util.APIHandleError

+ type PluginHandler interface

+ AddDefaultEnv func(est *api_model.ENVStruct) *util.APIHandleError

+ BatchBuildPlugins func(req *api_model.BatchBuildPlugins, tenantID string) *util.APIHandleError

+ BatchCreatePlugins func(tenantID string, plugins []*api_model.Plugin) *util.APIHandleError

+ BuildPluginManual func(bps *api_model.BuildPluginStruct) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

+ CreatePluginAct func(cps *api_model.CreatePluginStruct) *util.APIHandleError

+ DeleteDefaultEnv func(pluginID, versionID, envName string) *util.APIHandleError

+ DeletePluginAct func(pluginID, tenantID string) *util.APIHandleError

+ DeletePluginBuildVersion func(pluginID, versionID string) *util.APIHandleError

+ GetAllPluginBuildVersions func(pluginID string) ([]*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

+ GetDefaultEnv func(pluginID, versionID string) ([]*dbmodel.TenantPluginDefaultENV, *util.APIHandleError)

+ GetEnvsWhichCanBeSet func(serviceID, pluginID string) (interface{}, *util.APIHandleError)

+ GetPluginBuildVersion func(pluginID, versionID string) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)

+ GetPlugins func(tenantID string) ([]*dbmodel.TenantPlugin, *util.APIHandleError)

+ UpdateDefaultEnv func(est *api_model.ENVStruct) *util.APIHandleError

+ UpdatePluginAct func(pluginID, tenantID string, cps *api_model.UpdatePluginStruct) *util.APIHandleError

+ func GetPluginManager() PluginHandler

+ type PodAction struct

+ func (p *PodAction) PodDetail(namespace, podName string) (*pb.PodDetail, error)

+ type PodHandler interface

+ PodDetail func(namespace, podName string) (*pb.PodDetail, error)

+ func GetPodHandler() PodHandler

+ func NewPodHandler(statusCli *client.AppRuntimeSyncClient) PodHandler

+ type QueryResult struct

+ Data struct{ ... }

+ Status string

+ type RootAction struct

+ func CreateRootFuncManager(conf option.Config) *RootAction

+ func (r *RootAction) ResolvePHP(cs *api_model.ComposerStruct) (string, error)

+ type RootFuncHandler interface

+ func GetRootFuncHandler() RootFuncHandler

+ type ServiceAction struct

+ EtcdCli *clientv3.Client

+ MQClient gclient.MQClient

+ func CreateManager(conf option.Config, mqClient gclient.MQClient, etcdCli *clientv3.Client, ...) *ServiceAction

+ func (s *ServiceAction) AddAutoscalerRule(req *api_model.AutoscalerRuleReq) error

+ func (s *ServiceAction) AddLabel(l *api_model.LabelsStruct, serviceID string) error

+ func (s *ServiceAction) AddServiceMonitor(tenantID, serviceID string, add api_model.AddServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)

+ func (s *ServiceAction) CodeCheck(c *api_model.CheckCodeStruct) error

+ func (s *ServiceAction) CreatePorts(tenantID, serviceID string, vps *api_model.ServicePorts) error

+ func (s *ServiceAction) CreateTenandIDAndName(eid string) (string, string, error)

+ func (s *ServiceAction) CreateTenant(t *dbmodel.Tenants) error

+ func (s *ServiceAction) DeleteLabel(l *api_model.LabelsStruct, serviceID string) error

+ func (s *ServiceAction) DeletePluginConfig(serviceID, pluginID string) *util.APIHandleError

+ func (s *ServiceAction) DeleteServiceMonitor(tenantID, serviceID, name string) (*dbmodel.TenantServiceMonitor, error)

+ func (s *ServiceAction) EnvAttr(action string, at *dbmodel.TenantServiceEnvVar) error

+ func (s *ServiceAction) GetComponentPodNums(ctx context.Context, componentIDs []string) (map[string]int32, error)

+ func (s *ServiceAction) GetDepVolumes(serviceID string) ([]*dbmodel.TenantServiceMountRelation, *util.APIHandleError)

+ func (s *ServiceAction) GetEnterpriseRunningServices(enterpriseID string) ([]string, *util.APIHandleError)

+ func (s *ServiceAction) GetMultiServicePods(serviceIDs []string) (*K8sPodInfos, error)

+ func (s *ServiceAction) GetPagedTenantRes(offset, len int) ([]*api_model.TenantResource, int, error)

+ func (s *ServiceAction) GetPodContainerMemory(podNames []string) (map[string]map[string]string, error)

+ func (s *ServiceAction) GetPods(serviceID string) (*K8sPodInfos, error)

+ func (s *ServiceAction) GetService(tenantID string) ([]*dbmodel.TenantServices, error)

+ func (s *ServiceAction) GetServiceCheckInfo(uuid string) (*exector.ServiceCheckResult, *util.APIHandleError)

+ func (s *ServiceAction) GetServiceDeployInfo(tenantID, serviceID string) (*pb.DeployInfo, *util.APIHandleError)

+ func (s *ServiceAction) GetServicesByAppID(appID string, page, pageSize int) (*api_model.ListServiceResponse, error)

+ func (s *ServiceAction) GetServicesStatus(tenantID string, serviceIDs []string) []map[string]interface{}

+ func (s *ServiceAction) GetStatus(serviceID string) (*api_model.StatusList, error)

+ func (s *ServiceAction) GetTenantRes(uuid string) (*api_model.TenantResource, error)

+ func (s *ServiceAction) GetTenantServicePluginRelation(serviceID string) ([]*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

+ func (s *ServiceAction) GetVolumes(serviceID string) ([]*api_model.VolumeWithStatusStruct, *util.APIHandleError)

+ func (s *ServiceAction) LanguageSet(langS *api_model.LanguageSet) error

+ func (s *ServiceAction) ListScalingRecords(serviceID string, page, pageSize int) ([]*dbmodel.TenantServiceScalingRecords, int, error)

+ func (s *ServiceAction) ListVersionInfo(serviceID string) (*api_model.BuildListRespVO, error)

+ func (s *ServiceAction) Log(w http.ResponseWriter, r *http.Request, component *dbmodel.TenantServices, ...) error

+ func (s *ServiceAction) PortInner(tenantName, serviceID, operation string, port int) error

+ func (s *ServiceAction) PortOuter(tenantName, serviceID string, containerPort int, ...) (*dbmodel.TenantServiceLBMappingPort, string, error)

+ func (s *ServiceAction) PortVar(action, tenantID, serviceID string, vps *api_model.ServicePorts, oldPort int) error

+ func (s *ServiceAction) RollBack(rs *api_model.RollbackStruct) error

+ func (s *ServiceAction) SavePluginConfig(serviceID, pluginID string, config *api_model.ResourceSpec) *util.APIHandleError

+ func (s *ServiceAction) ServiceBuild(tenantID, serviceID string, r *api_model.BuildServiceStruct) error

+ func (s *ServiceAction) ServiceCheck(scs *api_model.ServiceCheckStruct) (string, string, *util.APIHandleError)

+ func (s *ServiceAction) ServiceCreate(sc *api_model.ServiceStruct) error

+ func (s *ServiceAction) ServiceDepend(action string, ds *api_model.DependService) error

+ func (s *ServiceAction) ServiceHorizontal(hs *model.HorizontalScalingTaskBody) error

+ func (s *ServiceAction) ServiceProbe(tsp *dbmodel.TenantServiceProbe, action string) error

+ func (s *ServiceAction) ServiceUpdate(sc map[string]interface{}) error

+ func (s *ServiceAction) ServiceUpgrade(ru *model.RollingUpgradeTaskBody) error

+ func (s *ServiceAction) ServiceVertical(ctx context.Context, vs *model.VerticalScalingTaskBody) error

+ func (s *ServiceAction) SetTenantServicePluginRelation(tenantID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

+ func (s *ServiceAction) StartStopService(sss *api_model.StartStopStruct) error

+ func (s *ServiceAction) SyncComponentBase(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentConfigFiles(tx *gorm.DB, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentEndpoints(tx *gorm.DB, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentEnvs(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentLabels(tx *gorm.DB, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentMonitors(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentPlugins(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentPorts(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentProbes(tx *gorm.DB, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentRelations(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentScaleRules(tx *gorm.DB, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentVolumeRels(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ func (s *ServiceAction) SyncComponentVolumes(tx *gorm.DB, components []*api_model.Component) error

+ func (s *ServiceAction) TenantServiceDeletePluginRelation(tenantID, serviceID, pluginID string) *util.APIHandleError

+ func (s *ServiceAction) TransServieToDelete(ctx context.Context, tenantID, serviceID string) error

+ func (s *ServiceAction) UpdAutoscalerRule(req *api_model.AutoscalerRuleReq) error

+ func (s *ServiceAction) UpdVolume(sid string, req *api_model.UpdVolumeReq) error

+ func (s *ServiceAction) UpdateLabel(l *api_model.LabelsStruct, serviceID string) error

+ func (s *ServiceAction) UpdateServiceMonitor(tenantID, serviceID, name string, ...) (*dbmodel.TenantServiceMonitor, error)

+ func (s *ServiceAction) UpdateTenantServicePluginRelation(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

+ func (s *ServiceAction) UpdateVersionEnv(uve *api_model.SetVersionEnv) *util.APIHandleError

+ func (s *ServiceAction) VolumeDependency(tsr *dbmodel.TenantServiceMountRelation, action string) *util.APIHandleError

+ func (s *ServiceAction) VolumnVar(tsv *dbmodel.TenantServiceVolume, tenantID, fileContent, action string) *util.APIHandleError

+ type ServiceDependency struct

+ func NewServiceDependency(serviceIDs []string) (*ServiceDependency, error)

+ type ServiceEventHandler struct

+ func GetServiceEventHandler() *ServiceEventHandler

+ func NewServiceEventHandler() *ServiceEventHandler

+ func (s *ServiceEventHandler) ListByEventIDs(eventIDs []string) ([]*dbmodel.ServiceEvent, error)

+ type ServiceHandler interface

+ AddAutoscalerRule func(req *api_model.AutoscalerRuleReq) error

+ AddLabel func(l *api_model.LabelsStruct, serviceID string) error

+ AddServiceMonitor func(tenantID, serviceID string, add api_model.AddServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)

+ CodeCheck func(c *api_model.CheckCodeStruct) error

+ CreatePorts func(tenantID, serviceID string, vps *api_model.ServicePorts) error

+ CreateTenandIDAndName func(eid string) (string, string, error)

+ CreateTenant func(*dbmodel.Tenants) error

+ DeleteLabel func(l *api_model.LabelsStruct, serviceID string) error

+ DeletePluginConfig func(serviceID, pluginID string) *util.APIHandleError

+ DeleteServiceMonitor func(tenantID, serviceID, name string) (*dbmodel.TenantServiceMonitor, error)

+ EnvAttr func(action string, at *dbmodel.TenantServiceEnvVar) error

+ GetComponentPodNums func(ctx context.Context, componentIDs []string) (map[string]int32, error)

+ GetDepVolumes func(serviceID string) ([]*dbmodel.TenantServiceMountRelation, *util.APIHandleError)

+ GetEnterpriseRunningServices func(enterpriseID string) ([]string, *util.APIHandleError)

+ GetMultiServicePods func(serviceIDs []string) (*K8sPodInfos, error)

+ GetPagedTenantRes func(offset, len int) ([]*api_model.TenantResource, int, error)

+ GetPods func(serviceID string) (*K8sPodInfos, error)

+ GetService func(tenantID string) ([]*dbmodel.TenantServices, error)

+ GetServiceCheckInfo func(uuid string) (*exector.ServiceCheckResult, *util.APIHandleError)

+ GetServiceDeployInfo func(tenantID, serviceID string) (*pb.DeployInfo, *util.APIHandleError)

+ GetServicesByAppID func(appID string, page, pageSize int) (*api_model.ListServiceResponse, error)

+ GetServicesStatus func(tenantID string, services []string) []map[string]interface{}

+ GetStatus func(serviceID string) (*api_model.StatusList, error)

+ GetTenantRes func(uuid string) (*api_model.TenantResource, error)

+ GetTenantServicePluginRelation func(serviceID string) ([]*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

+ GetVolumes func(serviceID string) ([]*api_model.VolumeWithStatusStruct, *util.APIHandleError)

+ LanguageSet func(langS *api_model.LanguageSet) error

+ ListScalingRecords func(serviceID string, page, pageSize int) ([]*dbmodel.TenantServiceScalingRecords, int, error)

+ ListVersionInfo func(serviceID string) (*api_model.BuildListRespVO, error)

+ Log func(w http.ResponseWriter, r *http.Request, component *dbmodel.TenantServices, ...) error

+ PortInner func(tenantName, serviceID, operation string, port int) error

+ PortOuter func(tenantName, serviceID string, containerPort int, ...) (*dbmodel.TenantServiceLBMappingPort, string, error)

+ PortVar func(action string, tenantID, serviceID string, vp *api_model.ServicePorts, ...) error

+ RollBack func(rs *api_model.RollbackStruct) error

+ ServiceBuild func(tenantID, serviceID string, r *api_model.BuildServiceStruct) error

+ ServiceCheck func(*api_model.ServiceCheckStruct) (string, string, *util.APIHandleError)

+ ServiceCreate func(ts *api_model.ServiceStruct) error

+ ServiceDepend func(action string, ds *api_model.DependService) error

+ ServiceHorizontal func(h *model.HorizontalScalingTaskBody) error

+ ServiceProbe func(tsp *dbmodel.TenantServiceProbe, action string) error

+ ServiceUpdate func(sc map[string]interface{}) error

+ ServiceUpgrade func(r *model.RollingUpgradeTaskBody) error

+ ServiceVertical func(ctx context.Context, v *model.VerticalScalingTaskBody) error

+ SetTenantServicePluginRelation func(tenantID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

+ StartStopService func(s *api_model.StartStopStruct) error

+ SyncComponentBase func(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ SyncComponentConfigFiles func(tx *gorm.DB, components []*api_model.Component) error

+ SyncComponentEndpoints func(tx *gorm.DB, components []*api_model.Component) error

+ SyncComponentEnvs func(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ SyncComponentLabels func(tx *gorm.DB, components []*api_model.Component) error

+ SyncComponentMonitors func(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ SyncComponentPlugins func(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ SyncComponentPorts func(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ SyncComponentProbes func(tx *gorm.DB, components []*api_model.Component) error

+ SyncComponentRelations func(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ SyncComponentScaleRules func(tx *gorm.DB, components []*api_model.Component) error

+ SyncComponentVolumeRels func(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error

+ SyncComponentVolumes func(tx *gorm.DB, components []*api_model.Component) error

+ TenantServiceDeletePluginRelation func(tenantID, serviceID, pluginID string) *util.APIHandleError

+ TransServieToDelete func(ctx context.Context, tenantID, serviceID string) error

+ UpdAutoscalerRule func(req *api_model.AutoscalerRuleReq) error

+ UpdVolume func(sid string, req *api_model.UpdVolumeReq) error

+ UpdateLabel func(l *api_model.LabelsStruct, serviceID string) error

+ UpdateServiceMonitor func(tenantID, serviceID, name string, ...) (*dbmodel.TenantServiceMonitor, error)

+ UpdateTenantServicePluginRelation func(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)

+ UpdateVersionEnv func(uve *api_model.SetVersionEnv) *util.APIHandleError

+ VolumeDependency func(tsr *dbmodel.TenantServiceMountRelation, action string) *util.APIHandleError

+ VolumnVar func(avs *dbmodel.TenantServiceVolume, tenantID, fileContent, action string) *util.APIHandleError

+ func GetServiceManager() ServiceHandler

+ type TenantAction struct

+ MQClient mqclient.MQClient

+ OptCfg *option.Config

+ func CreateTenManager(mqc mqclient.MQClient, statusCli *client.AppRuntimeSyncClient, ...) *TenantAction

+ func (t *TenantAction) BindTenantsResource(source []*dbmodel.Tenants) api_model.TenantList

+ func (t *TenantAction) CheckResourceName(ctx context.Context, namespace string, req *model.CheckResourceNameReq) (*model.CheckResourceNameResp, error)

+ func (t *TenantAction) DeleteTenant(ctx context.Context, tenantID string) error

+ func (t *TenantAction) GetAllocatableResources(ctx context.Context) (*ClusterResourceStats, error)

+ func (t *TenantAction) GetClusterResource(ctx context.Context) *ClusterResourceStats

+ func (t *TenantAction) GetProtocols() ([]*dbmodel.RegionProcotols, *util.APIHandleError)

+ func (t *TenantAction) GetServicesResources(tr *api_model.ServicesResources) (re map[string]map[string]interface{}, err error)

+ func (t *TenantAction) GetServicesStatus(ids string) map[string]string

+ func (t *TenantAction) GetTenantResource(tenantID string) (ts TenantResourceStats, err error)

+ func (t *TenantAction) GetTenants(query string) ([]*dbmodel.Tenants, error)

+ func (t *TenantAction) GetTenantsByEid(eid, query string) ([]*dbmodel.Tenants, error)

+ func (t *TenantAction) GetTenantsByName(name string) (*dbmodel.Tenants, error)

+ func (t *TenantAction) GetTenantsByUUID(uuid string) (*dbmodel.Tenants, error)

+ func (t *TenantAction) GetTenantsName() ([]string, error)

+ func (t *TenantAction) GetTenantsResources(ctx context.Context, tr *api_model.TenantResources) (map[string]map[string]interface{}, error)

+ func (t *TenantAction) IsClosedStatus(status string) bool

+ func (t *TenantAction) StatsMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)

+ func (t *TenantAction) TenantsSum() (int, error)

+ func (t *TenantAction) TotalMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)

+ func (t *TenantAction) TransPlugins(tenantID, tenantName, fromTenant string, pluginList []string) *util.APIHandleError

+ func (t *TenantAction) UpdateTenant(tenant *dbmodel.Tenants) error

+ type TenantHandler interface

+ BindTenantsResource func(source []*dbmodel.Tenants) api_model.TenantList

+ CheckResourceName func(ctx context.Context, namespace string, req *model.CheckResourceNameReq) (*model.CheckResourceNameResp, error)

+ DeleteTenant func(ctx context.Context, tenantID string) error

+ GetAllocatableResources func(ctx context.Context) (*ClusterResourceStats, error)

+ GetClusterResource func(ctx context.Context) *ClusterResourceStats

+ GetProtocols func() ([]*dbmodel.RegionProcotols, *util.APIHandleError)

+ GetServicesResources func(tr *api_model.ServicesResources) (map[string]map[string]interface{}, error)

+ GetServicesStatus func(ids string) map[string]string

+ GetTenantResource func(tenantID string) (TenantResourceStats, error)

+ GetTenants func(query string) ([]*dbmodel.Tenants, error)

+ GetTenantsByEid func(eid, query string) ([]*dbmodel.Tenants, error)

+ GetTenantsByName func(name string) (*dbmodel.Tenants, error)

+ GetTenantsByUUID func(uuid string) (*dbmodel.Tenants, error)

+ GetTenantsName func() ([]string, error)

+ GetTenantsResources func(ctx context.Context, tr *api_model.TenantResources) (map[string]map[string]interface{}, error)

+ IsClosedStatus func(status string) bool

+ StatsMemCPU func(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)

+ TenantsSum func() (int, error)

+ TotalMemCPU func(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)

+ TransPlugins func(tenantID, tenantName, fromTenant string, pluginList []string) *util.APIHandleError

+ UpdateTenant func(*dbmodel.Tenants) error

+ func GetTenantManager() TenantHandler

+ type TenantResourceStats struct

+ CPULimit int64

+ CPURequest int64

+ MemoryLimit int64

+ MemoryRequest int64

+ RunningAppNum int64

+ TenantID string

+ UnscdCPULimit int64

+ UnscdCPUReq int64

+ UnscdMemoryLimit int64

+ UnscdMemoryReq int64

+ type ThirdPartyServiceHanlder struct

+ func Create3rdPartySvcHandler(dbmanager db.Manager, statusCli *client.AppRuntimeSyncClient) *ThirdPartyServiceHanlder

+ func Get3rdPartySvcHandler() *ThirdPartyServiceHanlder

+ func (t *ThirdPartyServiceHanlder) AddEndpoints(sid string, d *model.AddEndpiontsReq) error

+ func (t *ThirdPartyServiceHanlder) DelEndpoints(epid, sid string) error

+ func (t *ThirdPartyServiceHanlder) ListEndpoints(componentID string) ([]*model.ThirdEndpoint, error)

+ func (t *ThirdPartyServiceHanlder) UpdEndpoints(d *model.UpdEndpiontsReq) error

+ type TokenIdenAction struct

+ func CreateTokenIdenManager(conf option.Config) (*TokenIdenAction, error)

+ func (t *TokenIdenAction) AddAPIManager(am *api_model.APIManager) *util.APIHandleError

+ func (t *TokenIdenAction) AddTokenIntoMap(rui *dbmodel.RegionUserInfo)

+ func (t *TokenIdenAction) CheckToken(token, uri string) bool

+ func (t *TokenIdenAction) DeleteAPIManager(am *api_model.APIManager) *util.APIHandleError

+ func (t *TokenIdenAction) DeleteTokenFromMap(oldtoken string, rui *dbmodel.RegionUserInfo)

+ func (t *TokenIdenAction) GetAPIManager() map[string][]*dbmodel.RegionAPIClass

+ func (t *TokenIdenAction) InitTokenMap() error

+ type TokenMap map[string]*dbmodel.RegionUserInfo

+ type TokenMapHandler interface

+ AddAPIManager func(am *api_model.APIManager) *util.APIHandleError

+ AddTokenIntoMap func(rui *dbmodel.RegionUserInfo)

+ CheckToken func(token, uri string) bool

+ DeleteAPIManager func(am *api_model.APIManager) *util.APIHandleError

+ DeleteTokenFromMap func(oldtoken string, rui *dbmodel.RegionUserInfo)

+ GetAPIManager func() map[string][]*dbmodel.RegionAPIClass

+ InitTokenMap func() error

+ func GetTokenIdenHandler() TokenMapHandler

+ type VersionInfo struct

+ Version []*LangInfo

+ type VolumeTypeAction struct

+ func CreateVolumeTypeManger(statusCli *client.AppRuntimeSyncClient) *VolumeTypeAction

+ func (vta *VolumeTypeAction) DeleteVolumeType(volumeType string) error

+ func (vta *VolumeTypeAction) GetAllStorageClasses() ([]*pb.StorageClassDetail, error)

+ func (vta *VolumeTypeAction) GetAllVolumeTypes() ([]*api_model.VolumeTypeStruct, error)

+ func (vta *VolumeTypeAction) GetAllVolumeTypesByPage(page int, pageSize int) ([]*api_model.VolumeTypeStruct, error)

+ func (vta *VolumeTypeAction) GetVolumeTypeByType(volumtType string) (*dbmodel.TenantServiceVolumeType, error)

+ func (vta *VolumeTypeAction) SetVolumeType(vol *api_model.VolumeTypeStruct) error

+ func (vta *VolumeTypeAction) UpdateVolumeType(dbVolume *dbmodel.TenantServiceVolumeType, vol *api_model.VolumeTypeStruct) error

+ func (vta *VolumeTypeAction) VolumeTypeAction(action, volumeTypeID string) error

+ func (vta *VolumeTypeAction) VolumeTypeVar(action string, vtm *dbmodel.TenantServiceVolumeType) error

+ type VolumeTypeHandler interface

+ DeleteVolumeType func(volumeTypeID string) error

+ GetAllStorageClasses func() ([]*pb.StorageClassDetail, error)

+ GetAllVolumeTypes func() ([]*api_model.VolumeTypeStruct, error)

+ GetAllVolumeTypesByPage func(page int, pageSize int) ([]*api_model.VolumeTypeStruct, error)

+ GetVolumeTypeByType func(volumeType string) (*dbmodel.TenantServiceVolumeType, error)

+ SetVolumeType func(vtm *api_model.VolumeTypeStruct) error

+ UpdateVolumeType func(dbVolume *dbmodel.TenantServiceVolumeType, vol *api_model.VolumeTypeStruct) error

+ VolumeTypeAction func(action, volumeTypeID string) error

+ VolumeTypeVar func(action string, vtm *dbmodel.TenantServiceVolumeType) error

+ func GetVolumeTypeHandler() VolumeTypeHandler

v1.0.0-beta

Mar 3, 2022

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