dao

package
v1.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 18, 2023 License: LGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppBackupDaoImpl 

type AppBackupDaoImpl struct {
	DB *gorm.DB
}

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 

type AppConfigGroupDaoImpl struct {
	DB *gorm.DB
}

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 

type AppConfigGroupItemDaoImpl struct {
	DB *gorm.DB
}

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 

type AppConfigGroupServiceDaoImpl struct {
	DB *gorm.DB
}

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 

type AppDaoImpl struct {
	DB *gorm.DB
}

AppDaoImpl -

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 -

type ApplicationDaoImpl 

type ApplicationDaoImpl struct {
	DB *gorm.DB
}

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 

type CertificateDaoImpl struct {
	DB *gorm.DB
}

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 

type CodeCheckResultDaoImpl struct {
	DB *gorm.DB
}

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 

type EndpointDaoImpl struct {
	DB *gorm.DB
}

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 

type EventDaoImpl struct {
	DB *gorm.DB
}

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 

type GwRuleConfigDaoImpl struct {
	DB *gorm.DB
}

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 

type HTTPRuleDaoImpl struct {
	DB *gorm.DB
}

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 

type HTTPRuleRewriteDaoTmpl struct {
	DB *gorm.DB
}

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 

type LicenseDaoImpl struct {
	DB *gorm.DB
}

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 

type LocalSchedulerDaoImpl struct {
	DB *gorm.DB
}

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 

type NotificationEventDaoImpl struct {
	DB *gorm.DB
}

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 

type PluginBuildVersionDaoImpl struct {
	DB *gorm.DB
}

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 

type PluginDaoImpl struct {
	DB *gorm.DB
}

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 

type PluginDefaultENVDaoImpl struct {
	DB *gorm.DB
}

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 

type PluginVersionConfigDaoImpl struct {
	DB *gorm.DB
}

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 

type PluginVersionEnvDaoImpl struct {
	DB *gorm.DB
}

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 

type RegionAPIClassDaoImpl struct {
	DB *gorm.DB
}

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 

type RuleExtensionDaoImpl struct {
	DB *gorm.DB
}

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 

type ServiceLabelDaoImpl struct {
	DB *gorm.DB
}

ServiceLabelDaoImpl ServiceLabelDaoImpl

func (*ServiceLabelDaoImpl) AddModel 

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

AddModel 添加应用Label

func (*ServiceLabelDaoImpl) CreateOrUpdateLabelsInBatch 

func (t *ServiceLabelDaoImpl) CreateOrUpdateLabelsInBatch(labels []*model.TenantEnvServiceLable) 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.TenantEnvServiceLable, error)

GetLabelByNodeSelectorKey returns a label by node-selector and label_value

func (*ServiceLabelDaoImpl) GetPrivilegedLabel 

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

GetPrivilegedLabel -

func (*ServiceLabelDaoImpl) GetTenantEnvNodeAffinityLabel added in v1.1.0 

func (t *ServiceLabelDaoImpl) GetTenantEnvNodeAffinityLabel(serviceID string) (*model.TenantEnvServiceLable, error)

GetTenantEnvNodeAffinityLabel returns TenantEnvServiceLable matching serviceID and LabelKeyNodeAffinity

func (*ServiceLabelDaoImpl) GetTenantEnvServiceAffinityLabel added in v1.1.0 

func (t *ServiceLabelDaoImpl) GetTenantEnvServiceAffinityLabel(serviceID string) ([]*model.TenantEnvServiceLable, error)

GetTenantEnvServiceAffinityLabel GetTenantEnvServiceAffinityLabel

func (*ServiceLabelDaoImpl) GetTenantEnvServiceLabel added in v1.1.0 

func (t *ServiceLabelDaoImpl) GetTenantEnvServiceLabel(serviceID string) ([]*model.TenantEnvServiceLable, error)

GetTenantEnvServiceLabel GetTenantEnvServiceLabel

func (*ServiceLabelDaoImpl) GetTenantEnvServiceNodeSelectorLabel added in v1.1.0 

func (t *ServiceLabelDaoImpl) GetTenantEnvServiceNodeSelectorLabel(serviceID string) ([]*model.TenantEnvServiceLable, error)

GetTenantEnvServiceNodeSelectorLabel GetTenantEnvServiceNodeSelectorLabel

func (*ServiceLabelDaoImpl) GetTenantEnvServiceTypeLabel added in v1.1.0 

