Documentation ¶
Index ¶
- Variables
- 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
- type AppAction
- type AppRestoreAction
- 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
- type ApplicationAction
- 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) 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
- type 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
- type 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
- type ClusterHandler
- type ClusterResourceStats
- type ComponentIngressTask
- type EtcdHandler
- type EtcdKeyType
- type EventHandler
- type 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
- type IPAndAvailablePort
- type Info
- type K8sPodInfo
- type K8sPodInfos
- type LangInfo
- type LicenseAction
- type LicenseHandler
- type LicenseInfoHandler
- type LicensesInfos
- type 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
- type MavenSetting
- type MinorInfo
- type MonitorHandler
- type 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
- type 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
- type 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
- type PodAction
- type PodHandler
- type QueryResult
- type RootAction
- type RootFuncHandler
- type 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
- type ServiceEventHandler
- type ServiceHandler
- type 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
- type TenantResourceStats
- type 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
- 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
- type TokenMapHandler
- type VersionInfo
- type 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
Constants ¶
This section is empty.
Variables ¶
var ( // ErrTenantStillHasServices - ErrTenantStillHasServices = errors.New("tenant still has services") // ErrTenantStillHasPlugins - ErrTenantStillHasPlugins = errors.New("tenant still has plugins") )
var ErrServiceNotClosed = errors.New("Service has not been closed")
ErrServiceNotClosed -
Functions ¶
func CheckTenantResource ¶
CheckTenantResource check tenant's resource is support action or not
func ClusterAllocMemory ¶
ClusterAllocMemory returns the allocatable memory of the cluster.
func CreateLicenseManger ¶
func CreateLicenseManger() error
CreateLicenseManger create service manager
func CreateLicensesInfoManager ¶
func CreateLicensesInfoManager() error
CreateLicensesInfoManager CreateLicensesInfoManager
func CreateRootFuncHandler ¶
CreateRootFuncHandler create root func handler
func CreateTokenIdenHandler ¶
CreateTokenIdenHandler create token identification handler
func GetAPPBackupHandler ¶
func GetAPPBackupHandler() *group.BackupHandle
GetAPPBackupHandler GetAPPBackupHandler
func GetDefaultSourceURI ¶
func GetDefaultSourceURI() map[string][]*dbmodel.RegionAPIClass
GetDefaultSourceURI
func GetDefaultTokenMap ¶
func GetDefaultTokenMap() map[string]*dbmodel.RegionUserInfo
GetDefaultTokenMap
func GetKubernetesDashboardProxy ¶
GetKubernetesDashboardProxy returns the kubernetes dashboard proxy.
func GetPluginShareHandle ¶
func GetPluginShareHandle() *share.PluginShareHandle
GetPluginShareHandle get plugin share handle
func GetServicesDiskDeprecated ¶
func GetServicesDiskDeprecated(ids []string, prometheusCli prometheus.Interface) map[string]float64
GetServicesDiskDeprecated get service disk
Deprecated
func GetShareHandle ¶
func GetShareHandle() *share.ServiceShareHandle
GetShareHandle get share handle
func InitHandle ¶
func InitHandle(conf option.Config, etcdClientArgs *etcdutil.ClientArgs, statusCli *client.AppRuntimeSyncClient, etcdcli *clientv3.Client, kubeClient *kubernetes.Clientset, katoClient versioned.Interface, k8sClient k8sclient.Client, ) error
InitHandle Initialize the handle
func ListLicense ¶
func ListLicense() (map[string]*api_model.LicenseInfo, error)
ListLicense list license
Types ¶
type AllocMemory ¶
type AllocMemory struct {
// contains filtered or unexported fields
}
AllocMemory represents a allocatable memory.
func NewAllocMemory ¶
func NewAllocMemory(ctx context.Context, statusCli *client.AppRuntimeSyncClient, tenant *dbmodel.Tenants, batchOpReqs model.BatchOpRequesters) (*AllocMemory, error)
NewAllocMemory creates a new AllocMemory.
func (*AllocMemory) BadOpRequests ¶
func (a *AllocMemory) BadOpRequests() model.BatchOpRequesters
BadOpRequests returns the badOpRequests.
func (*AllocMemory) BatchOpRequests ¶
func (a *AllocMemory) BatchOpRequests() model.BatchOpRequesters
BatchOpRequests returns the batchOpRequests.
func (*AllocMemory) BatchOpResult ¶
func (a *AllocMemory) BatchOpResult() model.BatchOpResult
BatchOpResult returns the batchOpResult.
type AppAction ¶
AppAction app action
func CreateAppManager ¶
CreateAppManager create app manager
func (*AppAction) Complete ¶
func (a *AppAction) Complete(tr *model.ExportAppStruct) error
Complete Complete
func (*AppAction) ExportApp ¶
func (a *AppAction) ExportApp(tr *model.ExportAppStruct) error
ExportApp ExportApp
func (*AppAction) GetStaticDir ¶
GetStaticDir get static dir
type AppRestoreAction ¶
type AppRestoreAction struct { }
AppRestoreAction is an implementation of AppRestoreHandler
func (*AppRestoreAction) RestoreDepVols ¶
func (a *AppRestoreAction) RestoreDepVols(tenantID, serviceID string, req *apimodel.RestoreDepVolsReq) error
RestoreDepVols restores service dependent volumes.
func (*AppRestoreAction) RestoreDeps ¶
func (a *AppRestoreAction) RestoreDeps(tenantID, serviceID string, req *apimodel.RestoreDepsReq) error
RestoreDeps restores service dependencies.
func (*AppRestoreAction) RestoreEnvs ¶
func (a *AppRestoreAction) RestoreEnvs(tenantID, serviceID string, req *apimodel.RestoreEnvsReq) error
RestoreEnvs restores environment variables.
func (*AppRestoreAction) RestorePlugins ¶
func (a *AppRestoreAction) RestorePlugins(tenantID, serviceID string, req *apimodel.RestorePluginsReq) error
RestorePlugins restores service plugins.
func (*AppRestoreAction) RestorePorts ¶
func (a *AppRestoreAction) RestorePorts(tenantID, serviceID string, req *apimodel.RestorePortsReq) error
RestorePorts restores service ports.
func (*AppRestoreAction) RestoreProbe ¶
func (a *AppRestoreAction) RestoreProbe(serviceID string, req *apimodel.ServiceProbe) error
RestoreProbe restores service probe.
func (*AppRestoreAction) RestoreVolumes ¶
func (a *AppRestoreAction) RestoreVolumes(tenantID, serviceID string, req *apimodel.RestoreVolumesReq) error
RestoreVolumes restores service volumes.
type AppRestoreHandler ¶
type AppRestoreHandler interface { RestoreEnvs(tenantID, serviceID string, req *apimodel.RestoreEnvsReq) error RestorePorts(tenantID, serviceID string, req *apimodel.RestorePortsReq) error RestoreVolumes(tenantID, serviceID string, req *apimodel.RestoreVolumesReq) error RestoreProbe(serviceID string, req *apimodel.ServiceProbe) error RestoreDeps(tenantID, serviceID string, req *apimodel.RestoreDepsReq) error RestoreDepVols(tenantID, serviceID string, req *apimodel.RestoreDepVolsReq) error RestorePlugins(tenantID, serviceID string, req *apimodel.RestorePluginsReq) error }
AppRestoreHandler defines handler methods to restore app. app means market service.
func GetAppRestoreHandler ¶
func GetAppRestoreHandler() AppRestoreHandler
GetAppRestoreHandler returns a default AppRestoreHandler
func NewAppRestoreHandler ¶
func NewAppRestoreHandler() AppRestoreHandler
NewAppRestoreHandler creates a new AppRestoreHandler.
type ApplicationAction ¶
type ApplicationAction struct {
// contains filtered or unexported fields
}
ApplicationAction -
func (*ApplicationAction) AddConfigGroup ¶
func (a *ApplicationAction) AddConfigGroup(appID string, req *model.ApplicationConfigGroup) (*model.ApplicationConfigGroupResp, error)
AddConfigGroup -
func (*ApplicationAction) BatchBindService ¶
func (a *ApplicationAction) BatchBindService(appID string, req model.BindServiceRequest) error
BatchBindService -
func (*ApplicationAction) BatchCreateApp ¶
func (a *ApplicationAction) BatchCreateApp(ctx context.Context, apps *model.CreateAppRequest, tenantID string) ([]model.CreateAppResponse, error)
BatchCreateApp -
func (*ApplicationAction) BatchUpdateComponentPorts ¶
func (a *ApplicationAction) BatchUpdateComponentPorts(appID string, ports []*model.AppPort) error
BatchUpdateComponentPorts -
func (*ApplicationAction) CreateApp ¶
func (a *ApplicationAction) CreateApp(ctx context.Context, req *model.Application) (*model.Application, error)
CreateApp -
func (*ApplicationAction) DeleteApp ¶
func (a *ApplicationAction) DeleteApp(ctx context.Context, app *dbmodel.Application) error
DeleteApp -
func (*ApplicationAction) DeleteConfigGroup ¶
func (a *ApplicationAction) DeleteConfigGroup(appID, configGroupName string) error
DeleteConfigGroup -
func (*ApplicationAction) GetAppByID ¶
func (a *ApplicationAction) GetAppByID(appID string) (*dbmodel.Application, error)
GetAppByID -
func (*ApplicationAction) GetStatus ¶
func (a *ApplicationAction) GetStatus(ctx context.Context, app *dbmodel.Application) (*model.AppStatus, error)
GetStatus -
func (*ApplicationAction) Install ¶
func (a *ApplicationAction) Install(ctx context.Context, app *dbmodel.Application, overrides []string) error
Install installs the application.
func (*ApplicationAction) ListAppStatuses ¶
func (a *ApplicationAction) ListAppStatuses(ctx context.Context, appIDs []string) ([]*model.AppStatus, error)
ListAppStatuses -
func (*ApplicationAction) ListApps ¶
func (a *ApplicationAction) ListApps(tenantID, appName string, page, pageSize int) (*model.ListAppResponse, error)
ListApps -
func (*ApplicationAction) ListConfigGroups ¶
func (a *ApplicationAction) ListConfigGroups(appID string, page, pageSize int) (*model.ListApplicationConfigGroupResp, error)
ListConfigGroups -
func (*ApplicationAction) ListHelmAppReleases ¶
func (a *ApplicationAction) ListHelmAppReleases(ctx context.Context, app *dbmodel.Application) ([]*model.HelmAppRelease, error)
ListHelmAppReleases returns the list of the helm app.
func (*ApplicationAction) ListServices ¶
func (a *ApplicationAction) ListServices(ctx context.Context, app *dbmodel.Application) ([]*model.AppService, error)
ListServices returns the list of the application.
func (*ApplicationAction) SyncAppConfigGroups ¶
func (a *ApplicationAction) SyncAppConfigGroups(app *dbmodel.Application, appConfigGroups []model.AppConfigGroup) error
SyncAppConfigGroups -
func (*ApplicationAction) SyncComponentConfigGroupRels ¶
func (a *ApplicationAction) SyncComponentConfigGroupRels(tx *gorm.DB, app *dbmodel.Application, components []*model.Component) error
SyncComponentConfigGroupRels -
func (*ApplicationAction) SyncComponents ¶
func (a *ApplicationAction) SyncComponents(app *dbmodel.Application, components []*model.Component, deleteComponentIDs []string) error
SyncComponents -
func (*ApplicationAction) UpdateApp ¶
func (a *ApplicationAction) UpdateApp(ctx context.Context, app *dbmodel.Application, req model.UpdateAppRequest) (*dbmodel.Application, error)
UpdateApp -
func (*ApplicationAction) UpdateConfigGroup ¶
func (a *ApplicationAction) UpdateConfigGroup(appID, configGroupName string, req *model.UpdateAppConfigGroupReq) (*model.ApplicationConfigGroupResp, error)
UpdateConfigGroup -
type ApplicationHandler ¶
type ApplicationHandler interface { CreateApp(ctx context.Context, req *model.Application) (*model.Application, error) BatchCreateApp(ctx context.Context, req *model.CreateAppRequest, tenantID string) ([]model.CreateAppResponse, error) UpdateApp(ctx context.Context, app *dbmodel.Application, req model.UpdateAppRequest) (*dbmodel.Application, error) ListApps(tenantID, appName string, page, pageSize int) (*model.ListAppResponse, error) GetAppByID(appID string) (*dbmodel.Application, error) BatchBindService(appID string, req model.BindServiceRequest) error DeleteApp(ctx context.Context, app *dbmodel.Application) error AddConfigGroup(appID string, req *model.ApplicationConfigGroup) (*model.ApplicationConfigGroupResp, error) UpdateConfigGroup(appID, configGroupName string, req *model.UpdateAppConfigGroupReq) (*model.ApplicationConfigGroupResp, error) BatchUpdateComponentPorts(appID string, ports []*model.AppPort) error GetStatus(ctx context.Context, app *dbmodel.Application) (*model.AppStatus, error) Install(ctx context.Context, app *dbmodel.Application, overrides []string) error ListServices(ctx context.Context, app *dbmodel.Application) ([]*model.AppService, error) ListHelmAppReleases(ctx context.Context, app *dbmodel.Application) ([]*model.HelmAppRelease, error) DeleteConfigGroup(appID, configGroupName string) error ListConfigGroups(appID string, page, pageSize int) (*model.ListApplicationConfigGroupResp, error) SyncComponents(app *dbmodel.Application, components []*model.Component, deleteComponentIDs []string) error SyncComponentConfigGroupRels(tx *gorm.DB, app *dbmodel.Application, components []*model.Component) error SyncAppConfigGroups(app *dbmodel.Application, appConfigGroups []model.AppConfigGroup) error ListAppStatuses(ctx context.Context, appIDs []string) ([]*model.AppStatus, error) }
ApplicationHandler defines handler methods to TenantApplication.
func GetApplicationHandler ¶
func GetApplicationHandler() ApplicationHandler
GetApplicationHandler returns the default tenant application handler.
func NewApplicationHandler ¶
func NewApplicationHandler(statusCli *client.AppRuntimeSyncClient, promClient prometheus.Interface, katoClient versioned.Interface, kubeClient clientset.Interface) ApplicationHandler
NewApplicationHandler creates a new Tenant Application Handler.
type BatchOperationHandler ¶
type BatchOperationHandler struct {
// contains filtered or unexported fields
}
BatchOperationHandler batch operation handler
func CreateBatchOperationHandler ¶
func CreateBatchOperationHandler(mqCli gclient.MQClient, statusCli *client.AppRuntimeSyncClient, operationHandler *OperationHandler) *BatchOperationHandler
CreateBatchOperationHandler create batch operation handler
func GetBatchOperationHandler ¶
func GetBatchOperationHandler() *BatchOperationHandler
GetBatchOperationHandler get handler
func (*BatchOperationHandler) Build ¶
func (b *BatchOperationHandler) Build(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)
Build build
func (*BatchOperationHandler) Start ¶
func (b *BatchOperationHandler) Start(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)
Start batch start
func (*BatchOperationHandler) Stop ¶
func (b *BatchOperationHandler) Stop(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)
Stop batch stop
func (*BatchOperationHandler) Upgrade ¶
func (b *BatchOperationHandler) Upgrade(ctx context.Context, tenant *dbmodel.Tenants, operator string, batchOpReqs model.BatchOpRequesters) (model.BatchOpResult, error)
Upgrade batch upgrade
type BatchOperationResult ¶
type BatchOperationResult struct {
BatchResult []OperationResult `json:"batche_result"`
}
BatchOperationResult batch operation result
type CloudAction ¶
CloudAction cloud action struct
func CreateCloudManager ¶
func CreateCloudManager(conf option.Config) *CloudAction
CreateCloudManager get cloud manager
func (*CloudAction) CertDispatcher ¶
func (c *CloudAction) CertDispatcher(gt *api_model.GetUserToken) ([]byte, []byte, error)
CertDispatcher Cert
func (*CloudAction) GetTokenInfo ¶
func (c *CloudAction) GetTokenInfo(eid string) (*dbmodel.RegionUserInfo, *util.APIHandleError)
GetTokenInfo GetTokenInfo
func (*CloudAction) TokenDispatcher ¶
func (c *CloudAction) TokenDispatcher(gt *api_model.GetUserToken) (*api_model.TokenInfo, *util.APIHandleError)
TokenDispatcher token
func (*CloudAction) UpdateTokenTime ¶
func (c *CloudAction) UpdateTokenTime(eid string, vd int) *util.APIHandleError
UpdateTokenTime UpdateTokenTime
type CloudHandler ¶
type CloudHandler interface { TokenDispatcher(gt *api_model.GetUserToken) (*api_model.TokenInfo, *util.APIHandleError) GetTokenInfo(eid string) (*dbmodel.RegionUserInfo, *util.APIHandleError) UpdateTokenTime(eid string, vd int) *util.APIHandleError }
CloudHandler define source handler
type ClusterHandler ¶
type ClusterHandler interface { GetClusterInfo(ctx context.Context) (*model.ClusterResource, error) MavenSettingAdd(ctx context.Context, ms *MavenSetting) *util.APIHandleError MavenSettingList(ctx context.Context) (re []MavenSetting) MavenSettingUpdate(ctx context.Context, ms *MavenSetting) *util.APIHandleError MavenSettingDelete(ctx context.Context, name string) *util.APIHandleError MavenSettingDetail(ctx context.Context, name string) (*MavenSetting, *util.APIHandleError) }
ClusterHandler -
func GetClusterHandler ¶
func GetClusterHandler() ClusterHandler
GetClusterHandler returns the default cluster handler.
func NewClusterHandler ¶
func NewClusterHandler(clientset *kubernetes.Clientset, RbdNamespace string) ClusterHandler
NewClusterHandler -
type ClusterResourceStats ¶
type ClusterResourceStats struct { AllCPU int64 AllMemory int64 RequestCPU int64 RequestMemory int64 }
ClusterResourceStats cluster resource stats
type ComponentIngressTask ¶
type ComponentIngressTask struct { ComponentID string `json:"service_id"` Action string `json:"action"` Port int `json:"port"` IsInner bool `json:"is_inner"` }
ComponentIngressTask -
type EtcdHandler ¶
type EtcdHandler struct {
// contains filtered or unexported fields
}
EtcdHandler defines handler methods about k8s pods.
func GetEtcdHandler ¶
func GetEtcdHandler() *EtcdHandler
GetEtcdHandler returns the default etcd handler.
func NewEtcdHandler ¶
func NewEtcdHandler(etcdCli *clientv3.Client) *EtcdHandler
NewEtcdHandler creates a new PodHandler.
func (*EtcdHandler) CleanAllServiceData ¶
func (h *EtcdHandler) CleanAllServiceData(keys []string)
func (*EtcdHandler) CleanServiceCheckData ¶
func (h *EtcdHandler) CleanServiceCheckData(key string)
CleanServiceCheckData clean service check etcd data
type EtcdKeyType ¶
type EtcdKeyType int
EtcdKeyType etcd key type
const ( // ServiceCheckEtcdKey source check etcd key ServiceCheckEtcdKey EtcdKeyType = iota ShareResultEtcdKey //BackupRestoreEtcdKey backup restore etcd key BackupRestoreEtcdKey )
type EventHandler ¶
type EventHandler interface { GetLogList(serviceAlias string) ([]*model.HistoryLogFile, error) GetLogInstance(serviceID string) (string, error) GetLevelLog(eventID string, level string) (*api_model.DataLog, error) GetLogFile(serviceAlias, fileName string) (string, string, error) GetEvents(target, targetID string, page, size int) ([]*dbmodel.ServiceEvent, int, error) }
EventHandler event handler interface
type GatewayAction ¶
type GatewayAction struct {
// contains filtered or unexported fields
}
GatewayAction -
func CreateGatewayManager ¶
func CreateGatewayManager(dbmanager db.Manager, mqclient client.MQClient, etcdCli *clientv3.Client) *GatewayAction
CreateGatewayManager creates gateway manager.
func (*GatewayAction) AddCertificate ¶
func (g *GatewayAction) AddCertificate(req *apimodel.AddHTTPRuleStruct, tx *gorm.DB) error
AddCertificate adds certificate to db if it doesn't exists
func (*GatewayAction) AddHTTPRule ¶
func (g *GatewayAction) AddHTTPRule(req *apimodel.AddHTTPRuleStruct) error
AddHTTPRule adds http rule to db if it doesn't exists.
func (*GatewayAction) AddRuleExtensions ¶
func (g *GatewayAction) AddRuleExtensions(ruleID string, ruleExtensions []*apimodel.RuleExtensionStruct, tx *gorm.DB) error
AddRuleExtensions adds rule extensions to db if any of they doesn't exists
func (*GatewayAction) AddTCPRule ¶
func (g *GatewayAction) AddTCPRule(req *apimodel.AddTCPRuleStruct) error
AddTCPRule adds tcp rule.
func (*GatewayAction) CreateHTTPRule ¶
func (g *GatewayAction) CreateHTTPRule(tx *gorm.DB, req *apimodel.AddHTTPRuleStruct) error
CreateHTTPRule Create http rules through transactions
func (*GatewayAction) CreateTCPRule ¶
func (g *GatewayAction) CreateTCPRule(tx *gorm.DB, req *apimodel.AddTCPRuleStruct) error
CreateTCPRule Create tcp rules through transactions
func (*GatewayAction) DeleteHTTPRule ¶
func (g *GatewayAction) DeleteHTTPRule(req *apimodel.DeleteHTTPRuleStruct) error
DeleteHTTPRule deletes http rule, including certificate and rule extensions
func (*GatewayAction) DeleteHTTPRuleByServiceIDWithTransaction ¶
func (g *GatewayAction) DeleteHTTPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error
DeleteHTTPRuleByServiceIDWithTransaction deletes http rule, including certificate and rule extensions
func (*GatewayAction) DeleteIngressRulesByComponentPort ¶
func (g *GatewayAction) DeleteIngressRulesByComponentPort(tx *gorm.DB, componentID string, port int) error
DeleteIngressRulesByComponentPort deletes ingress rules, including http rules and tcp rules, based on the given componentID and port.
func (*GatewayAction) DeleteTCPRule ¶
func (g *GatewayAction) DeleteTCPRule(req *apimodel.DeleteTCPRuleStruct) error
DeleteTCPRule deletes a tcp rule
func (*GatewayAction) DeleteTCPRuleByServiceIDWithTransaction ¶
func (g *GatewayAction) DeleteTCPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error
DeleteTCPRuleByServiceIDWithTransaction deletes a tcp rule
func (*GatewayAction) GetAvailablePort ¶
func (g *GatewayAction) GetAvailablePort(ip string, lock bool) (int, error)
GetAvailablePort returns a available port
func (*GatewayAction) GetGatewayIPs ¶
func (g *GatewayAction) GetGatewayIPs() []IPAndAvailablePort
GetGatewayIPs get all gateway node ips
func (*GatewayAction) ListHTTPRulesByCertID ¶
func (g *GatewayAction) ListHTTPRulesByCertID(certID string) ([]*model.HTTPRule, error)
ListHTTPRulesByCertID -
func (*GatewayAction) RuleConfig ¶
func (g *GatewayAction) RuleConfig(req *apimodel.RuleConfigReq) error
RuleConfig -
func (*GatewayAction) SendTask ¶
func (g *GatewayAction) SendTask(task *ComponentIngressTask) error
SendTask sends apply rules task
func (*GatewayAction) SendTaskDeprecated ¶
func (g *GatewayAction) SendTaskDeprecated(in map[string]interface{}) error
SendTaskDeprecated sends apply rules task
func (*GatewayAction) SyncHTTPRules ¶
SyncHTTPRules -
func (*GatewayAction) SyncRuleConfigs ¶
SyncRuleConfigs -
func (*GatewayAction) SyncTCPRules ¶
SyncTCPRules -
func (*GatewayAction) TCPIPPortExists ¶
func (g *GatewayAction) TCPIPPortExists(host string, port int) bool
TCPIPPortExists returns if the port exists
func (*GatewayAction) UpdCertificate ¶
func (g *GatewayAction) UpdCertificate(req *apimodel.UpdCertificateReq) error
UpdCertificate -
func (*GatewayAction) UpdateCertificate ¶
func (g *GatewayAction) UpdateCertificate(req apimodel.AddHTTPRuleStruct, httpRule *model.HTTPRule, tx *gorm.DB) error
UpdateCertificate updates certificate for http rule
func (*GatewayAction) UpdateHTTPRule ¶
func (g *GatewayAction) UpdateHTTPRule(req *apimodel.UpdateHTTPRuleStruct) error
UpdateHTTPRule updates http rule
func (*GatewayAction) UpdateTCPRule ¶
func (g *GatewayAction) UpdateTCPRule(req *apimodel.UpdateTCPRuleStruct, minPort int) error
UpdateTCPRule updates a tcp rule
type GatewayHandler ¶
type GatewayHandler interface { AddHTTPRule(req *apimodel.AddHTTPRuleStruct) error CreateHTTPRule(tx *gorm.DB, req *apimodel.AddHTTPRuleStruct) error UpdateHTTPRule(req *apimodel.UpdateHTTPRuleStruct) error DeleteHTTPRule(req *apimodel.DeleteHTTPRuleStruct) error DeleteHTTPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error AddCertificate(req *apimodel.AddHTTPRuleStruct, tx *gorm.DB) error UpdateCertificate(req apimodel.AddHTTPRuleStruct, httpRule *dbmodel.HTTPRule, tx *gorm.DB) error AddTCPRule(req *apimodel.AddTCPRuleStruct) error CreateTCPRule(tx *gorm.DB, req *apimodel.AddTCPRuleStruct) error UpdateTCPRule(req *apimodel.UpdateTCPRuleStruct, minPort int) error DeleteTCPRule(req *apimodel.DeleteTCPRuleStruct) error DeleteTCPRuleByServiceIDWithTransaction(sid string, tx *gorm.DB) error AddRuleExtensions(ruleID string, ruleExtensions []*apimodel.RuleExtensionStruct, tx *gorm.DB) error GetAvailablePort(ip string, lock bool) (int, error) TCPIPPortExists(ip string, port int) bool // Deprecated. SendTaskDeprecated(in map[string]interface{}) error SendTask(task *ComponentIngressTask) error RuleConfig(req *apimodel.RuleConfigReq) error UpdCertificate(req *apimodel.UpdCertificateReq) error GetGatewayIPs() []IPAndAvailablePort ListHTTPRulesByCertID(certID string) ([]*dbmodel.HTTPRule, error) DeleteIngressRulesByComponentPort(tx *gorm.DB, componentID string, port int) error SyncHTTPRules(tx *gorm.DB, components []*apimodel.Component) error SyncTCPRules(tx *gorm.DB, components []*apimodel.Component) error }
GatewayHandler gateway api handler
func GetGatewayHandler ¶
func GetGatewayHandler() GatewayHandler
GetGatewayHandler returns a default GatewayHandler
type IPAndAvailablePort ¶
IPAndAvailablePort ip and advice available port
type Info ¶
type Info struct { Code string `json:"code"` Company string `json:"company"` Node int64 `json:"node"` CPU int64 `json:"cpu"` Memory int64 `json:"memory"` Tenant int64 `json:"tenant"` EndTime string `json:"end_time"` StartTime string `json:"start_time"` DataCenter int64 `json:"data_center"` ModuleList []string `json:"module_list"` }
Info license information
func ReadLicenseFromFile ¶
ReadLicenseFromFile
type K8sPodInfo ¶
type K8sPodInfo struct { PodName string `json:"pod_name"` PodIP string `json:"pod_ip"` PodStatus string `json:"pod_status"` ServiceID string `json:"service_id"` Container map[string]map[string]string `json:"container"` }
K8sPodInfo for api
type K8sPodInfos ¶
type K8sPodInfos struct { NewPods []*K8sPodInfo `json:"new_pods"` OldPods []*K8sPodInfo `json:"old_pods"` }
K8sPodInfos -
type LicenseAction ¶
type LicenseAction struct{}
LicenseAction LicenseAction
func (*LicenseAction) PackLicense ¶
func (l *LicenseAction) PackLicense(encrypted string) ([]byte, error)
PackLicense PackLicense
func (*LicenseAction) StoreLicense ¶
func (l *LicenseAction) StoreLicense(license, token string) error
StoreLicense StoreLicense
type LicenseHandler ¶
type LicenseHandler interface { PackLicense(encrypted string) ([]byte, error) StoreLicense(license, token string) error }
LicenseHandler LicenseAction
func GetLicenseHandler ¶
func GetLicenseHandler() LicenseHandler
GetLicenseHandler get license handler
type LicenseInfoHandler ¶
type LicenseInfoHandler interface {
ShowInfos() (map[string]*api_model.LicenseInfo, error)
}
LicenseInfoHandler LicenseInfoHandler
func GetLicensesInfosHandler ¶
func GetLicensesInfosHandler() LicenseInfoHandler
GetLicensesInfosHandler GetLicensesInfosHandler
type LicensesInfos ¶
type LicensesInfos struct {
Infos map[string]*api_model.LicenseInfo
}
LicensesInfos verification
func (*LicensesInfos) ShowInfos ¶
func (l *LicensesInfos) ShowInfos() (map[string]*api_model.LicenseInfo, error)
ShowInfos ShowInfos
type LogAction ¶
LogAction log action struct
func CreateLogManager ¶
CreateLogManager get log manager
func (*LogAction) GetEvents ¶
func (l *LogAction) GetEvents(target, targetID string, page, size int) ([]*dbmodel.ServiceEvent, int, error)
GetEvents get target logs
func (*LogAction) GetLevelLog ¶
GetLevelLog get event log
func (*LogAction) GetLogFile ¶
GetLogFile GetLogFile
func (*LogAction) GetLogInstance ¶
GetLogInstance get log web socket instance
func (*LogAction) GetLogList ¶
func (l *LogAction) GetLogList(serviceAlias string) ([]*model.HistoryLogFile, error)
GetLogList get log list
type MavenSetting ¶
type MavenSetting struct { Name string `json:"name" validate:"required"` CreateTime string `json:"create_time"` UpdateTime string `json:"update_time"` Content string `json:"content" validate:"required"` IsDefault bool `json:"is_default"` }
MavenSetting maven setting
type MonitorHandler ¶
type MonitorHandler interface { GetTenantMonitorMetrics(tenantID string) []prometheus.Metadata GetAppMonitorMetrics(tenantID, appID string) []prometheus.Metadata GetComponentMonitorMetrics(tenantID, componentID string) []prometheus.Metadata }
MonitorHandler monitor api handler
func NewMonitorHandler ¶
func NewMonitorHandler(cli prometheus.Interface) MonitorHandler
NewMonitorHandler new monitor handler
type NetRulesAction ¶
type NetRulesAction struct {
// contains filtered or unexported fields
}
NetRulesAction rules action struct
func CreateNetRulesManager ¶
func CreateNetRulesManager(etcdCli *clientv3.Client) *NetRulesAction
CreateNetRulesManager get net rules manager
func (*NetRulesAction) CreateDownStreamNetRules ¶
func (n *NetRulesAction) CreateDownStreamNetRules( tenantID string, rs *api_model.SetNetDownStreamRuleStruct) *util.APIHandleError
CreateDownStreamNetRules CreateDownStreamNetRules
func (*NetRulesAction) GetDownStreamNetRule ¶
func (n *NetRulesAction) GetDownStreamNetRule( tenantID, serviceAlias, destServiceAlias, port string) (*api_model.NetRulesDownStreamBody, *util.APIHandleError)
GetDownStreamNetRule GetDownStreamNetRule
func (*NetRulesAction) UpdateDownStreamNetRule ¶
func (n *NetRulesAction) UpdateDownStreamNetRule( tenantID string, urs *api_model.UpdateNetDownStreamRuleStruct) *util.APIHandleError
UpdateDownStreamNetRule UpdateDownStreamNetRule
type NetRulesHandler ¶
type NetRulesHandler interface { CreateDownStreamNetRules( tenantID string, rs *api_model.SetNetDownStreamRuleStruct) *util.APIHandleError GetDownStreamNetRule( tenantID, serviceAlias, destServiceAlias, port string) (*api_model.NetRulesDownStreamBody, *util.APIHandleError) UpdateDownStreamNetRule( tenantID string, urs *api_model.UpdateNetDownStreamRuleStruct) *util.APIHandleError }
NetRulesHandler net rules handler
type OperationHandler ¶
type OperationHandler struct {
// contains filtered or unexported fields
}
OperationHandler operation handler
func CreateOperationHandler ¶
func CreateOperationHandler(mqCli gclient.MQClient) *OperationHandler
CreateOperationHandler create operation handler
func GetOperationHandler ¶
func GetOperationHandler() *OperationHandler
GetOperationHandler get handler
func (*OperationHandler) Build ¶
func (o *OperationHandler) Build(batchOpReq model.ComponentOpReq) (*model.ComponentOpResult, error)
Build service build,will create new version if deploy version not define, will create by time
func (*OperationHandler) RollBack ¶
func (o *OperationHandler) RollBack(rollback model.RollbackInfoRequestStruct) (re OperationResult)
RollBack service rollback
func (*OperationHandler) Start ¶
func (o *OperationHandler) Start(batchOpReq model.ComponentOpReq) error
Start service start
func (*OperationHandler) Stop ¶
func (o *OperationHandler) Stop(batchOpReq model.ComponentOpReq) error
Stop service stop
func (*OperationHandler) Upgrade ¶
func (o *OperationHandler) Upgrade(batchOpReq model.ComponentOpReq) (*model.ComponentOpResult, error)
Upgrade service upgrade
type OperationResult ¶
type OperationResult struct { ServiceID string `json:"service_id"` Operation string `json:"operation"` EventID string `json:"event_id"` Status string `json:"status"` ErrMsg string `json:"err_message"` DeployVersion string `json:"deploy_version"` }
OperationResult batch operation result
type PluginAction ¶
PluginAction plugin action struct
func CreatePluginManager ¶
func CreatePluginManager(mqClient client.MQClient) *PluginAction
CreatePluginManager get plugin manager
func (*PluginAction) AddDefaultEnv ¶
func (p *PluginAction) AddDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError
AddDefaultEnv AddDefaultEnv
func (*PluginAction) BatchBuildPlugins ¶
func (p *PluginAction) BatchBuildPlugins(req *api_model.BatchBuildPlugins, tenantID string) *util.APIHandleError
BatchBuildPlugins -
func (*PluginAction) BatchCreatePlugins ¶
func (p *PluginAction) BatchCreatePlugins(tenantID string, plugins []*api_model.Plugin) *util.APIHandleError
BatchCreatePlugins -
func (*PluginAction) BuildPluginManual ¶
func (p *PluginAction) BuildPluginManual(bps *api_model.BuildPluginStruct) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)
BuildPluginManual BuildPluginManual
func (*PluginAction) CreatePluginAct ¶
func (p *PluginAction) CreatePluginAct(cps *api_model.CreatePluginStruct) *util.APIHandleError
CreatePluginAct PluginAct
func (*PluginAction) DeleteDefaultEnv ¶
func (p *PluginAction) DeleteDefaultEnv(pluginID, versionID, name string) *util.APIHandleError
DeleteDefaultEnv DeleteDefaultEnv
func (*PluginAction) DeletePluginAct ¶
func (p *PluginAction) DeletePluginAct(pluginID, tenantID string) *util.APIHandleError
DeletePluginAct DeletePluginAct
func (*PluginAction) DeletePluginBuildVersion ¶
func (p *PluginAction) DeletePluginBuildVersion(pluginID, versionID string) *util.APIHandleError
DeletePluginBuildVersion DeletePluginBuildVersion
func (*PluginAction) GetAllPluginBuildVersions ¶
func (p *PluginAction) GetAllPluginBuildVersions(pluginID string) ([]*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)
GetAllPluginBuildVersions GetAllPluginBuildVersions
func (*PluginAction) GetDefaultEnv ¶
func (p *PluginAction) GetDefaultEnv(pluginID, versionID string) ([]*dbmodel.TenantPluginDefaultENV, *util.APIHandleError)
GetDefaultEnv GetDefaultEnv
func (*PluginAction) GetEnvsWhichCanBeSet ¶
func (p *PluginAction) GetEnvsWhichCanBeSet(serviceID, pluginID string) (interface{}, *util.APIHandleError)
GetEnvsWhichCanBeSet GetEnvsWhichCanBeSet
func (*PluginAction) GetPluginBuildVersion ¶
func (p *PluginAction) GetPluginBuildVersion(pluginID, versionID string) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError)
GetPluginBuildVersion GetPluginBuildVersion
func (*PluginAction) GetPlugins ¶
func (p *PluginAction) GetPlugins(tenantID string) ([]*dbmodel.TenantPlugin, *util.APIHandleError)
GetPlugins get all plugins by tenantID
func (*PluginAction) UpdateDefaultEnv ¶
func (p *PluginAction) UpdateDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError
UpdateDefaultEnv UpdateDefaultEnv
func (*PluginAction) UpdatePluginAct ¶
func (p *PluginAction) UpdatePluginAct(pluginID, tenantID string, cps *api_model.UpdatePluginStruct) *util.APIHandleError
UpdatePluginAct UpdatePluginAct
type PluginHandler ¶
type PluginHandler interface { CreatePluginAct(cps *api_model.CreatePluginStruct) *util.APIHandleError UpdatePluginAct(pluginID, tenantID string, cps *api_model.UpdatePluginStruct) *util.APIHandleError DeletePluginAct(pluginID, tenantID string) *util.APIHandleError GetPlugins(tenantID string) ([]*dbmodel.TenantPlugin, *util.APIHandleError) AddDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError UpdateDefaultEnv(est *api_model.ENVStruct) *util.APIHandleError DeleteDefaultEnv(pluginID, versionID, envName string) *util.APIHandleError BuildPluginManual(bps *api_model.BuildPluginStruct) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError) GetAllPluginBuildVersions(pluginID string) ([]*dbmodel.TenantPluginBuildVersion, *util.APIHandleError) GetPluginBuildVersion(pluginID, versionID string) (*dbmodel.TenantPluginBuildVersion, *util.APIHandleError) DeletePluginBuildVersion(pluginID, versionID string) *util.APIHandleError GetDefaultEnv(pluginID, versionID string) ([]*dbmodel.TenantPluginDefaultENV, *util.APIHandleError) GetEnvsWhichCanBeSet(serviceID, pluginID string) (interface{}, *util.APIHandleError) BatchCreatePlugins(tenantID string, plugins []*api_model.Plugin) *util.APIHandleError BatchBuildPlugins(req *api_model.BatchBuildPlugins, tenantID string) *util.APIHandleError }
PluginHandler plugin handler
type PodAction ¶
type PodAction struct {
// contains filtered or unexported fields
}
PodAction is an implementation of PodHandler
type PodHandler ¶
PodHandler defines handler methods about k8s pods.
func NewPodHandler ¶
func NewPodHandler(statusCli *client.AppRuntimeSyncClient) PodHandler
NewPodHandler creates a new PodHandler.
type QueryResult ¶
type QueryResult struct { Data struct { Type string `json:"resultType"` Result []map[string]interface{} `json:"result"` } `json:"data"` Status string `json:"status"` }
QueryResult contains result data for a query.
type RootAction ¶
type RootAction struct{}
RootAction root function action struct
func CreateRootFuncManager ¶
func CreateRootFuncManager(conf option.Config) *RootAction
CreateRootFuncManager get root func manager
func (*RootAction) ResolvePHP ¶
func (r *RootAction) ResolvePHP(cs *api_model.ComposerStruct) (string, error)
ResolvePHP php - application build
type RootFuncHandler ¶
type RootFuncHandler interface { }
RootFuncHandler root function handler interface
func GetRootFuncHandler ¶
func GetRootFuncHandler() RootFuncHandler
GetRootFuncHandler get root handler
type ServiceAction ¶
type ServiceAction struct { MQClient gclient.MQClient EtcdCli *clientv3.Client // contains filtered or unexported fields }
ServiceAction service act
func CreateManager ¶
func CreateManager(conf option.Config, mqClient gclient.MQClient, etcdCli *clientv3.Client, statusCli *client.AppRuntimeSyncClient, prometheusCli prometheus.Interface, katoClient versioned.Interface, kubeClient kubernetes.Interface) *ServiceAction
CreateManager create Manger
func (*ServiceAction) AddAutoscalerRule ¶
func (s *ServiceAction) AddAutoscalerRule(req *api_model.AutoscalerRuleReq) error
AddAutoscalerRule -
func (*ServiceAction) AddLabel ¶
func (s *ServiceAction) AddLabel(l *api_model.LabelsStruct, serviceID string) error
AddLabel add labels
func (*ServiceAction) AddServiceMonitor ¶
func (s *ServiceAction) AddServiceMonitor(tenantID, serviceID string, add api_model.AddServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)
AddServiceMonitor add service monitor
func (*ServiceAction) CodeCheck ¶
func (s *ServiceAction) CodeCheck(c *api_model.CheckCodeStruct) error
CodeCheck code check
func (*ServiceAction) CreatePorts ¶
func (s *ServiceAction) CreatePorts(tenantID, serviceID string, vps *api_model.ServicePorts) error
CreatePorts -
func (*ServiceAction) CreateTenandIDAndName ¶
func (s *ServiceAction) CreateTenandIDAndName(eid string) (string, string, error)
CreateTenandIDAndName create tenant_id and tenant_name
func (*ServiceAction) CreateTenant ¶
func (s *ServiceAction) CreateTenant(t *dbmodel.Tenants) error
CreateTenant create tenant
func (*ServiceAction) DeleteLabel ¶
func (s *ServiceAction) DeleteLabel(l *api_model.LabelsStruct, serviceID string) error
DeleteLabel deletes label
func (*ServiceAction) DeletePluginConfig ¶
func (s *ServiceAction) DeletePluginConfig(serviceID, pluginID string) *util.APIHandleError
DeletePluginConfig delete service plugin dynamic discovery config
func (*ServiceAction) DeleteServiceMonitor ¶
func (s *ServiceAction) DeleteServiceMonitor(tenantID, serviceID, name string) (*dbmodel.TenantServiceMonitor, error)
DeleteServiceMonitor delete
func (*ServiceAction) EnvAttr ¶
func (s *ServiceAction) EnvAttr(action string, at *dbmodel.TenantServiceEnvVar) error
EnvAttr env attr
func (*ServiceAction) GetComponentPodNums ¶
func (s *ServiceAction) GetComponentPodNums(ctx context.Context, componentIDs []string) (map[string]int32, error)
GetComponentPodNums get pods
func (*ServiceAction) GetDepVolumes ¶
func (s *ServiceAction) GetDepVolumes(serviceID string) ([]*dbmodel.TenantServiceMountRelation, *util.APIHandleError)
GetDepVolumes Get dependent storage
func (*ServiceAction) GetEnterpriseRunningServices ¶
func (s *ServiceAction) GetEnterpriseRunningServices(enterpriseID string) ([]string, *util.APIHandleError)
GetEnterpriseRunningServices get running services
func (*ServiceAction) GetMultiServicePods ¶
func (s *ServiceAction) GetMultiServicePods(serviceIDs []string) (*K8sPodInfos, error)
GetMultiServicePods get pods
func (*ServiceAction) GetPagedTenantRes ¶
func (s *ServiceAction) GetPagedTenantRes(offset, len int) ([]*api_model.TenantResource, int, error)
GetPagedTenantRes get pagedTenantServiceRes(s)
func (*ServiceAction) GetPodContainerMemory ¶
func (s *ServiceAction) GetPodContainerMemory(podNames []string) (map[string]map[string]string, error)
GetPodContainerMemory Use Prometheus to query memory resources
func (*ServiceAction) GetPods ¶
func (s *ServiceAction) GetPods(serviceID string) (*K8sPodInfos, error)
GetPods get pods
func (*ServiceAction) GetService ¶
func (s *ServiceAction) GetService(tenantID string) ([]*dbmodel.TenantServices, error)
GetService get service(s)
func (*ServiceAction) GetServiceCheckInfo ¶
func (s *ServiceAction) GetServiceCheckInfo(uuid string) (*exector.ServiceCheckResult, *util.APIHandleError)
GetServiceCheckInfo get application source detection information
func (*ServiceAction) GetServiceDeployInfo ¶
func (s *ServiceAction) GetServiceDeployInfo(tenantID, serviceID string) (*pb.DeployInfo, *util.APIHandleError)
GetServiceDeployInfo get service deploy info
func (*ServiceAction) GetServicesByAppID ¶
func (s *ServiceAction) GetServicesByAppID(appID string, page, pageSize int) (*api_model.ListServiceResponse, error)
GetServicesByAppID get service(s) by appID
func (*ServiceAction) GetServicesStatus ¶
func (s *ServiceAction) GetServicesStatus(tenantID string, serviceIDs []string) []map[string]interface{}
GetServicesStatus Get a set of application status, if serviceIDs is empty, get all application status of the tenant
func (*ServiceAction) GetStatus ¶
func (s *ServiceAction) GetStatus(serviceID string) (*api_model.StatusList, error)
GetStatus GetStatus
func (*ServiceAction) GetTenantRes ¶
func (s *ServiceAction) GetTenantRes(uuid string) (*api_model.TenantResource, error)
GetTenantRes get pagedTenantServiceRes(s)
func (*ServiceAction) GetTenantServicePluginRelation ¶
func (s *ServiceAction) GetTenantServicePluginRelation(serviceID string) ([]*dbmodel.TenantServicePluginRelation, *util.APIHandleError)
GetTenantServicePluginRelation
func (*ServiceAction) GetVolumes ¶
func (s *ServiceAction) GetVolumes(serviceID string) ([]*api_model.VolumeWithStatusStruct, *util.APIHandleError)
GetVolumes Get all application storage
func (*ServiceAction) LanguageSet ¶
func (s *ServiceAction) LanguageSet(langS *api_model.LanguageSet) error
LanguageSet language set
func (*ServiceAction) ListScalingRecords ¶
func (s *ServiceAction) ListScalingRecords(serviceID string, page, pageSize int) ([]*dbmodel.TenantServiceScalingRecords, int, error)
ListScalingRecords -
func (*ServiceAction) ListVersionInfo ¶
func (s *ServiceAction) ListVersionInfo(serviceID string) (*api_model.BuildListRespVO, error)
ListVersionInfo lists version info
func (*ServiceAction) Log ¶
func (s *ServiceAction) Log(w http.ResponseWriter, r *http.Request, component *dbmodel.TenantServices, podName, containerName string, follow bool) error
Log returns the logs reader for a container in a pod, a pod or a component.
func (*ServiceAction) PortInner ¶
func (s *ServiceAction) PortInner(tenantName, serviceID, operation string, port int) error
PortInner Port internal service operation TODO: send task to worker
func (*ServiceAction) PortOuter ¶
func (s *ServiceAction) PortOuter(tenantName, serviceID string, containerPort int, servicePort *api_model.ServicePortInnerOrOuter) (*dbmodel.TenantServiceLBMappingPort, string, error)
PortOuter Port external service operation
func (*ServiceAction) PortVar ¶
func (s *ServiceAction) PortVar(action, tenantID, serviceID string, vps *api_model.ServicePorts, oldPort int) error
PortVar port var
func (*ServiceAction) RollBack ¶
func (s *ServiceAction) RollBack(rs *api_model.RollbackStruct) error
RollBack RollBack
func (*ServiceAction) SavePluginConfig ¶
func (s *ServiceAction) SavePluginConfig(serviceID, pluginID string, config *api_model.ResourceSpec) *util.APIHandleError
SavePluginConfig save plugin dynamic discovery config
func (*ServiceAction) ServiceBuild ¶
func (s *ServiceAction) ServiceBuild(tenantID, serviceID string, r *api_model.BuildServiceStruct) error
ServiceBuild service build
func (*ServiceAction) ServiceCheck ¶
func (s *ServiceAction) ServiceCheck(scs *api_model.ServiceCheckStruct) (string, string, *util.APIHandleError)
ServiceCheck check service build source
func (*ServiceAction) ServiceCreate ¶
func (s *ServiceAction) ServiceCreate(sc *api_model.ServiceStruct) error
ServiceCreate create service
func (*ServiceAction) ServiceDepend ¶
func (s *ServiceAction) ServiceDepend(action string, ds *api_model.DependService) error
ServiceDepend service depend
func (*ServiceAction) ServiceHorizontal ¶
func (s *ServiceAction) ServiceHorizontal(hs *model.HorizontalScalingTaskBody) error
ServiceHorizontal Service Horizontal
func (*ServiceAction) ServiceProbe ¶
func (s *ServiceAction) ServiceProbe(tsp *dbmodel.TenantServiceProbe, action string) error
ServiceProbe ServiceProbe
func (*ServiceAction) ServiceUpdate ¶
func (s *ServiceAction) ServiceUpdate(sc map[string]interface{}) error
ServiceUpdate update service
func (*ServiceAction) ServiceUpgrade ¶
func (s *ServiceAction) ServiceUpgrade(ru *model.RollingUpgradeTaskBody) error
ServiceUpgrade service upgrade
func (*ServiceAction) ServiceVertical ¶
func (s *ServiceAction) ServiceVertical(ctx context.Context, vs *model.VerticalScalingTaskBody) error
ServiceVertical vertical service
func (*ServiceAction) SetTenantServicePluginRelation ¶
func (s *ServiceAction) SetTenantServicePluginRelation(tenantID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)
SetTenantServicePluginRelation
func (*ServiceAction) StartStopService ¶
func (s *ServiceAction) StartStopService(sss *api_model.StartStopStruct) error
StartStopService start service
func (*ServiceAction) SyncComponentBase ¶
func (s *ServiceAction) SyncComponentBase(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
SyncComponentBase -
func (*ServiceAction) SyncComponentConfigFiles ¶
func (s *ServiceAction) SyncComponentConfigFiles(tx *gorm.DB, components []*api_model.Component) error
SyncComponentConfigFiles -
func (*ServiceAction) SyncComponentEndpoints ¶
func (s *ServiceAction) SyncComponentEndpoints(tx *gorm.DB, components []*api_model.Component) error
SyncComponentEndpoints -
func (*ServiceAction) SyncComponentEnvs ¶
func (s *ServiceAction) SyncComponentEnvs(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
SyncComponentEnvs -
func (*ServiceAction) SyncComponentLabels ¶
SyncComponentLabels -
func (*ServiceAction) SyncComponentMonitors ¶
func (s *ServiceAction) SyncComponentMonitors(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
SyncComponentMonitors -
func (*ServiceAction) SyncComponentPlugins ¶
func (s *ServiceAction) SyncComponentPlugins(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
SyncComponentPlugins -
func (*ServiceAction) SyncComponentPorts ¶
func (s *ServiceAction) SyncComponentPorts(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
SyncComponentPorts -
func (*ServiceAction) SyncComponentProbes ¶
SyncComponentProbes -
func (*ServiceAction) SyncComponentRelations ¶
func (s *ServiceAction) SyncComponentRelations(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
SyncComponentRelations -
func (*ServiceAction) SyncComponentScaleRules ¶
func (s *ServiceAction) SyncComponentScaleRules(tx *gorm.DB, components []*api_model.Component) error
SyncComponentScaleRules -
func (*ServiceAction) SyncComponentVolumeRels ¶
func (s *ServiceAction) SyncComponentVolumeRels(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error
SyncComponentVolumeRels -
func (*ServiceAction) SyncComponentVolumes ¶
SyncComponentVolumes -
func (*ServiceAction) TenantServiceDeletePluginRelation ¶
func (s *ServiceAction) TenantServiceDeletePluginRelation(tenantID, serviceID, pluginID string) *util.APIHandleError
TenantServiceDeletePluginRelation uninstall plugin for app
func (*ServiceAction) TransServieToDelete ¶
func (s *ServiceAction) TransServieToDelete(ctx context.Context, tenantID, serviceID string) error
TransServieToDelete trans service info to delete table
func (*ServiceAction) UpdAutoscalerRule ¶
func (s *ServiceAction) UpdAutoscalerRule(req *api_model.AutoscalerRuleReq) error
UpdAutoscalerRule -
func (*ServiceAction) UpdVolume ¶
func (s *ServiceAction) UpdVolume(sid string, req *api_model.UpdVolumeReq) error
UpdVolume updates service volume.
func (*ServiceAction) UpdateLabel ¶
func (s *ServiceAction) UpdateLabel(l *api_model.LabelsStruct, serviceID string) error
UpdateLabel updates labels
func (*ServiceAction) UpdateServiceMonitor ¶
func (s *ServiceAction) UpdateServiceMonitor(tenantID, serviceID, name string, update api_model.UpdateServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error)
UpdateServiceMonitor update service monitor
func (*ServiceAction) UpdateTenantServicePluginRelation ¶
func (s *ServiceAction) UpdateTenantServicePluginRelation(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError)
UpdateTenantServicePluginRelation
func (*ServiceAction) UpdateVersionEnv ¶
func (s *ServiceAction) UpdateVersionEnv(uve *api_model.SetVersionEnv) *util.APIHandleError
UpdateVersionEnv
func (*ServiceAction) VolumeDependency ¶
func (s *ServiceAction) VolumeDependency(tsr *dbmodel.TenantServiceMountRelation, action string) *util.APIHandleError
VolumeDependency VolumeDependency
func (*ServiceAction) VolumnVar ¶
func (s *ServiceAction) VolumnVar(tsv *dbmodel.TenantServiceVolume, tenantID, fileContent, action string) *util.APIHandleError
VolumnVar var volumn
type ServiceDependency ¶
type ServiceDependency struct {
// contains filtered or unexported fields
}
ServiceDependency documents a set of services and their dependencies. provides the ability to build linked lists of dependencies and find circular dependencies.
func NewServiceDependency ¶
func NewServiceDependency(serviceIDs []string) (*ServiceDependency, error)
NewServiceDependency creates a new ServiceDependency.
type ServiceEventHandler ¶
type ServiceEventHandler struct { }
ServiceEventHandler -
func GetServiceEventHandler ¶
func GetServiceEventHandler() *ServiceEventHandler
GetServiceEventHandler -
func NewServiceEventHandler ¶
func NewServiceEventHandler() *ServiceEventHandler
NewServiceEventHandler -
func (*ServiceEventHandler) ListByEventIDs ¶
func (s *ServiceEventHandler) ListByEventIDs(eventIDs []string) ([]*dbmodel.ServiceEvent, error)
ListByEventIDs -
type ServiceHandler ¶
type ServiceHandler interface { ServiceBuild(tenantID, serviceID string, r *api_model.BuildServiceStruct) error AddLabel(l *api_model.LabelsStruct, serviceID string) error DeleteLabel(l *api_model.LabelsStruct, serviceID string) error UpdateLabel(l *api_model.LabelsStruct, serviceID string) error StartStopService(s *api_model.StartStopStruct) error ServiceVertical(ctx context.Context, v *model.VerticalScalingTaskBody) error ServiceHorizontal(h *model.HorizontalScalingTaskBody) error ServiceUpgrade(r *model.RollingUpgradeTaskBody) error ServiceCreate(ts *api_model.ServiceStruct) error ServiceUpdate(sc map[string]interface{}) error LanguageSet(langS *api_model.LanguageSet) error GetService(tenantID string) ([]*dbmodel.TenantServices, error) GetServicesByAppID(appID string, page, pageSize int) (*api_model.ListServiceResponse, error) GetPagedTenantRes(offset, len int) ([]*api_model.TenantResource, int, error) GetTenantRes(uuid string) (*api_model.TenantResource, error) CodeCheck(c *api_model.CheckCodeStruct) error ServiceDepend(action string, ds *api_model.DependService) error EnvAttr(action string, at *dbmodel.TenantServiceEnvVar) error PortVar(action string, tenantID, serviceID string, vp *api_model.ServicePorts, oldPort int) error CreatePorts(tenantID, serviceID string, vps *api_model.ServicePorts) error PortOuter(tenantName, serviceID string, containerPort int, servicePort *api_model.ServicePortInnerOrOuter) (*dbmodel.TenantServiceLBMappingPort, string, error) PortInner(tenantName, serviceID, operation string, port int) error VolumnVar(avs *dbmodel.TenantServiceVolume, tenantID, fileContent, action string) *util.APIHandleError UpdVolume(sid string, req *api_model.UpdVolumeReq) error VolumeDependency(tsr *dbmodel.TenantServiceMountRelation, action string) *util.APIHandleError GetDepVolumes(serviceID string) ([]*dbmodel.TenantServiceMountRelation, *util.APIHandleError) GetVolumes(serviceID string) ([]*api_model.VolumeWithStatusStruct, *util.APIHandleError) ServiceProbe(tsp *dbmodel.TenantServiceProbe, action string) error RollBack(rs *api_model.RollbackStruct) error GetStatus(serviceID string) (*api_model.StatusList, error) GetServicesStatus(tenantID string, services []string) []map[string]interface{} GetEnterpriseRunningServices(enterpriseID string) ([]string, *util.APIHandleError) CreateTenant(*dbmodel.Tenants) error CreateTenandIDAndName(eid string) (string, string, error) GetPods(serviceID string) (*K8sPodInfos, error) GetMultiServicePods(serviceIDs []string) (*K8sPodInfos, error) GetComponentPodNums(ctx context.Context, componentIDs []string) (map[string]int32, error) TransServieToDelete(ctx context.Context, tenantID, serviceID string) error TenantServiceDeletePluginRelation(tenantID, serviceID, pluginID string) *util.APIHandleError GetTenantServicePluginRelation(serviceID string) ([]*dbmodel.TenantServicePluginRelation, *util.APIHandleError) SetTenantServicePluginRelation(tenantID, serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError) UpdateTenantServicePluginRelation(serviceID string, pss *api_model.PluginSetStruct) (*dbmodel.TenantServicePluginRelation, *util.APIHandleError) UpdateVersionEnv(uve *api_model.SetVersionEnv) *util.APIHandleError DeletePluginConfig(serviceID, pluginID string) *util.APIHandleError ServiceCheck(*api_model.ServiceCheckStruct) (string, string, *util.APIHandleError) GetServiceCheckInfo(uuid string) (*exector.ServiceCheckResult, *util.APIHandleError) GetServiceDeployInfo(tenantID, serviceID string) (*pb.DeployInfo, *util.APIHandleError) ListVersionInfo(serviceID string) (*api_model.BuildListRespVO, error) AddAutoscalerRule(req *api_model.AutoscalerRuleReq) error UpdAutoscalerRule(req *api_model.AutoscalerRuleReq) error ListScalingRecords(serviceID string, page, pageSize int) ([]*dbmodel.TenantServiceScalingRecords, int, error) UpdateServiceMonitor(tenantID, serviceID, name string, update api_model.UpdateServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error) DeleteServiceMonitor(tenantID, serviceID, name string) (*dbmodel.TenantServiceMonitor, error) AddServiceMonitor(tenantID, serviceID string, add api_model.AddServiceMonitorRequestStruct) (*dbmodel.TenantServiceMonitor, error) SyncComponentBase(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error SyncComponentMonitors(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error SyncComponentPorts(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error SyncComponentRelations(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error SyncComponentEnvs(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error SyncComponentVolumeRels(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error SyncComponentVolumes(tx *gorm.DB, components []*api_model.Component) error SyncComponentConfigFiles(tx *gorm.DB, components []*api_model.Component) error SyncComponentProbes(tx *gorm.DB, components []*api_model.Component) error SyncComponentLabels(tx *gorm.DB, components []*api_model.Component) error SyncComponentPlugins(tx *gorm.DB, app *dbmodel.Application, components []*api_model.Component) error SyncComponentScaleRules(tx *gorm.DB, components []*api_model.Component) error SyncComponentEndpoints(tx *gorm.DB, components []*api_model.Component) error Log(w http.ResponseWriter, r *http.Request, component *dbmodel.TenantServices, podName, containerName string, follow bool) error }
ServiceHandler service handler
type TenantAction ¶
type TenantAction struct { MQClient mqclient.MQClient OptCfg *option.Config // contains filtered or unexported fields }
TenantAction tenant act
func CreateTenManager ¶
func CreateTenManager(mqc mqclient.MQClient, statusCli *client.AppRuntimeSyncClient, optCfg *option.Config, kubeClient *kubernetes.Clientset, prometheusCli prometheus.Interface, k8sClient k8sclient.Client) *TenantAction
CreateTenManager create Manger
func (*TenantAction) BindTenantsResource ¶
func (t *TenantAction) BindTenantsResource(source []*dbmodel.Tenants) api_model.TenantList
BindTenantsResource query tenant resource used and sort
func (*TenantAction) CheckResourceName ¶
func (t *TenantAction) CheckResourceName(ctx context.Context, namespace string, req *model.CheckResourceNameReq) (*model.CheckResourceNameResp, error)
CheckResourceName checks resource name.
func (*TenantAction) DeleteTenant ¶
func (t *TenantAction) DeleteTenant(ctx context.Context, tenantID string) error
DeleteTenant deletes tenant based on the given tenantID.
tenant can only be deleted without service or plugin
func (*TenantAction) GetAllocatableResources ¶
func (t *TenantAction) GetAllocatableResources(ctx context.Context) (*ClusterResourceStats, error)
GetAllocatableResources returns allocatable cpu and memory (MB)
func (*TenantAction) GetClusterResource ¶
func (t *TenantAction) GetClusterResource(ctx context.Context) *ClusterResourceStats
GetClusterResource get cluster resource
func (*TenantAction) GetProtocols ¶
func (t *TenantAction) GetProtocols() ([]*dbmodel.RegionProcotols, *util.APIHandleError)
GetProtocols GetProtocols
func (*TenantAction) GetServicesResources ¶
func (t *TenantAction) GetServicesResources(tr *api_model.ServicesResources) (re map[string]map[string]interface{}, err error)
GetServicesResources Gets the resource usage of the specified service.
func (*TenantAction) GetServicesStatus ¶
func (t *TenantAction) GetServicesStatus(ids string) map[string]string
GetServicesStatus returns a list of service status matching ids.
func (*TenantAction) GetTenantResource ¶
func (t *TenantAction) GetTenantResource(tenantID string) (ts TenantResourceStats, err error)
GetTenantResource get tenant resource
func (*TenantAction) GetTenants ¶
func (t *TenantAction) GetTenants(query string) ([]*dbmodel.Tenants, error)
GetTenants get tenants
func (*TenantAction) GetTenantsByEid ¶
func (t *TenantAction) GetTenantsByEid(eid, query string) ([]*dbmodel.Tenants, error)
GetTenantsByEid GetTenantsByEid
func (*TenantAction) GetTenantsByName ¶
func (t *TenantAction) GetTenantsByName(name string) (*dbmodel.Tenants, error)
GetTenantsByName get tenants
func (*TenantAction) GetTenantsByUUID ¶
func (t *TenantAction) GetTenantsByUUID(uuid string) (*dbmodel.Tenants, error)
GetTenantsByUUID get tenants
func (*TenantAction) GetTenantsName ¶
func (t *TenantAction) GetTenantsName() ([]string, error)
GetTenantsName get tenants name
func (*TenantAction) GetTenantsResources ¶
func (t *TenantAction) GetTenantsResources(ctx context.Context, tr *api_model.TenantResources) (map[string]map[string]interface{}, error)
GetTenantsResources Gets the resource usage of the specified tenant.
func (*TenantAction) IsClosedStatus ¶
func (t *TenantAction) IsClosedStatus(status string) bool
IsClosedStatus checks if the status is closed status.
func (*TenantAction) StatsMemCPU ¶
func (t *TenantAction) StatsMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)
StatsMemCPU StatsMemCPU
func (*TenantAction) TenantsSum ¶
func (t *TenantAction) TenantsSum() (int, error)
TenantsSum TenantsSum
func (*TenantAction) TotalMemCPU ¶
func (t *TenantAction) TotalMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error)
TotalMemCPU StatsMemCPU
func (*TenantAction) TransPlugins ¶
func (t *TenantAction) TransPlugins(tenantID, tenantName, fromTenant string, pluginList []string) *util.APIHandleError
TransPlugins TransPlugins
func (*TenantAction) UpdateTenant ¶
func (t *TenantAction) UpdateTenant(tenant *dbmodel.Tenants) error
UpdateTenant update tenant info
type TenantHandler ¶
type TenantHandler interface { GetTenants(query string) ([]*dbmodel.Tenants, error) GetTenantsByName(name string) (*dbmodel.Tenants, error) GetTenantsByEid(eid, query string) ([]*dbmodel.Tenants, error) GetTenantsByUUID(uuid string) (*dbmodel.Tenants, error) GetTenantsName() ([]string, error) StatsMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error) TotalMemCPU(services []*dbmodel.TenantServices) (*api_model.StatsInfo, error) GetTenantsResources(ctx context.Context, tr *api_model.TenantResources) (map[string]map[string]interface{}, error) GetTenantResource(tenantID string) (TenantResourceStats, error) GetAllocatableResources(ctx context.Context) (*ClusterResourceStats, error) GetServicesResources(tr *api_model.ServicesResources) (map[string]map[string]interface{}, error) TenantsSum() (int, error) GetProtocols() ([]*dbmodel.RegionProcotols, *util.APIHandleError) TransPlugins(tenantID, tenantName, fromTenant string, pluginList []string) *util.APIHandleError GetServicesStatus(ids string) map[string]string IsClosedStatus(status string) bool BindTenantsResource(source []*dbmodel.Tenants) api_model.TenantList UpdateTenant(*dbmodel.Tenants) error DeleteTenant(ctx context.Context, tenantID string) error GetClusterResource(ctx context.Context) *ClusterResourceStats CheckResourceName(ctx context.Context, namespace string, req *model.CheckResourceNameReq) (*model.CheckResourceNameResp, error) }
TenantHandler tenant handler
type TenantResourceStats ¶
type TenantResourceStats struct { TenantID string `json:"tenant_id,omitempty"` CPURequest int64 `json:"cpu_request,omitempty"` CPULimit int64 `json:"cpu_limit,omitempty"` MemoryRequest int64 `json:"memory_request,omitempty"` MemoryLimit int64 `json:"memory_limit,omitempty"` RunningAppNum int64 `json:"running_app_num"` UnscdCPUReq int64 `json:"unscd_cpu_req,omitempty"` UnscdCPULimit int64 `json:"unscd_cpu_limit,omitempty"` UnscdMemoryReq int64 `json:"unscd_memory_req,omitempty"` UnscdMemoryLimit int64 `json:"unscd_memory_limit,omitempty"` }
TenantResourceStats tenant resource stats
type ThirdPartyServiceHanlder ¶
type ThirdPartyServiceHanlder struct {
// contains filtered or unexported fields
}
ThirdPartyServiceHanlder handles business logic for all third-party services
func Create3rdPartySvcHandler ¶
func Create3rdPartySvcHandler(dbmanager db.Manager, statusCli *client.AppRuntimeSyncClient) *ThirdPartyServiceHanlder
Create3rdPartySvcHandler creates a new *ThirdPartyServiceHanlder.
func Get3rdPartySvcHandler ¶
func Get3rdPartySvcHandler() *ThirdPartyServiceHanlder
Get3rdPartySvcHandler returns the defalut ThirdParthServiceHanlder
func (*ThirdPartyServiceHanlder) AddEndpoints ¶
func (t *ThirdPartyServiceHanlder) AddEndpoints(sid string, d *model.AddEndpiontsReq) error
AddEndpoints adds endpoints for third-party service.
func (*ThirdPartyServiceHanlder) DelEndpoints ¶
func (t *ThirdPartyServiceHanlder) DelEndpoints(epid, sid string) error
DelEndpoints deletes endpoints for third-party service.
func (*ThirdPartyServiceHanlder) ListEndpoints ¶
func (t *ThirdPartyServiceHanlder) ListEndpoints(componentID string) ([]*model.ThirdEndpoint, error)
ListEndpoints lists third-party service endpoints.
func (*ThirdPartyServiceHanlder) UpdEndpoints ¶
func (t *ThirdPartyServiceHanlder) UpdEndpoints(d *model.UpdEndpiontsReq) error
UpdEndpoints updates endpoints for third-party service.
type TokenIdenAction ¶
type TokenIdenAction struct{}
TokenIdenAction
func CreateTokenIdenManager ¶
func CreateTokenIdenManager(conf option.Config) (*TokenIdenAction, error)
CreateTokenIdenManager token identification
func (*TokenIdenAction) AddAPIManager ¶
func (t *TokenIdenAction) AddAPIManager(am *api_model.APIManager) *util.APIHandleError
AddAPIManager
func (*TokenIdenAction) AddTokenIntoMap ¶
func (t *TokenIdenAction) AddTokenIntoMap(rui *dbmodel.RegionUserInfo)
AddTokenIntoMap
func (*TokenIdenAction) CheckToken ¶
func (t *TokenIdenAction) CheckToken(token, uri string) bool
CheckToken
func (*TokenIdenAction) DeleteAPIManager ¶
func (t *TokenIdenAction) DeleteAPIManager(am *api_model.APIManager) *util.APIHandleError
DeleteAPIManager
func (*TokenIdenAction) DeleteTokenFromMap ¶
func (t *TokenIdenAction) DeleteTokenFromMap(oldtoken string, rui *dbmodel.RegionUserInfo)
DeleteTokenFromMap
func (*TokenIdenAction) GetAPIManager ¶
func (t *TokenIdenAction) GetAPIManager() map[string][]*dbmodel.RegionAPIClass
GetAPIManager
type TokenMapHandler ¶
type TokenMapHandler interface { AddTokenIntoMap(rui *dbmodel.RegionUserInfo) DeleteTokenFromMap(oldtoken string, rui *dbmodel.RegionUserInfo) CheckToken(token, uri string) bool GetAPIManager() map[string][]*dbmodel.RegionAPIClass AddAPIManager(am *api_model.APIManager) *util.APIHandleError DeleteAPIManager(am *api_model.APIManager) *util.APIHandleError InitTokenMap() error }
TokenMapHandler DefaultTokenMapHandler
type VersionInfo ¶
type VersionInfo struct {
Version []*LangInfo `json:"version"`
}
VersionInfo VersionInfo
type VolumeTypeAction ¶
type VolumeTypeAction struct {
// contains filtered or unexported fields
}
VolumeTypeAction action
func CreateVolumeTypeManger ¶
func CreateVolumeTypeManger(statusCli *client.AppRuntimeSyncClient) *VolumeTypeAction
CreateVolumeTypeManger create VolumeType manager
func (*VolumeTypeAction) DeleteVolumeType ¶
func (vta *VolumeTypeAction) DeleteVolumeType(volumeType string) error
DeleteVolumeType delte volume type
func (*VolumeTypeAction) GetAllStorageClasses ¶
func (vta *VolumeTypeAction) GetAllStorageClasses() ([]*pb.StorageClassDetail, error)
GetAllStorageClasses get all storage class
func (*VolumeTypeAction) GetAllVolumeTypes ¶
func (vta *VolumeTypeAction) GetAllVolumeTypes() ([]*api_model.VolumeTypeStruct, error)
GetAllVolumeTypes get all volume types
func (*VolumeTypeAction) GetAllVolumeTypesByPage ¶
func (vta *VolumeTypeAction) GetAllVolumeTypesByPage(page int, pageSize int) ([]*api_model.VolumeTypeStruct, error)
GetAllVolumeTypesByPage get all volume types by page
func (*VolumeTypeAction) GetVolumeTypeByType ¶
func (vta *VolumeTypeAction) GetVolumeTypeByType(volumtType string) (*dbmodel.TenantServiceVolumeType, error)
GetVolumeTypeByType get volume type by type
func (*VolumeTypeAction) SetVolumeType ¶
func (vta *VolumeTypeAction) SetVolumeType(vol *api_model.VolumeTypeStruct) error
SetVolumeType set volume type
func (*VolumeTypeAction) UpdateVolumeType ¶
func (vta *VolumeTypeAction) UpdateVolumeType(dbVolume *dbmodel.TenantServiceVolumeType, vol *api_model.VolumeTypeStruct) error
UpdateVolumeType
func (*VolumeTypeAction) VolumeTypeAction ¶
func (vta *VolumeTypeAction) VolumeTypeAction(action, volumeTypeID string) error
VolumeTypeAction open volme type or close it
func (*VolumeTypeAction) VolumeTypeVar ¶
func (vta *VolumeTypeAction) VolumeTypeVar(action string, vtm *dbmodel.TenantServiceVolumeType) error
VolumeTypeVar volume type crud
type VolumeTypeHandler ¶
type VolumeTypeHandler interface { VolumeTypeVar(action string, vtm *dbmodel.TenantServiceVolumeType) error GetAllVolumeTypes() ([]*api_model.VolumeTypeStruct, error) GetAllVolumeTypesByPage(page int, pageSize int) ([]*api_model.VolumeTypeStruct, error) GetVolumeTypeByType(volumeType string) (*dbmodel.TenantServiceVolumeType, error) GetAllStorageClasses() ([]*pb.StorageClassDetail, error) VolumeTypeAction(action, volumeTypeID string) error DeleteVolumeType(volumeTypeID string) error SetVolumeType(vtm *api_model.VolumeTypeStruct) error UpdateVolumeType(dbVolume *dbmodel.TenantServiceVolumeType, vol *api_model.VolumeTypeStruct) error }
VolumeTypeHandler LicenseAction
func GetVolumeTypeHandler ¶
func GetVolumeTypeHandler() VolumeTypeHandler
GetVolumeTypeHandler get volumeType handler
Source Files ¶
- LicenseHandler.go
- PluginHandler.go
- app.go
- app_restore_action.go
- app_restore_handler.go
- application_config_group.go
- application_handler.go
- cloud.go
- cloudHandler.go
- cluster.go
- etcd_handler.go
- event.go
- eventLog.go
- eventlog_interface.go
- gateway_action.go
- gateway_handler.go
- handler.go
- license.go
- license_pack.go
- monitor.go
- netRules.go
- netRulesHandler.go
- plugin.go
- pod_action.go
- pod_handler.go
- proxy.go
- rootFunc.go
- rootFuncHandler.go
- service.go
- service_batch_operation.go
- service_check.go
- service_handler.go
- service_monitor.go
- service_operation.go
- service_plugin.go
- tenant.go
- tenant_handler.go
- tenantsResource.go
- third_party_service_handler.go
- tokenIden.go
- tokenIdenHandler.go
- types.go
- volume_type_handler.go