Versions in this module Expand all Collapse all v1 v1.0.1 Aug 15, 2024 Changes in this version + const DeployModePAAS + const DeployModeSAAS + const GatewayEndpoint + const GatewayProviderMSE + const GatewayProviderVendorKey + const ResourceApiGateway + const ResourceConfigCenter + const ResourceEtcd + const ResourceJvmProfiler + const ResourceLogAnalytics + const ResourceLogEs + const ResourceLogExporter + const ResourceLogService + const ResourceMonitor + const ResourceMonitorCollector + const ResourceMonitorKafka + const ResourceMonitorZk + const ResourceMysql + const ResourceNacos + const ResourcePostgresql + const ResourceRegisterCenter + const ResourceServiceMesh + const ResourceTerminusZKProxy + const ResourceZKProxy + const ResourceZookeeper + const RuntimeMaxUpTimeoutSeconds + const TmcInstanceStatusDeleteError + const TmcInstanceStatusDeleted + const TmcInstanceStatusError + const TmcInstanceStatusInit + const TmcInstanceStatusRunning + type DefaultDeployHandler struct + Bdl *bundle.Bundle + InstanceDb *db.InstanceDB + Log logs.Logger + TenantDb *db.InstanceTenantDB + TmcDb *db.TmcDB + TmcIniDb *db.TmcIniDB + TmcRequestRelationDb *db.TmcRequestRelationDB + TmcVersionDb *db.TmcVersionDB + func NewDefaultHandler(client *gorm.DB, log logs.Logger) *DefaultDeployHandler + func (h *DefaultDeployHandler) BuildDeployResult(tmcInstance *db.Instance, tenant *db.InstanceTenant) ResourceDeployResult + func (h *DefaultDeployHandler) BuildRequestRelation(parentRequest string, childRequest string) error + func (h *DefaultDeployHandler) BuildServiceGroupRequest(resourceInfo *ResourceInfo, tmcInstance *db.Instance, ...) interface{} + func (h *DefaultDeployHandler) BuildSubResourceDeployRequest(name string, addon *diceyml.AddOn, req *ResourceDeployRequest) *ResourceDeployRequest + func (h *DefaultDeployHandler) BuildTmcInstanceConfig(tmcInstance *db.Instance, serviceGroupDeployResult interface{}, ...) map[string]string + func (h *DefaultDeployHandler) Callback(url string, id string, success bool, config map[string]string, ...) error + func (h *DefaultDeployHandler) CheckIfHasCustomConfig(clusterConfig map[string]string) (map[string]string, bool) + func (h *DefaultDeployHandler) CheckIfNeedTmcInstance(req *ResourceDeployRequest, resourceInfo *ResourceInfo) (*db.Instance, bool, error) + func (h *DefaultDeployHandler) CheckIfNeedTmcInstanceTenant(req *ResourceDeployRequest, resourceInfo *ResourceInfo) (*db.InstanceTenant, bool, error) + func (h *DefaultDeployHandler) DeleteRequestRelation(parentId string, childId string) error + func (h *DefaultDeployHandler) DeleteTenant(tenant *db.InstanceTenant, tmcInstance *db.Instance, ...) error + func (h *DefaultDeployHandler) DeleteTmcInstance(tmcInstance *db.Instance, status string) error + func (h *DefaultDeployHandler) DoApplyTmcInstanceTenant(req *ResourceDeployRequest, resourceInfo *ResourceInfo, ...) (map[string]string, error) + func (h *DefaultDeployHandler) DoDeploy(serviceGroupDeployRequest interface{}, resourceInfo *ResourceInfo, ...) (interface{}, error) + func (h *DefaultDeployHandler) DoPostDeployJob(tmcInstance *db.Instance, serviceGroupDeployResult interface{}, ...) (map[string]string, error) + func (h *DefaultDeployHandler) DoPreDeployJob(resourceInfo *ResourceInfo, tmcInstance *db.Instance) error + func (h *DefaultDeployHandler) GetClusterConfig(az string) (map[string]string, error) + func (h *DefaultDeployHandler) GetDiceOperatorId() string + func (h *DefaultDeployHandler) GetInstanceById(id string) (instance *db.Instance, tenant *db.InstanceTenant, tmc *db.Tmc, ...) + func (h *DefaultDeployHandler) GetRelationResourceIds(parentId string) []string + func (h *DefaultDeployHandler) GetResourceInfo(req *ResourceDeployRequest) (*ResourceInfo, error) + func (h *DefaultDeployHandler) InitializeTmcInstance(req *ResourceDeployRequest, resourceInfo *ResourceInfo, ...) (*db.Instance, error) + func (h *DefaultDeployHandler) InitializeTmcInstanceTenant(req *ResourceDeployRequest, tmcInstance *db.Instance, ...) (*db.InstanceTenant, error) + func (h *DefaultDeployHandler) IsMatch(tmc *db.Tmc) bool + func (h *DefaultDeployHandler) IsNotDCOSCluster(clusterType string) bool + func (h *DefaultDeployHandler) UnDeploy(tmcInstance *db.Instance) error + func (h *DefaultDeployHandler) UpdateTmcInstanceOnCustom(tmcInstance *db.Instance, sgConfig map[string]string) error + func (h *DefaultDeployHandler) UpdateTmcInstanceOnFinish(tmcInstance *db.Instance, sgConfig map[string]string, sgStatus string) error + func (h *DefaultDeployHandler) UpdateTmcInstanceTenantOnFinish(tenant *db.InstanceTenant, config map[string]string) (*db.InstanceTenant, error) + type ResourceDeployHandler interface + BuildDeployResult func(tmcInstance *db.Instance, tenant *db.InstanceTenant) ResourceDeployResult + BuildRequestRelation func(parentRequest string, childRequest string) error + BuildServiceGroupRequest func(resourceInfo *ResourceInfo, tmcInstance *db.Instance, ...) interface{} + BuildSubResourceDeployRequest func(name string, addon *diceyml.AddOn, req *ResourceDeployRequest) *ResourceDeployRequest + BuildTmcInstanceConfig func(tmcInstance *db.Instance, serviceGroupDeployResult interface{}, ...) map[string]string + CheckIfHasCustomConfig func(clusterConfig map[string]string) (map[string]string, bool) + CheckIfNeedTmcInstance func(req *ResourceDeployRequest, resourceInfo *ResourceInfo) (*db.Instance, bool, error) + CheckIfNeedTmcInstanceTenant func(req *ResourceDeployRequest, resourceInfo *ResourceInfo) (*db.InstanceTenant, bool, error) + DeleteRequestRelation func(parentId string, childId string) error + DeleteTenant func(tenant *db.InstanceTenant, tmcInstance *db.Instance, ...) error + DeleteTmcInstance func(tmcInstance *db.Instance, status string) error + DoApplyTmcInstanceTenant func(req *ResourceDeployRequest, resourceInfo *ResourceInfo, ...) (map[string]string, error) + DoDeploy func(serviceGroupDeployRequest interface{}, resourceInfo *ResourceInfo, ...) (interface{}, error) + DoPostDeployJob func(tmcInstance *db.Instance, serviceGroupDeployResult interface{}, ...) (map[string]string, error) + DoPreDeployJob func(resourceInfo *ResourceInfo, tmcInstance *db.Instance) error + GetClusterConfig func(az string) (map[string]string, error) + GetRelationResourceIds func(parentId string) []string + GetResourceInfo func(req *ResourceDeployRequest) (*ResourceInfo, error) + InitializeTmcInstance func(req *ResourceDeployRequest, resourceInfo *ResourceInfo, ...) (*db.Instance, error) + InitializeTmcInstanceTenant func(req *ResourceDeployRequest, tmcInstance *db.Instance, ...) (*db.InstanceTenant, error) + IsMatch func(tmc *db.Tmc) bool + UnDeploy func(tmcInstance *db.Instance) error + UpdateTmcInstanceOnCustom func(tmcInstance *db.Instance, sgConfig map[string]string) error + UpdateTmcInstanceOnFinish func(tmcInstance *db.Instance, sgConfig map[string]string, sgStatus string) error + UpdateTmcInstanceTenantOnFinish func(tenant *db.InstanceTenant, config map[string]string) (*db.InstanceTenant, error) + type ResourceDeployRequest struct + Az string + Callback string + Engine string + Options map[string]string + Plan string + TenantGroup string + Uuid string + type ResourceDeployResult struct + Config map[string]string + CreatedTime time.Time + ID string + Options map[string]string + Status string + UpdatedTime time.Time + type ResourceInfo struct + Dice *diceyml.Object + Spec *apistructs.AddonExtension + Tmc *db.Tmc + TmcVersion *db.TmcVersion
Go to main page