func (t *ServiceLabelDaoImpl) GetTenantEnvServiceTypeLabel(serviceID string) (*model.TenantEnvServiceLable, 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 

type ServiceProbeDaoImpl struct {
	DB *gorm.DB
}

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 ServiceSourceImpl 

type ServiceSourceImpl struct {
	DB *gorm.DB
}

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 

type TCPRuleDaoTmpl struct {
	DB *gorm.DB
}

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 

type TenantEnvDaoImpl struct {
	DB *gorm.DB
}

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 TenantEnvServceAutoscalerRuleMetricsDaoImpl added in v1.1.0 

type TenantEnvServceAutoscalerRuleMetricsDaoImpl struct {
	DB *gorm.DB
}

TenantEnvServceAutoscalerRuleMetricsDaoImpl -

func (*TenantEnvServceAutoscalerRuleMetricsDaoImpl) AddModel added in v1.1.0 

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

AddModel -

func (*TenantEnvServceAutoscalerRuleMetricsDaoImpl) CreateOrUpdateScaleRuleMetricsInBatch added in v1.1.0 

func (t *TenantEnvServceAutoscalerRuleMetricsDaoImpl) CreateOrUpdateScaleRuleMetricsInBatch(metrics []*model.TenantEnvServiceAutoscalerRuleMetrics) error

CreateOrUpdateScaleRuleMetricsInBatch -

func (*TenantEnvServceAutoscalerRuleMetricsDaoImpl) DeleteByRuleID added in v1.1.0 

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

DeleteByRuleID -

func (*TenantEnvServceAutoscalerRuleMetricsDaoImpl) DeleteByRuleIDs added in v1.1.0 

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

DeleteByRuleIDs deletes rule metrics based on componentIDs

func (*TenantEnvServceAutoscalerRuleMetricsDaoImpl) ListByRuleID added in v1.1.0 

func (t *TenantEnvServceAutoscalerRuleMetricsDaoImpl) ListByRuleID(ruleID string) ([]*model.TenantEnvServiceAutoscalerRuleMetrics, error)

ListByRuleID -

func (*TenantEnvServceAutoscalerRuleMetricsDaoImpl) UpdateModel added in v1.1.0 

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

UpdateModel -

func (*TenantEnvServceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate added in v1.1.0 

func (t *TenantEnvServceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate(metric *model.TenantEnvServiceAutoscalerRuleMetrics) error

UpdateOrCreate -

type TenantEnvServceAutoscalerRulesDaoImpl added in v1.1.0 

type TenantEnvServceAutoscalerRulesDaoImpl struct {
	DB *gorm.DB
}

TenantEnvServceAutoscalerRulesDaoImpl -

func (*TenantEnvServceAutoscalerRulesDaoImpl) AddModel added in v1.1.0 

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

AddModel -

func (*TenantEnvServceAutoscalerRulesDaoImpl) CreateOrUpdateScaleRulesInBatch added in v1.1.0 

func (t *TenantEnvServceAutoscalerRulesDaoImpl) CreateOrUpdateScaleRulesInBatch(rules []*model.TenantEnvServiceAutoscalerRules) error

CreateOrUpdateScaleRulesInBatch -

func (*TenantEnvServceAutoscalerRulesDaoImpl) DeleteByComponentIDs added in v1.1.0 

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

DeleteByComponentIDs deletes rule based on componentIDs

func (*TenantEnvServceAutoscalerRulesDaoImpl) GetByRuleID added in v1.1.0 

func (t *TenantEnvServceAutoscalerRulesDaoImpl) GetByRuleID(ruleID string) (*model.TenantEnvServiceAutoscalerRules, error)

GetByRuleID -

func (*TenantEnvServceAutoscalerRulesDaoImpl) ListByComponentIDs added in v1.1.0 

func (t *TenantEnvServceAutoscalerRulesDaoImpl) ListByComponentIDs(componentIDs []string) ([]*model.TenantEnvServiceAutoscalerRules, error)

ListByComponentIDs -

func (*TenantEnvServceAutoscalerRulesDaoImpl) ListByServiceID added in v1.1.0 

func (t *TenantEnvServceAutoscalerRulesDaoImpl) ListByServiceID(serviceID string) ([]*model.TenantEnvServiceAutoscalerRules, error)

ListByServiceID -

func (*TenantEnvServceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID added in v1.1.0 

func (t *TenantEnvServceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID(serviceID string) ([]*model.TenantEnvServiceAutoscalerRules, error)

ListEnableOnesByServiceID -

func (*TenantEnvServceAutoscalerRulesDaoImpl) UpdateModel added in v1.1.0 

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

UpdateModel -

type TenantEnvServiceConfigFileDaoImpl added in v1.1.0 

type TenantEnvServiceConfigFileDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServiceEnvVarDaoImpl struct {
	DB *gorm.DB
}

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

type TenantEnvServiceLBMappingPortDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServiceMonitorDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServiceMountRelationDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServicePluginRelationDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServiceRelationDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServiceScalingRecordsDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServiceVolumeDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServicesDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServicesDeleteImpl struct {
	DB *gorm.DB
}

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

type TenantEnvServicesPortDaoImpl struct {
	DB *gorm.DB
}

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 

type TenantEnvServicesStreamPluginPortDaoImpl struct {
	DB *gorm.DB
}

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 

type ThirdPartySvcDiscoveryCfgDaoImpl struct {
	DB *gorm.DB
}

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 

type VersionInfoDaoImpl struct {
	DB *gorm.DB
}

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 

type VolumeTypeDaoImpl struct {
	DB *gorm.DB
}

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.