Documentation ¶
Index ¶
- type AppBackupDaoImpl
- func (a *AppBackupDaoImpl) AddModel(mo model.Interface) error
- func (a *AppBackupDaoImpl) CheckHistory(groupID, version string) bool
- func (a *AppBackupDaoImpl) DeleteAppBackup(backupID string) error
- func (a *AppBackupDaoImpl) GetAppBackup(backupID string) (*model.AppBackup, error)
- func (a *AppBackupDaoImpl) GetAppBackups(groupID string) ([]*model.AppBackup, error)
- func (a *AppBackupDaoImpl) GetDeleteAppBackup(backupID string) (*model.AppBackup, error)
- func (a *AppBackupDaoImpl) GetDeleteAppBackups() ([]*model.AppBackup, error)
- func (a *AppBackupDaoImpl) UpdateModel(mo model.Interface) error
- type AppConfigGroupDaoImpl
- func (a *AppConfigGroupDaoImpl) AddModel(mo model.Interface) error
- func (a *AppConfigGroupDaoImpl) CreateOrUpdateConfigGroupsInBatch(cgroups []*model.ApplicationConfigGroup) error
- func (a *AppConfigGroupDaoImpl) DeleteByAppID(appID string) error
- func (a *AppConfigGroupDaoImpl) DeleteConfigGroup(appID, configGroupName string) error
- func (a *AppConfigGroupDaoImpl) GetConfigGroupByID(appID, configGroupName string) (*model.ApplicationConfigGroup, error)
- func (a *AppConfigGroupDaoImpl) GetConfigGroupsByAppID(appID string, page, pageSize int) ([]*model.ApplicationConfigGroup, int64, error)
- func (a *AppConfigGroupDaoImpl) ListByServiceID(sid string) ([]*model.ApplicationConfigGroup, error)
- func (a *AppConfigGroupDaoImpl) UpdateModel(mo model.Interface) error
- type AppConfigGroupItemDaoImpl
- func (a *AppConfigGroupItemDaoImpl) AddModel(mo model.Interface) error
- func (a *AppConfigGroupItemDaoImpl) CreateOrUpdateConfigGroupItemsInBatch(cgitems []*model.ConfigGroupItem) error
- func (a *AppConfigGroupItemDaoImpl) DeleteByAppID(appID string) error
- func (a *AppConfigGroupItemDaoImpl) DeleteConfigGroupItem(appID, configGroupName string) error
- func (a *AppConfigGroupItemDaoImpl) GetConfigGroupItemsByID(appID, configGroupName string) ([]*model.ConfigGroupItem, error)
- func (a *AppConfigGroupItemDaoImpl) ListByServiceID(sid string) ([]*model.ConfigGroupItem, error)
- func (a *AppConfigGroupItemDaoImpl) UpdateModel(mo model.Interface) error
- type AppConfigGroupServiceDaoImpl
- func (a *AppConfigGroupServiceDaoImpl) AddModel(mo model.Interface) error
- func (a *AppConfigGroupServiceDaoImpl) CreateOrUpdateConfigGroupServicesInBatch(cgservices []*model.ConfigGroupService) error
- func (a *AppConfigGroupServiceDaoImpl) DeleteByAppID(appID string) error
- func (a *AppConfigGroupServiceDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (a *AppConfigGroupServiceDaoImpl) DeleteConfigGroupService(appID, configGroupName string) error
- func (a *AppConfigGroupServiceDaoImpl) DeleteEffectiveServiceByServiceID(serviceID string) error
- func (a *AppConfigGroupServiceDaoImpl) GetConfigGroupServicesByID(appID, configGroupName string) ([]*model.ConfigGroupService, error)
- func (a *AppConfigGroupServiceDaoImpl) UpdateModel(mo model.Interface) error
- type AppDaoImpl
- type ApplicationDaoImpl
- func (a *ApplicationDaoImpl) AddModel(mo model.Interface) error
- func (a *ApplicationDaoImpl) DeleteApp(appID string) error
- func (a *ApplicationDaoImpl) GetAppByID(appID string) (*model.Application, error)
- func (a *ApplicationDaoImpl) GetByServiceID(sid string) (*model.Application, error)
- func (a *ApplicationDaoImpl) IsK8sAppDuplicate(tenantEnvID, AppID, k8sApp string) bool
- func (a *ApplicationDaoImpl) ListApps(tenantEnvID, appName string, page, pageSize int) ([]*model.Application, int64, error)
- func (a *ApplicationDaoImpl) ListByAppIDs(appIDs []string) ([]*model.Application, error)
- func (a *ApplicationDaoImpl) UpdateModel(mo model.Interface) error
- type CertificateDaoImpl
- type CodeCheckResultDaoImpl
- func (c *CodeCheckResultDaoImpl) AddModel(mo model.Interface) error
- func (c *CodeCheckResultDaoImpl) DeleteByServiceID(serviceID string) error
- func (c *CodeCheckResultDaoImpl) GetCodeCheckResult(serviceID string) (*model.CodeCheckResult, error)
- func (c *CodeCheckResultDaoImpl) UpdateModel(mo model.Interface) error
- type EndpointDaoImpl
- func (e *EndpointDaoImpl) AddModel(mo model.Interface) error
- func (e *EndpointDaoImpl) DelByUUID(uuid string) error
- func (e *EndpointDaoImpl) DeleteByServiceID(sid string) error
- func (e *EndpointDaoImpl) GetByUUID(uuid string) (*model.Endpoint, error)
- func (e *EndpointDaoImpl) List(sid string) ([]*model.Endpoint, error)
- func (e *EndpointDaoImpl) UpdateModel(mo model.Interface) error
- type EventDaoImpl
- func (c *EventDaoImpl) AddModel(mo model.Interface) error
- func (c *EventDaoImpl) CreateEventsInBatch(events []*model.ServiceEvent) error
- func (c *EventDaoImpl) DelEventByServiceID(serviceID string) error
- func (c *EventDaoImpl) DeleteEvents(eventIDs []string) error
- func (c *EventDaoImpl) GetEventByEventID(eventID string) (*model.ServiceEvent, error)
- func (c *EventDaoImpl) GetEventByEventIDs(eventIDs []string) ([]*model.ServiceEvent, error)
- func (c *EventDaoImpl) GetEventByServiceID(serviceID string) ([]*model.ServiceEvent, error)
- func (c *EventDaoImpl) GetEventsByTarget(target, targetID string, offset, limit int) ([]*model.ServiceEvent, int, error)
- func (c *EventDaoImpl) GetEventsByTenantEnvID(tenantEnvID string, offset, limit int) ([]*model.ServiceEvent, int, error)
- func (c *EventDaoImpl) GetLastASyncEvent(target, targetID string) (*model.ServiceEvent, error)
- func (c *EventDaoImpl) LatestFailurePodEvent(podName string) (*model.ServiceEvent, error)
- func (c *EventDaoImpl) ListByTargetID(targetID string) ([]*model.ServiceEvent, error)
- func (c *EventDaoImpl) SetEventStatus(ctx context.Context, status model.EventStatus) error
- func (c *EventDaoImpl) UnfinishedEvents(target, targetID string, optTypes ...string) ([]*model.ServiceEvent, error)
- func (c *EventDaoImpl) UpdateInBatch(events []*model.ServiceEvent) error
- func (c *EventDaoImpl) UpdateModel(mo model.Interface) error
- func (c *EventDaoImpl) UpdateReason(eventID string, reason string) error
- type GwRuleConfigDaoImpl
- func (t *GwRuleConfigDaoImpl) AddModel(mo model.Interface) error
- func (t *GwRuleConfigDaoImpl) CreateOrUpdateGwRuleConfigsInBatch(ruleConfigs []*model.GwRuleConfig) error
- func (t *GwRuleConfigDaoImpl) DeleteByRuleID(rid string) error
- func (t *GwRuleConfigDaoImpl) DeleteByRuleIDs(ruleIDs []string) error
- func (t *GwRuleConfigDaoImpl) ListByRuleID(rid string) ([]*model.GwRuleConfig, error)
- func (t *GwRuleConfigDaoImpl) UpdateModel(mo model.Interface) error
- type HTTPRuleDaoImpl
- func (h *HTTPRuleDaoImpl) AddModel(mo model.Interface) error
- func (h *HTTPRuleDaoImpl) CreateOrUpdateHTTPRuleInBatch(httpRules []*model.HTTPRule) error
- func (h *HTTPRuleDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (h *HTTPRuleDaoImpl) DeleteByComponentPort(componentID string, port int) error
- func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByID(id string) error
- func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID(serviceID string) error
- func (h *HTTPRuleDaoImpl) GetHTTPRuleByDomainAndHost(domain, path string) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) GetHTTPRuleByID(id string) (*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) GetHTTPRulesByCertificateID(certificateID string) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) ListByCertID(certID string) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) ListByComponentIDs(componentIDs []string) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) ListByComponentPort(componentID string, port int) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) ListByServiceID(serviceID string) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) UpdateModel(mo model.Interface) error
- type HTTPRuleRewriteDaoTmpl
- func (h *HTTPRuleRewriteDaoTmpl) AddModel(mo model.Interface) error
- func (h *HTTPRuleRewriteDaoTmpl) CreateOrUpdateHTTPRuleRewriteInBatch(httpRuleRewrites []*model.HTTPRuleRewrite) error
- func (h *HTTPRuleRewriteDaoTmpl) DeleteByHTTPRuleID(httpRuleID string) error
- func (h *HTTPRuleRewriteDaoTmpl) DeleteByHTTPRuleIDs(httpRuleIDs []string) error
- func (h *HTTPRuleRewriteDaoTmpl) ListByHTTPRuleID(httpRuleID string) ([]*model.HTTPRuleRewrite, error)
- func (h *HTTPRuleRewriteDaoTmpl) UpdateModel(mo model.Interface) error
- type LicenseDaoImpl
- type LocalSchedulerDaoImpl
- type NotificationEventDaoImpl
- func (c *NotificationEventDaoImpl) AddModel(mo model.Interface) error
- func (c *NotificationEventDaoImpl) GetNotificationEventByHash(hash string) (*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) GetNotificationEventByKind(kind, kindID string) ([]*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) GetNotificationEventByTime(start, end time.Time) ([]*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) GetNotificationEventNotHandle() ([]*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) UpdateModel(mo model.Interface) error
- type PluginBuildVersionDaoImpl
- func (t *PluginBuildVersionDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginBuildVersionDaoImpl) CreateOrUpdatePluginBuildVersionsInBatch(buildVersions []*model.TenantEnvPluginBuildVersion) error
- func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByPluginID(pluginID string) error
- func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByVersionID(versionID string) error
- func (t *PluginBuildVersionDaoImpl) GetBuildVersionByDeployVersion(pluginID, versionID, deployVersion string) (*model.TenantEnvPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) GetBuildVersionByPluginID(pluginID string) ([]*model.TenantEnvPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) GetBuildVersionByVersionID(pluginID, versionID string) (*model.TenantEnvPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID(pluginID, versionID string) (*model.TenantEnvPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) ListSuccessfulOnesByPluginIDs(pluginIDs []string) ([]*model.TenantEnvPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) UpdateModel(mo model.Interface) error
- type PluginDaoImpl
- func (t *PluginDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginDaoImpl) CreateOrUpdatePluginsInBatch(plugins []*model.TenantEnvPlugin) error
- func (t *PluginDaoImpl) DeletePluginByID(id, tenantEnvID string) error
- func (t *PluginDaoImpl) GetPluginByID(id, tenantEnvID string) (*model.TenantEnvPlugin, error)
- func (t *PluginDaoImpl) GetPluginsByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvPlugin, error)
- func (t *PluginDaoImpl) ListByIDs(ids []string) ([]*model.TenantEnvPlugin, error)
- func (t *PluginDaoImpl) ListByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvPlugin, error)
- func (t *PluginDaoImpl) UpdateModel(mo model.Interface) error
- type PluginDefaultENVDaoImpl
- func (t *PluginDefaultENVDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginDefaultENVDaoImpl) DeleteAllDefaultENVByPluginID(pluginID string) error
- func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByName(pluginID, name, versionID string) error
- func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByPluginIDAndVersionID(pluginID, versionID string) error
- func (t *PluginDefaultENVDaoImpl) GetALLMasterDefultENVs(pluginID string) ([]*model.TenantEnvPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) GetDefaultENVByName(pluginID, name, versionID string) (*model.TenantEnvPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID(pluginID, versionID string) ([]*model.TenantEnvPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID(pluginID, versionID string) ([]*model.TenantEnvPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) UpdateModel(mo model.Interface) error
- type PluginVersionConfigDaoImpl
- func (t *PluginVersionConfigDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginVersionConfigDaoImpl) CreateOrUpdatePluginVersionConfigsInBatch(versionConfigs []*model.TenantEnvPluginVersionDiscoverConfig) error
- func (t *PluginVersionConfigDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *PluginVersionConfigDaoImpl) DeletePluginConfig(serviceID, pluginID string) error
- func (t *PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID(serviceID string) error
- func (t *PluginVersionConfigDaoImpl) GetPluginConfig(serviceID, pluginID string) (*model.TenantEnvPluginVersionDiscoverConfig, error)
- func (t *PluginVersionConfigDaoImpl) GetPluginConfigs(serviceID string) ([]*model.TenantEnvPluginVersionDiscoverConfig, error)
- func (t *PluginVersionConfigDaoImpl) UpdateModel(mo model.Interface) error
- type PluginVersionEnvDaoImpl
- func (t *PluginVersionEnvDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginVersionEnvDaoImpl) CreateOrUpdatePluginVersionEnvsInBatch(versionEnvs []*model.TenantEnvPluginVersionEnv) error
- func (t *PluginVersionEnvDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *PluginVersionEnvDaoImpl) DeleteEnvByEnvName(envName, pluginID, serviceID string) error
- func (t *PluginVersionEnvDaoImpl) DeleteEnvByPluginID(serviceID, pluginID string) error
- func (t *PluginVersionEnvDaoImpl) DeleteEnvByServiceID(serviceID string) error
- func (t *PluginVersionEnvDaoImpl) GetVersionEnvByEnvName(serviceID, pluginID, envName string) (*model.TenantEnvPluginVersionEnv, error)
- func (t *PluginVersionEnvDaoImpl) GetVersionEnvByServiceID(serviceID string, pluginID string) ([]*model.TenantEnvPluginVersionEnv, error)
- func (t *PluginVersionEnvDaoImpl) ListByServiceID(serviceID string) ([]*model.TenantEnvPluginVersionEnv, error)
- func (t *PluginVersionEnvDaoImpl) UpdateModel(mo model.Interface) error
- type RegionAPIClassDaoImpl
- func (t *RegionAPIClassDaoImpl) AddModel(mo model.Interface) error
- func (t *RegionAPIClassDaoImpl) DeletePrefixInClass(apiClass, prefix string) error
- func (t *RegionAPIClassDaoImpl) GetPrefixesByClass(apiClass string) ([]*model.RegionAPIClass, error)
- func (t *RegionAPIClassDaoImpl) UpdateModel(mo model.Interface) error
- type RuleExtensionDaoImpl
- func (c *RuleExtensionDaoImpl) AddModel(mo model.Interface) error
- func (c *RuleExtensionDaoImpl) CreateOrUpdateRuleExtensionsInBatch(exts []*model.RuleExtension) error
- func (c *RuleExtensionDaoImpl) DeleteByRuleIDs(ruleIDs []string) error
- func (c *RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID(ruleID string) error
- func (c *RuleExtensionDaoImpl) GetRuleExtensionByRuleID(ruleID string) ([]*model.RuleExtension, error)
- func (c *RuleExtensionDaoImpl) UpdateModel(model.Interface) error
- type ServiceLabelDaoImpl
- func (t *ServiceLabelDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceLabelDaoImpl) CreateOrUpdateLabelsInBatch(labels []*model.TenantEnvServiceLabel) error
- func (t *ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByLabelValuesAndServiceID(serviceID string) error
- func (t *ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByServiceIDKey(serviceID string, labelKey string) error
- func (t *ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByServiceIDKeyValue(serviceID string, labelKey string, labelValue string) error
- func (t *ServiceLabelDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *ServiceLabelDaoImpl) DeleteLabelByServiceID(serviceID string) error
- func (t *ServiceLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceLabelDaoImpl) GetLabelByNodeSelectorKey(serviceID string, labelValue string) (*model.TenantEnvServiceLabel, error)
- func (t *ServiceLabelDaoImpl) GetPrivilegedLabel(serviceID string) (*model.TenantEnvServiceLabel, error)
- func (t *ServiceLabelDaoImpl) GetTenantEnvNodeAffinityLabel(serviceID string) (*model.TenantEnvServiceLabel, error)
- func (t *ServiceLabelDaoImpl) GetTenantEnvServiceAffinityLabel(serviceID string) ([]*model.TenantEnvServiceLabel, error)
- func (t *ServiceLabelDaoImpl) GetTenantEnvServiceLabel(serviceID string) ([]*model.TenantEnvServiceLabel, error)
- func (t *ServiceLabelDaoImpl) GetTenantEnvServiceNodeSelectorLabel(serviceID string) ([]*model.TenantEnvServiceLabel, error)
- func (t *ServiceLabelDaoImpl) GetTenantEnvServiceTypeLabel(serviceID string) (*model.TenantEnvServiceLabel, error)
- func (t *ServiceLabelDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceProbeDaoImpl
- func (t *ServiceProbeDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceProbeDaoImpl) CreateOrUpdateProbesInBatch(probes []*model.TenantEnvServiceProbe) error
- func (t *ServiceProbeDaoImpl) DELServiceProbesByServiceID(serviceID string) error
- func (t *ServiceProbeDaoImpl) DelByServiceID(sid string) error
- func (t *ServiceProbeDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *ServiceProbeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceProbeDaoImpl) GetServiceProbes(serviceID string) ([]*model.TenantEnvServiceProbe, error)
- func (t *ServiceProbeDaoImpl) GetServiceUsedProbe(serviceID, mode string) (*model.TenantEnvServiceProbe, error)
- func (t *ServiceProbeDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceSchedulingLabelDaoImpl
- func (t *ServiceSchedulingLabelDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceSchedulingLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceSchedulingLabelDaoImpl) GetServiceSchedulingLabelByKey(serviceID, key string) (*model.TenantEnvServiceSchedulingLabel, error)
- func (t *ServiceSchedulingLabelDaoImpl) ListServiceSchedulingLabels(serviceID string) ([]*model.TenantEnvServiceSchedulingLabel, error)
- func (t *ServiceSchedulingLabelDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceSchedulingNodeDaoImpl
- func (t *ServiceSchedulingNodeDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceSchedulingNodeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceSchedulingNodeDaoImpl) ListServiceSchedulingNodes(serviceID string) ([]*model.TenantEnvServiceSchedulingNode, error)
- func (t *ServiceSchedulingNodeDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceSchedulingTolerationDaoImpl
- func (t *ServiceSchedulingTolerationDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceSchedulingTolerationDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceSchedulingTolerationDaoImpl) GetServiceSchedulingTolerationByKey(serviceID, key string) (*model.TenantEnvServiceSchedulingToleration, error)
- func (t *ServiceSchedulingTolerationDaoImpl) ListServiceSchedulingTolerations(serviceID string) ([]*model.TenantEnvServiceSchedulingToleration, error)
- func (t *ServiceSchedulingTolerationDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceSourceImpl
- type TCPRuleDaoTmpl
- func (t *TCPRuleDaoTmpl) AddModel(mo model.Interface) error
- func (t *TCPRuleDaoTmpl) CreateOrUpdateTCPRuleInBatch(tcpRules []*model.TCPRule) error
- func (t *TCPRuleDaoTmpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TCPRuleDaoTmpl) DeleteByComponentPort(componentID string, port int) error
- func (t *TCPRuleDaoTmpl) DeleteByID(uuid string) error
- func (t *TCPRuleDaoTmpl) DeleteTCPRuleByServiceID(serviceID string) error
- func (t *TCPRuleDaoTmpl) GetTCPRuleByID(id string) (*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceID(sid string) ([]*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) GetUsedPortsByIP(ip string) ([]*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) ListByServiceID(serviceID string) ([]*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) UpdateModel(mo model.Interface) error
- type TenantEnvDaoImpl
- func (t *TenantEnvDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvDaoImpl) DelByTenantEnvID(tenantEnvID string) error
- func (t *TenantEnvDaoImpl) GetAllTenantEnvs(query string) ([]*model.TenantEnvs, error)
- func (t *TenantEnvDaoImpl) GetPagedTenantEnvs(offset, len int) ([]*model.TenantEnvs, error)
- func (t *TenantEnvDaoImpl) GetTenantEnvByUUID(uuid string) (*model.TenantEnvs, error)
- func (t *TenantEnvDaoImpl) GetTenantEnvByUUIDIsExist(uuid string) bool
- func (t *TenantEnvDaoImpl) GetTenantEnvIDByName(tenantName, tenantEnvName string) (*model.TenantEnvs, error)
- func (t *TenantEnvDaoImpl) GetTenantEnvIDsByNames(tenantName string, tenantEnvNames []string) (re []string, err error)
- func (t *TenantEnvDaoImpl) GetTenantEnvLimitsByNames(tenantName string, tenantEnvNames []string) (limit map[string]int, err error)
- func (t *TenantEnvDaoImpl) GetTenantEnvs(tenantName string, query string) ([]*model.TenantEnvs, error)
- func (t *TenantEnvDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceAutoscalerRuleMetricsDaoImpl
- func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) CreateOrUpdateScaleRuleMetricsInBatch(metrics []*model.TenantEnvServiceAutoscalerRuleMetrics) error
- func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) DeleteByRuleID(ruldID string) error
- func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) DeleteByRuleIDs(ruleIDs []string) error
- func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) ListByRuleID(ruleID string) ([]*model.TenantEnvServiceAutoscalerRuleMetrics, error)
- func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) UpdateModel(mo model.Interface) error
- func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate(metric *model.TenantEnvServiceAutoscalerRuleMetrics) error
- type TenantEnvServiceAutoscalerRulesDaoImpl
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) CreateOrUpdateScaleRulesInBatch(rules []*model.TenantEnvServiceAutoscalerRules) error
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) DeleteByRuleID(ruleID string) error
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) GetByRuleID(ruleID string) (*model.TenantEnvServiceAutoscalerRules, error)
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) ListByComponentIDs(componentIDs []string) ([]*model.TenantEnvServiceAutoscalerRules, error)
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) ListByServiceID(serviceID string) ([]*model.TenantEnvServiceAutoscalerRules, error)
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID(serviceID string) ([]*model.TenantEnvServiceAutoscalerRules, error)
- func (t *TenantEnvServiceAutoscalerRulesDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceConfigFileDaoImpl
- func (t *TenantEnvServiceConfigFileDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceConfigFileDaoImpl) CreateOrUpdateConfigFilesInBatch(configFiles []*model.TenantEnvServiceConfigFile) error
- func (t *TenantEnvServiceConfigFileDaoImpl) DelByServiceID(sid string) error
- func (t *TenantEnvServiceConfigFileDaoImpl) DelByVolumeID(sid, volumeName string) error
- func (t *TenantEnvServiceConfigFileDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServiceConfigFileDaoImpl) GetByVolumeName(sid string, volumeName string) (*model.TenantEnvServiceConfigFile, error)
- func (t *TenantEnvServiceConfigFileDaoImpl) GetConfigFileByServiceID(serviceID string) ([]*model.TenantEnvServiceConfigFile, error)
- func (t *TenantEnvServiceConfigFileDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceEnvVarDaoImpl
- func (t *TenantEnvServiceEnvVarDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceEnvVarDaoImpl) CreateOrUpdateEnvsInBatch(envs []*model.TenantEnvServiceEnvVar) error
- func (t *TenantEnvServiceEnvVarDaoImpl) DELServiceEnvsByServiceID(serviceID string) error
- func (t *TenantEnvServiceEnvVarDaoImpl) DelByServiceIDAndScope(sid, scope string) error
- func (t *TenantEnvServiceEnvVarDaoImpl) DeleteByComponentID(componentID string) error
- func (t *TenantEnvServiceEnvVarDaoImpl) DeleteByComponentIDAndScope(componentID, scope string) error
- func (t *TenantEnvServiceEnvVarDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServiceEnvVarDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantEnvServiceEnvVarDaoImpl) GetDependServiceEnvs(serviceIDs []string, scopes []string) ([]*model.TenantEnvServiceEnvVar, error)
- func (t *TenantEnvServiceEnvVarDaoImpl) GetEnv(serviceID, envName string) (*model.TenantEnvServiceEnvVar, error)
- func (t *TenantEnvServiceEnvVarDaoImpl) GetServiceEnvs(serviceID string, scopes []string) ([]*model.TenantEnvServiceEnvVar, error)
- func (t *TenantEnvServiceEnvVarDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceLBMappingPortDaoImpl
- func (t *TenantEnvServiceLBMappingPortDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceLBMappingPortDaoImpl) CreateTenantEnvServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantEnvServiceLBMappingPort, error)
- func (t *TenantEnvServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID(serviceID string) error
- func (t *TenantEnvServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort(serviceID string, lbport int) error
- func (t *TenantEnvServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort(serviceID string, port int) (*model.TenantEnvServiceLBMappingPort, error)
- func (t *TenantEnvServiceLBMappingPortDaoImpl) GetLBPortByTenantEnvAndPort(tenantEnvID string, lbport int) (*model.TenantEnvServiceLBMappingPort, error)
- func (t *TenantEnvServiceLBMappingPortDaoImpl) GetLBPortsASC() ([]*model.TenantEnvServiceLBMappingPort, error)
- func (t *TenantEnvServiceLBMappingPortDaoImpl) GetTenantEnvServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantEnvServiceLBMappingPort, error)
- func (t *TenantEnvServiceLBMappingPortDaoImpl) GetTenantEnvServiceLBMappingPortByService(serviceID string) ([]*model.TenantEnvServiceLBMappingPort, error)
- func (t *TenantEnvServiceLBMappingPortDaoImpl) PortExists(port int) bool
- func (t *TenantEnvServiceLBMappingPortDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceMonitorDaoImpl
- func (t *TenantEnvServiceMonitorDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceMonitorDaoImpl) CreateOrUpdateMonitorInBatch(monitors []*model.TenantEnvServiceMonitor) error
- func (t *TenantEnvServiceMonitorDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServiceMonitorDaoImpl) DeleteServiceMonitor(mo *model.TenantEnvServiceMonitor) error
- func (t *TenantEnvServiceMonitorDaoImpl) DeleteServiceMonitorByServiceID(serviceID string) error
- func (t *TenantEnvServiceMonitorDaoImpl) GetByName(serviceID, name string) (*model.TenantEnvServiceMonitor, error)
- func (t *TenantEnvServiceMonitorDaoImpl) GetByServiceID(serviceID string) ([]*model.TenantEnvServiceMonitor, error)
- func (t *TenantEnvServiceMonitorDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceMountRelationDaoImpl
- func (t *TenantEnvServiceMountRelationDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceMountRelationDaoImpl) CreateOrUpdateVolumeRelsInBatch(volRels []*model.TenantEnvServiceMountRelation) error
- func (t *TenantEnvServiceMountRelationDaoImpl) DELTenantEnvServiceMountRelationByServiceID(serviceID string) error
- func (t *TenantEnvServiceMountRelationDaoImpl) DElTenantEnvServiceMountRelationByDepService(serviceID, depServiceID string) error
- func (t *TenantEnvServiceMountRelationDaoImpl) DElTenantEnvServiceMountRelationByServiceAndName(serviceID, name string) error
- func (t *TenantEnvServiceMountRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServiceMountRelationDaoImpl) GetTenantEnvServiceMountRelationsByService(serviceID string) ([]*model.TenantEnvServiceMountRelation, error)
- func (t *TenantEnvServiceMountRelationDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServicePluginRelationDaoImpl
- func (t *TenantEnvServicePluginRelationDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServicePluginRelationDaoImpl) CheckPluginBeforeInstall(serviceID, pluginModel string) (bool, error)
- func (t *TenantEnvServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID(serviceID, pluginModel string) (bool, error)
- func (t *TenantEnvServicePluginRelationDaoImpl) CreateOrUpdatePluginRelsInBatch(relations []*model.TenantEnvServicePluginRelation) error
- func (t *TenantEnvServicePluginRelationDaoImpl) DeleteALLRelationByPluginID(pluginID string) error
- func (t *TenantEnvServicePluginRelationDaoImpl) DeleteALLRelationByServiceID(serviceID string) error
- func (t *TenantEnvServicePluginRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID(serviceID, pluginID string) error
- func (t *TenantEnvServicePluginRelationDaoImpl) GetALLRelationByServiceID(serviceID string) ([]*model.TenantEnvServicePluginRelation, error)
- func (t *TenantEnvServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID(serviceID, pluginID string) (*model.TenantEnvServicePluginRelation, error)
- func (t *TenantEnvServicePluginRelationDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceRelationDaoImpl
- func (t *TenantEnvServiceRelationDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceRelationDaoImpl) CreateOrUpdateRelationsInBatch(relations []*model.TenantEnvServiceRelation) error
- func (t *TenantEnvServiceRelationDaoImpl) DELRelationsByServiceID(serviceID string) error
- func (t *TenantEnvServiceRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServiceRelationDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantEnvServiceRelationDaoImpl) DeleteRelationByDepID(serviceID, depID string) error
- func (t *TenantEnvServiceRelationDaoImpl) GetTenantEnvServiceRelations(serviceID string) ([]*model.TenantEnvServiceRelation, error)
- func (t *TenantEnvServiceRelationDaoImpl) GetTenantEnvServiceRelationsByDependServiceID(dependServiceID string) ([]*model.TenantEnvServiceRelation, error)
- func (t *TenantEnvServiceRelationDaoImpl) HaveRelations(serviceID string) bool
- func (t *TenantEnvServiceRelationDaoImpl) ListByServiceIDs(serviceIDs []string) ([]*model.TenantEnvServiceRelation, error)
- func (t *TenantEnvServiceRelationDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServiceScalingRecordsDaoImpl
- func (t *TenantEnvServiceScalingRecordsDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceScalingRecordsDaoImpl) CountByServiceID(serviceID string) (int, error)
- func (t *TenantEnvServiceScalingRecordsDaoImpl) ListByServiceID(serviceID string, offset, limit int) ([]*model.TenantEnvServiceScalingRecords, error)
- func (t *TenantEnvServiceScalingRecordsDaoImpl) UpdateModel(mo model.Interface) error
- func (t *TenantEnvServiceScalingRecordsDaoImpl) UpdateOrCreate(new *model.TenantEnvServiceScalingRecords) error
- type TenantEnvServiceVolumeDaoImpl
- func (t *TenantEnvServiceVolumeDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServiceVolumeDaoImpl) CreateOrUpdateVolumesInBatch(volumes []*model.TenantEnvServiceVolume) error
- func (t *TenantEnvServiceVolumeDaoImpl) DelShareableBySID(sid string) error
- func (t *TenantEnvServiceVolumeDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath(serviceID string, volumePath string) error
- func (t *TenantEnvServiceVolumeDaoImpl) DeleteByVolumeIDs(volumeIDs []uint) error
- func (t *TenantEnvServiceVolumeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantEnvServiceVolumeDaoImpl) DeleteTenantEnvServiceVolumesByServiceID(serviceID string) error
- func (t *TenantEnvServiceVolumeDaoImpl) GetAllVolumes() ([]*model.TenantEnvServiceVolume, error)
- func (t *TenantEnvServiceVolumeDaoImpl) GetTenantEnvServiceVolumesByServiceID(serviceID string) ([]*model.TenantEnvServiceVolume, error)
- func (t *TenantEnvServiceVolumeDaoImpl) GetVolumeByID(id int) (*model.TenantEnvServiceVolume, error)
- func (t *TenantEnvServiceVolumeDaoImpl) GetVolumeByServiceIDAndName(serviceID, name string) (*model.TenantEnvServiceVolume, error)
- func (t *TenantEnvServiceVolumeDaoImpl) ListVolumesByComponentIDs(componentIDs []string) ([]*model.TenantEnvServiceVolume, error)
- func (t *TenantEnvServiceVolumeDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServicesDaoImpl
- func (t *TenantEnvServicesDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServicesDaoImpl) BindAppByServiceIDs(appID string, serviceIDs []string) error
- func (t *TenantEnvServicesDaoImpl) CountServiceByAppID(appID string) (int64, error)
- func (t *TenantEnvServicesDaoImpl) CreateOrUpdateComponentsInBatch(components []*model.TenantEnvServices) error
- func (t *TenantEnvServicesDaoImpl) DeleteByComponentIDs(tenantEnvID, appID string, componentIDs []string) error
- func (t *TenantEnvServicesDaoImpl) DeleteServiceByServiceID(serviceID string) error
- func (t *TenantEnvServicesDaoImpl) GetAllServicesID() ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetPagedTenantEnvService(offset, length int, serviceIDs []string) ([]map[string]interface{}, int, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceAliasByIDs(uids []string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceByID(serviceID string) (*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceByIDs(uids []string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceByServiceAlias(serviceAlias string) (*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceByTenantEnvIDAndServiceAlias(tenantEnvID, serviceName string) (*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceIDsByAppID(appID string) (re []model.ServiceID)
- func (t *TenantEnvServicesDaoImpl) GetServiceMemoryByServiceIDs(serviceIDs []string) (map[string]map[string]interface{}, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceMemoryByTenantEnvIDs(tenantEnvIDs []string, runningServiceIDs []string) (map[string]map[string]interface{}, error)
- func (t *TenantEnvServicesDaoImpl) GetServiceTypeByID(serviceID string) (*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServicesAllInfoByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServicesByServiceIDs(serviceIDs []string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServicesByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServicesByTenantEnvIDs(tenantEnvIDs []string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) GetServicesInfoByAppID(appID string, page, pageSize int) ([]*model.TenantEnvServices, int64, error)
- func (t *TenantEnvServicesDaoImpl) IsK8sComponentNameDuplicate(appID, serviceID, k8sComponentName string) bool
- func (t *TenantEnvServicesDaoImpl) ListByAppID(appID string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) ListServicesByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) ListThirdPartyServices() ([]*model.TenantEnvServices, error)
- func (t *TenantEnvServicesDaoImpl) SetTenantEnvServiceStatus(serviceID, status string) error
- func (t *TenantEnvServicesDaoImpl) UpdateDeployVersion(serviceID, deployversion string) error
- func (t *TenantEnvServicesDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServicesDeleteImpl
- func (t *TenantEnvServicesDeleteImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServicesDeleteImpl) DeleteTenantEnvServicesDelete(record *model.TenantEnvServicesDelete) error
- func (t *TenantEnvServicesDeleteImpl) GetServiceByID(serviceID string) (*model.TenantEnvServicesDelete, error)
- func (t *TenantEnvServicesDeleteImpl) GetTenantEnvServicesDeleteByCreateTime(createTime time.Time) ([]*model.TenantEnvServicesDelete, error)
- func (t *TenantEnvServicesDeleteImpl) List() ([]*model.TenantEnvServicesDelete, error)
- func (t *TenantEnvServicesDeleteImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServicesPortDaoImpl
- func (t *TenantEnvServicesPortDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServicesPortDaoImpl) CreateOrUpdatePortsInBatch(ports []*model.TenantEnvServicesPort) error
- func (t *TenantEnvServicesPortDaoImpl) DELPortsByServiceID(serviceID string) error
- func (t *TenantEnvServicesPortDaoImpl) DelByServiceID(sid string) error
- func (t *TenantEnvServicesPortDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServicesPortDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantEnvServicesPortDaoImpl) GetByTenantEnvAndName(tenantEnvID, name string) (*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) GetDepUDPPort(serviceID string) ([]*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) GetInnerPorts(serviceID string) ([]*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) GetOpenedPorts(serviceID string) ([]*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) GetOuterPorts(serviceID string) ([]*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) GetPort(serviceID string, port int) (*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) GetPortsByServiceID(serviceID string) ([]*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) HasOpenPort(sid string) bool
- func (t *TenantEnvServicesPortDaoImpl) ListByK8sServiceNames(k8sServiceNames []string) ([]*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) ListInnerPortsByServiceIDs(serviceIDs []string) ([]*model.TenantEnvServicesPort, error)
- func (t *TenantEnvServicesPortDaoImpl) UpdateModel(mo model.Interface) error
- type TenantEnvServicesStreamPluginPortDaoImpl
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) CreateOrUpdateStreamPluginPortsInBatch(spPorts []*model.TenantEnvServicesStreamPluginPort) error
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID(serviceID string) error
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort(serviceID string, pluginModel string, containerPort int) error
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort(serviceID string, pluginModel string, containerPort int) (*model.TenantEnvServicesStreamPluginPort, error)
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) GetPluginMappingPorts(serviceID string) ([]*model.TenantEnvServicesStreamPluginPort, error)
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) ListByServiceID(sid string) ([]*model.TenantEnvServicesStreamPluginPort, error)
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) SetPluginMappingPort(tenantEnvID string, serviceID string, pluginModel string, containerPort int) (int, error)
- func (t *TenantEnvServicesStreamPluginPortDaoImpl) UpdateModel(mo model.Interface) error
- type ThirdPartySvcDiscoveryCfgDaoImpl
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) AddModel(mo model.Interface) error
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) CreateOrUpdate3rdSvcDiscoveryCfgInBatch(cfgs []*model.ThirdPartySvcDiscoveryCfg) error
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByComponentIDs(componentIDs []string) error
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID(sid string) error
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID(sid string) (*model.ThirdPartySvcDiscoveryCfg, error)
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) UpdateModel(mo model.Interface) error
- type VersionInfoDaoImpl
- func (c *VersionInfoDaoImpl) AddModel(mo model.Interface) error
- func (c *VersionInfoDaoImpl) DeleteFailureVersionInfo(timePoint time.Time, status string, serviceIDs []string) error
- func (c *VersionInfoDaoImpl) DeleteVersionByEventID(eventID string) error
- func (c *VersionInfoDaoImpl) DeleteVersionByServiceID(serviceID string) error
- func (c *VersionInfoDaoImpl) DeleteVersionInfo(obj *model.VersionInfo) error
- func (c *VersionInfoDaoImpl) GetAllVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) GetLatestScsVersion(sid string) (*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) GetVersionByDeployVersion(version, serviceID string) (*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) GetVersionByEventID(eventID string) (*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) GetVersionInfo(timePoint time.Time, serviceIDs []string) ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) ListByServiceIDStatus(serviceID string, finalStatus *bool) ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) ListSuccessfulOnes() ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) ListVersionsByComponentIDs(componentIDs []string) ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) SearchVersionInfo() ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) UpdateModel(mo model.Interface) error
- type VolumeTypeDaoImpl
- func (vtd *VolumeTypeDaoImpl) AddModel(mo model.Interface) error
- func (vtd *VolumeTypeDaoImpl) CreateOrUpdateVolumeType(vt *model.TenantEnvServiceVolumeType) (*model.TenantEnvServiceVolumeType, error)
- func (vtd *VolumeTypeDaoImpl) DeleteModelByVolumeTypes(volumeType string) error
- func (vtd *VolumeTypeDaoImpl) GetAllVolumeTypes() ([]*model.TenantEnvServiceVolumeType, error)
- func (vtd *VolumeTypeDaoImpl) GetAllVolumeTypesByPage(page int, pageSize int) ([]*model.TenantEnvServiceVolumeType, error)
- func (vtd *VolumeTypeDaoImpl) GetVolumeTypeByType(vt string) (*model.TenantEnvServiceVolumeType, error)
- func (vtd *VolumeTypeDaoImpl) UpdateModel(mo model.Interface) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppBackupDaoImpl ¶
AppBackupDaoImpl group app backup info store mysql impl
func (*AppBackupDaoImpl) AddModel ¶
func (a *AppBackupDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*AppBackupDaoImpl) CheckHistory ¶
func (a *AppBackupDaoImpl) CheckHistory(groupID, version string) bool
CheckHistory CheckHistory
func (*AppBackupDaoImpl) DeleteAppBackup ¶
func (a *AppBackupDaoImpl) DeleteAppBackup(backupID string) error
DeleteAppBackup DeleteAppBackup
func (*AppBackupDaoImpl) GetAppBackup ¶
func (a *AppBackupDaoImpl) GetAppBackup(backupID string) (*model.AppBackup, error)
GetAppBackup GetAppBackup
func (*AppBackupDaoImpl) GetAppBackups ¶
func (a *AppBackupDaoImpl) GetAppBackups(groupID string) ([]*model.AppBackup, error)
GetAppBackups GetAppBackups
func (*AppBackupDaoImpl) GetDeleteAppBackup ¶
func (a *AppBackupDaoImpl) GetDeleteAppBackup(backupID string) (*model.AppBackup, error)
GetDeleteAppBackup GetDeleteAppBackup
func (*AppBackupDaoImpl) GetDeleteAppBackups ¶
func (a *AppBackupDaoImpl) GetDeleteAppBackups() ([]*model.AppBackup, error)
GetDeleteAppBackups GetDeleteAppBackups
func (*AppBackupDaoImpl) UpdateModel ¶
func (a *AppBackupDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel
type AppConfigGroupDaoImpl ¶
AppConfigGroupDaoImpl -
func (*AppConfigGroupDaoImpl) AddModel ¶
func (a *AppConfigGroupDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*AppConfigGroupDaoImpl) CreateOrUpdateConfigGroupsInBatch ¶
func (a *AppConfigGroupDaoImpl) CreateOrUpdateConfigGroupsInBatch(cgroups []*model.ApplicationConfigGroup) error
CreateOrUpdateConfigGroupsInBatch -
func (*AppConfigGroupDaoImpl) DeleteByAppID ¶
func (a *AppConfigGroupDaoImpl) DeleteByAppID(appID string) error
DeleteByAppID -
func (*AppConfigGroupDaoImpl) DeleteConfigGroup ¶
func (a *AppConfigGroupDaoImpl) DeleteConfigGroup(appID, configGroupName string) error
DeleteConfigGroup -
func (*AppConfigGroupDaoImpl) GetConfigGroupByID ¶
func (a *AppConfigGroupDaoImpl) GetConfigGroupByID(appID, configGroupName string) (*model.ApplicationConfigGroup, error)
GetConfigGroupByID -
func (*AppConfigGroupDaoImpl) GetConfigGroupsByAppID ¶
func (a *AppConfigGroupDaoImpl) GetConfigGroupsByAppID(appID string, page, pageSize int) ([]*model.ApplicationConfigGroup, int64, error)
GetConfigGroupsByAppID -
func (*AppConfigGroupDaoImpl) ListByServiceID ¶
func (a *AppConfigGroupDaoImpl) ListByServiceID(sid string) ([]*model.ApplicationConfigGroup, error)
ListByServiceID -
func (*AppConfigGroupDaoImpl) UpdateModel ¶
func (a *AppConfigGroupDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type AppConfigGroupItemDaoImpl ¶
AppConfigGroupItemDaoImpl -
func (*AppConfigGroupItemDaoImpl) AddModel ¶
func (a *AppConfigGroupItemDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*AppConfigGroupItemDaoImpl) CreateOrUpdateConfigGroupItemsInBatch ¶
func (a *AppConfigGroupItemDaoImpl) CreateOrUpdateConfigGroupItemsInBatch(cgitems []*model.ConfigGroupItem) error
CreateOrUpdateConfigGroupItemsInBatch -
func (*AppConfigGroupItemDaoImpl) DeleteByAppID ¶
func (a *AppConfigGroupItemDaoImpl) DeleteByAppID(appID string) error
DeleteByAppID -
func (*AppConfigGroupItemDaoImpl) DeleteConfigGroupItem ¶
func (a *AppConfigGroupItemDaoImpl) DeleteConfigGroupItem(appID, configGroupName string) error
DeleteConfigGroupItem -
func (*AppConfigGroupItemDaoImpl) GetConfigGroupItemsByID ¶
func (a *AppConfigGroupItemDaoImpl) GetConfigGroupItemsByID(appID, configGroupName string) ([]*model.ConfigGroupItem, error)
GetConfigGroupItemsByID -
func (*AppConfigGroupItemDaoImpl) ListByServiceID ¶
func (a *AppConfigGroupItemDaoImpl) ListByServiceID(sid string) ([]*model.ConfigGroupItem, error)
ListByServiceID -
func (*AppConfigGroupItemDaoImpl) UpdateModel ¶
func (a *AppConfigGroupItemDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type AppConfigGroupServiceDaoImpl ¶
AppConfigGroupServiceDaoImpl -
func (*AppConfigGroupServiceDaoImpl) AddModel ¶
func (a *AppConfigGroupServiceDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*AppConfigGroupServiceDaoImpl) CreateOrUpdateConfigGroupServicesInBatch ¶
func (a *AppConfigGroupServiceDaoImpl) CreateOrUpdateConfigGroupServicesInBatch(cgservices []*model.ConfigGroupService) error
CreateOrUpdateConfigGroupServicesInBatch -
func (*AppConfigGroupServiceDaoImpl) DeleteByAppID ¶
func (a *AppConfigGroupServiceDaoImpl) DeleteByAppID(appID string) error
DeleteByAppID deletes ConfigGroupService based on the given appID.
func (*AppConfigGroupServiceDaoImpl) DeleteByComponentIDs ¶
func (a *AppConfigGroupServiceDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*AppConfigGroupServiceDaoImpl) DeleteConfigGroupService ¶
func (a *AppConfigGroupServiceDaoImpl) DeleteConfigGroupService(appID, configGroupName string) error
DeleteConfigGroupService -
func (*AppConfigGroupServiceDaoImpl) DeleteEffectiveServiceByServiceID ¶
func (a *AppConfigGroupServiceDaoImpl) DeleteEffectiveServiceByServiceID(serviceID string) error
DeleteEffectiveServiceByServiceID -
func (*AppConfigGroupServiceDaoImpl) GetConfigGroupServicesByID ¶
func (a *AppConfigGroupServiceDaoImpl) GetConfigGroupServicesByID(appID, configGroupName string) ([]*model.ConfigGroupService, error)
GetConfigGroupServicesByID -
func (*AppConfigGroupServiceDaoImpl) UpdateModel ¶
func (a *AppConfigGroupServiceDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type AppDaoImpl ¶
AppDaoImpl -
func (*AppDaoImpl) DeleteModelByEventId ¶
func (a *AppDaoImpl) DeleteModelByEventId(eventID string) error
DeleteModelByEventId -
func (*AppDaoImpl) GetByEventId ¶
func (a *AppDaoImpl) GetByEventId(eventID string) (*model.AppStatus, error)
GetByEventId -
func (*AppDaoImpl) UpdateModel ¶
func (a *AppDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type ApplicationDaoImpl ¶
ApplicationDaoImpl -
func (*ApplicationDaoImpl) AddModel ¶
func (a *ApplicationDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*ApplicationDaoImpl) DeleteApp ¶
func (a *ApplicationDaoImpl) DeleteApp(appID string) error
DeleteApp Delete application By appID -
func (*ApplicationDaoImpl) GetAppByID ¶
func (a *ApplicationDaoImpl) GetAppByID(appID string) (*model.Application, error)
GetAppByID -
func (*ApplicationDaoImpl) GetByServiceID ¶
func (a *ApplicationDaoImpl) GetByServiceID(sid string) (*model.Application, error)
GetByServiceID -
func (*ApplicationDaoImpl) IsK8sAppDuplicate ¶
func (a *ApplicationDaoImpl) IsK8sAppDuplicate(tenantEnvID, AppID, k8sApp string) bool
IsK8sAppDuplicate Verify whether the k8s app under the same team are duplicate
func (*ApplicationDaoImpl) ListApps ¶
func (a *ApplicationDaoImpl) ListApps(tenantEnvID, appName string, page, pageSize int) ([]*model.Application, int64, error)
ListApps -
func (*ApplicationDaoImpl) ListByAppIDs ¶
func (a *ApplicationDaoImpl) ListByAppIDs(appIDs []string) ([]*model.Application, error)
ListByAppIDs -
func (*ApplicationDaoImpl) UpdateModel ¶
func (a *ApplicationDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type CertificateDaoImpl ¶
CertificateDaoImpl -
func (*CertificateDaoImpl) AddModel ¶
func (c *CertificateDaoImpl) AddModel(mo model.Interface) error
AddModel add model
func (*CertificateDaoImpl) AddOrUpdate ¶
func (c *CertificateDaoImpl) AddOrUpdate(mo model.Interface) error
AddOrUpdate add or update Certificate
func (*CertificateDaoImpl) GetCertificateByID ¶
func (c *CertificateDaoImpl) GetCertificateByID(certificateID string) (*model.Certificate, error)
GetCertificateByID gets a certificate by matching id
func (*CertificateDaoImpl) UpdateModel ¶
func (c *CertificateDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel update Certificate
type CodeCheckResultDaoImpl ¶
CodeCheckResultDaoImpl EventLogMessageDaoImpl
func (*CodeCheckResultDaoImpl) AddModel ¶
func (c *CodeCheckResultDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*CodeCheckResultDaoImpl) DeleteByServiceID ¶
func (c *CodeCheckResultDaoImpl) DeleteByServiceID(serviceID string) error
DeleteByServiceID deletes a CodeCheckResult base on serviceID.
func (*CodeCheckResultDaoImpl) GetCodeCheckResult ¶
func (c *CodeCheckResultDaoImpl) GetCodeCheckResult(serviceID string) (*model.CodeCheckResult, error)
GetCodeCheckResult get event log message
func (*CodeCheckResultDaoImpl) UpdateModel ¶
func (c *CodeCheckResultDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel
type EndpointDaoImpl ¶
EndpointDaoImpl implements EndpintDao
func (*EndpointDaoImpl) AddModel ¶
func (e *EndpointDaoImpl) AddModel(mo model.Interface) error
AddModel add one record for table 3rd_party_svc_endpoint
func (*EndpointDaoImpl) DelByUUID ¶
func (e *EndpointDaoImpl) DelByUUID(uuid string) error
DelByUUID deletes endpoints matching uuid.
func (*EndpointDaoImpl) DeleteByServiceID ¶
func (e *EndpointDaoImpl) DeleteByServiceID(sid string) error
DeleteByServiceID delete endpoints based on service id.
func (*EndpointDaoImpl) GetByUUID ¶
func (e *EndpointDaoImpl) GetByUUID(uuid string) (*model.Endpoint, error)
GetByUUID returns endpints matching the given uuid.
func (*EndpointDaoImpl) List ¶
func (e *EndpointDaoImpl) List(sid string) ([]*model.Endpoint, error)
List list all endpints matching the given serivce_id(sid).
func (*EndpointDaoImpl) UpdateModel ¶
func (e *EndpointDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel updates one record for table 3rd_party_svc_endpoint
type EventDaoImpl ¶
EventDaoImpl EventLogMessageDaoImpl
func (*EventDaoImpl) AddModel ¶
func (c *EventDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*EventDaoImpl) CreateEventsInBatch ¶
func (c *EventDaoImpl) CreateEventsInBatch(events []*model.ServiceEvent) error
CreateEventsInBatch creates events in batch.
func (*EventDaoImpl) DelEventByServiceID ¶
func (c *EventDaoImpl) DelEventByServiceID(serviceID string) error
DelEventByServiceID delete event log
func (*EventDaoImpl) DeleteEvents ¶ added in v1.1.0
func (c *EventDaoImpl) DeleteEvents(eventIDs []string) error
DeleteEvents delete event
func (*EventDaoImpl) GetEventByEventID ¶
func (c *EventDaoImpl) GetEventByEventID(eventID string) (*model.ServiceEvent, error)
GetEventByEventID get event log message
func (*EventDaoImpl) GetEventByEventIDs ¶
func (c *EventDaoImpl) GetEventByEventIDs(eventIDs []string) ([]*model.ServiceEvent, error)
GetEventByEventIDs get event info
func (*EventDaoImpl) GetEventByServiceID ¶
func (c *EventDaoImpl) GetEventByServiceID(serviceID string) ([]*model.ServiceEvent, error)
GetEventByServiceID get event log message
func (*EventDaoImpl) GetEventsByTarget ¶
func (c *EventDaoImpl) GetEventsByTarget(target, targetID string, offset, limit int) ([]*model.ServiceEvent, int, error)
GetEventsByTarget get event by target with page
func (*EventDaoImpl) GetEventsByTenantEnvID ¶ added in v1.1.0
func (c *EventDaoImpl) GetEventsByTenantEnvID(tenantEnvID string, offset, limit int) ([]*model.ServiceEvent, int, error)
GetEventsByTenantEnvID get event by tenantEnvID
func (*EventDaoImpl) GetLastASyncEvent ¶
func (c *EventDaoImpl) GetLastASyncEvent(target, targetID string) (*model.ServiceEvent, error)
GetLastASyncEvent get last sync event
func (*EventDaoImpl) LatestFailurePodEvent ¶
func (c *EventDaoImpl) LatestFailurePodEvent(podName string) (*model.ServiceEvent, error)
LatestFailurePodEvent returns the latest failure pod event.
func (*EventDaoImpl) ListByTargetID ¶
func (c *EventDaoImpl) ListByTargetID(targetID string) ([]*model.ServiceEvent, error)
ListByTargetID -
func (*EventDaoImpl) SetEventStatus ¶
func (c *EventDaoImpl) SetEventStatus(ctx context.Context, status model.EventStatus) error
SetEventStatus -
func (*EventDaoImpl) UnfinishedEvents ¶
func (c *EventDaoImpl) UnfinishedEvents(target, targetID string, optTypes ...string) ([]*model.ServiceEvent, error)
UnfinishedEvents returns unfinished events.
func (*EventDaoImpl) UpdateInBatch ¶
func (c *EventDaoImpl) UpdateInBatch(events []*model.ServiceEvent) error
UpdateInBatch -
func (*EventDaoImpl) UpdateModel ¶
func (c *EventDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel
func (*EventDaoImpl) UpdateReason ¶
func (c *EventDaoImpl) UpdateReason(eventID string, reason string) error
UpdateReason update reasion.
type GwRuleConfigDaoImpl ¶
GwRuleConfigDaoImpl is a implementation of GwRuleConfigDao.
func (*GwRuleConfigDaoImpl) AddModel ¶
func (t *GwRuleConfigDaoImpl) AddModel(mo model.Interface) error
AddModel creates a new gateway rule config.
func (*GwRuleConfigDaoImpl) CreateOrUpdateGwRuleConfigsInBatch ¶
func (t *GwRuleConfigDaoImpl) CreateOrUpdateGwRuleConfigsInBatch(ruleConfigs []*model.GwRuleConfig) error
CreateOrUpdateGwRuleConfigsInBatch creates or updates rule configs in batch.
func (*GwRuleConfigDaoImpl) DeleteByRuleID ¶
func (t *GwRuleConfigDaoImpl) DeleteByRuleID(rid string) error
DeleteByRuleID deletes gateway rule configs by rule id.
func (*GwRuleConfigDaoImpl) DeleteByRuleIDs ¶
func (t *GwRuleConfigDaoImpl) DeleteByRuleIDs(ruleIDs []string) error
DeleteByRuleIDs deletes rule configs based on the given ruleIDs.
func (*GwRuleConfigDaoImpl) ListByRuleID ¶
func (t *GwRuleConfigDaoImpl) ListByRuleID(rid string) ([]*model.GwRuleConfig, error)
ListByRuleID lists GwRuleConfig by rule id.
func (*GwRuleConfigDaoImpl) UpdateModel ¶
func (t *GwRuleConfigDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel updates a gateway rule config.
type HTTPRuleDaoImpl ¶
HTTPRuleDaoImpl http rule
func (*HTTPRuleDaoImpl) AddModel ¶
func (h *HTTPRuleDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*HTTPRuleDaoImpl) CreateOrUpdateHTTPRuleInBatch ¶
func (h *HTTPRuleDaoImpl) CreateOrUpdateHTTPRuleInBatch(httpRules []*model.HTTPRule) error
CreateOrUpdateHTTPRuleInBatch Batch insert or update http rule
func (*HTTPRuleDaoImpl) DeleteByComponentIDs ¶
func (h *HTTPRuleDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs delete http rule by component ids
func (*HTTPRuleDaoImpl) DeleteByComponentPort ¶
func (h *HTTPRuleDaoImpl) DeleteByComponentPort(componentID string, port int) error
DeleteByComponentPort deletes http rules based on componentID and port.
func (*HTTPRuleDaoImpl) DeleteHTTPRuleByID ¶
func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByID(id string) error
DeleteHTTPRuleByID delete http rule by rule id
func (*HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID ¶
func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID(serviceID string) error
DeleteHTTPRuleByServiceID delete http rule by service id
func (*HTTPRuleDaoImpl) GetHTTPRuleByDomainAndHost ¶ added in v1.7.0
func (h *HTTPRuleDaoImpl) GetHTTPRuleByDomainAndHost(domain, path string) ([]*model.HTTPRule, error)
func (*HTTPRuleDaoImpl) GetHTTPRuleByID ¶
func (h *HTTPRuleDaoImpl) GetHTTPRuleByID(id string) (*model.HTTPRule, error)
GetHTTPRuleByID gets a HTTPRule based on uuid
func (*HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort ¶
func (h *HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.HTTPRule, error)
GetHTTPRuleByServiceIDAndContainerPort gets a HTTPRule based on serviceID and containerPort
func (*HTTPRuleDaoImpl) GetHTTPRulesByCertificateID ¶
func (h *HTTPRuleDaoImpl) GetHTTPRulesByCertificateID(certificateID string) ([]*model.HTTPRule, error)
GetHTTPRulesByCertificateID get http rules by certificateID
func (*HTTPRuleDaoImpl) ListByCertID ¶
func (h *HTTPRuleDaoImpl) ListByCertID(certID string) ([]*model.HTTPRule, error)
ListByCertID lists all HTTPRules matching certificate id
func (*HTTPRuleDaoImpl) ListByComponentIDs ¶
func (h *HTTPRuleDaoImpl) ListByComponentIDs(componentIDs []string) ([]*model.HTTPRule, error)
ListByComponentIDs -
func (*HTTPRuleDaoImpl) ListByComponentPort ¶
func (h *HTTPRuleDaoImpl) ListByComponentPort(componentID string, port int) ([]*model.HTTPRule, error)
ListByComponentPort lists http rules based on the given componentID and port.
func (*HTTPRuleDaoImpl) ListByServiceID ¶
func (h *HTTPRuleDaoImpl) ListByServiceID(serviceID string) ([]*model.HTTPRule, error)
ListByServiceID lists all HTTPRules matching serviceID
func (*HTTPRuleDaoImpl) UpdateModel ¶
func (h *HTTPRuleDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type HTTPRuleRewriteDaoTmpl ¶
HTTPRuleRewriteDaoTmpl is a implementation of HTTPRuleRewriteDao
func (*HTTPRuleRewriteDaoTmpl) AddModel ¶
func (h *HTTPRuleRewriteDaoTmpl) AddModel(mo model.Interface) error
AddModel -
func (*HTTPRuleRewriteDaoTmpl) CreateOrUpdateHTTPRuleRewriteInBatch ¶
func (h *HTTPRuleRewriteDaoTmpl) CreateOrUpdateHTTPRuleRewriteInBatch(httpRuleRewrites []*model.HTTPRuleRewrite) error
CreateOrUpdateHTTPRuleRewriteInBatch -
func (*HTTPRuleRewriteDaoTmpl) DeleteByHTTPRuleID ¶
func (h *HTTPRuleRewriteDaoTmpl) DeleteByHTTPRuleID(httpRuleID string) error
DeleteByHTTPRuleID -
func (*HTTPRuleRewriteDaoTmpl) DeleteByHTTPRuleIDs ¶
func (h *HTTPRuleRewriteDaoTmpl) DeleteByHTTPRuleIDs(httpRuleIDs []string) error
DeleteByHTTPRuleIDs deletes http rule rewrites by given httpRuleIDs.
func (*HTTPRuleRewriteDaoTmpl) ListByHTTPRuleID ¶
func (h *HTTPRuleRewriteDaoTmpl) ListByHTTPRuleID(httpRuleID string) ([]*model.HTTPRuleRewrite, error)
ListByHTTPRuleID -
func (*HTTPRuleRewriteDaoTmpl) UpdateModel ¶
func (h *HTTPRuleRewriteDaoTmpl) UpdateModel(mo model.Interface) error
UpdateModel -
type LicenseDaoImpl ¶
LicenseDaoImpl license model 管理
func (*LicenseDaoImpl) AddModel ¶
func (l *LicenseDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*LicenseDaoImpl) DeleteLicense ¶
func (l *LicenseDaoImpl) DeleteLicense(token string) error
DeleteLicense DeleteLicense
func (*LicenseDaoImpl) ListLicenses ¶
func (l *LicenseDaoImpl) ListLicenses() ([]*model.LicenseInfo, error)
ListLicenses ListLicenses
func (*LicenseDaoImpl) UpdateModel ¶
func (l *LicenseDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel
type LocalSchedulerDaoImpl ¶
LocalSchedulerDaoImpl 本地调度存储mysql实现
func (*LocalSchedulerDaoImpl) AddModel ¶
func (t *LocalSchedulerDaoImpl) AddModel(mo model.Interface) error
AddModel 添加本地调度信息
func (*LocalSchedulerDaoImpl) GetLocalScheduler ¶
func (t *LocalSchedulerDaoImpl) GetLocalScheduler(serviceID string) ([]*model.LocalScheduler, error)
GetLocalScheduler 获取应用本地调度信息
func (*LocalSchedulerDaoImpl) UpdateModel ¶
func (t *LocalSchedulerDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新调度信息
type NotificationEventDaoImpl ¶
NotificationEventDaoImpl NotificationEventDaoImpl
func (*NotificationEventDaoImpl) AddModel ¶
func (c *NotificationEventDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*NotificationEventDaoImpl) GetNotificationEventByHash ¶
func (c *NotificationEventDaoImpl) GetNotificationEventByHash(hash string) (*model.NotificationEvent, error)
GetNotificationEventByHash GetNotificationEventByHash
func (*NotificationEventDaoImpl) GetNotificationEventByKind ¶
func (c *NotificationEventDaoImpl) GetNotificationEventByKind(kind, kindID string) ([]*model.NotificationEvent, error)
GetNotificationEventByKind GetNotificationEventByKind
func (*NotificationEventDaoImpl) GetNotificationEventByTime ¶
func (c *NotificationEventDaoImpl) GetNotificationEventByTime(start, end time.Time) ([]*model.NotificationEvent, error)
GetNotificationEventByTime GetNotificationEventByTime
func (*NotificationEventDaoImpl) GetNotificationEventNotHandle ¶
func (c *NotificationEventDaoImpl) GetNotificationEventNotHandle() ([]*model.NotificationEvent, error)
GetNotificationEventNotHandle GetNotificationEventNotHandle
func (*NotificationEventDaoImpl) UpdateModel ¶
func (c *NotificationEventDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel
type PluginBuildVersionDaoImpl ¶
PluginBuildVersionDaoImpl PluginBuildVersionDaoImpl
func (*PluginBuildVersionDaoImpl) AddModel ¶
func (t *PluginBuildVersionDaoImpl) AddModel(mo model.Interface) error
AddModel 添加插件构建版本信息
func (*PluginBuildVersionDaoImpl) CreateOrUpdatePluginBuildVersionsInBatch ¶
func (t *PluginBuildVersionDaoImpl) CreateOrUpdatePluginBuildVersionsInBatch(buildVersions []*model.TenantEnvPluginBuildVersion) error
CreateOrUpdatePluginBuildVersionsInBatch -
func (*PluginBuildVersionDaoImpl) DeleteBuildVersionByPluginID ¶
func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByPluginID(pluginID string) error
DeleteBuildVersionByPluginID DeleteBuildVersionByPluginID
func (*PluginBuildVersionDaoImpl) DeleteBuildVersionByVersionID ¶
func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByVersionID(versionID string) error
DeleteBuildVersionByVersionID DeleteBuildVersionByVersionID
func (*PluginBuildVersionDaoImpl) GetBuildVersionByDeployVersion ¶
func (t *PluginBuildVersionDaoImpl) GetBuildVersionByDeployVersion(pluginID, versionID, deployVersion string) (*model.TenantEnvPluginBuildVersion, error)
GetBuildVersionByDeployVersion GetBuildVersionByDeployVersion
func (*PluginBuildVersionDaoImpl) GetBuildVersionByPluginID ¶
func (t *PluginBuildVersionDaoImpl) GetBuildVersionByPluginID(pluginID string) ([]*model.TenantEnvPluginBuildVersion, error)
GetBuildVersionByPluginID GetBuildVersionByPluginID
func (*PluginBuildVersionDaoImpl) GetBuildVersionByVersionID ¶
func (t *PluginBuildVersionDaoImpl) GetBuildVersionByVersionID(pluginID, versionID string) (*model.TenantEnvPluginBuildVersion, error)
GetBuildVersionByVersionID GetBuildVersionByVersionID
func (*PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID ¶
func (t *PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID(pluginID, versionID string) (*model.TenantEnvPluginBuildVersion, error)
GetLastBuildVersionByVersionID get last success build version
func (*PluginBuildVersionDaoImpl) ListSuccessfulOnesByPluginIDs ¶
func (t *PluginBuildVersionDaoImpl) ListSuccessfulOnesByPluginIDs(pluginIDs []string) ([]*model.TenantEnvPluginBuildVersion, error)
ListSuccessfulOnesByPluginIDs returns the list of successful build versions,
func (*PluginBuildVersionDaoImpl) UpdateModel ¶
func (t *PluginBuildVersionDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新插件默认变量 主体信息一般不变更,仅构建的本地镜像名与status需要变更
type PluginDaoImpl ¶
PluginDaoImpl PluginDaoImpl
func (*PluginDaoImpl) AddModel ¶
func (t *PluginDaoImpl) AddModel(mo model.Interface) error
AddModel 创建插件
func (*PluginDaoImpl) CreateOrUpdatePluginsInBatch ¶
func (t *PluginDaoImpl) CreateOrUpdatePluginsInBatch(plugins []*model.TenantEnvPlugin) error
CreateOrUpdatePluginsInBatch -
func (*PluginDaoImpl) DeletePluginByID ¶
func (t *PluginDaoImpl) DeletePluginByID(id, tenantEnvID string) error
DeletePluginByID DeletePluginByID
func (*PluginDaoImpl) GetPluginByID ¶
func (t *PluginDaoImpl) GetPluginByID(id, tenantEnvID string) (*model.TenantEnvPlugin, error)
GetPluginByID GetPluginByID
func (*PluginDaoImpl) GetPluginsByTenantEnvID ¶ added in v1.1.0
func (t *PluginDaoImpl) GetPluginsByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvPlugin, error)
GetPluginsByTenantEnvID GetPluginsByTenantEnvID
func (*PluginDaoImpl) ListByIDs ¶
func (t *PluginDaoImpl) ListByIDs(ids []string) ([]*model.TenantEnvPlugin, error)
ListByIDs returns the list of plugins based on the given plugin ids.
func (*PluginDaoImpl) ListByTenantEnvID ¶ added in v1.1.0
func (t *PluginDaoImpl) ListByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvPlugin, error)
ListByTenantEnvID -
func (*PluginDaoImpl) UpdateModel ¶
func (t *PluginDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新插件
type PluginDefaultENVDaoImpl ¶
PluginDefaultENVDaoImpl PluginDefaultENVDaoImpl
func (*PluginDefaultENVDaoImpl) AddModel ¶
func (t *PluginDefaultENVDaoImpl) AddModel(mo model.Interface) error
AddModel 添加插件默认变量
func (*PluginDefaultENVDaoImpl) DeleteAllDefaultENVByPluginID ¶
func (t *PluginDefaultENVDaoImpl) DeleteAllDefaultENVByPluginID(pluginID string) error
DeleteAllDefaultENVByPluginID DeleteAllDefaultENVByPluginID
func (*PluginDefaultENVDaoImpl) DeleteDefaultENVByName ¶
func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByName(pluginID, name, versionID string) error
DeleteDefaultENVByName DeleteDefaultENVByName
func (*PluginDefaultENVDaoImpl) DeleteDefaultENVByPluginIDAndVersionID ¶
func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByPluginIDAndVersionID(pluginID, versionID string) error
DeleteDefaultENVByPluginIDAndVersionID DeleteDefaultENVByPluginIDAndVersionID
func (*PluginDefaultENVDaoImpl) GetALLMasterDefultENVs ¶
func (t *PluginDefaultENVDaoImpl) GetALLMasterDefultENVs(pluginID string) ([]*model.TenantEnvPluginDefaultENV, error)
GetALLMasterDefultENVs GetALLMasterDefultENVs
func (*PluginDefaultENVDaoImpl) GetDefaultENVByName ¶
func (t *PluginDefaultENVDaoImpl) GetDefaultENVByName(pluginID, name, versionID string) (*model.TenantEnvPluginDefaultENV, error)
GetDefaultENVByName GetDefaultENVByName
func (*PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID ¶
func (t *PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID(pluginID, versionID string) ([]*model.TenantEnvPluginDefaultENV, error)
GetDefaultENVSByPluginID GetDefaultENVSByPluginID
func (*PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID ¶
func (t *PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID(pluginID, versionID string) ([]*model.TenantEnvPluginDefaultENV, error)
GetDefaultEnvWhichCanBeSetByPluginID GetDefaultEnvWhichCanBeSetByPluginID
func (*PluginDefaultENVDaoImpl) UpdateModel ¶
func (t *PluginDefaultENVDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新插件默认变量
type PluginVersionConfigDaoImpl ¶
PluginVersionConfigDaoImpl PluginVersionEnvDaoImpl
func (*PluginVersionConfigDaoImpl) AddModel ¶
func (t *PluginVersionConfigDaoImpl) AddModel(mo model.Interface) error
AddModel add or update service plugin config
func (*PluginVersionConfigDaoImpl) CreateOrUpdatePluginVersionConfigsInBatch ¶
func (t *PluginVersionConfigDaoImpl) CreateOrUpdatePluginVersionConfigsInBatch(versionConfigs []*model.TenantEnvPluginVersionDiscoverConfig) error
CreateOrUpdatePluginVersionConfigsInBatch -
func (*PluginVersionConfigDaoImpl) DeleteByComponentIDs ¶
func (t *PluginVersionConfigDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*PluginVersionConfigDaoImpl) DeletePluginConfig ¶
func (t *PluginVersionConfigDaoImpl) DeletePluginConfig(serviceID, pluginID string) error
DeletePluginConfig delete service plugin config
func (*PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID ¶
func (t *PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID(serviceID string) error
DeletePluginConfigByServiceID Batch delete config by service id
func (*PluginVersionConfigDaoImpl) GetPluginConfig ¶
func (t *PluginVersionConfigDaoImpl) GetPluginConfig(serviceID, pluginID string) (*model.TenantEnvPluginVersionDiscoverConfig, error)
GetPluginConfig get service plugin config
func (*PluginVersionConfigDaoImpl) GetPluginConfigs ¶
func (t *PluginVersionConfigDaoImpl) GetPluginConfigs(serviceID string) ([]*model.TenantEnvPluginVersionDiscoverConfig, error)
GetPluginConfigs get plugin configs
func (*PluginVersionConfigDaoImpl) UpdateModel ¶
func (t *PluginVersionConfigDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel update service plugin config
type PluginVersionEnvDaoImpl ¶
PluginVersionEnvDaoImpl PluginVersionEnvDaoImpl
func (*PluginVersionEnvDaoImpl) AddModel ¶
func (t *PluginVersionEnvDaoImpl) AddModel(mo model.Interface) error
AddModel 添加插件默认变量
func (*PluginVersionEnvDaoImpl) CreateOrUpdatePluginVersionEnvsInBatch ¶
func (t *PluginVersionEnvDaoImpl) CreateOrUpdatePluginVersionEnvsInBatch(versionEnvs []*model.TenantEnvPluginVersionEnv) error
CreateOrUpdatePluginVersionEnvsInBatch -
func (*PluginVersionEnvDaoImpl) DeleteByComponentIDs ¶
func (t *PluginVersionEnvDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*PluginVersionEnvDaoImpl) DeleteEnvByEnvName ¶
func (t *PluginVersionEnvDaoImpl) DeleteEnvByEnvName(envName, pluginID, serviceID string) error
DeleteEnvByEnvName 删除单个env
func (*PluginVersionEnvDaoImpl) DeleteEnvByPluginID ¶
func (t *PluginVersionEnvDaoImpl) DeleteEnvByPluginID(serviceID, pluginID string) error
DeleteEnvByPluginID 删除插件依赖关系时,需要操作删除对应env
func (*PluginVersionEnvDaoImpl) DeleteEnvByServiceID ¶
func (t *PluginVersionEnvDaoImpl) DeleteEnvByServiceID(serviceID string) error
DeleteEnvByServiceID 删除应用时,需要进行此操作
func (*PluginVersionEnvDaoImpl) GetVersionEnvByEnvName ¶
func (t *PluginVersionEnvDaoImpl) GetVersionEnvByEnvName(serviceID, pluginID, envName string) (*model.TenantEnvPluginVersionEnv, error)
GetVersionEnvByEnvName GetVersionEnvByEnvName
func (*PluginVersionEnvDaoImpl) GetVersionEnvByServiceID ¶
func (t *PluginVersionEnvDaoImpl) GetVersionEnvByServiceID(serviceID string, pluginID string) ([]*model.TenantEnvPluginVersionEnv, error)
GetVersionEnvByServiceID 获取该应用下使用的某个插件依赖的插件变量
func (*PluginVersionEnvDaoImpl) ListByServiceID ¶
func (t *PluginVersionEnvDaoImpl) ListByServiceID(serviceID string) ([]*model.TenantEnvPluginVersionEnv, error)
ListByServiceID returns the list of environment variables for the plugin via serviceID
func (*PluginVersionEnvDaoImpl) UpdateModel ¶
func (t *PluginVersionEnvDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新插件默认变量
type RegionAPIClassDaoImpl ¶
RegionAPIClassDaoImpl RegionAPIClassDaoImpl
func (*RegionAPIClassDaoImpl) AddModel ¶
func (t *RegionAPIClassDaoImpl) AddModel(mo model.Interface) error
AddModel 添加api分类信息
func (*RegionAPIClassDaoImpl) DeletePrefixInClass ¶
func (t *RegionAPIClassDaoImpl) DeletePrefixInClass(apiClass, prefix string) error
DeletePrefixInClass DeletePrefixInClass
func (*RegionAPIClassDaoImpl) GetPrefixesByClass ¶
func (t *RegionAPIClassDaoImpl) GetPrefixesByClass(apiClass string) ([]*model.RegionAPIClass, error)
GetPrefixesByClass GetPrefixesByClass
func (*RegionAPIClassDaoImpl) UpdateModel ¶
func (t *RegionAPIClassDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新api分类信息
type RuleExtensionDaoImpl ¶
RuleExtensionDaoImpl rule extension dao
func (*RuleExtensionDaoImpl) AddModel ¶
func (c *RuleExtensionDaoImpl) AddModel(mo model.Interface) error
AddModel add
func (*RuleExtensionDaoImpl) CreateOrUpdateRuleExtensionsInBatch ¶
func (c *RuleExtensionDaoImpl) CreateOrUpdateRuleExtensionsInBatch(exts []*model.RuleExtension) error
CreateOrUpdateRuleExtensionsInBatch -
func (*RuleExtensionDaoImpl) DeleteByRuleIDs ¶
func (c *RuleExtensionDaoImpl) DeleteByRuleIDs(ruleIDs []string) error
DeleteByRuleIDs deletes rule extentions based on the given ruleIDs.
func (*RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID ¶
func (c *RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID(ruleID string) error
DeleteRuleExtensionByRuleID delete rule extensions by ruleID
func (*RuleExtensionDaoImpl) GetRuleExtensionByRuleID ¶
func (c *RuleExtensionDaoImpl) GetRuleExtensionByRuleID(ruleID string) ([]*model.RuleExtension, error)
GetRuleExtensionByRuleID get extension by rule
func (*RuleExtensionDaoImpl) UpdateModel ¶
func (c *RuleExtensionDaoImpl) UpdateModel(model.Interface) error
UpdateModel update model,do not impl
type ServiceLabelDaoImpl ¶
ServiceLabelDaoImpl ServiceLabelDaoImpl
func (*ServiceLabelDaoImpl) AddModel ¶
func (t *ServiceLabelDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用Label
func (*ServiceLabelDaoImpl) CreateOrUpdateLabelsInBatch ¶
func (t *ServiceLabelDaoImpl) CreateOrUpdateLabelsInBatch(labels []*model.TenantEnvServiceLabel) error
CreateOrUpdateLabelsInBatch -
func (*ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByLabelValuesAndServiceID ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByLabelValuesAndServiceID(serviceID string) error
DelTenantEnvServiceLabelsByLabelValuesAndServiceID DELTenantEnvServiceLabelsByLabelvaluesAndServiceID
func (*ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByServiceIDKey ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByServiceIDKey(serviceID string, labelKey string) error
DelTenantEnvServiceLabelsByServiceIDKey deletes labels by serviceID and labelKey
func (*ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByServiceIDKeyValue ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) DelTenantEnvServiceLabelsByServiceIDKeyValue(serviceID string, labelKey string, labelValue string) error
DelTenantEnvServiceLabelsByServiceIDKeyValue deletes labels
func (*ServiceLabelDaoImpl) DeleteByComponentIDs ¶
func (t *ServiceLabelDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs deletes labels based on componentIDs
func (*ServiceLabelDaoImpl) DeleteLabelByServiceID ¶
func (t *ServiceLabelDaoImpl) DeleteLabelByServiceID(serviceID string) error
DeleteLabelByServiceID 删除应用全部label
func (*ServiceLabelDaoImpl) DeleteModel ¶
func (t *ServiceLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
DeleteModel 删除应用label
func (*ServiceLabelDaoImpl) GetLabelByNodeSelectorKey ¶
func (t *ServiceLabelDaoImpl) GetLabelByNodeSelectorKey(serviceID string, labelValue string) (*model.TenantEnvServiceLabel, error)
GetLabelByNodeSelectorKey returns a label by node-selector and label_value
func (*ServiceLabelDaoImpl) GetPrivilegedLabel ¶
func (t *ServiceLabelDaoImpl) GetPrivilegedLabel(serviceID string) (*model.TenantEnvServiceLabel, error)
GetPrivilegedLabel -
func (*ServiceLabelDaoImpl) GetTenantEnvNodeAffinityLabel ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) GetTenantEnvNodeAffinityLabel(serviceID string) (*model.TenantEnvServiceLabel, error)
GetTenantEnvNodeAffinityLabel returns TenantEnvServiceLable matching serviceID and LabelKeyNodeAffinity
func (*ServiceLabelDaoImpl) GetTenantEnvServiceAffinityLabel ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) GetTenantEnvServiceAffinityLabel(serviceID string) ([]*model.TenantEnvServiceLabel, error)
GetTenantEnvServiceAffinityLabel GetTenantEnvServiceAffinityLabel
func (*ServiceLabelDaoImpl) GetTenantEnvServiceLabel ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) GetTenantEnvServiceLabel(serviceID string) ([]*model.TenantEnvServiceLabel, error)
GetTenantEnvServiceLabel GetTenantEnvServiceLabel
func (*ServiceLabelDaoImpl) GetTenantEnvServiceNodeSelectorLabel ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) GetTenantEnvServiceNodeSelectorLabel(serviceID string) ([]*model.TenantEnvServiceLabel, error)
GetTenantEnvServiceNodeSelectorLabel GetTenantEnvServiceNodeSelectorLabel
func (*ServiceLabelDaoImpl) GetTenantEnvServiceTypeLabel ¶ added in v1.1.0
func (t *ServiceLabelDaoImpl) GetTenantEnvServiceTypeLabel(serviceID string) (*model.TenantEnvServiceLabel, error)
GetTenantEnvServiceTypeLabel GetTenantEnvServiceTypeLabel no usages func. get tenant env service type use TenantEnvServiceDao.GetServiceTypeByID(serviceID string)
func (*ServiceLabelDaoImpl) UpdateModel ¶
func (t *ServiceLabelDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用Label
type ServiceProbeDaoImpl ¶
ServiceProbeDaoImpl probe dao impl
func (*ServiceProbeDaoImpl) AddModel ¶
func (t *ServiceProbeDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用Probe
func (*ServiceProbeDaoImpl) CreateOrUpdateProbesInBatch ¶
func (t *ServiceProbeDaoImpl) CreateOrUpdateProbesInBatch(probes []*model.TenantEnvServiceProbe) error
CreateOrUpdateProbesInBatch -
func (*ServiceProbeDaoImpl) DELServiceProbesByServiceID ¶
func (t *ServiceProbeDaoImpl) DELServiceProbesByServiceID(serviceID string) error
DELServiceProbesByServiceID DELServiceProbesByServiceID
func (*ServiceProbeDaoImpl) DelByServiceID ¶
func (t *ServiceProbeDaoImpl) DelByServiceID(sid string) error
DelByServiceID deletes TenantEnvServiceProbe based on sid(service_id)
func (*ServiceProbeDaoImpl) DeleteByComponentIDs ¶
func (t *ServiceProbeDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs deletes TenantEnvServiceProbe based on componentIDs
func (*ServiceProbeDaoImpl) DeleteModel ¶
func (t *ServiceProbeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
DeleteModel 删除应用探针
func (*ServiceProbeDaoImpl) GetServiceProbes ¶
func (t *ServiceProbeDaoImpl) GetServiceProbes(serviceID string) ([]*model.TenantEnvServiceProbe, error)
GetServiceProbes 获取应用探针
func (*ServiceProbeDaoImpl) GetServiceUsedProbe ¶
func (t *ServiceProbeDaoImpl) GetServiceUsedProbe(serviceID, mode string) (*model.TenantEnvServiceProbe, error)
GetServiceUsedProbe 获取指定模式的可用探针定义
func (*ServiceProbeDaoImpl) UpdateModel ¶
func (t *ServiceProbeDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用Probe
type ServiceSchedulingLabelDaoImpl ¶ added in v1.10.0
func (*ServiceSchedulingLabelDaoImpl) AddModel ¶ added in v1.10.0
func (t *ServiceSchedulingLabelDaoImpl) AddModel(mo model.Interface) error
func (*ServiceSchedulingLabelDaoImpl) DeleteModel ¶ added in v1.10.0
func (t *ServiceSchedulingLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
func (*ServiceSchedulingLabelDaoImpl) GetServiceSchedulingLabelByKey ¶ added in v1.10.0
func (t *ServiceSchedulingLabelDaoImpl) GetServiceSchedulingLabelByKey(serviceID, key string) (*model.TenantEnvServiceSchedulingLabel, error)
func (*ServiceSchedulingLabelDaoImpl) ListServiceSchedulingLabels ¶ added in v1.10.0
func (t *ServiceSchedulingLabelDaoImpl) ListServiceSchedulingLabels(serviceID string) ([]*model.TenantEnvServiceSchedulingLabel, error)
func (*ServiceSchedulingLabelDaoImpl) UpdateModel ¶ added in v1.10.0
func (t *ServiceSchedulingLabelDaoImpl) UpdateModel(mo model.Interface) error
type ServiceSchedulingNodeDaoImpl ¶ added in v1.10.0
func (*ServiceSchedulingNodeDaoImpl) AddModel ¶ added in v1.10.0
func (t *ServiceSchedulingNodeDaoImpl) AddModel(mo model.Interface) error
func (*ServiceSchedulingNodeDaoImpl) DeleteModel ¶ added in v1.10.0
func (t *ServiceSchedulingNodeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
func (*ServiceSchedulingNodeDaoImpl) ListServiceSchedulingNodes ¶ added in v1.11.0
func (t *ServiceSchedulingNodeDaoImpl) ListServiceSchedulingNodes(serviceID string) ([]*model.TenantEnvServiceSchedulingNode, error)
func (*ServiceSchedulingNodeDaoImpl) UpdateModel ¶ added in v1.10.0
func (t *ServiceSchedulingNodeDaoImpl) UpdateModel(mo model.Interface) error
type ServiceSchedulingTolerationDaoImpl ¶ added in v1.10.0
func (*ServiceSchedulingTolerationDaoImpl) AddModel ¶ added in v1.10.0
func (t *ServiceSchedulingTolerationDaoImpl) AddModel(mo model.Interface) error
func (*ServiceSchedulingTolerationDaoImpl) DeleteModel ¶ added in v1.10.0
func (t *ServiceSchedulingTolerationDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
func (*ServiceSchedulingTolerationDaoImpl) GetServiceSchedulingTolerationByKey ¶ added in v1.10.0
func (t *ServiceSchedulingTolerationDaoImpl) GetServiceSchedulingTolerationByKey(serviceID, key string) (*model.TenantEnvServiceSchedulingToleration, error)
func (*ServiceSchedulingTolerationDaoImpl) ListServiceSchedulingTolerations ¶ added in v1.10.0
func (t *ServiceSchedulingTolerationDaoImpl) ListServiceSchedulingTolerations(serviceID string) ([]*model.TenantEnvServiceSchedulingToleration, error)
func (*ServiceSchedulingTolerationDaoImpl) UpdateModel ¶ added in v1.10.0
func (t *ServiceSchedulingTolerationDaoImpl) UpdateModel(mo model.Interface) error
type ServiceSourceImpl ¶
ServiceSourceImpl service source
func (*ServiceSourceImpl) AddModel ¶
func (t *ServiceSourceImpl) AddModel(mo model.Interface) error
AddModel add service source
func (*ServiceSourceImpl) GetServiceSource ¶
func (t *ServiceSourceImpl) GetServiceSource(serviceID string) ([]*model.ServiceSourceConfig, error)
GetServiceSource get services source
func (*ServiceSourceImpl) UpdateModel ¶
func (t *ServiceSourceImpl) UpdateModel(mo model.Interface) error
UpdateModel update service source
type TCPRuleDaoTmpl ¶
TCPRuleDaoTmpl is a implementation of TcpRuleDao
func (*TCPRuleDaoTmpl) AddModel ¶
func (t *TCPRuleDaoTmpl) AddModel(mo model.Interface) error
AddModel adds model.TCPRule
func (*TCPRuleDaoTmpl) CreateOrUpdateTCPRuleInBatch ¶
func (t *TCPRuleDaoTmpl) CreateOrUpdateTCPRuleInBatch(tcpRules []*model.TCPRule) error
CreateOrUpdateTCPRuleInBatch Batch insert or update tcp rule
func (*TCPRuleDaoTmpl) DeleteByComponentIDs ¶
func (t *TCPRuleDaoTmpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs delete tcp rule by component ids
func (*TCPRuleDaoTmpl) DeleteByComponentPort ¶
func (t *TCPRuleDaoTmpl) DeleteByComponentPort(componentID string, port int) error
DeleteByComponentPort deletes tcp rules based on the given component id and port.
func (*TCPRuleDaoTmpl) DeleteByID ¶
func (t *TCPRuleDaoTmpl) DeleteByID(uuid string) error
DeleteByID deletes model.TCPRule
func (*TCPRuleDaoTmpl) DeleteTCPRuleByServiceID ¶
func (t *TCPRuleDaoTmpl) DeleteTCPRuleByServiceID(serviceID string) error
DeleteTCPRuleByServiceID deletes model.TCPRule
func (*TCPRuleDaoTmpl) GetTCPRuleByID ¶
func (t *TCPRuleDaoTmpl) GetTCPRuleByID(id string) (*model.TCPRule, error)
GetTCPRuleByID gets a TCPRule based on tcpRuleID
func (*TCPRuleDaoTmpl) GetTCPRuleByServiceID ¶
func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceID(sid string) ([]*model.TCPRule, error)
GetTCPRuleByServiceID gets a TCPRules based on service id.
func (*TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort ¶
func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.TCPRule, error)
GetTCPRuleByServiceIDAndContainerPort gets a TCPRule based on serviceID and containerPort
func (*TCPRuleDaoTmpl) GetUsedPortsByIP ¶
func (t *TCPRuleDaoTmpl) GetUsedPortsByIP(ip string) ([]*model.TCPRule, error)
GetUsedPortsByIP get used port by ip sort by port
func (*TCPRuleDaoTmpl) ListByServiceID ¶
func (t *TCPRuleDaoTmpl) ListByServiceID(serviceID string) ([]*model.TCPRule, error)
ListByServiceID lists all TCPRules matching serviceID
func (*TCPRuleDaoTmpl) UpdateModel ¶
func (t *TCPRuleDaoTmpl) UpdateModel(mo model.Interface) error
UpdateModel updates model.TCPRule
type TenantEnvDaoImpl ¶ added in v1.1.0
TenantEnvDaoImpl 租户环境信息管理
func (*TenantEnvDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) AddModel(mo model.Interface) error
AddModel 添加租户
func (*TenantEnvDaoImpl) DelByTenantEnvID ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) DelByTenantEnvID(tenantEnvID string) error
DelByTenantEnvID -
func (*TenantEnvDaoImpl) GetAllTenantEnvs ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetAllTenantEnvs(query string) ([]*model.TenantEnvs, error)
GetAllTenantEnvs GetAllTenantEnvs
func (*TenantEnvDaoImpl) GetPagedTenantEnvs ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetPagedTenantEnvs(offset, len int) ([]*model.TenantEnvs, error)
GetPagedTenantEnvs -
func (*TenantEnvDaoImpl) GetTenantEnvByUUID ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetTenantEnvByUUID(uuid string) (*model.TenantEnvs, error)
GetTenantEnvByUUID 获取租户
func (*TenantEnvDaoImpl) GetTenantEnvByUUIDIsExist ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetTenantEnvByUUIDIsExist(uuid string) bool
GetTenantEnvByUUIDIsExist 获取租户
func (*TenantEnvDaoImpl) GetTenantEnvIDByName ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetTenantEnvIDByName(tenantName, tenantEnvName string) (*model.TenantEnvs, error)
GetTenantEnvIDByName 获取租户
func (*TenantEnvDaoImpl) GetTenantEnvIDsByNames ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetTenantEnvIDsByNames(tenantName string, tenantEnvNames []string) (re []string, err error)
GetTenantEnvIDsByNames get tenant env ids by names
func (*TenantEnvDaoImpl) GetTenantEnvLimitsByNames ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetTenantEnvLimitsByNames(tenantName string, tenantEnvNames []string) (limit map[string]int, err error)
GetTenantEnvLimitsByNames get tenantEnvs memory limit
func (*TenantEnvDaoImpl) GetTenantEnvs ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) GetTenantEnvs(tenantName string, query string) ([]*model.TenantEnvs, error)
GetTenantEnvs GetTenantEnvs
func (*TenantEnvDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户
type TenantEnvServiceAutoscalerRuleMetricsDaoImpl ¶ added in v1.13.0
TenantEnvServiceAutoscalerRuleMetricsDaoImpl -
func (*TenantEnvServiceAutoscalerRuleMetricsDaoImpl) AddModel ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*TenantEnvServiceAutoscalerRuleMetricsDaoImpl) CreateOrUpdateScaleRuleMetricsInBatch ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) CreateOrUpdateScaleRuleMetricsInBatch(metrics []*model.TenantEnvServiceAutoscalerRuleMetrics) error
CreateOrUpdateScaleRuleMetricsInBatch -
func (*TenantEnvServiceAutoscalerRuleMetricsDaoImpl) DeleteByRuleID ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) DeleteByRuleID(ruldID string) error
DeleteByRuleID -
func (*TenantEnvServiceAutoscalerRuleMetricsDaoImpl) DeleteByRuleIDs ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) DeleteByRuleIDs(ruleIDs []string) error
DeleteByRuleIDs deletes rule metrics based on componentIDs
func (*TenantEnvServiceAutoscalerRuleMetricsDaoImpl) ListByRuleID ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) ListByRuleID(ruleID string) ([]*model.TenantEnvServiceAutoscalerRuleMetrics, error)
ListByRuleID -
func (*TenantEnvServiceAutoscalerRuleMetricsDaoImpl) UpdateModel ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
func (*TenantEnvServiceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate(metric *model.TenantEnvServiceAutoscalerRuleMetrics) error
UpdateOrCreate -
type TenantEnvServiceAutoscalerRulesDaoImpl ¶ added in v1.13.0
TenantEnvServiceAutoscalerRulesDaoImpl -
func (*TenantEnvServiceAutoscalerRulesDaoImpl) AddModel ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*TenantEnvServiceAutoscalerRulesDaoImpl) CreateOrUpdateScaleRulesInBatch ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) CreateOrUpdateScaleRulesInBatch(rules []*model.TenantEnvServiceAutoscalerRules) error
CreateOrUpdateScaleRulesInBatch -
func (*TenantEnvServiceAutoscalerRulesDaoImpl) DeleteByComponentIDs ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs deletes rule based on componentIDs
func (*TenantEnvServiceAutoscalerRulesDaoImpl) DeleteByRuleID ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) DeleteByRuleID(ruleID string) error
func (*TenantEnvServiceAutoscalerRulesDaoImpl) GetByRuleID ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) GetByRuleID(ruleID string) (*model.TenantEnvServiceAutoscalerRules, error)
GetByRuleID -
func (*TenantEnvServiceAutoscalerRulesDaoImpl) ListByComponentIDs ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) ListByComponentIDs(componentIDs []string) ([]*model.TenantEnvServiceAutoscalerRules, error)
ListByComponentIDs -
func (*TenantEnvServiceAutoscalerRulesDaoImpl) ListByServiceID ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) ListByServiceID(serviceID string) ([]*model.TenantEnvServiceAutoscalerRules, error)
ListByServiceID -
func (*TenantEnvServiceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID(serviceID string) ([]*model.TenantEnvServiceAutoscalerRules, error)
ListEnableOnesByServiceID -
func (*TenantEnvServiceAutoscalerRulesDaoImpl) UpdateModel ¶ added in v1.13.0
func (t *TenantEnvServiceAutoscalerRulesDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type TenantEnvServiceConfigFileDaoImpl ¶ added in v1.1.0
TenantEnvServiceConfigFileDaoImpl is a implementation of TenantEnvServiceConfigFileDao
func (*TenantEnvServiceConfigFileDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) AddModel(mo model.Interface) error
AddModel creates a new TenantEnvServiceConfigFile
func (*TenantEnvServiceConfigFileDaoImpl) CreateOrUpdateConfigFilesInBatch ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) CreateOrUpdateConfigFilesInBatch(configFiles []*model.TenantEnvServiceConfigFile) error
CreateOrUpdateConfigFilesInBatch -
func (*TenantEnvServiceConfigFileDaoImpl) DelByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) DelByServiceID(sid string) error
DelByServiceID deletes config files according to service id.
func (*TenantEnvServiceConfigFileDaoImpl) DelByVolumeID ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) DelByVolumeID(sid, volumeName string) error
DelByVolumeID deletes config files according to service id and volume id.
func (*TenantEnvServiceConfigFileDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServiceConfigFileDaoImpl) GetByVolumeName ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) GetByVolumeName(sid string, volumeName string) (*model.TenantEnvServiceConfigFile, error)
GetByVolumeName get config file by volume name
func (*TenantEnvServiceConfigFileDaoImpl) GetConfigFileByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) GetConfigFileByServiceID(serviceID string) ([]*model.TenantEnvServiceConfigFile, error)
GetConfigFileByServiceID -
func (*TenantEnvServiceConfigFileDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceConfigFileDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel updates config file
type TenantEnvServiceEnvVarDaoImpl ¶ added in v1.1.0
TenantEnvServiceEnvVarDaoImpl TenantEnvServiceEnvVarDaoImpl
func (*TenantEnvServiceEnvVarDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用环境变量
func (*TenantEnvServiceEnvVarDaoImpl) CreateOrUpdateEnvsInBatch ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) CreateOrUpdateEnvsInBatch(envs []*model.TenantEnvServiceEnvVar) error
CreateOrUpdateEnvsInBatch Batch insert or update environment variables
func (*TenantEnvServiceEnvVarDaoImpl) DELServiceEnvsByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) DELServiceEnvsByServiceID(serviceID string) error
DELServiceEnvsByServiceID 通过serviceID 删除envs
func (*TenantEnvServiceEnvVarDaoImpl) DelByServiceIDAndScope ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) DelByServiceIDAndScope(sid, scope string) error
DelByServiceIDAndScope deletes TenantEnvServiceEnvVar based on sid(service_id) and scope.
func (*TenantEnvServiceEnvVarDaoImpl) DeleteByComponentID ¶ added in v1.13.0
func (t *TenantEnvServiceEnvVarDaoImpl) DeleteByComponentID(componentID string) error
DeleteByComponentID -
func (*TenantEnvServiceEnvVarDaoImpl) DeleteByComponentIDAndScope ¶ added in v1.13.0
func (t *TenantEnvServiceEnvVarDaoImpl) DeleteByComponentIDAndScope(componentID, scope string) error
DeleteByComponentIDAndScope -
func (*TenantEnvServiceEnvVarDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServiceEnvVarDaoImpl) DeleteModel ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
DeleteModel 删除env
func (*TenantEnvServiceEnvVarDaoImpl) GetDependServiceEnvs ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) GetDependServiceEnvs(serviceIDs []string, scopes []string) ([]*model.TenantEnvServiceEnvVar, error)
GetDependServiceEnvs 获取依赖服务的环境变量
func (*TenantEnvServiceEnvVarDaoImpl) GetEnv ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) GetEnv(serviceID, envName string) (*model.TenantEnvServiceEnvVar, error)
GetEnv 获取某个环境变量
func (*TenantEnvServiceEnvVarDaoImpl) GetServiceEnvs ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) GetServiceEnvs(serviceID string, scopes []string) ([]*model.TenantEnvServiceEnvVar, error)
GetServiceEnvs 获取服务环境变量
func (*TenantEnvServiceEnvVarDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceEnvVarDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel update env support attr_value\is_change\scope
type TenantEnvServiceLBMappingPortDaoImpl ¶ added in v1.1.0
TenantEnvServiceLBMappingPortDaoImpl stream服务映射
func (*TenantEnvServiceLBMappingPortDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用端口映射
func (*TenantEnvServiceLBMappingPortDaoImpl) CreateTenantEnvServiceLBMappingPort ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) CreateTenantEnvServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantEnvServiceLBMappingPort, error)
CreateTenantEnvServiceLBMappingPort 创建负载均衡VS端口,如果端口分配已存在,直接返回
func (*TenantEnvServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID(serviceID string) error
DELServiceLBMappingPortByServiceID DELServiceLBMappingPortByServiceID
func (*TenantEnvServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort(serviceID string, lbport int) error
DELServiceLBMappingPortByServiceIDAndPort DELServiceLBMappingPortByServiceIDAndPort
func (*TenantEnvServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort(serviceID string, port int) (*model.TenantEnvServiceLBMappingPort, error)
GetLBMappingPortByServiceIDAndPort returns a LBMappingPort by serviceID and port
func (*TenantEnvServiceLBMappingPortDaoImpl) GetLBPortByTenantEnvAndPort ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) GetLBPortByTenantEnvAndPort(tenantEnvID string, lbport int) (*model.TenantEnvServiceLBMappingPort, error)
GetLBPortByTenantEnvAndPort GetLBPortByTenantEnvAndPort
func (*TenantEnvServiceLBMappingPortDaoImpl) GetLBPortsASC ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) GetLBPortsASC() ([]*model.TenantEnvServiceLBMappingPort, error)
GetLBPortsASC gets all LBMappingPorts ascending
func (*TenantEnvServiceLBMappingPortDaoImpl) GetTenantEnvServiceLBMappingPort ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) GetTenantEnvServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantEnvServiceLBMappingPort, error)
GetTenantEnvServiceLBMappingPort 获取端口映射
func (*TenantEnvServiceLBMappingPortDaoImpl) GetTenantEnvServiceLBMappingPortByService ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) GetTenantEnvServiceLBMappingPortByService(serviceID string) ([]*model.TenantEnvServiceLBMappingPort, error)
GetTenantEnvServiceLBMappingPortByService 获取端口映射
func (*TenantEnvServiceLBMappingPortDaoImpl) PortExists ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) PortExists(port int) bool
PortExists checks if the port exists
func (*TenantEnvServiceLBMappingPortDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceLBMappingPortDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用端口映射
type TenantEnvServiceMonitorDaoImpl ¶ added in v1.1.0
TenantEnvServiceMonitorDaoImpl -
func (*TenantEnvServiceMonitorDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) AddModel(mo model.Interface) error
AddModel create service monitor
func (*TenantEnvServiceMonitorDaoImpl) CreateOrUpdateMonitorInBatch ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) CreateOrUpdateMonitorInBatch(monitors []*model.TenantEnvServiceMonitor) error
CreateOrUpdateMonitorInBatch -
func (*TenantEnvServiceMonitorDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs delete service monitor by component ids
func (*TenantEnvServiceMonitorDaoImpl) DeleteServiceMonitor ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) DeleteServiceMonitor(mo *model.TenantEnvServiceMonitor) error
DeleteServiceMonitor delete service monitor
func (*TenantEnvServiceMonitorDaoImpl) DeleteServiceMonitorByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) DeleteServiceMonitorByServiceID(serviceID string) error
DeleteServiceMonitorByServiceID delete service monitor by service id
func (*TenantEnvServiceMonitorDaoImpl) GetByName ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) GetByName(serviceID, name string) (*model.TenantEnvServiceMonitor, error)
GetByName get by name
func (*TenantEnvServiceMonitorDaoImpl) GetByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) GetByServiceID(serviceID string) ([]*model.TenantEnvServiceMonitor, error)
GetByServiceID get tsm by service id
func (*TenantEnvServiceMonitorDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceMonitorDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel update service monitor
type TenantEnvServiceMountRelationDaoImpl ¶ added in v1.1.0
TenantEnvServiceMountRelationDaoImpl 依赖存储
func (*TenantEnvServiceMountRelationDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用依赖挂载
func (*TenantEnvServiceMountRelationDaoImpl) CreateOrUpdateVolumeRelsInBatch ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) CreateOrUpdateVolumeRelsInBatch(volRels []*model.TenantEnvServiceMountRelation) error
CreateOrUpdateVolumeRelsInBatch -
func (*TenantEnvServiceMountRelationDaoImpl) DELTenantEnvServiceMountRelationByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) DELTenantEnvServiceMountRelationByServiceID(serviceID string) error
DELTenantEnvServiceMountRelationByServiceID DELTenantEnvServiceMountRelationByServiceID
func (*TenantEnvServiceMountRelationDaoImpl) DElTenantEnvServiceMountRelationByDepService ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) DElTenantEnvServiceMountRelationByDepService(serviceID, depServiceID string) error
DElTenantEnvServiceMountRelationByDepService del mount relation
func (*TenantEnvServiceMountRelationDaoImpl) DElTenantEnvServiceMountRelationByServiceAndName ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) DElTenantEnvServiceMountRelationByServiceAndName(serviceID, name string) error
DElTenantEnvServiceMountRelationByServiceAndName DElTenantEnvServiceMountRelationByServiceAndName
func (*TenantEnvServiceMountRelationDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServiceMountRelationDaoImpl) GetTenantEnvServiceMountRelationsByService ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) GetTenantEnvServiceMountRelationsByService(serviceID string) ([]*model.TenantEnvServiceMountRelation, error)
GetTenantEnvServiceMountRelationsByService 获取应用的所有挂载依赖
func (*TenantEnvServiceMountRelationDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceMountRelationDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用依赖挂载
type TenantEnvServicePluginRelationDaoImpl ¶ added in v1.1.0
TenantEnvServicePluginRelationDaoImpl TenantEnvServicePluginRelationDaoImpl
func (*TenantEnvServicePluginRelationDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) AddModel(mo model.Interface) error
AddModel 添加插件默认变量
func (*TenantEnvServicePluginRelationDaoImpl) CheckPluginBeforeInstall ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) CheckPluginBeforeInstall(serviceID, pluginModel string) (bool, error)
CheckPluginBeforeInstall 插件安装前的检查 1. 如果组件之前已经安装过网络类插件,不能继续安装同类插件 2. 如果组件之前已经安装过数据中间件管理插件,不能继续安装同类插件
func (*TenantEnvServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID(serviceID, pluginModel string) (bool, error)
CheckSomeModelPluginByServiceID 检查是否绑定了某种插件且处于启用状态
func (*TenantEnvServicePluginRelationDaoImpl) CreateOrUpdatePluginRelsInBatch ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) CreateOrUpdatePluginRelsInBatch(relations []*model.TenantEnvServicePluginRelation) error
CreateOrUpdatePluginRelsInBatch -
func (*TenantEnvServicePluginRelationDaoImpl) DeleteALLRelationByPluginID ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) DeleteALLRelationByPluginID(pluginID string) error
DeleteALLRelationByPluginID 删除pluginID所有依赖 一般不要使用 会影响关联过的应用启动
func (*TenantEnvServicePluginRelationDaoImpl) DeleteALLRelationByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) DeleteALLRelationByServiceID(serviceID string) error
DeleteALLRelationByServiceID 删除serviceID所有插件依赖 一般用于删除应用时使用
func (*TenantEnvServicePluginRelationDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID(serviceID, pluginID string) error
DeleteRelationByServiceIDAndPluginID 删除service plugin 对应关系
func (*TenantEnvServicePluginRelationDaoImpl) GetALLRelationByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) GetALLRelationByServiceID(serviceID string) ([]*model.TenantEnvServicePluginRelation, error)
GetALLRelationByServiceID 获取当前应用所有的插件依赖关系
func (*TenantEnvServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID(serviceID, pluginID string) (*model.TenantEnvServicePluginRelation, error)
GetRelateionByServiceIDAndPluginID GetRelateionByServiceIDAndPluginID
func (*TenantEnvServicePluginRelationDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServicePluginRelationDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新插件默认变量 更新依赖的version id
type TenantEnvServiceRelationDaoImpl ¶ added in v1.1.0
TenantEnvServiceRelationDaoImpl TenantEnvServiceRelationDaoImpl
func (*TenantEnvServiceRelationDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用依赖关系
func (*TenantEnvServiceRelationDaoImpl) CreateOrUpdateRelationsInBatch ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) CreateOrUpdateRelationsInBatch(relations []*model.TenantEnvServiceRelation) error
CreateOrUpdateRelationsInBatch -
func (*TenantEnvServiceRelationDaoImpl) DELRelationsByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) DELRelationsByServiceID(serviceID string) error
DELRelationsByServiceID DELRelationsByServiceID
func (*TenantEnvServiceRelationDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServiceRelationDaoImpl) DeleteModel ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
DeleteModel 删除依赖
func (*TenantEnvServiceRelationDaoImpl) DeleteRelationByDepID ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) DeleteRelationByDepID(serviceID, depID string) error
DeleteRelationByDepID DeleteRelationByDepID
func (*TenantEnvServiceRelationDaoImpl) GetTenantEnvServiceRelations ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) GetTenantEnvServiceRelations(serviceID string) ([]*model.TenantEnvServiceRelation, error)
GetTenantEnvServiceRelations 获取应用依赖关系
func (*TenantEnvServiceRelationDaoImpl) GetTenantEnvServiceRelationsByDependServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) GetTenantEnvServiceRelationsByDependServiceID(dependServiceID string) ([]*model.TenantEnvServiceRelation, error)
GetTenantEnvServiceRelationsByDependServiceID 获取全部依赖当前服务的应用
func (*TenantEnvServiceRelationDaoImpl) HaveRelations ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) HaveRelations(serviceID string) bool
HaveRelations 是否有依赖
func (*TenantEnvServiceRelationDaoImpl) ListByServiceIDs ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) ListByServiceIDs(serviceIDs []string) ([]*model.TenantEnvServiceRelation, error)
ListByServiceIDs -
func (*TenantEnvServiceRelationDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceRelationDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用依赖关系
type TenantEnvServiceScalingRecordsDaoImpl ¶ added in v1.1.0
TenantEnvServiceScalingRecordsDaoImpl -
func (*TenantEnvServiceScalingRecordsDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceScalingRecordsDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*TenantEnvServiceScalingRecordsDaoImpl) CountByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceScalingRecordsDaoImpl) CountByServiceID(serviceID string) (int, error)
CountByServiceID -
func (*TenantEnvServiceScalingRecordsDaoImpl) ListByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceScalingRecordsDaoImpl) ListByServiceID(serviceID string, offset, limit int) ([]*model.TenantEnvServiceScalingRecords, error)
ListByServiceID -
func (*TenantEnvServiceScalingRecordsDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceScalingRecordsDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
func (*TenantEnvServiceScalingRecordsDaoImpl) UpdateOrCreate ¶ added in v1.1.0
func (t *TenantEnvServiceScalingRecordsDaoImpl) UpdateOrCreate(new *model.TenantEnvServiceScalingRecords) error
UpdateOrCreate -
type TenantEnvServiceVolumeDaoImpl ¶ added in v1.1.0
TenantEnvServiceVolumeDaoImpl 应用存储
func (*TenantEnvServiceVolumeDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用挂载
func (*TenantEnvServiceVolumeDaoImpl) CreateOrUpdateVolumesInBatch ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) CreateOrUpdateVolumesInBatch(volumes []*model.TenantEnvServiceVolume) error
CreateOrUpdateVolumesInBatch -
func (*TenantEnvServiceVolumeDaoImpl) DelShareableBySID ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) DelShareableBySID(sid string) error
DelShareableBySID deletes shareable volumes based on sid(service_id)
func (*TenantEnvServiceVolumeDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath(serviceID string, volumePath string) error
DeleteByServiceIDAndVolumePath 删除挂载通过挂载的目录
func (*TenantEnvServiceVolumeDaoImpl) DeleteByVolumeIDs ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) DeleteByVolumeIDs(volumeIDs []uint) error
DeleteByVolumeIDs -
func (*TenantEnvServiceVolumeDaoImpl) DeleteModel ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
DeleteModel 删除挂载
func (*TenantEnvServiceVolumeDaoImpl) DeleteTenantEnvServiceVolumesByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) DeleteTenantEnvServiceVolumesByServiceID(serviceID string) error
DeleteTenantEnvServiceVolumesByServiceID 删除挂载
func (*TenantEnvServiceVolumeDaoImpl) GetAllVolumes ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) GetAllVolumes() ([]*model.TenantEnvServiceVolume, error)
GetAllVolumes 获取全部存储信息
func (*TenantEnvServiceVolumeDaoImpl) GetTenantEnvServiceVolumesByServiceID ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) GetTenantEnvServiceVolumesByServiceID(serviceID string) ([]*model.TenantEnvServiceVolume, error)
GetTenantEnvServiceVolumesByServiceID 获取应用挂载
func (*TenantEnvServiceVolumeDaoImpl) GetVolumeByID ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) GetVolumeByID(id int) (*model.TenantEnvServiceVolume, error)
GetVolumeByID get volume by id
func (*TenantEnvServiceVolumeDaoImpl) GetVolumeByServiceIDAndName ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) GetVolumeByServiceIDAndName(serviceID, name string) (*model.TenantEnvServiceVolume, error)
GetVolumeByServiceIDAndName 获取存储信息
func (*TenantEnvServiceVolumeDaoImpl) ListVolumesByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) ListVolumesByComponentIDs(componentIDs []string) ([]*model.TenantEnvServiceVolume, error)
ListVolumesByComponentIDs -
func (*TenantEnvServiceVolumeDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServiceVolumeDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更��应用挂载
type TenantEnvServicesDaoImpl ¶ added in v1.1.0
TenantEnvServicesDaoImpl 租户应用dao
func (*TenantEnvServicesDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) AddModel(mo model.Interface) error
AddModel 添加租户应用
func (*TenantEnvServicesDaoImpl) BindAppByServiceIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) BindAppByServiceIDs(appID string, serviceIDs []string) error
BindAppByServiceIDs binding application by serviceIDs
func (*TenantEnvServicesDaoImpl) CountServiceByAppID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) CountServiceByAppID(appID string) (int64, error)
CountServiceByAppID get Service number by AppID
func (*TenantEnvServicesDaoImpl) CreateOrUpdateComponentsInBatch ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) CreateOrUpdateComponentsInBatch(components []*model.TenantEnvServices) error
CreateOrUpdateComponentsInBatch Batch insert or update component
func (*TenantEnvServicesDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) DeleteByComponentIDs(tenantEnvID, appID string, componentIDs []string) error
DeleteByComponentIDs deletes components based on the given componentIDs.
func (*TenantEnvServicesDaoImpl) DeleteServiceByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) DeleteServiceByServiceID(serviceID string) error
DeleteServiceByServiceID DeleteServiceByServiceID
func (*TenantEnvServicesDaoImpl) GetAllServicesID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetAllServicesID() ([]*model.TenantEnvServices, error)
GetAllServicesID get all service sample info
func (*TenantEnvServicesDaoImpl) GetPagedTenantEnvService ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetPagedTenantEnvService(offset, length int, serviceIDs []string) ([]map[string]interface{}, int, error)
GetPagedTenantEnvService GetPagedTenantEnvResource
func (*TenantEnvServicesDaoImpl) GetServiceAliasByIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceAliasByIDs(uids []string) ([]*model.TenantEnvServices, error)
GetServiceAliasByIDs 获取应用别名
func (*TenantEnvServicesDaoImpl) GetServiceByID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceByID(serviceID string) (*model.TenantEnvServices, error)
GetServiceByID 获取服务通过服务id
func (*TenantEnvServicesDaoImpl) GetServiceByIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceByIDs(uids []string) ([]*model.TenantEnvServices, error)
GetServiceByIDs get some service by service ids
func (*TenantEnvServicesDaoImpl) GetServiceByServiceAlias ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceByServiceAlias(serviceAlias string) (*model.TenantEnvServices, error)
GetServiceByServiceAlias 获取服务通过服务别名
func (*TenantEnvServicesDaoImpl) GetServiceByTenantEnvIDAndServiceAlias ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceByTenantEnvIDAndServiceAlias(tenantEnvID, serviceName string) (*model.TenantEnvServices, error)
GetServiceByTenantEnvIDAndServiceAlias 根据租户名和服务名
func (*TenantEnvServicesDaoImpl) GetServiceIDsByAppID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceIDsByAppID(appID string) (re []model.ServiceID)
GetServiceIDsByAppID get ServiceIDs by AppID
func (*TenantEnvServicesDaoImpl) GetServiceMemoryByServiceIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceMemoryByServiceIDs(serviceIDs []string) (map[string]map[string]interface{}, error)
GetServiceMemoryByServiceIDs get service memory by service ids
func (*TenantEnvServicesDaoImpl) GetServiceMemoryByTenantEnvIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceMemoryByTenantEnvIDs(tenantEnvIDs []string, runningServiceIDs []string) (map[string]map[string]interface{}, error)
GetServiceMemoryByTenantEnvIDs get service memory by tenant env ids
func (*TenantEnvServicesDaoImpl) GetServiceTypeByID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServiceTypeByID(serviceID string) (*model.TenantEnvServices, error)
GetServiceTypeByID get service type by service id
func (*TenantEnvServicesDaoImpl) GetServicesAllInfoByTenantEnvID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServicesAllInfoByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvServices, error)
GetServicesAllInfoByTenantEnvID GetServicesAllInfoByTenantEnvID
func (*TenantEnvServicesDaoImpl) GetServicesByServiceIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServicesByServiceIDs(serviceIDs []string) ([]*model.TenantEnvServices, error)
GetServicesByServiceIDs Get Services By ServiceIDs
func (*TenantEnvServicesDaoImpl) GetServicesByTenantEnvID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServicesByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvServices, error)
GetServicesByTenantEnvID GetServicesByTenantEnvID
func (*TenantEnvServicesDaoImpl) GetServicesByTenantEnvIDs ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServicesByTenantEnvIDs(tenantEnvIDs []string) ([]*model.TenantEnvServices, error)
GetServicesByTenantEnvIDs GetServicesByTenantEnvIDs
func (*TenantEnvServicesDaoImpl) GetServicesInfoByAppID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) GetServicesInfoByAppID(appID string, page, pageSize int) ([]*model.TenantEnvServices, int64, error)
GetServicesInfoByAppID Get Services Info By ApplicationID
func (*TenantEnvServicesDaoImpl) IsK8sComponentNameDuplicate ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) IsK8sComponentNameDuplicate(appID, serviceID, k8sComponentName string) bool
IsK8sComponentNameDuplicate -
func (*TenantEnvServicesDaoImpl) ListByAppID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) ListByAppID(appID string) ([]*model.TenantEnvServices, error)
func (*TenantEnvServicesDaoImpl) ListServicesByTenantEnvID ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) ListServicesByTenantEnvID(tenantEnvID string) ([]*model.TenantEnvServices, error)
ListServicesByTenantEnvID -
func (*TenantEnvServicesDaoImpl) ListThirdPartyServices ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) ListThirdPartyServices() ([]*model.TenantEnvServices, error)
ListThirdPartyServices lists all third party services
func (*TenantEnvServicesDaoImpl) SetTenantEnvServiceStatus ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) SetTenantEnvServiceStatus(serviceID, status string) error
SetTenantEnvServiceStatus SetTenantEnvServiceStatus
func (*TenantEnvServicesDaoImpl) UpdateDeployVersion ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) UpdateDeployVersion(serviceID, deployversion string) error
UpdateDeployVersion update service current deploy version
func (*TenantEnvServicesDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServicesDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户应用
type TenantEnvServicesDeleteImpl ¶ added in v1.1.0
TenantEnvServicesDeleteImpl TenantEnvServiceDeleteImpl
func (*TenantEnvServicesDeleteImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServicesDeleteImpl) AddModel(mo model.Interface) error
AddModel 添加已删除的应用
func (*TenantEnvServicesDeleteImpl) DeleteTenantEnvServicesDelete ¶ added in v1.1.0
func (t *TenantEnvServicesDeleteImpl) DeleteTenantEnvServicesDelete(record *model.TenantEnvServicesDelete) error
DeleteTenantEnvServicesDelete -
func (*TenantEnvServicesDeleteImpl) GetServiceByID ¶ added in v1.11.0
func (t *TenantEnvServicesDeleteImpl) GetServiceByID(serviceID string) (*model.TenantEnvServicesDelete, error)
GetServiceByID 获取服务通过服务id
func (*TenantEnvServicesDeleteImpl) GetTenantEnvServicesDeleteByCreateTime ¶ added in v1.1.0
func (t *TenantEnvServicesDeleteImpl) GetTenantEnvServicesDeleteByCreateTime(createTime time.Time) ([]*model.TenantEnvServicesDelete, error)
GetTenantEnvServicesDeleteByCreateTime -
func (*TenantEnvServicesDeleteImpl) List ¶ added in v1.1.0
func (t *TenantEnvServicesDeleteImpl) List() ([]*model.TenantEnvServicesDelete, error)
List returns a list of TenantEnvServicesDeletes.
func (*TenantEnvServicesDeleteImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServicesDeleteImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户应用
type TenantEnvServicesPortDaoImpl ¶ added in v1.1.0
TenantEnvServicesPortDaoImpl 租户应用端口操作
func (*TenantEnvServicesPortDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用端口
func (*TenantEnvServicesPortDaoImpl) CreateOrUpdatePortsInBatch ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) CreateOrUpdatePortsInBatch(ports []*model.TenantEnvServicesPort) error
CreateOrUpdatePortsInBatch Batch insert or update ports variables
func (*TenantEnvServicesPortDaoImpl) DELPortsByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) DELPortsByServiceID(serviceID string) error
DELPortsByServiceID DELPortsByServiceID
func (*TenantEnvServicesPortDaoImpl) DelByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) DelByServiceID(sid string) error
DelByServiceID deletes TenantEnvServicesPort matching sid(service_id).
func (*TenantEnvServicesPortDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServicesPortDaoImpl) DeleteModel ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
DeleteModel 删除端口
func (*TenantEnvServicesPortDaoImpl) GetByTenantEnvAndName ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) GetByTenantEnvAndName(tenantEnvID, name string) (*model.TenantEnvServicesPort, error)
GetByTenantEnvAndName -
func (*TenantEnvServicesPortDaoImpl) GetDepUDPPort ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) GetDepUDPPort(serviceID string) ([]*model.TenantEnvServicesPort, error)
GetDepUDPPort get all depend service udp port
func (*TenantEnvServicesPortDaoImpl) GetInnerPorts ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) GetInnerPorts(serviceID string) ([]*model.TenantEnvServicesPort, error)
GetInnerPorts 获取对内端口
func (*TenantEnvServicesPortDaoImpl) GetOpenedPorts ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) GetOpenedPorts(serviceID string) ([]*model.TenantEnvServicesPort, error)
GetOpenedPorts returns opened ports.
func (*TenantEnvServicesPortDaoImpl) GetOuterPorts ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) GetOuterPorts(serviceID string) ([]*model.TenantEnvServicesPort, error)
GetOuterPorts 获取对外端口
func (*TenantEnvServicesPortDaoImpl) GetPort ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) GetPort(serviceID string, port int) (*model.TenantEnvServicesPort, error)
GetPort get port
func (*TenantEnvServicesPortDaoImpl) GetPortsByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) GetPortsByServiceID(serviceID string) ([]*model.TenantEnvServicesPort, error)
GetPortsByServiceID 通过服务获取port
func (*TenantEnvServicesPortDaoImpl) HasOpenPort ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) HasOpenPort(sid string) bool
HasOpenPort checks if the given service(according to sid) has open port.
func (*TenantEnvServicesPortDaoImpl) ListByK8sServiceNames ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) ListByK8sServiceNames(k8sServiceNames []string) ([]*model.TenantEnvServicesPort, error)
ListByK8sServiceNames -
func (*TenantEnvServicesPortDaoImpl) ListInnerPortsByServiceIDs ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) ListInnerPortsByServiceIDs(serviceIDs []string) ([]*model.TenantEnvServicesPort, error)
ListInnerPortsByServiceIDs -
func (*TenantEnvServicesPortDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServicesPortDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户
type TenantEnvServicesStreamPluginPortDaoImpl ¶ added in v1.1.0
TenantEnvServicesStreamPluginPortDaoImpl TenantEnvServicesStreamPluginPortDaoImpl
func (*TenantEnvServicesStreamPluginPortDaoImpl) AddModel ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) AddModel(mo model.Interface) error
AddModel 添加插件端口映射信息
func (*TenantEnvServicesStreamPluginPortDaoImpl) CreateOrUpdateStreamPluginPortsInBatch ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) CreateOrUpdateStreamPluginPortsInBatch(spPorts []*model.TenantEnvServicesStreamPluginPort) error
CreateOrUpdateStreamPluginPortsInBatch -
func (*TenantEnvServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID(serviceID string) error
DeleteAllPluginMappingPortByServiceID DeleteAllPluginMappingPortByServiceID
func (*TenantEnvServicesStreamPluginPortDaoImpl) DeleteByComponentIDs ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs -
func (*TenantEnvServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort( serviceID string, pluginModel string, containerPort int) error
DeletePluginMappingPortByContainerPort DeletePluginMappingPortByContainerPort
func (*TenantEnvServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort( serviceID string, pluginModel string, containerPort int, ) (*model.TenantEnvServicesStreamPluginPort, error)
GetPluginMappingPortByServiceIDAndContainerPort GetPluginMappingPortByServiceIDAndContainerPort
func (*TenantEnvServicesStreamPluginPortDaoImpl) GetPluginMappingPorts ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) GetPluginMappingPorts( serviceID string) ([]*model.TenantEnvServicesStreamPluginPort, error)
GetPluginMappingPorts GetPluginMappingPorts 降序排列
func (*TenantEnvServicesStreamPluginPortDaoImpl) ListByServiceID ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) ListByServiceID(sid string) ([]*model.TenantEnvServicesStreamPluginPort, error)
ListByServiceID returns the list of environment variables for the plugin via serviceID
func (*TenantEnvServicesStreamPluginPortDaoImpl) SetPluginMappingPort ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) SetPluginMappingPort( tenantEnvID string, serviceID string, pluginModel string, containerPort int) (int, error)
SetPluginMappingPort SetPluginMappingPort
func (*TenantEnvServicesStreamPluginPortDaoImpl) UpdateModel ¶ added in v1.1.0
func (t *TenantEnvServicesStreamPluginPortDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新插件端口映射信息
type ThirdPartySvcDiscoveryCfgDaoImpl ¶
ThirdPartySvcDiscoveryCfgDaoImpl implements ThirdPartySvcDiscoveryCfgDao
func (*ThirdPartySvcDiscoveryCfgDaoImpl) AddModel ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) AddModel(mo model.Interface) error
AddModel add one record for table 3rd_party_svc_discovery_cfg.
func (*ThirdPartySvcDiscoveryCfgDaoImpl) CreateOrUpdate3rdSvcDiscoveryCfgInBatch ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) CreateOrUpdate3rdSvcDiscoveryCfgInBatch(cfgs []*model.ThirdPartySvcDiscoveryCfg) error
CreateOrUpdate3rdSvcDiscoveryCfgInBatch -
func (*ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByComponentIDs ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByComponentIDs(componentIDs []string) error
DeleteByComponentIDs delete discovery config based on componentIDs.
func (*ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID(sid string) error
DeleteByServiceID delete discovery config based on service id.
func (*ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID(sid string) (*model.ThirdPartySvcDiscoveryCfg, error)
GetByServiceID return third-party service discovery configuration according to service_id.
func (*ThirdPartySvcDiscoveryCfgDaoImpl) UpdateModel ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel blabla
type VersionInfoDaoImpl ¶
VersionInfoDaoImpl VersionInfoDaoImpl
func (*VersionInfoDaoImpl) AddModel ¶
func (c *VersionInfoDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*VersionInfoDaoImpl) DeleteFailureVersionInfo ¶
func (c *VersionInfoDaoImpl) DeleteFailureVersionInfo(timePoint time.Time, status string, serviceIDs []string) error
DeleteFailureVersionInfo delete failure version
func (*VersionInfoDaoImpl) DeleteVersionByEventID ¶
func (c *VersionInfoDaoImpl) DeleteVersionByEventID(eventID string) error
DeleteVersionByEventID DeleteVersionByEventID
func (*VersionInfoDaoImpl) DeleteVersionByServiceID ¶
func (c *VersionInfoDaoImpl) DeleteVersionByServiceID(serviceID string) error
DeleteVersionByServiceID DeleteVersionByServiceID
func (*VersionInfoDaoImpl) DeleteVersionInfo ¶
func (c *VersionInfoDaoImpl) DeleteVersionInfo(obj *model.VersionInfo) error
DeleteVersionInfo delete version
func (*VersionInfoDaoImpl) GetAllVersionByServiceID ¶
func (c *VersionInfoDaoImpl) GetAllVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
GetAllVersionByServiceID get all versions by service id, not only successful
func (*VersionInfoDaoImpl) GetLatestScsVersion ¶
func (c *VersionInfoDaoImpl) GetLatestScsVersion(sid string) (*model.VersionInfo, error)
GetLatestScsVersion returns the latest versoin that the final_status is 'success'.
func (*VersionInfoDaoImpl) GetVersionByDeployVersion ¶
func (c *VersionInfoDaoImpl) GetVersionByDeployVersion(version, serviceID string) (*model.VersionInfo, error)
GetVersionByDeployVersion get version by deploy version
func (*VersionInfoDaoImpl) GetVersionByEventID ¶
func (c *VersionInfoDaoImpl) GetVersionByEventID(eventID string) (*model.VersionInfo, error)
GetVersionByEventID get version by event id
func (*VersionInfoDaoImpl) GetVersionByServiceID ¶
func (c *VersionInfoDaoImpl) GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
GetVersionByServiceID get versions by service id only return success version info
func (*VersionInfoDaoImpl) GetVersionInfo ¶
func (c *VersionInfoDaoImpl) GetVersionInfo(timePoint time.Time, serviceIDs []string) ([]*model.VersionInfo, error)
GetVersionInfo get version info by service ids
func (*VersionInfoDaoImpl) ListByServiceIDStatus ¶
func (c *VersionInfoDaoImpl) ListByServiceIDStatus(serviceID string, finalStatus *bool) ([]*model.VersionInfo, error)
ListByServiceIDStatus returns a list of versions based on the given serviceID and finalStatus.
func (*VersionInfoDaoImpl) ListSuccessfulOnes ¶
func (c *VersionInfoDaoImpl) ListSuccessfulOnes() ([]*model.VersionInfo, error)
ListSuccessfulOnes r-
func (*VersionInfoDaoImpl) ListVersionsByComponentIDs ¶
func (c *VersionInfoDaoImpl) ListVersionsByComponentIDs(componentIDs []string) ([]*model.VersionInfo, error)
ListVersionsByComponentIDs -
func (*VersionInfoDaoImpl) SearchVersionInfo ¶
func (c *VersionInfoDaoImpl) SearchVersionInfo() ([]*model.VersionInfo, error)
SearchVersionInfo query version count >5
func (*VersionInfoDaoImpl) UpdateModel ¶
func (c *VersionInfoDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel
type VolumeTypeDaoImpl ¶
VolumeTypeDaoImpl license model 管理
func (*VolumeTypeDaoImpl) AddModel ¶
func (vtd *VolumeTypeDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*VolumeTypeDaoImpl) CreateOrUpdateVolumeType ¶
func (vtd *VolumeTypeDaoImpl) CreateOrUpdateVolumeType(vt *model.TenantEnvServiceVolumeType) (*model.TenantEnvServiceVolumeType, error)
CreateOrUpdateVolumeType find or create volumeType, !!! attention:just for store sync storageclass from k8s
func (*VolumeTypeDaoImpl) DeleteModelByVolumeTypes ¶
func (vtd *VolumeTypeDaoImpl) DeleteModelByVolumeTypes(volumeType string) error
DeleteModelByVolumeTypes delete volume by type
func (*VolumeTypeDaoImpl) GetAllVolumeTypes ¶
func (vtd *VolumeTypeDaoImpl) GetAllVolumeTypes() ([]*model.TenantEnvServiceVolumeType, error)
GetAllVolumeTypes get all volumeTypes
func (*VolumeTypeDaoImpl) GetAllVolumeTypesByPage ¶
func (vtd *VolumeTypeDaoImpl) GetAllVolumeTypesByPage(page int, pageSize int) ([]*model.TenantEnvServiceVolumeType, error)
GetAllVolumeTypesByPage get all volumeTypes by page
func (*VolumeTypeDaoImpl) GetVolumeTypeByType ¶
func (vtd *VolumeTypeDaoImpl) GetVolumeTypeByType(vt string) (*model.TenantEnvServiceVolumeType, error)
GetVolumeTypeByType get volume type by type
func (*VolumeTypeDaoImpl) UpdateModel ¶
func (vtd *VolumeTypeDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel update model