dao

func (*AppBackupDaoImpl) AddModel ¶

func (a *AppBackupDaoImpl) AddModel(mo model.Interface) error

AddModel

func (*AppBackupDaoImpl) CheckHistory ¶

func (a *AppBackupDaoImpl) CheckHistory(groupID, version string) bool

CheckHistory

func (*AppBackupDaoImpl) DeleteAppBackup ¶

func (a *AppBackupDaoImpl) DeleteAppBackup(backupID string) error

DeleteAppBackup

func (*AppBackupDaoImpl) GetAppBackup ¶

func (a *AppBackupDaoImpl) GetAppBackup(backupID string) (*model.AppBackup, error)

GetAppBackup

func (*AppBackupDaoImpl) GetAppBackups ¶

func (a *AppBackupDaoImpl) GetAppBackups(groupID string) ([]*model.AppBackup, error)

GetAppBackups

func (*AppBackupDaoImpl) GetDeleteAppBackup ¶

func (a *AppBackupDaoImpl) GetDeleteAppBackup(backupID string) (*model.AppBackup, error)

GetDeleteAppBackup

func (*AppBackupDaoImpl) GetDeleteAppBackups ¶

func (a *AppBackupDaoImpl) GetDeleteAppBackups() ([]*model.AppBackup, error)

GetDeleteAppBackups

func (*AppBackupDaoImpl) UpdateModel ¶

func (a *AppBackupDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel

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 -

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 -

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 -

func (*AppDaoImpl) AddModel ¶

func (a *AppDaoImpl) AddModel(mo model.Interface) error

AddModel

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

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) ListApps ¶

func (a *ApplicationDaoImpl) ListApps(tenantID, 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 -

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

func (*CodeCheckResultDaoImpl) AddModel ¶

func (c *CodeCheckResultDaoImpl) AddModel(mo model.Interface) error

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

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) ListIsOnline ¶

func (e *EndpointDaoImpl) ListIsOnline(sid string) ([]*model.Endpoint, error)

ListIsOnline lists *model.Endpoint according to sid, and filter out the ones that are not online.

func (*EndpointDaoImpl) UpdateModel ¶

func (e *EndpointDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel updates one record for table 3rd_party_svc_endpoint

func (*EnterpriseDaoImpl) GetEnterpriseTenants ¶

func (e *EnterpriseDaoImpl) GetEnterpriseTenants(enterpriseID string) ([]*model.Tenants, error)

GetEnterpriseTenants

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) 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) GetEventsByTenantID ¶

func (c *EventDaoImpl) GetEventsByTenantID(tenantID string, offset, limit int) ([]*model.ServiceEvent, int, error)

GetEventsByTenantID get event by tenantID

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.

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.

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

func (*LicenseDaoImpl) AddModel ¶

func (l *LicenseDaoImpl) AddModel(mo model.Interface) error

AddModel

func (*LicenseDaoImpl) DeleteLicense ¶

func (l *LicenseDaoImpl) DeleteLicense(token string) error

DeleteLicense

func (*LicenseDaoImpl) ListLicenses ¶

func (l *LicenseDaoImpl) ListLicenses() ([]*model.LicenseInfo, error)

ListLicenses

func (*LicenseDaoImpl) UpdateModel ¶

func (l *LicenseDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel

func (*LocalSchedulerDaoImpl) AddModel ¶

func (t *LocalSchedulerDaoImpl) AddModel(mo model.Interface) error

AddModel Add local scheduling information

func (*LocalSchedulerDaoImpl) GetLocalScheduler ¶

func (t *LocalSchedulerDaoImpl) GetLocalScheduler(serviceID string) ([]*model.LocalScheduler, error)

GetLocalScheduler Obtain application local scheduling information

func (*LocalSchedulerDaoImpl) UpdateModel ¶

func (t *LocalSchedulerDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update scheduling information

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

func (*PluginBuildVersionDaoImpl) AddModel ¶

func (t *PluginBuildVersionDaoImpl) AddModel(mo model.Interface) error

AddModel Add plug-in build version information

func (*PluginBuildVersionDaoImpl) CreateOrUpdatePluginBuildVersionsInBatch ¶

func (t *PluginBuildVersionDaoImpl) CreateOrUpdatePluginBuildVersionsInBatch(buildVersions []*model.TenantPluginBuildVersion) 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.TenantPluginBuildVersion, error)

GetBuildVersionByDeployVersion GetBuildVersionByDeployVersion

func (*PluginBuildVersionDaoImpl) GetBuildVersionByPluginID ¶

func (t *PluginBuildVersionDaoImpl) GetBuildVersionByPluginID(pluginID string) ([]*model.TenantPluginBuildVersion, error)

GetBuildVersionByPluginID GetBuildVersionByPluginID

func (*PluginBuildVersionDaoImpl) GetBuildVersionByVersionID ¶

func (t *PluginBuildVersionDaoImpl) GetBuildVersionByVersionID(pluginID, versionID string) (*model.TenantPluginBuildVersion, error)

GetBuildVersionByVersionID GetBuildVersionByVersionID

func (*PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID ¶

func (t *PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID(pluginID, versionID string) (*model.TenantPluginBuildVersion, error)

GetLastBuildVersionByVersionID get last success build version

func (*PluginBuildVersionDaoImpl) ListSuccessfulOnesByPluginIDs ¶

func (t *PluginBuildVersionDaoImpl) ListSuccessfulOnesByPluginIDs(pluginIDs []string) ([]*model.TenantPluginBuildVersion, error)

ListSuccessfulOnesByPluginIDs returns the list of successful build versions,

func (*PluginBuildVersionDaoImpl) UpdateModel ¶

func (t *PluginBuildVersionDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update plugin default variables The main information generally does not change, only the name and status of the built local mirror need to be changed

func (*PluginDaoImpl) AddModel ¶

func (t *PluginDaoImpl) AddModel(mo model.Interface) error

AddModel Create plugin

func (*PluginDaoImpl) CreateOrUpdatePluginsInBatch ¶

func (t *PluginDaoImpl) CreateOrUpdatePluginsInBatch(plugins []*model.TenantPlugin) error

CreateOrUpdatePluginsInBatch -

func (*PluginDaoImpl) DeletePluginByID ¶

func (t *PluginDaoImpl) DeletePluginByID(id, tenantID string) error

DeletePluginByID DeletePluginByID

func (*PluginDaoImpl) GetPluginByID ¶

func (t *PluginDaoImpl) GetPluginByID(id, tenantID string) (*model.TenantPlugin, error)

GetPluginByID GetPluginByID

func (*PluginDaoImpl) GetPluginsByTenantID ¶

func (t *PluginDaoImpl) GetPluginsByTenantID(tenantID string) ([]*model.TenantPlugin, error)

GetPluginsByTenantID GetPluginsByTenantID

func (*PluginDaoImpl) ListByIDs ¶

func (t *PluginDaoImpl) ListByIDs(ids []string) ([]*model.TenantPlugin, error)

ListByIDs returns the list of plugins based on the given plugin ids.

func (*PluginDaoImpl) ListByTenantID ¶

func (t *PluginDaoImpl) ListByTenantID(tenantID string) ([]*model.TenantPlugin, error)

ListByTenantID -

func (*PluginDaoImpl) UpdateModel ¶

func (t *PluginDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update plugin

func (*PluginDefaultENVDaoImpl) AddModel ¶

func (t *PluginDefaultENVDaoImpl) AddModel(mo model.Interface) error

AddModel Add plugin default variables

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.TenantPluginDefaultENV, error)

GetALLMasterDefultENVs GetALLMasterDefultENVs

func (*PluginDefaultENVDaoImpl) GetDefaultENVByName ¶

func (t *PluginDefaultENVDaoImpl) GetDefaultENVByName(pluginID, name, versionID string) (*model.TenantPluginDefaultENV, error)

GetDefaultENVByName GetDefaultENVByName

func (*PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID ¶

func (t *PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID(pluginID, versionID string) ([]*model.TenantPluginDefaultENV, error)

GetDefaultENVSByPluginID GetDefaultENVSByPluginID

func (*PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID ¶

func (t *PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID(pluginID, versionID string) ([]*model.TenantPluginDefaultENV, error)

GetDefaultEnvWhichCanBeSetByPluginID GetDefaultEnvWhichCanBeSetByPluginID

func (*PluginDefaultENVDaoImpl) UpdateModel ¶

func (t *PluginDefaultENVDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update plugin default variables

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.TenantPluginVersionDiscoverConfig) 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.TenantPluginVersionDiscoverConfig, error)

GetPluginConfig get service plugin config

func (*PluginVersionConfigDaoImpl) GetPluginConfigs ¶

func (t *PluginVersionConfigDaoImpl) GetPluginConfigs(serviceID string) ([]*model.TenantPluginVersionDiscoverConfig, error)

GetPluginConfigs get plugin configs

func (*PluginVersionConfigDaoImpl) UpdateModel ¶

func (t *PluginVersionConfigDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel update service plugin config

func (*PluginVersionEnvDaoImpl) AddModel ¶

func (t *PluginVersionEnvDaoImpl) AddModel(mo model.Interface) error

AddModel Add plugin default variables

func (*PluginVersionEnvDaoImpl) CreateOrUpdatePluginVersionEnvsInBatch ¶

func (t *PluginVersionEnvDaoImpl) CreateOrUpdatePluginVersionEnvsInBatch(versionEnvs []*model.TenantPluginVersionEnv) 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 Delete a single env

func (*PluginVersionEnvDaoImpl) DeleteEnvByPluginID ¶

func (t *PluginVersionEnvDaoImpl) DeleteEnvByPluginID(serviceID, pluginID string) error

DeleteEnvByPluginID When deleting plugin dependencies, you need to delete the corresponding env

func (*PluginVersionEnvDaoImpl) DeleteEnvByServiceID ¶

func (t *PluginVersionEnvDaoImpl) DeleteEnvByServiceID(serviceID string) error

DeleteEnvByServiceID This is required when deleting the app

func (*PluginVersionEnvDaoImpl) GetVersionEnvByEnvName ¶

func (t *PluginVersionEnvDaoImpl) GetVersionEnvByEnvName(serviceID, pluginID, envName string) (*model.TenantPluginVersionEnv, error)

GetVersionEnvByEnvName GetVersionEnvByEnvName

func (*PluginVersionEnvDaoImpl) GetVersionEnvByServiceID ¶

func (t *PluginVersionEnvDaoImpl) GetVersionEnvByServiceID(serviceID string, pluginID string) ([]*model.TenantPluginVersionEnv, error)

GetVersionEnvByServiceID Get the plugin variables that a plugin used under the application depends on

func (*PluginVersionEnvDaoImpl) ListByServiceID ¶

func (t *PluginVersionEnvDaoImpl) ListByServiceID(serviceID string) ([]*model.TenantPluginVersionEnv, 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 Update plugin default variables

func (*RegionAPIClassDaoImpl) AddModel ¶

func (t *RegionAPIClassDaoImpl) AddModel(mo model.Interface) error

AddModel - add api classification information

func (*RegionAPIClassDaoImpl) DeletePrefixInClass ¶

func (t *RegionAPIClassDaoImpl) DeletePrefixInClass(apiClass, prefix string) error

DeletePrefixInClass

func (*RegionAPIClassDaoImpl) GetPrefixesByClass ¶

func (t *RegionAPIClassDaoImpl) GetPrefixesByClass(apiClass string) ([]*model.RegionAPIClass, error)

GetPrefixesByClass

func (*RegionAPIClassDaoImpl) UpdateModel ¶

func (t *RegionAPIClassDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel - update api classification information

func (*RegionUserInfoDaoImpl) AddModel ¶

func (t *RegionUserInfoDaoImpl) AddModel(mo model.Interface) error

AddModel - add cloud information

func (*RegionUserInfoDaoImpl) GetALLTokenInValidityPeriod ¶

func (t *RegionUserInfoDaoImpl) GetALLTokenInValidityPeriod() ([]*model.RegionUserInfo, error)

GetALLTokenInValidityPeriod

func (*RegionUserInfoDaoImpl) GetTokenByEid ¶

func (t *RegionUserInfoDaoImpl) GetTokenByEid(eid string) (*model.RegionUserInfo, error)

GetTokenByEid

func (*RegionUserInfoDaoImpl) GetTokenByTokenID ¶

func (t *RegionUserInfoDaoImpl) GetTokenByTokenID(token string) (*model.RegionUserInfo, error)

GetTokenByTokenID

func (*RegionUserInfoDaoImpl) UpdateModel ¶

func (t *RegionUserInfoDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel - update cloud information

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

func (*ServiceLabelDaoImpl) AddModel ¶

func (t *ServiceLabelDaoImpl) AddModel(mo model.Interface) error

AddModel Add application Label

func (*ServiceLabelDaoImpl) CreateOrUpdateLabelsInBatch ¶

func (t *ServiceLabelDaoImpl) CreateOrUpdateLabelsInBatch(labels []*model.TenantServiceLable) error

CreateOrUpdateLabelsInBatch -

func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByLabelValuesAndServiceID ¶

func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByLabelValuesAndServiceID(serviceID string) error

DelTenantServiceLabelsByLabelValuesAndServiceID DELTenantServiceLabelsByLabelvaluesAndServiceID

func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKey ¶

func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKey(serviceID string, labelKey string) error

DelTenantServiceLabelsByServiceIDKey deletes labels by serviceID and labelKey

func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKeyValue ¶

func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKeyValue(serviceID string, labelKey string,
	labelValue string) error

DelTenantServiceLabelsByServiceIDKeyValue 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 Delete all labels of the application

func (*ServiceLabelDaoImpl) DeleteModel ¶

func (t *ServiceLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error

DeleteModel Delete application label

func (*ServiceLabelDaoImpl) GetLabelByNodeSelectorKey ¶

func (t *ServiceLabelDaoImpl) GetLabelByNodeSelectorKey(serviceID string, labelValue string) (*model.TenantServiceLable, error)

GetLabelByNodeSelectorKey returns a label by node-selector and label_value

func (*ServiceLabelDaoImpl) GetPrivilegedLabel ¶

func (t *ServiceLabelDaoImpl) GetPrivilegedLabel(serviceID string) (*model.TenantServiceLable, error)

GetPrivilegedLabel -

func (*ServiceLabelDaoImpl) GetTenantNodeAffinityLabel ¶

func (t *ServiceLabelDaoImpl) GetTenantNodeAffinityLabel(serviceID string) (*model.TenantServiceLable, error)

GetTenantNodeAffinityLabel returns TenantServiceLable matching serviceID and LabelKeyNodeAffinity

func (*ServiceLabelDaoImpl) GetTenantServiceAffinityLabel ¶

func (t *ServiceLabelDaoImpl) GetTenantServiceAffinityLabel(serviceID string) ([]*model.TenantServiceLable, error)

GetTenantServiceAffinityLabel GetTenantServiceAffinityLabel

func (*ServiceLabelDaoImpl) GetTenantServiceLabel ¶

func (t *ServiceLabelDaoImpl) GetTenantServiceLabel(serviceID string) ([]*model.TenantServiceLable, error)

GetTenantServiceLabel GetTenantServiceLabel

func (*ServiceLabelDaoImpl) GetTenantServiceNodeSelectorLabel ¶

func (t *ServiceLabelDaoImpl) GetTenantServiceNodeSelectorLabel(serviceID string) ([]*model.TenantServiceLable, error)

GetTenantServiceNodeSelectorLabel GetTenantServiceNodeSelectorLabel

func (*ServiceLabelDaoImpl) GetTenantServiceTypeLabel ¶

func (t *ServiceLabelDaoImpl) GetTenantServiceTypeLabel(serviceID string) (*model.TenantServiceLable, error)

GetTenantServiceTypeLabel GetTenantServiceTypeLabel no usages func. get tenant service type use TenantServiceDao.GetServiceTypeByID(serviceID string)

func (*ServiceLabelDaoImpl) UpdateModel ¶

func (t *ServiceLabelDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update application Label

func (*ServiceProbeDaoImpl) AddModel ¶

func (t *ServiceProbeDaoImpl) AddModel(mo model.Interface) error

AddModel Add application Probe

func (*ServiceProbeDaoImpl) CreateOrUpdateProbesInBatch ¶

func (t *ServiceProbeDaoImpl) CreateOrUpdateProbesInBatch(probes []*model.TenantServiceProbe) 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 TenantServiceProbe based on sid(service_id)

func (*ServiceProbeDaoImpl) DeleteByComponentIDs ¶

func (t *ServiceProbeDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs deletes TenantServiceProbe based on componentIDs

func (*ServiceProbeDaoImpl) DeleteModel ¶

func (t *ServiceProbeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error

DeleteModel Delete application probe

func (*ServiceProbeDaoImpl) GetServiceProbes ¶

func (t *ServiceProbeDaoImpl) GetServiceProbes(serviceID string) ([]*model.TenantServiceProbe, error)

GetServiceProbes Get application probe

func (*ServiceProbeDaoImpl) GetServiceUsedProbe ¶

func (t *ServiceProbeDaoImpl) GetServiceUsedProbe(serviceID, mode string) (*model.TenantServiceProbe, error)

GetServiceUsedProbe Get the available probe definitions of the specified mode

func (*ServiceProbeDaoImpl) UpdateModel ¶

func (t *ServiceProbeDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update application Probe

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

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

func (*TenantDaoImpl) AddModel ¶

func (t *TenantDaoImpl) AddModel(mo model.Interface) error

AddModel Add tenant

func (*TenantDaoImpl) DelByTenantID ¶

func (t *TenantDaoImpl) DelByTenantID(tenantID string) error

DelByTenantID -

func (*TenantDaoImpl) GetALLTenants ¶

func (t *TenantDaoImpl) GetALLTenants(query string) ([]*model.Tenants, error)

GetALLTenants GetALLTenants

func (*TenantDaoImpl) GetPagedTenants ¶

func (t *TenantDaoImpl) GetPagedTenants(offset, len int) ([]*model.Tenants, error)

GetPagedTenants -

func (*TenantDaoImpl) GetTenantByEid ¶

func (t *TenantDaoImpl) GetTenantByEid(eid, query string) ([]*model.Tenants, error)

GetTenantByEid get tenants by eid

func (*TenantDaoImpl) GetTenantByUUID ¶

func (t *TenantDaoImpl) GetTenantByUUID(uuid string) (*model.Tenants, error)

GetTenantByUUID Get tenant

func (*TenantDaoImpl) GetTenantByUUIDIsExist ¶

func (t *TenantDaoImpl) GetTenantByUUIDIsExist(uuid string) bool

GetTenantByUUIDIsExist Get tenant

func (*TenantDaoImpl) GetTenantIDByName ¶

func (t *TenantDaoImpl) GetTenantIDByName(name string) (*model.Tenants, error)

GetTenantIDByName Get tenant

func (*TenantDaoImpl) GetTenantIDsByNames ¶

func (t *TenantDaoImpl) GetTenantIDsByNames(names []string) (re []string, err error)

GetTenantIDsByNames get tenant ids by names

func (*TenantDaoImpl) GetTenantLimitsByNames ¶

func (t *TenantDaoImpl) GetTenantLimitsByNames(names []string) (limit map[string]int, err error)

GetTenantLimitsByNames get tenants memory limit

func (*TenantDaoImpl) UpdateModel ¶

func (t *TenantDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update tenant

func (*TenantServceAutoscalerRuleMetricsDaoImpl) AddModel ¶

func (t *TenantServceAutoscalerRuleMetricsDaoImpl) AddModel(mo model.Interface) error

AddModel -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) CreateOrUpdateScaleRuleMetricsInBatch ¶

func (t *TenantServceAutoscalerRuleMetricsDaoImpl) CreateOrUpdateScaleRuleMetricsInBatch(metrics []*model.TenantServiceAutoscalerRuleMetrics) error

CreateOrUpdateScaleRuleMetricsInBatch -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) DeleteByRuleID ¶

func (t *TenantServceAutoscalerRuleMetricsDaoImpl) DeleteByRuleID(ruldID string) error

DeleteByRuleID -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) DeleteByRuleIDs ¶

func (t *TenantServceAutoscalerRuleMetricsDaoImpl) DeleteByRuleIDs(ruleIDs []string) error

DeleteByRuleIDs deletes rule metrics based on componentIDs

func (*TenantServceAutoscalerRuleMetricsDaoImpl) ListByRuleID ¶

func (t *TenantServceAutoscalerRuleMetricsDaoImpl) ListByRuleID(ruleID string) ([]*model.TenantServiceAutoscalerRuleMetrics, error)

ListByRuleID -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) UpdateModel ¶

func (t *TenantServceAutoscalerRuleMetricsDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate ¶

func (t *TenantServceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate(metric *model.TenantServiceAutoscalerRuleMetrics) error

UpdateOrCreate -

func (*TenantServceAutoscalerRulesDaoImpl) AddModel ¶

func (t *TenantServceAutoscalerRulesDaoImpl) AddModel(mo model.Interface) error

AddModel -

func (*TenantServceAutoscalerRulesDaoImpl) CreateOrUpdateScaleRulesInBatch ¶

func (t *TenantServceAutoscalerRulesDaoImpl) CreateOrUpdateScaleRulesInBatch(rules []*model.TenantServiceAutoscalerRules) error

CreateOrUpdateScaleRulesInBatch -

func (*TenantServceAutoscalerRulesDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServceAutoscalerRulesDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs deletes rule based on componentIDs

func (*TenantServceAutoscalerRulesDaoImpl) GetByRuleID ¶

func (t *TenantServceAutoscalerRulesDaoImpl) GetByRuleID(ruleID string) (*model.TenantServiceAutoscalerRules, error)

GetByRuleID -

func (*TenantServceAutoscalerRulesDaoImpl) ListByComponentIDs ¶

func (t *TenantServceAutoscalerRulesDaoImpl) ListByComponentIDs(componentIDs []string) ([]*model.TenantServiceAutoscalerRules, error)

ListByComponentIDs -

func (*TenantServceAutoscalerRulesDaoImpl) ListByServiceID ¶

func (t *TenantServceAutoscalerRulesDaoImpl) ListByServiceID(serviceID string) ([]*model.TenantServiceAutoscalerRules, error)

ListByServiceID -

func (*TenantServceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID ¶

func (t *TenantServceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID(serviceID string) ([]*model.TenantServiceAutoscalerRules, error)

ListEnableOnesByServiceID -

func (*TenantServceAutoscalerRulesDaoImpl) UpdateModel ¶

func (t *TenantServceAutoscalerRulesDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel -

func (*TenantServiceConfigFileDaoImpl) AddModel ¶

func (t *TenantServiceConfigFileDaoImpl) AddModel(mo model.Interface) error

AddModel creates a new TenantServiceConfigFile

func (*TenantServiceConfigFileDaoImpl) CreateOrUpdateConfigFilesInBatch ¶

func (t *TenantServiceConfigFileDaoImpl) CreateOrUpdateConfigFilesInBatch(configFiles []*model.TenantServiceConfigFile) error

CreateOrUpdateConfigFilesInBatch -

func (*TenantServiceConfigFileDaoImpl) DelByServiceID ¶

func (t *TenantServiceConfigFileDaoImpl) DelByServiceID(sid string) error

DelByServiceID deletes config files according to service id.

func (*TenantServiceConfigFileDaoImpl) DelByVolumeID ¶

func (t *TenantServiceConfigFileDaoImpl) DelByVolumeID(sid, volumeName string) error

DelByVolumeID deletes config files according to service id and volume id.

func (*TenantServiceConfigFileDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServiceConfigFileDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServiceConfigFileDaoImpl) GetByVolumeName ¶

func (t *TenantServiceConfigFileDaoImpl) GetByVolumeName(sid string, volumeName string) (*model.TenantServiceConfigFile, error)

GetByVolumeName get config file by volume name

func (*TenantServiceConfigFileDaoImpl) GetConfigFileByServiceID ¶

func (t *TenantServiceConfigFileDaoImpl) GetConfigFileByServiceID(serviceID string) ([]*model.TenantServiceConfigFile, error)

GetConfigFileByServiceID -

func (*TenantServiceConfigFileDaoImpl) UpdateModel ¶

func (t *TenantServiceConfigFileDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel updates config file

func (*TenantServiceEnvVarDaoImpl) AddModel ¶

func (t *TenantServiceEnvVarDaoImpl) AddModel(mo model.Interface) error

AddModel Add application environment variables

func (*TenantServiceEnvVarDaoImpl) CreateOrUpdateEnvsInBatch ¶

func (t *TenantServiceEnvVarDaoImpl) CreateOrUpdateEnvsInBatch(envs []*model.TenantServiceEnvVar) error

CreateOrUpdateEnvsInBatch Batch insert or update environment variables

func (*TenantServiceEnvVarDaoImpl) DELServiceEnvsByServiceID ¶

func (t *TenantServiceEnvVarDaoImpl) DELServiceEnvsByServiceID(serviceID string) error

DELServiceEnvsByServiceID Delete envs by serviceID

func (*TenantServiceEnvVarDaoImpl) DelByServiceIDAndScope ¶

func (t *TenantServiceEnvVarDaoImpl) DelByServiceIDAndScope(sid, scope string) error

DelByServiceIDAndScope deletes TenantServiceEnvVar based on sid(service_id) and scope.

func (*TenantServiceEnvVarDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServiceEnvVarDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServiceEnvVarDaoImpl) DeleteModel ¶

func (t *TenantServiceEnvVarDaoImpl) DeleteModel(serviceID string, args ...interface{}) error

DeleteModel Delete env

func (*TenantServiceEnvVarDaoImpl) GetDependServiceEnvs ¶

func (t *TenantServiceEnvVarDaoImpl) GetDependServiceEnvs(serviceIDs []string, scopes []string) ([]*model.TenantServiceEnvVar, error)

GetDependServiceEnvs Obtain environment variables of dependent services

func (*TenantServiceEnvVarDaoImpl) GetEnv ¶

func (t *TenantServiceEnvVarDaoImpl) GetEnv(serviceID, envName string) (*model.TenantServiceEnvVar, error)

GetEnv Get an environment variable

func (*TenantServiceEnvVarDaoImpl) GetServiceEnvs ¶

func (t *TenantServiceEnvVarDaoImpl) GetServiceEnvs(serviceID string, scopes []string) ([]*model.TenantServiceEnvVar, error)

GetServiceEnvs Get service environment variables

func (*TenantServiceEnvVarDaoImpl) UpdateModel ¶

func (t *TenantServiceEnvVarDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel update env support attr_value\is_change\scope

func (*TenantServiceLBMappingPortDaoImpl) AddModel ¶

func (t *TenantServiceLBMappingPortDaoImpl) AddModel(mo model.Interface) error

AddModel Add application port mapping

func (*TenantServiceLBMappingPortDaoImpl) CreateTenantServiceLBMappingPort ¶

func (t *TenantServiceLBMappingPortDaoImpl) CreateTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)

CreateTenantServiceLBMappingPort Create a load balancing VS port, if the port assignment already exists, return directly

func (*TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID ¶

func (t *TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID(serviceID string) error

DELServiceLBMappingPortByServiceID DELServiceLBMappingPortByServiceID

func (*TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort ¶

func (t *TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort(serviceID string, lbport int) error

DELServiceLBMappingPortByServiceIDAndPort DELServiceLBMappingPortByServiceIDAndPort

func (*TenantServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort ¶

func (t *TenantServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort(serviceID string, port int) (*model.TenantServiceLBMappingPort, error)

GetLBMappingPortByServiceIDAndPort returns a LBMappingPort by serviceID and port

func (*TenantServiceLBMappingPortDaoImpl) GetLBPortByTenantAndPort ¶

func (t *TenantServiceLBMappingPortDaoImpl) GetLBPortByTenantAndPort(tenantID string, lbport int) (*model.TenantServiceLBMappingPort, error)

GetLBPortByTenantAndPort GetLBPortByTenantAndPort

func (*TenantServiceLBMappingPortDaoImpl) GetLBPortsASC ¶

func (t *TenantServiceLBMappingPortDaoImpl) GetLBPortsASC() ([]*model.TenantServiceLBMappingPort, error)

GetLBPortsASC gets all LBMappingPorts ascending

func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort ¶

func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)

GetTenantServiceLBMappingPort Get port mapping

func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService ¶

func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService(serviceID string) ([]*model.TenantServiceLBMappingPort, error)

GetTenantServiceLBMappingPortByService Get port mapping

func (*TenantServiceLBMappingPortDaoImpl) PortExists ¶

func (t *TenantServiceLBMappingPortDaoImpl) PortExists(port int) bool

PortExists checks if the port exists

func (*TenantServiceLBMappingPortDaoImpl) UpdateModel ¶

func (t *TenantServiceLBMappingPortDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update application port mapping

func (*TenantServiceMonitorDaoImpl) AddModel ¶

func (t *TenantServiceMonitorDaoImpl) AddModel(mo model.Interface) error

AddModel create service monitor

func (*TenantServiceMonitorDaoImpl) CreateOrUpdateMonitorInBatch ¶

func (t *TenantServiceMonitorDaoImpl) CreateOrUpdateMonitorInBatch(monitors []*model.TenantServiceMonitor) error

CreateOrUpdateMonitorInBatch -

func (*TenantServiceMonitorDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServiceMonitorDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs delete service monitor by component ids

func (*TenantServiceMonitorDaoImpl) DeleteServiceMonitor ¶

func (t *TenantServiceMonitorDaoImpl) DeleteServiceMonitor(mo *model.TenantServiceMonitor) error

DeleteServiceMonitor delete service monitor

func (*TenantServiceMonitorDaoImpl) DeleteServiceMonitorByServiceID ¶

func (t *TenantServiceMonitorDaoImpl) DeleteServiceMonitorByServiceID(serviceID string) error

DeleteServiceMonitorByServiceID delete service monitor by service id

func (*TenantServiceMonitorDaoImpl) GetByName ¶

func (t *TenantServiceMonitorDaoImpl) GetByName(serviceID, name string) (*model.TenantServiceMonitor, error)

GetByName get by name

func (*TenantServiceMonitorDaoImpl) GetByServiceID ¶

func (t *TenantServiceMonitorDaoImpl) GetByServiceID(serviceID string) ([]*model.TenantServiceMonitor, error)

GetByServiceID get tsm by service id

func (*TenantServiceMonitorDaoImpl) UpdateModel ¶

func (t *TenantServiceMonitorDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel update service monitor

func (*TenantServiceMountRelationDaoImpl) AddModel ¶

func (t *TenantServiceMountRelationDaoImpl) AddModel(mo model.Interface) error

AddModel Add application dependency mount

func (*TenantServiceMountRelationDaoImpl) CreateOrUpdateVolumeRelsInBatch ¶

func (t *TenantServiceMountRelationDaoImpl) CreateOrUpdateVolumeRelsInBatch(volRels []*model.TenantServiceMountRelation) error

CreateOrUpdateVolumeRelsInBatch -

func (*TenantServiceMountRelationDaoImpl) DELTenantServiceMountRelationByServiceID ¶

func (t *TenantServiceMountRelationDaoImpl) DELTenantServiceMountRelationByServiceID(serviceID string) error

DELTenantServiceMountRelationByServiceID DELTenantServiceMountRelationByServiceID

func (*TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByDepService ¶

func (t *TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByDepService(serviceID, depServiceID string) error

DElTenantServiceMountRelationByDepService del mount relation

func (*TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByServiceAndName ¶

func (t *TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByServiceAndName(serviceID, name string) error

DElTenantServiceMountRelationByServiceAndName DElTenantServiceMountRelationByServiceAndName

func (*TenantServiceMountRelationDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServiceMountRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServiceMountRelationDaoImpl) GetTenantServiceMountRelationsByService ¶

func (t *TenantServiceMountRelationDaoImpl) GetTenantServiceMountRelationsByService(serviceID string) ([]*model.TenantServiceMountRelation, error)

GetTenantServiceMountRelationsByService Get all the mount dependencies of the application

func (*TenantServiceMountRelationDaoImpl) UpdateModel ¶

func (t *TenantServiceMountRelationDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update application dependency mount

func (*TenantServicePluginRelationDaoImpl) AddModel ¶

func (t *TenantServicePluginRelationDaoImpl) AddModel(mo model.Interface) error

AddModel Add plugin default variables

func (*TenantServicePluginRelationDaoImpl) CheckSomeModelLikePluginByServiceID ¶

func (t *TenantServicePluginRelationDaoImpl) CheckSomeModelLikePluginByServiceID(serviceID, pluginModel string) (bool, error)

CheckSomeModelLikePluginByServiceID Check whether a certain type of plug-in is bound

func (*TenantServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID ¶

func (t *TenantServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID(serviceID, pluginModel string) (bool, error)

CheckSomeModelPluginByServiceID Check whether a certain plug-in is bound and enabled

func (*TenantServicePluginRelationDaoImpl) CreateOrUpdatePluginRelsInBatch ¶

func (t *TenantServicePluginRelationDaoImpl) CreateOrUpdatePluginRelsInBatch(relations []*model.TenantServicePluginRelation) error

CreateOrUpdatePluginRelsInBatch -

func (*TenantServicePluginRelationDaoImpl) DeleteALLRelationByPluginID ¶

func (t *TenantServicePluginRelationDaoImpl) DeleteALLRelationByPluginID(pluginID string) error

DeleteALLRelationByPluginID Delete all dependencies of pluginID, generally don't use it, it will affect the startup of associated applications

func (*TenantServicePluginRelationDaoImpl) DeleteALLRelationByServiceID ¶

func (t *TenantServicePluginRelationDaoImpl) DeleteALLRelationByServiceID(serviceID string) error

DeleteALLRelationByServiceID Delete all plug-in dependencies of serviceID Generally used when deleting applications

func (*TenantServicePluginRelationDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServicePluginRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID ¶

func (t *TenantServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID(serviceID, pluginID string) error

DeleteRelationByServiceIDAndPluginID Delete service plugin correspondence

func (*TenantServicePluginRelationDaoImpl) GetALLRelationByServiceID ¶

func (t *TenantServicePluginRelationDaoImpl) GetALLRelationByServiceID(serviceID string) ([]*model.TenantServicePluginRelation, error)

GetALLRelationByServiceID Get all the plug-in dependencies of the current application

func (*TenantServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID ¶

func (t *TenantServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID(serviceID, pluginID string) (*model.TenantServicePluginRelation, error)

GetRelateionByServiceIDAndPluginID GetRelateionByServiceIDAndPluginID

func (*TenantServicePluginRelationDaoImpl) UpdateModel ¶

func (t *TenantServicePluginRelationDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update plugin default variables Update dependent version id

func (*TenantServiceRelationDaoImpl) AddModel ¶

func (t *TenantServiceRelationDaoImpl) AddModel(mo model.Interface) error

AddModel Add application dependencies

func (*TenantServiceRelationDaoImpl) CreateOrUpdateRelationsInBatch ¶

func (t *TenantServiceRelationDaoImpl) CreateOrUpdateRelationsInBatch(relations []*model.TenantServiceRelation) error

CreateOrUpdateRelationsInBatch -

func (*TenantServiceRelationDaoImpl) DELRelationsByServiceID ¶

func (t *TenantServiceRelationDaoImpl) DELRelationsByServiceID(serviceID string) error

DELRelationsByServiceID DELRelationsByServiceID

func (*TenantServiceRelationDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServiceRelationDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServiceRelationDaoImpl) DeleteModel ¶

func (t *TenantServiceRelationDaoImpl) DeleteModel(serviceID string, args ...interface{}) error

DeleteModel Remove dependency

func (*TenantServiceRelationDaoImpl) DeleteRelationByDepID ¶

func (t *TenantServiceRelationDaoImpl) DeleteRelationByDepID(serviceID, depID string) error

DeleteRelationByDepID DeleteRelationByDepID

func (*TenantServiceRelationDaoImpl) GetTenantServiceRelations ¶

func (t *TenantServiceRelationDaoImpl) GetTenantServiceRelations(serviceID string) ([]*model.TenantServiceRelation, error)

GetTenantServiceRelations Get application dependencies

func (*TenantServiceRelationDaoImpl) GetTenantServiceRelationsByDependServiceID ¶

func (t *TenantServiceRelationDaoImpl) GetTenantServiceRelationsByDependServiceID(dependServiceID string) ([]*model.TenantServiceRelation, error)

GetTenantServiceRelationsByDependServiceID Get all applications that depend on the current service

func (*TenantServiceRelationDaoImpl) HaveRelations ¶

func (t *TenantServiceRelationDaoImpl) HaveRelations(serviceID string) bool

HaveRelations Is there any dependency

func (*TenantServiceRelationDaoImpl) ListByServiceIDs ¶

func (t *TenantServiceRelationDaoImpl) ListByServiceIDs(serviceIDs []string) ([]*model.TenantServiceRelation, error)

ListByServiceIDs -

func (*TenantServiceRelationDaoImpl) UpdateModel ¶

func (t *TenantServiceRelationDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update application dependencies

func (*TenantServiceScalingRecordsDaoImpl) AddModel ¶

func (t *TenantServiceScalingRecordsDaoImpl) AddModel(mo model.Interface) error

AddModel -

func (*TenantServiceScalingRecordsDaoImpl) CountByServiceID ¶

func (t *TenantServiceScalingRecordsDaoImpl) CountByServiceID(serviceID string) (int, error)

CountByServiceID -

func (*TenantServiceScalingRecordsDaoImpl) ListByServiceID ¶

func (t *TenantServiceScalingRecordsDaoImpl) ListByServiceID(serviceID string, offset, limit int) ([]*model.TenantServiceScalingRecords, error)

ListByServiceID -

func (*TenantServiceScalingRecordsDaoImpl) UpdateModel ¶

func (t *TenantServiceScalingRecordsDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel -

func (*TenantServiceScalingRecordsDaoImpl) UpdateOrCreate ¶

func (t *TenantServiceScalingRecordsDaoImpl) UpdateOrCreate(new *model.TenantServiceScalingRecords) error

UpdateOrCreate -

func (*TenantServiceVolumeDaoImpl) AddModel ¶

func (t *TenantServiceVolumeDaoImpl) AddModel(mo model.Interface) error

AddModel Add application mount

func (*TenantServiceVolumeDaoImpl) CreateOrUpdateVolumesInBatch ¶

func (t *TenantServiceVolumeDaoImpl) CreateOrUpdateVolumesInBatch(volumes []*model.TenantServiceVolume) error

CreateOrUpdateVolumesInBatch -

func (*TenantServiceVolumeDaoImpl) DelShareableBySID ¶

func (t *TenantServiceVolumeDaoImpl) DelShareableBySID(sid string) error

DelShareableBySID deletes shareable volumes based on sid(service_id)

func (*TenantServiceVolumeDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServiceVolumeDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath ¶

func (t *TenantServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath(serviceID string, volumePath string) error

DeleteByServiceIDAndVolumePath Delete the directory mounted via ServiceID

func (*TenantServiceVolumeDaoImpl) DeleteByVolumeIDs ¶

func (t *TenantServiceVolumeDaoImpl) DeleteByVolumeIDs(volumeIDs []uint) error

DeleteByVolumeIDs -

func (*TenantServiceVolumeDaoImpl) DeleteModel ¶

func (t *TenantServiceVolumeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error

DeleteModel Remove mount

func (*TenantServiceVolumeDaoImpl) DeleteTenantServiceVolumesByServiceID ¶

func (t *TenantServiceVolumeDaoImpl) DeleteTenantServiceVolumesByServiceID(serviceID string) error

DeleteTenantServiceVolumesByServiceID Remove mount

func (*TenantServiceVolumeDaoImpl) GetAllVolumes ¶

func (t *TenantServiceVolumeDaoImpl) GetAllVolumes() ([]*model.TenantServiceVolume, error)

GetAllVolumes Get all storage information

func (*TenantServiceVolumeDaoImpl) GetTenantServiceVolumesByServiceID ¶

func (t *TenantServiceVolumeDaoImpl) GetTenantServiceVolumesByServiceID(serviceID string) ([]*model.TenantServiceVolume, error)

GetTenantServiceVolumesByServiceID Get application mount

func (*TenantServiceVolumeDaoImpl) GetVolumeByID ¶

func (t *TenantServiceVolumeDaoImpl) GetVolumeByID(id int) (*model.TenantServiceVolume, error)

GetVolumeByID get volume by id

func (*TenantServiceVolumeDaoImpl) GetVolumeByServiceIDAndName ¶

func (t *TenantServiceVolumeDaoImpl) GetVolumeByServiceIDAndName(serviceID, name string) (*model.TenantServiceVolume, error)

GetVolumeByServiceIDAndName Get storage information

func (*TenantServiceVolumeDaoImpl) ListVolumesByComponentIDs ¶

func (t *TenantServiceVolumeDaoImpl) ListVolumesByComponentIDs(componentIDs []string) ([]*model.TenantServiceVolume, error)

ListVolumesByComponentIDs -

func (*TenantServiceVolumeDaoImpl) UpdateModel ¶

func (t *TenantServiceVolumeDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update application mount

func (*TenantServicesDaoImpl) AddModel ¶

func (t *TenantServicesDaoImpl) AddModel(mo model.Interface) error

AddModel Add tenant application

func (*TenantServicesDaoImpl) BindAppByServiceIDs ¶

func (t *TenantServicesDaoImpl) BindAppByServiceIDs(appID string, serviceIDs []string) error

BindAppByServiceIDs binding application by serviceIDs

func (*TenantServicesDaoImpl) CountServiceByAppID ¶

func (t *TenantServicesDaoImpl) CountServiceByAppID(appID string) (int64, error)

CountServiceByAppID get Service number by AppID

func (*TenantServicesDaoImpl) CreateOrUpdateComponentsInBatch ¶

func (t *TenantServicesDaoImpl) CreateOrUpdateComponentsInBatch(components []*model.TenantServices) error

CreateOrUpdateComponentsInBatch Batch insert or update component

func (*TenantServicesDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServicesDaoImpl) DeleteByComponentIDs(tenantID, appID string, componentIDs []string) error

DeleteByComponentIDs deletes components based on the given componentIDs.

func (*TenantServicesDaoImpl) DeleteServiceByServiceID ¶

func (t *TenantServicesDaoImpl) DeleteServiceByServiceID(serviceID string) error

DeleteServiceByServiceID DeleteServiceByServiceID

func (*TenantServicesDaoImpl) GetAllServicesID ¶

func (t *TenantServicesDaoImpl) GetAllServicesID() ([]*model.TenantServices, error)

GetAllServicesID get all service sample info

func (*TenantServicesDaoImpl) GetPagedTenantService ¶

func (t *TenantServicesDaoImpl) GetPagedTenantService(offset, length int, serviceIDs []string) ([]map[string]interface{}, int, error)

GetPagedTenantService GetPagedTenantResource

func (*TenantServicesDaoImpl) GetServiceAliasByIDs ¶

func (t *TenantServicesDaoImpl) GetServiceAliasByIDs(uids []string) ([]*model.TenantServices, error)

GetServiceAliasByIDs Get app alias

func (*TenantServicesDaoImpl) GetServiceByID ¶

func (t *TenantServicesDaoImpl) GetServiceByID(serviceID string) (*model.TenantServices, error)

GetServiceByID Get service by service id

func (*TenantServicesDaoImpl) GetServiceByIDs ¶

func (t *TenantServicesDaoImpl) GetServiceByIDs(uids []string) ([]*model.TenantServices, error)

GetServiceByIDs get some service by service ids

func (*TenantServicesDaoImpl) GetServiceByServiceAlias ¶

func (t *TenantServicesDaoImpl) GetServiceByServiceAlias(serviceAlias string) (*model.TenantServices, error)

GetServiceByServiceAlias Get service through service alias

func (*TenantServicesDaoImpl) GetServiceByTenantIDAndServiceAlias ¶

func (t *TenantServicesDaoImpl) GetServiceByTenantIDAndServiceAlias(tenantID, serviceName string) (*model.TenantServices, error)

GetServiceByTenantIDAndServiceAlias Based on tenant name and service name

func (*TenantServicesDaoImpl) GetServiceIDsByAppID ¶

func (t *TenantServicesDaoImpl) GetServiceIDsByAppID(appID string) (re []model.ServiceID)

GetServiceIDsByAppID get ServiceIDs by AppID

func (*TenantServicesDaoImpl) GetServiceMemoryByServiceIDs ¶

func (t *TenantServicesDaoImpl) GetServiceMemoryByServiceIDs(serviceIDs []string) (map[string]map[string]interface{}, error)

GetServiceMemoryByServiceIDs get service memory by service ids

func (*TenantServicesDaoImpl) GetServiceMemoryByTenantIDs ¶

func (t *TenantServicesDaoImpl) GetServiceMemoryByTenantIDs(tenantIDs []string, runningServiceIDs []string) (map[string]map[string]interface{}, error)

GetServiceMemoryByTenantIDs get service memory by tenant ids

func (*TenantServicesDaoImpl) GetServiceTypeByID ¶

func (t *TenantServicesDaoImpl) GetServiceTypeByID(serviceID string) (*model.TenantServices, error)

GetServiceTypeByID get service type by service id

func (*TenantServicesDaoImpl) GetServicesAllInfoByTenantID ¶

func (t *TenantServicesDaoImpl) GetServicesAllInfoByTenantID(tenantID string) ([]*model.TenantServices, error)

GetServicesAllInfoByTenantID GetServicesAllInfoByTenantID

func (*TenantServicesDaoImpl) GetServicesByServiceIDs ¶

func (t *TenantServicesDaoImpl) GetServicesByServiceIDs(serviceIDs []string) ([]*model.TenantServices, error)

GetServicesByServiceIDs Get Services By ServiceIDs

func (*TenantServicesDaoImpl) GetServicesByTenantID ¶

func (t *TenantServicesDaoImpl) GetServicesByTenantID(tenantID string) ([]*model.TenantServices, error)

GetServicesByTenantID GetServicesByTenantID

func (*TenantServicesDaoImpl) GetServicesByTenantIDs ¶

func (t *TenantServicesDaoImpl) GetServicesByTenantIDs(tenantIDs []string) ([]*model.TenantServices, error)

GetServicesByTenantIDs GetServicesByTenantIDs

func (*TenantServicesDaoImpl) GetServicesInfoByAppID ¶

func (t *TenantServicesDaoImpl) GetServicesInfoByAppID(appID string, page, pageSize int) ([]*model.TenantServices, int64, error)

GetServicesInfoByAppID Get Services Info By ApplicationID

func (*TenantServicesDaoImpl) ListByAppID ¶

func (t *TenantServicesDaoImpl) ListByAppID(appID string) ([]*model.TenantServices, error)

func (*TenantServicesDaoImpl) ListServicesByTenantID ¶

func (t *TenantServicesDaoImpl) ListServicesByTenantID(tenantID string) ([]*model.TenantServices, error)

ListServicesByTenantID -

func (*TenantServicesDaoImpl) ListThirdPartyServices ¶

func (t *TenantServicesDaoImpl) ListThirdPartyServices() ([]*model.TenantServices, error)

ListThirdPartyServices lists all third party services

func (*TenantServicesDaoImpl) SetTenantServiceStatus ¶

func (t *TenantServicesDaoImpl) SetTenantServiceStatus(serviceID, status string) error

SetTenantServiceStatus SetTenantServiceStatus

func (*TenantServicesDaoImpl) UpdateDeployVersion ¶

func (t *TenantServicesDaoImpl) UpdateDeployVersion(serviceID, deployversion string) error

UpdateDeployVersion update service current deploy version

func (*TenantServicesDaoImpl) UpdateModel ¶

func (t *TenantServicesDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update tenant application

func (*TenantServicesDeleteImpl) AddModel ¶

func (t *TenantServicesDeleteImpl) AddModel(mo model.Interface) error

AddModel Add deleted apps

func (*TenantServicesDeleteImpl) DeleteTenantServicesDelete ¶

func (t *TenantServicesDeleteImpl) DeleteTenantServicesDelete(record *model.TenantServicesDelete) error

DeleteTenantServicesDelete -

func (*TenantServicesDeleteImpl) GetTenantServicesDeleteByCreateTime ¶

func (t *TenantServicesDeleteImpl) GetTenantServicesDeleteByCreateTime(createTime time.Time) ([]*model.TenantServicesDelete, error)

GetTenantServicesDeleteByCreateTime -

func (*TenantServicesDeleteImpl) List ¶

func (t *TenantServicesDeleteImpl) List() ([]*model.TenantServicesDelete, error)

List returns a list of TenantServicesDeletes.

func (*TenantServicesDeleteImpl) UpdateModel ¶

func (t *TenantServicesDeleteImpl) UpdateModel(mo model.Interface) error

UpdateModel Update tenant application

func (*TenantServicesPortDaoImpl) AddModel ¶

func (t *TenantServicesPortDaoImpl) AddModel(mo model.Interface) error

AddModel Add application port

func (*TenantServicesPortDaoImpl) CreateOrUpdatePortsInBatch ¶

func (t *TenantServicesPortDaoImpl) CreateOrUpdatePortsInBatch(ports []*model.TenantServicesPort) error

CreateOrUpdatePortsInBatch Batch insert or update ports variables

func (*TenantServicesPortDaoImpl) DELPortsByServiceID ¶

func (t *TenantServicesPortDaoImpl) DELPortsByServiceID(serviceID string) error

DELPortsByServiceID DELPortsByServiceID

func (*TenantServicesPortDaoImpl) DelByServiceID ¶

func (t *TenantServicesPortDaoImpl) DelByServiceID(sid string) error

DelByServiceID deletes TenantServicesPort matching sid(service_id).

func (*TenantServicesPortDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServicesPortDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServicesPortDaoImpl) DeleteModel ¶

func (t *TenantServicesPortDaoImpl) DeleteModel(serviceID string, args ...interface{}) error

DeleteModel Delete port

func (*TenantServicesPortDaoImpl) GetByTenantAndName ¶

func (t *TenantServicesPortDaoImpl) GetByTenantAndName(tenantID, name string) (*model.TenantServicesPort, error)

GetByTenantAndName -

func (*TenantServicesPortDaoImpl) GetDepUDPPort ¶

func (t *TenantServicesPortDaoImpl) GetDepUDPPort(serviceID string) ([]*model.TenantServicesPort, error)

GetDepUDPPort get all depend service udp port

func (*TenantServicesPortDaoImpl) GetInnerPorts ¶

func (t *TenantServicesPortDaoImpl) GetInnerPorts(serviceID string) ([]*model.TenantServicesPort, error)

GetInnerPorts Get internal port

func (*TenantServicesPortDaoImpl) GetOpenedPorts ¶

func (t *TenantServicesPortDaoImpl) GetOpenedPorts(serviceID string) ([]*model.TenantServicesPort, error)

GetOpenedPorts returns opened ports.

func (*TenantServicesPortDaoImpl) GetOuterPorts ¶

func (t *TenantServicesPortDaoImpl) GetOuterPorts(serviceID string) ([]*model.TenantServicesPort, error)

GetOuterPorts Get external port

func (*TenantServicesPortDaoImpl) GetPort ¶

func (t *TenantServicesPortDaoImpl) GetPort(serviceID string, port int) (*model.TenantServicesPort, error)

GetPort get port

func (*TenantServicesPortDaoImpl) GetPortsByServiceID ¶

func (t *TenantServicesPortDaoImpl) GetPortsByServiceID(serviceID string) ([]*model.TenantServicesPort, error)

GetPortsByServiceID Get port through service

func (*TenantServicesPortDaoImpl) HasOpenPort ¶

func (t *TenantServicesPortDaoImpl) HasOpenPort(sid string) bool

HasOpenPort checks if the given service(according to sid) has open port.

func (*TenantServicesPortDaoImpl) ListByK8sServiceNames ¶

func (t *TenantServicesPortDaoImpl) ListByK8sServiceNames(k8sServiceNames []string) ([]*model.TenantServicesPort, error)

ListByK8sServiceNames -

func (*TenantServicesPortDaoImpl) ListInnerPortsByServiceIDs ¶

func (t *TenantServicesPortDaoImpl) ListInnerPortsByServiceIDs(serviceIDs []string) ([]*model.TenantServicesPort, error)

ListInnerPortsByServiceIDs -

func (*TenantServicesPortDaoImpl) UpdateModel ¶

func (t *TenantServicesPortDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update tenant

func (*TenantServicesStreamPluginPortDaoImpl) AddModel ¶

func (t *TenantServicesStreamPluginPortDaoImpl) AddModel(mo model.Interface) error

AddModel Add plug-in port mapping information

func (*TenantServicesStreamPluginPortDaoImpl) CreateOrUpdateStreamPluginPortsInBatch ¶

func (t *TenantServicesStreamPluginPortDaoImpl) CreateOrUpdateStreamPluginPortsInBatch(spPorts []*model.TenantServicesStreamPluginPort) error

CreateOrUpdateStreamPluginPortsInBatch -

func (*TenantServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID ¶

func (t *TenantServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID(serviceID string) error

DeleteAllPluginMappingPortByServiceID DeleteAllPluginMappingPortByServiceID

func (*TenantServicesStreamPluginPortDaoImpl) DeleteByComponentIDs ¶

func (t *TenantServicesStreamPluginPortDaoImpl) DeleteByComponentIDs(componentIDs []string) error

DeleteByComponentIDs -

func (*TenantServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort ¶

func (t *TenantServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort(
	serviceID string,
	pluginModel string,
	containerPort int) error

DeletePluginMappingPortByContainerPort DeletePluginMappingPortByContainerPort

func (*TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort ¶

func (t *TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort(
	serviceID string,
	pluginModel string,
	containerPort int,
) (*model.TenantServicesStreamPluginPort, error)

GetPluginMappingPortByServiceIDAndContainerPort GetPluginMappingPortByServiceIDAndContainerPort

func (*TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPorts ¶

func (t *TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPorts(
	serviceID string) ([]*model.TenantServicesStreamPluginPort, error)

GetPluginMappingPorts GetPluginMappingPorts descending sort

func (*TenantServicesStreamPluginPortDaoImpl) ListByServiceID ¶

func (t *TenantServicesStreamPluginPortDaoImpl) ListByServiceID(sid string) ([]*model.TenantServicesStreamPluginPort, error)

ListByServiceID returns the list of environment variables for the plugin via serviceID

func (*TenantServicesStreamPluginPortDaoImpl) SetPluginMappingPort ¶

func (t *TenantServicesStreamPluginPortDaoImpl) SetPluginMappingPort(
	tenantID string,
	serviceID string,
	pluginModel string,
	containerPort int) (int, error)

SetPluginMappingPort SetPluginMappingPort

func (*TenantServicesStreamPluginPortDaoImpl) UpdateModel ¶

func (t *TenantServicesStreamPluginPortDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel Update plug-in port mapping information

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

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

func (*VolumeTypeDaoImpl) AddModel ¶

func (vtd *VolumeTypeDaoImpl) AddModel(mo model.Interface) error

AddModel

func (*VolumeTypeDaoImpl) CreateOrUpdateVolumeType ¶

func (vtd *VolumeTypeDaoImpl) CreateOrUpdateVolumeType(vt *model.TenantServiceVolumeType) (*model.TenantServiceVolumeType, 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

func (*VolumeTypeDaoImpl) GetAllVolumeTypes ¶

func (vtd *VolumeTypeDaoImpl) GetAllVolumeTypes() ([]*model.TenantServiceVolumeType, error)

GetAllVolumeTypes

func (*VolumeTypeDaoImpl) GetAllVolumeTypesByPage ¶

func (vtd *VolumeTypeDaoImpl) GetAllVolumeTypesByPage(page int, pageSize int) ([]*model.TenantServiceVolumeType, error)

GetAllVolumeTypesByPage

func (*VolumeTypeDaoImpl) GetVolumeTypeByType ¶

func (vtd *VolumeTypeDaoImpl) GetVolumeTypeByType(vt string) (*model.TenantServiceVolumeType, error)

GetVolumeTypeByType

func (*VolumeTypeDaoImpl) UpdateModel ¶

func (vtd *VolumeTypeDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel