rainbond: github.com/goodrain/rainbond/db/mysql/dao Index | Files

package dao

import "github.com/goodrain/rainbond/db/mysql/dao"

Index

Package Files

3rd_party.go apiClass.go app.go cloud.go codecheck.go event.go gateway.go k8s.go license.go plugin.go protocol.go tenants.go version.go

type AppBackupDaoImpl Uses

type AppBackupDaoImpl struct {
    DB *gorm.DB
}

AppBackupDaoImpl group app backup info store mysql impl

func (*AppBackupDaoImpl) AddModel Uses

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

AddModel AddModel

func (*AppBackupDaoImpl) CheckHistory Uses

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

CheckHistory CheckHistory

func (*AppBackupDaoImpl) DeleteAppBackup Uses

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

DeleteAppBackup DeleteAppBackup

func (*AppBackupDaoImpl) GetAppBackup Uses

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

GetAppBackup GetAppBackup

func (*AppBackupDaoImpl) GetAppBackups Uses

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

GetAppBackups GetAppBackups

func (*AppBackupDaoImpl) GetDeleteAppBackup Uses

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

GetDeleteAppBackup GetDeleteAppBackup

func (*AppBackupDaoImpl) GetDeleteAppBackups Uses

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

GetDeleteAppBackups GetDeleteAppBackups

func (*AppBackupDaoImpl) UpdateModel Uses

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

UpdateModel UpdateModel

type AppDaoImpl Uses

type AppDaoImpl struct {
    DB *gorm.DB
}

func (*AppDaoImpl) AddModel Uses

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

func (*AppDaoImpl) DeleteModelByEventId Uses

func (a *AppDaoImpl) DeleteModelByEventId(eventID string) error

func (*AppDaoImpl) GetByEventId Uses

func (a *AppDaoImpl) GetByEventId(eventID string) (*model.AppStatus, error)

func (*AppDaoImpl) UpdateModel Uses

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

type CertificateDaoImpl Uses

type CertificateDaoImpl struct {
    DB *gorm.DB
}

CertificateDaoImpl -

func (*CertificateDaoImpl) AddModel Uses

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

AddModel add model

func (*CertificateDaoImpl) AddOrUpdate Uses

func (c *CertificateDaoImpl) AddOrUpdate(mo model.Interface) error

AddOrUpdate add or update Certificate

func (*CertificateDaoImpl) DeleteCertificateByID Uses

func (c *CertificateDaoImpl) DeleteCertificateByID(certificateID string) error

DeleteCertificateByID delete certificate

func (*CertificateDaoImpl) GetCertificateByID Uses

func (c *CertificateDaoImpl) GetCertificateByID(certificateID string) (*model.Certificate, error)

GetCertificateByID gets a certificate by matching id

func (*CertificateDaoImpl) UpdateModel Uses

func (c *CertificateDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel update Certificate

type CodeCheckResultDaoImpl Uses

type CodeCheckResultDaoImpl struct {
    DB *gorm.DB
}

CodeCheckResultDaoImpl EventLogMessageDaoImpl

func (*CodeCheckResultDaoImpl) AddModel Uses

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

AddModel AddModel

func (*CodeCheckResultDaoImpl) GetCodeCheckResult Uses

func (c *CodeCheckResultDaoImpl) GetCodeCheckResult(serviceID string) (*model.CodeCheckResult, error)

GetCodeCheckResult get event log message

func (*CodeCheckResultDaoImpl) UpdateModel Uses

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

UpdateModel UpdateModel

type EndpointDaoImpl Uses

type EndpointDaoImpl struct {
    DB *gorm.DB
}

EndpointDaoImpl implements EndpintDao

func (*EndpointDaoImpl) AddModel Uses

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

AddModel add one record for table 3rd_party_svc_endpoint

func (*EndpointDaoImpl) DelByUUID Uses

func (e *EndpointDaoImpl) DelByUUID(uuid string) error

DelByUUID deletes endpoints matching uuid.

func (*EndpointDaoImpl) DeleteByServiceID Uses

func (e *EndpointDaoImpl) DeleteByServiceID(sid string) error

DeleteByServiceID delete endpoints based on service id.

func (*EndpointDaoImpl) GetByUUID Uses

func (e *EndpointDaoImpl) GetByUUID(uuid string) (*model.Endpoint, error)

GetByUUID returns endpints matching the given uuid.

func (*EndpointDaoImpl) List Uses

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

List list all endpints matching the given serivce_id(sid).

func (*EndpointDaoImpl) ListIsOnline Uses

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 Uses

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

UpdateModel updates one record for table 3rd_party_svc_endpoint

type EventDaoImpl Uses

type EventDaoImpl struct {
    DB *gorm.DB
}

EventDaoImpl EventLogMessageDaoImpl

func (*EventDaoImpl) AddModel Uses

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

AddModel AddModel

func (*EventDaoImpl) DelEventByServiceID Uses

func (c *EventDaoImpl) DelEventByServiceID(serviceID string) error

DelEventByServiceID delete event log

func (*EventDaoImpl) GetEventByEventID Uses

func (c *EventDaoImpl) GetEventByEventID(eventID string) (*model.ServiceEvent, error)

GetEventByEventID get event log message

func (*EventDaoImpl) GetEventByEventIDs Uses

func (c *EventDaoImpl) GetEventByEventIDs(eventIDs []string) ([]*model.ServiceEvent, error)

GetEventByEventIDs get event info

func (*EventDaoImpl) GetEventByServiceID Uses

func (c *EventDaoImpl) GetEventByServiceID(serviceID string) ([]*model.ServiceEvent, error)

GetEventByServiceID get event log message

func (*EventDaoImpl) GetEventsByTarget Uses

func (c *EventDaoImpl) GetEventsByTarget(target, targetID string, offset, limit int) ([]*model.ServiceEvent, int, error)

GetEventsByTarget get event by target with page

func (*EventDaoImpl) GetEventsByTenantID Uses

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

GetEventsByTenantID get event by tenantID

func (*EventDaoImpl) GetLastASyncEvent Uses

func (c *EventDaoImpl) GetLastASyncEvent(target, targetID string) (*model.ServiceEvent, error)

GetLastASyncEvent get last sync event

func (*EventDaoImpl) LatestFailurePodEvent Uses

func (c *EventDaoImpl) LatestFailurePodEvent(podName string) (*model.ServiceEvent, error)

LatestFailurePodEvent returns the latest failure pod event.

func (*EventDaoImpl) UnfinishedEvents Uses

func (c *EventDaoImpl) UnfinishedEvents(target, targetID string, optTypes ...string) ([]*model.ServiceEvent, error)

UnfinishedEvents returns unfinished events.

func (*EventDaoImpl) UpdateModel Uses

func (c *EventDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel UpdateModel

type GwRuleConfigDaoImpl Uses

type GwRuleConfigDaoImpl struct {
    DB *gorm.DB
}

GwRuleConfigDaoImpl is a implementation of GwRuleConfigDao.

func (*GwRuleConfigDaoImpl) AddModel Uses

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

AddModel creates a new gateway rule config.

func (*GwRuleConfigDaoImpl) DeleteByRuleID Uses

func (t *GwRuleConfigDaoImpl) DeleteByRuleID(rid string) error

DeleteByRuleID deletes gateway rule configs by rule id.

func (*GwRuleConfigDaoImpl) ListByRuleID Uses

func (t *GwRuleConfigDaoImpl) ListByRuleID(rid string) ([]*model.GwRuleConfig, error)

ListByRuleID lists GwRuleConfig by rule id.

func (*GwRuleConfigDaoImpl) UpdateModel Uses

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

UpdateModel updates a gateway rule config.

type HTTPRuleDaoImpl Uses

type HTTPRuleDaoImpl struct {
    DB *gorm.DB
}

HTTPRuleDaoImpl http rule

func (*HTTPRuleDaoImpl) AddModel Uses

func (h *HTTPRuleDaoImpl) AddModel(mo model.Interface) error

AddModel -

func (*HTTPRuleDaoImpl) DeleteHTTPRuleByID Uses

func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByID(id string) error

DeleteHTTPRuleByID delete http rule by rule id

func (*HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID Uses

func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID(serviceID string) error

DeleteHTTPRuleByServiceID delete http rule by service id

func (*HTTPRuleDaoImpl) GetHTTPRuleByID Uses

func (h *HTTPRuleDaoImpl) GetHTTPRuleByID(id string) (*model.HTTPRule, error)

GetHTTPRuleByID gets a HTTPRule based on uuid

func (*HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort Uses

func (h *HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort(serviceID string,
    containerPort int) ([]*model.HTTPRule, error)

GetHTTPRuleByServiceIDAndContainerPort gets a HTTPRule based on serviceID and containerPort

func (*HTTPRuleDaoImpl) ListByServiceID Uses

func (h *HTTPRuleDaoImpl) ListByServiceID(serviceID string) ([]*model.HTTPRule, error)

ListByServiceID lists all HTTPRules matching serviceID

func (*HTTPRuleDaoImpl) UpdateModel Uses

func (h *HTTPRuleDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel -

type LicenseDaoImpl Uses

type LicenseDaoImpl struct {
    DB *gorm.DB
}

LicenseDaoImpl license model 管理

func (*LicenseDaoImpl) AddModel Uses

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

AddModel AddModel

func (*LicenseDaoImpl) DeleteLicense Uses

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

DeleteLicense DeleteLicense

func (*LicenseDaoImpl) ListLicenses Uses

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

ListLicenses ListLicenses

func (*LicenseDaoImpl) UpdateModel Uses

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

UpdateModel UpdateModel

type LocalSchedulerDaoImpl Uses

type LocalSchedulerDaoImpl struct {
    DB *gorm.DB
}

LocalSchedulerDaoImpl 本地调度存储mysql实现

func (*LocalSchedulerDaoImpl) AddModel Uses

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

AddModel 添加本地调度信息

func (*LocalSchedulerDaoImpl) GetLocalScheduler Uses

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

GetLocalScheduler 获取应用本地调度信息

func (*LocalSchedulerDaoImpl) UpdateModel Uses

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

UpdateModel 更新调度信息

type NotificationEventDaoImpl Uses

type NotificationEventDaoImpl struct {
    DB *gorm.DB
}

NotificationEventDaoImpl NotificationEventDaoImpl

func (*NotificationEventDaoImpl) AddModel Uses

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

AddModel AddModel

func (*NotificationEventDaoImpl) GetNotificationEventByHash Uses

func (c *NotificationEventDaoImpl) GetNotificationEventByHash(hash string) (*model.NotificationEvent, error)

GetNotificationEventByHash GetNotificationEventByHash

func (*NotificationEventDaoImpl) GetNotificationEventByKind Uses

func (c *NotificationEventDaoImpl) GetNotificationEventByKind(kind, kindID string) ([]*model.NotificationEvent, error)

GetNotificationEventByKind GetNotificationEventByKind

func (*NotificationEventDaoImpl) GetNotificationEventByTime Uses

func (c *NotificationEventDaoImpl) GetNotificationEventByTime(start, end time.Time) ([]*model.NotificationEvent, error)

GetNotificationEventByTime GetNotificationEventByTime

func (*NotificationEventDaoImpl) GetNotificationEventNotHandle Uses

func (c *NotificationEventDaoImpl) GetNotificationEventNotHandle() ([]*model.NotificationEvent, error)

GetNotificationEventNotHandle GetNotificationEventNotHandle

func (*NotificationEventDaoImpl) UpdateModel Uses

func (c *NotificationEventDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel UpdateModel

type PluginBuildVersionDaoImpl Uses

type PluginBuildVersionDaoImpl struct {
    DB *gorm.DB
}

PluginBuildVersionDaoImpl PluginBuildVersionDaoImpl

func (*PluginBuildVersionDaoImpl) AddModel Uses

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

AddModel 添加插件构建版本信息

func (*PluginBuildVersionDaoImpl) DeleteBuildVersionByPluginID Uses

func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByPluginID(pluginID string) error

DeleteBuildVersionByPluginID DeleteBuildVersionByPluginID

func (*PluginBuildVersionDaoImpl) DeleteBuildVersionByVersionID Uses

func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByVersionID(versionID string) error

DeleteBuildVersionByVersionID DeleteBuildVersionByVersionID

func (*PluginBuildVersionDaoImpl) GetBuildVersionByDeployVersion Uses

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

GetBuildVersionByDeployVersion GetBuildVersionByDeployVersion

func (*PluginBuildVersionDaoImpl) GetBuildVersionByPluginID Uses

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

GetBuildVersionByPluginID GetBuildVersionByPluginID

func (*PluginBuildVersionDaoImpl) GetBuildVersionByVersionID Uses

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

GetBuildVersionByVersionID GetBuildVersionByVersionID

func (*PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID Uses

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

GetLastBuildVersionByVersionID get last success build version

func (*PluginBuildVersionDaoImpl) ListSuccessfulOnesByPluginIDs Uses

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

ListSuccessfulOnesByPluginIDs returns the list of successful build versions,

func (*PluginBuildVersionDaoImpl) UpdateModel Uses

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

UpdateModel 更新插件默认变量 主体信息一般不变更,仅构建的本地镜像名与status需要变更

type PluginDaoImpl Uses

type PluginDaoImpl struct {
    DB *gorm.DB
}

PluginDaoImpl PluginDaoImpl

func (*PluginDaoImpl) AddModel Uses

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

AddModel 创建插件

func (*PluginDaoImpl) DeletePluginByID Uses

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

DeletePluginByID DeletePluginByID

func (*PluginDaoImpl) GetPluginByID Uses

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

GetPluginByID GetPluginByID

func (*PluginDaoImpl) GetPluginsByTenantID Uses

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

GetPluginsByTenantID GetPluginsByTenantID

func (*PluginDaoImpl) ListByIDs Uses

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

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

func (*PluginDaoImpl) ListByTenantID Uses

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

ListByTenantID -

func (*PluginDaoImpl) UpdateModel Uses

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

UpdateModel 更新插件

type PluginDefaultENVDaoImpl Uses

type PluginDefaultENVDaoImpl struct {
    DB *gorm.DB
}

PluginDefaultENVDaoImpl PluginDefaultENVDaoImpl

func (*PluginDefaultENVDaoImpl) AddModel Uses

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

AddModel 添加插件默认变量

func (*PluginDefaultENVDaoImpl) DeleteAllDefaultENVByPluginID Uses

func (t *PluginDefaultENVDaoImpl) DeleteAllDefaultENVByPluginID(pluginID string) error

DeleteAllDefaultENVByPluginID DeleteAllDefaultENVByPluginID

func (*PluginDefaultENVDaoImpl) DeleteDefaultENVByName Uses

func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByName(pluginID, name, versionID string) error

DeleteDefaultENVByName DeleteDefaultENVByName

func (*PluginDefaultENVDaoImpl) DeleteDefaultENVByPluginIDAndVersionID Uses

func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByPluginIDAndVersionID(pluginID, versionID string) error

DeleteDefaultENVByPluginIDAndVersionID DeleteDefaultENVByPluginIDAndVersionID

func (*PluginDefaultENVDaoImpl) GetALLMasterDefultENVs Uses

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

GetALLMasterDefultENVs GetALLMasterDefultENVs

func (*PluginDefaultENVDaoImpl) GetDefaultENVByName Uses

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

GetDefaultENVByName GetDefaultENVByName

func (*PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID Uses

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

GetDefaultENVSByPluginID GetDefaultENVSByPluginID

func (*PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID Uses

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

GetDefaultEnvWhichCanBeSetByPluginID GetDefaultEnvWhichCanBeSetByPluginID

func (*PluginDefaultENVDaoImpl) UpdateModel Uses

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

UpdateModel 更新插件默认变量

type PluginVersionConfigDaoImpl Uses

type PluginVersionConfigDaoImpl struct {
    DB *gorm.DB
}

PluginVersionConfigDaoImpl PluginVersionEnvDaoImpl

func (*PluginVersionConfigDaoImpl) AddModel Uses

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

AddModel add or update service plugin config

func (*PluginVersionConfigDaoImpl) DeletePluginConfig Uses

func (t *PluginVersionConfigDaoImpl) DeletePluginConfig(serviceID, pluginID string) error

DeletePluginConfig delete service plugin config

func (*PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID Uses

func (t *PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID(serviceID string) error

DeletePluginConfigByServiceID Batch delete config by service id

func (*PluginVersionConfigDaoImpl) GetPluginConfig Uses

func (t *PluginVersionConfigDaoImpl) GetPluginConfig(serviceID, pluginID string) (*model.TenantPluginVersionDiscoverConfig, error)

GetPluginConfig get service plugin config

func (*PluginVersionConfigDaoImpl) GetPluginConfigs Uses

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

GetPluginConfigs get plugin configs

func (*PluginVersionConfigDaoImpl) UpdateModel Uses

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

UpdateModel update service plugin config

type PluginVersionEnvDaoImpl Uses

type PluginVersionEnvDaoImpl struct {
    DB *gorm.DB
}

PluginVersionEnvDaoImpl PluginVersionEnvDaoImpl

func (*PluginVersionEnvDaoImpl) AddModel Uses

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

AddModel 添加插件默认变量

func (*PluginVersionEnvDaoImpl) DeleteEnvByEnvName Uses

func (t *PluginVersionEnvDaoImpl) DeleteEnvByEnvName(envName, pluginID, serviceID string) error

DeleteEnvByEnvName 删除单个env

func (*PluginVersionEnvDaoImpl) DeleteEnvByPluginID Uses

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

DeleteEnvByPluginID 删除插件依赖关系时,需要操作删除对应env

func (*PluginVersionEnvDaoImpl) DeleteEnvByServiceID Uses

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

DeleteEnvByServiceID 删除应用时,需要进行此操作

func (*PluginVersionEnvDaoImpl) GetVersionEnvByEnvName Uses

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

GetVersionEnvByEnvName GetVersionEnvByEnvName

func (*PluginVersionEnvDaoImpl) GetVersionEnvByServiceID Uses

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

GetVersionEnvByServiceID 获取该应用下使用的某个插件依赖的插件变量

func (*PluginVersionEnvDaoImpl) ListByServiceID Uses

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

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

func (*PluginVersionEnvDaoImpl) UpdateModel Uses

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

UpdateModel 更新插件默认变量

type RegionAPIClassDaoImpl Uses

type RegionAPIClassDaoImpl struct {
    DB *gorm.DB
}

RegionAPIClassDaoImpl RegionAPIClassDaoImpl

func (*RegionAPIClassDaoImpl) AddModel Uses

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

AddModel 添加api分类信息

func (*RegionAPIClassDaoImpl) DeletePrefixInClass Uses

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

DeletePrefixInClass DeletePrefixInClass

func (*RegionAPIClassDaoImpl) GetPrefixesByClass Uses

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

GetPrefixesByClass GetPrefixesByClass

func (*RegionAPIClassDaoImpl) UpdateModel Uses

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

UpdateModel 更新api分类信息

type RegionProcotolsDaoImpl Uses

type RegionProcotolsDaoImpl struct {
    DB *gorm.DB
}

RegionProcotolsDaoImpl RegionProcotolsDaoImpl

func (*RegionProcotolsDaoImpl) AddModel Uses

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

AddModel 添加cloud信息

func (*RegionProcotolsDaoImpl) GetAllSupportProtocol Uses

func (t *RegionProcotolsDaoImpl) GetAllSupportProtocol(version string) ([]*model.RegionProcotols, error)

GetAllSupportProtocol 获取当前数据中心支持的所有协议

func (*RegionProcotolsDaoImpl) GetProtocolGroupByProtocolChild Uses

func (t *RegionProcotolsDaoImpl) GetProtocolGroupByProtocolChild(
    version,
    protocolChild string) (*model.RegionProcotols, error)

GetProtocolGroupByProtocolChild 获取协议族名称

func (*RegionProcotolsDaoImpl) UpdateModel Uses

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

UpdateModel 更新cloud信息

type RegionUserInfoDaoImpl Uses

type RegionUserInfoDaoImpl struct {
    DB *gorm.DB
}

RegionUserInfoDaoImpl CloudDaoImpl

func (*RegionUserInfoDaoImpl) AddModel Uses

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

AddModel 添加cloud信息

func (*RegionUserInfoDaoImpl) GetALLTokenInValidityPeriod Uses

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

GetALLTokenInValidityPeriod GetALLTokenInValidityPeriod

func (*RegionUserInfoDaoImpl) GetTokenByEid Uses

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

GetTokenByEid GetTokenByEid

func (*RegionUserInfoDaoImpl) GetTokenByTokenID Uses

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

GetTokenByTokenID GetTokenByTokenID

func (*RegionUserInfoDaoImpl) UpdateModel Uses

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

UpdateModel 更新cloud信息

type RuleExtensionDaoImpl Uses

type RuleExtensionDaoImpl struct {
    DB *gorm.DB
}

RuleExtensionDaoImpl rule extension dao

func (*RuleExtensionDaoImpl) AddModel Uses

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

AddModel add

func (*RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID Uses

func (c *RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID(ruleID string) error

DeleteRuleExtensionByRuleID delete rule extensions by ruleID

func (*RuleExtensionDaoImpl) GetRuleExtensionByRuleID Uses

func (c *RuleExtensionDaoImpl) GetRuleExtensionByRuleID(ruleID string) ([]*model.RuleExtension, error)

GetRuleExtensionByRuleID get extension by rule

func (*RuleExtensionDaoImpl) UpdateModel Uses

func (c *RuleExtensionDaoImpl) UpdateModel(model.Interface) error

UpdateModel update model,do not impl

type ServiceLabelDaoImpl Uses

type ServiceLabelDaoImpl struct {
    DB *gorm.DB
}

ServiceLabelDaoImpl ServiceLabelDaoImpl

func (*ServiceLabelDaoImpl) AddModel Uses

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

AddModel 添加应用Label

func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByLabelValuesAndServiceID Uses

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

DelTenantServiceLabelsByLabelValuesAndServiceID DELTenantServiceLabelsByLabelvaluesAndServiceID

func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKey Uses

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

DelTenantServiceLabelsByServiceIDKey deletes labels by serviceID and labelKey

func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKeyValue Uses

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

DelTenantServiceLabelsByServiceIDKeyValue deletes labels

func (*ServiceLabelDaoImpl) DeleteLabelByServiceID Uses

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

DeleteLabelByServiceID 删除应用全部label

func (*ServiceLabelDaoImpl) DeleteModel Uses

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

DeleteModel 删除应用label

func (*ServiceLabelDaoImpl) GetLabelByNodeSelectorKey Uses

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

GetLabelByNodeSelectorKey returns a label by node-selector and label_value

func (*ServiceLabelDaoImpl) GetTenantNodeAffinityLabel Uses

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

GetTenantNodeAffinityLabel returns TenantServiceLable matching serviceID and LabelKeyNodeAffinity

func (*ServiceLabelDaoImpl) GetTenantServiceAffinityLabel Uses

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

GetTenantServiceAffinityLabel GetTenantServiceAffinityLabel

func (*ServiceLabelDaoImpl) GetTenantServiceLabel Uses

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

GetTenantServiceLabel GetTenantServiceLabel

func (*ServiceLabelDaoImpl) GetTenantServiceNodeSelectorLabel Uses

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

GetTenantServiceNodeSelectorLabel GetTenantServiceNodeSelectorLabel

func (*ServiceLabelDaoImpl) GetTenantServiceTypeLabel Uses

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

GetTenantServiceTypeLabel GetTenantServiceTypeLabel

func (*ServiceLabelDaoImpl) UpdateModel Uses

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

UpdateModel 更新应用Label

type ServiceProbeDaoImpl Uses

type ServiceProbeDaoImpl struct {
    DB *gorm.DB
}

ServiceProbeDaoImpl probe dao impl

func (*ServiceProbeDaoImpl) AddModel Uses

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

AddModel 添加应用Probe

func (*ServiceProbeDaoImpl) DELServiceProbesByServiceID Uses

func (t *ServiceProbeDaoImpl) DELServiceProbesByServiceID(serviceID string) error

DELServiceProbesByServiceID DELServiceProbesByServiceID

func (*ServiceProbeDaoImpl) DelByServiceID Uses

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

DelByServiceID deletes TenantServiceProbe based on sid(service_id)

func (*ServiceProbeDaoImpl) DeleteModel Uses

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

DeleteModel 删除应用探针

func (*ServiceProbeDaoImpl) GetServiceProbes Uses

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

GetServiceProbes 获取应用探针

func (*ServiceProbeDaoImpl) GetServiceUsedProbe Uses

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

GetServiceUsedProbe 获取指定模式的可用探针定义

func (*ServiceProbeDaoImpl) UpdateModel Uses

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

UpdateModel 更新应用Probe

type ServiceSourceImpl Uses

type ServiceSourceImpl struct {
    DB *gorm.DB
}

ServiceSourceImpl service source

func (*ServiceSourceImpl) AddModel Uses

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

AddModel add service source

func (*ServiceSourceImpl) GetServiceSource Uses

func (t *ServiceSourceImpl) GetServiceSource(serviceID string) ([]*model.ServiceSourceConfig, error)

GetServiceSource get services source

func (*ServiceSourceImpl) UpdateModel Uses

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

UpdateModel update service source

type TCPRuleDaoTmpl Uses

type TCPRuleDaoTmpl struct {
    DB *gorm.DB
}

TCPRuleDaoTmpl is a implementation of TcpRuleDao

func (*TCPRuleDaoTmpl) AddModel Uses

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

AddModel adds model.TCPRule

func (*TCPRuleDaoTmpl) DeleteByID Uses

func (t *TCPRuleDaoTmpl) DeleteByID(uuid string) error

DeleteByID deletes model.TCPRule

func (*TCPRuleDaoTmpl) DeleteTCPRuleByServiceID Uses

func (t *TCPRuleDaoTmpl) DeleteTCPRuleByServiceID(serviceID string) error

DeleteTCPRuleByServiceID deletes model.TCPRule

func (*TCPRuleDaoTmpl) GetTCPRuleByID Uses

func (t *TCPRuleDaoTmpl) GetTCPRuleByID(id string) (*model.TCPRule, error)

GetTCPRuleByID gets a TCPRule based on tcpRuleID

func (*TCPRuleDaoTmpl) GetTCPRuleByServiceID Uses

func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceID(sid string) ([]*model.TCPRule, error)

GetTCPRuleByServiceID gets a TCPRules based on service id.

func (*TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort Uses

func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort(serviceID string,
    containerPort int) ([]*model.TCPRule, error)

GetTCPRuleByServiceIDAndContainerPort gets a TCPRule based on serviceID and containerPort

func (*TCPRuleDaoTmpl) GetUsedPortsByIP Uses

func (t *TCPRuleDaoTmpl) GetUsedPortsByIP(ip string) ([]*model.TCPRule, error)

GetUsedPortsByIP get used port by ip sort by port

func (*TCPRuleDaoTmpl) ListByServiceID Uses

func (t *TCPRuleDaoTmpl) ListByServiceID(serviceID string) ([]*model.TCPRule, error)

ListByServiceID lists all TCPRules matching serviceID

func (*TCPRuleDaoTmpl) UpdateModel Uses

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

UpdateModel updates model.TCPRule

type TenantDaoImpl Uses

type TenantDaoImpl struct {
    DB *gorm.DB
}

TenantDaoImpl 租户信息管理

func (*TenantDaoImpl) AddModel Uses

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

AddModel 添加租户

func (*TenantDaoImpl) DelByTenantID Uses

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

DelByTenantID -

func (*TenantDaoImpl) GetALLTenants Uses

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

GetALLTenants GetALLTenants

func (*TenantDaoImpl) GetPagedTenants Uses

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

GetPagedTenants -

func (*TenantDaoImpl) GetTenantByEid Uses

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

GetTenantByEid get tenants by eid

func (*TenantDaoImpl) GetTenantByUUID Uses

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

GetTenantByUUID 获取租户

func (*TenantDaoImpl) GetTenantByUUIDIsExist Uses

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

GetTenantByUUIDIsExist 获取租户

func (*TenantDaoImpl) GetTenantIDByName Uses

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

GetTenantIDByName 获取租户

func (*TenantDaoImpl) GetTenantIDsByNames Uses

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

GetTenantIDsByNames get tenant ids by names

func (*TenantDaoImpl) GetTenantLimitsByNames Uses

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

GetTenantLimitsByNames get tenants memory limit

func (*TenantDaoImpl) UpdateModel Uses

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

UpdateModel 更新租户

type TenantServceAutoscalerRuleMetricsDaoImpl Uses

type TenantServceAutoscalerRuleMetricsDaoImpl struct {
    DB *gorm.DB
}

TenantServceAutoscalerRuleMetricsDaoImpl -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) AddModel Uses

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

AddModel -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) ListByRuleID Uses

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

ListByRuleID -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) UpdateModel Uses

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

UpdateModel -

func (*TenantServceAutoscalerRuleMetricsDaoImpl) UpdateOrCreate Uses

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

UpdateOrCreate -

type TenantServceAutoscalerRulesDaoImpl Uses

type TenantServceAutoscalerRulesDaoImpl struct {
    DB *gorm.DB
}

TenantServceAutoscalerRulesDaoImpl -

func (*TenantServceAutoscalerRulesDaoImpl) AddModel Uses

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

AddModel -

func (*TenantServceAutoscalerRulesDaoImpl) GetByRuleID Uses

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

GetByRuleID -

func (*TenantServceAutoscalerRulesDaoImpl) ListByServiceID Uses

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

ListByServiceID -

func (*TenantServceAutoscalerRulesDaoImpl) ListEnableOnesByServiceID Uses

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

ListEnableOnesByServiceID -

func (*TenantServceAutoscalerRulesDaoImpl) UpdateModel Uses

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

UpdateModel -

type TenantServiceConfigFileDaoImpl Uses

type TenantServiceConfigFileDaoImpl struct {
    DB *gorm.DB
}

TenantServiceConfigFileDaoImpl is a implementation of TenantServiceConfigFileDao

func (*TenantServiceConfigFileDaoImpl) AddModel Uses

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

AddModel creates a new TenantServiceConfigFile

func (*TenantServiceConfigFileDaoImpl) DelByServiceID Uses

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

DelByServiceID deletes config files according to service id.

func (*TenantServiceConfigFileDaoImpl) DelByVolumeID Uses

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

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

func (*TenantServiceConfigFileDaoImpl) GetByVolumeName Uses

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

GetByVolumeName get config file by volume name

func (*TenantServiceConfigFileDaoImpl) UpdateModel Uses

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

UpdateModel updates config file

type TenantServiceEnvVarDaoImpl Uses

type TenantServiceEnvVarDaoImpl struct {
    DB *gorm.DB
}

TenantServiceEnvVarDaoImpl TenantServiceEnvVarDaoImpl

func (*TenantServiceEnvVarDaoImpl) AddModel Uses

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

AddModel 添加应用环境变量

func (*TenantServiceEnvVarDaoImpl) DELServiceEnvsByServiceID Uses

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

DELServiceEnvsByServiceID 通过serviceID 删除envs

func (*TenantServiceEnvVarDaoImpl) DelByServiceIDAndScope Uses

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

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

func (*TenantServiceEnvVarDaoImpl) DeleteModel Uses

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

DeleteModel 删除env

func (*TenantServiceEnvVarDaoImpl) GetDependServiceEnvs Uses

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

GetDependServiceEnvs 获取依赖服务的环境变量

func (*TenantServiceEnvVarDaoImpl) GetEnv Uses

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

GetEnv 获取某个环境变量

func (*TenantServiceEnvVarDaoImpl) GetServiceEnvs Uses

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

GetServiceEnvs 获取服务环境变量

func (*TenantServiceEnvVarDaoImpl) UpdateModel Uses

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

UpdateModel update env support attr_value\is_change\scope

type TenantServiceLBMappingPortDaoImpl Uses

type TenantServiceLBMappingPortDaoImpl struct {
    DB *gorm.DB
}

TenantServiceLBMappingPortDaoImpl stream服务映射

func (*TenantServiceLBMappingPortDaoImpl) AddModel Uses

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

AddModel 添加应用端口映射

func (*TenantServiceLBMappingPortDaoImpl) CreateTenantServiceLBMappingPort Uses

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

CreateTenantServiceLBMappingPort 创建负载均衡VS端口,如果端口分配已存在,直接返回

func (*TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID Uses

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

DELServiceLBMappingPortByServiceID DELServiceLBMappingPortByServiceID

func (*TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort Uses

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

DELServiceLBMappingPortByServiceIDAndPort DELServiceLBMappingPortByServiceIDAndPort

func (*TenantServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort Uses

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

GetLBMappingPortByServiceIDAndPort returns a LBMappingPort by serviceID and port

func (*TenantServiceLBMappingPortDaoImpl) GetLBPortByTenantAndPort Uses

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

GetLBPortByTenantAndPort GetLBPortByTenantAndPort

func (*TenantServiceLBMappingPortDaoImpl) GetLBPortsASC Uses

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

GetLBPortsASC gets all LBMappingPorts ascending

func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort Uses

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

GetTenantServiceLBMappingPort 获取端口映射

func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService Uses

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

GetTenantServiceLBMappingPortByService 获取端口映射

func (*TenantServiceLBMappingPortDaoImpl) PortExists Uses

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

PortExists checks if the port exists

func (*TenantServiceLBMappingPortDaoImpl) UpdateModel Uses

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

UpdateModel 更新应用端口映射

type TenantServiceMountRelationDaoImpl Uses

type TenantServiceMountRelationDaoImpl struct {
    DB *gorm.DB
}

TenantServiceMountRelationDaoImpl 依赖存储

func (*TenantServiceMountRelationDaoImpl) AddModel Uses

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

AddModel 添加应用依赖挂载

func (*TenantServiceMountRelationDaoImpl) DELTenantServiceMountRelationByServiceID Uses

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

DELTenantServiceMountRelationByServiceID DELTenantServiceMountRelationByServiceID

func (*TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByDepService Uses

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

DElTenantServiceMountRelationByDepService del mount relation

func (*TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByServiceAndName Uses

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

DElTenantServiceMountRelationByServiceAndName DElTenantServiceMountRelationByServiceAndName

func (*TenantServiceMountRelationDaoImpl) GetTenantServiceMountRelationsByService Uses

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

GetTenantServiceMountRelationsByService 获取应用的所有挂载依赖

func (*TenantServiceMountRelationDaoImpl) UpdateModel Uses

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

UpdateModel 更新应用依赖挂载

type TenantServicePluginRelationDaoImpl Uses

type TenantServicePluginRelationDaoImpl struct {
    DB *gorm.DB
}

TenantServicePluginRelationDaoImpl TenantServicePluginRelationDaoImpl

func (*TenantServicePluginRelationDaoImpl) AddModel Uses

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

AddModel 添加插件默认变量

func (*TenantServicePluginRelationDaoImpl) CheckSomeModelLikePluginByServiceID Uses

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

CheckSomeModelLikePluginByServiceID 检查是否绑定了某大类插件

func (*TenantServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID Uses

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

CheckSomeModelPluginByServiceID 检查是否绑定了某种插件且处于启用状态

func (*TenantServicePluginRelationDaoImpl) DeleteALLRelationByPluginID Uses

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

DeleteALLRelationByPluginID 删除pluginID所有依赖 一般不要使用 会影响关联过的应用启动

func (*TenantServicePluginRelationDaoImpl) DeleteALLRelationByServiceID Uses

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

DeleteALLRelationByServiceID 删除serviceID所有插件依赖 一般用于删除应用时使用

func (*TenantServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID Uses

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

DeleteRelationByServiceIDAndPluginID 删除service plugin 对应关系

func (*TenantServicePluginRelationDaoImpl) GetALLRelationByServiceID Uses

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

GetALLRelationByServiceID 获取当前应用所有的插件依赖关系

func (*TenantServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID Uses

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

GetRelateionByServiceIDAndPluginID GetRelateionByServiceIDAndPluginID

func (*TenantServicePluginRelationDaoImpl) UpdateModel Uses

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

UpdateModel 更新插件默认变量 更新依赖的version id

type TenantServiceRelationDaoImpl Uses

type TenantServiceRelationDaoImpl struct {
    DB *gorm.DB
}

TenantServiceRelationDaoImpl TenantServiceRelationDaoImpl

func (*TenantServiceRelationDaoImpl) AddModel Uses

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

AddModel 添加应用依赖关系

func (*TenantServiceRelationDaoImpl) DELRelationsByServiceID Uses

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

DELRelationsByServiceID DELRelationsByServiceID

func (*TenantServiceRelationDaoImpl) DeleteModel Uses

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

DeleteModel 删除依赖

func (*TenantServiceRelationDaoImpl) DeleteRelationByDepID Uses

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

DeleteRelationByDepID DeleteRelationByDepID

func (*TenantServiceRelationDaoImpl) GetTenantServiceRelations Uses

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

GetTenantServiceRelations 获取应用依赖关系

func (*TenantServiceRelationDaoImpl) GetTenantServiceRelationsByDependServiceID Uses

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

GetTenantServiceRelationsByDependServiceID 获取全部依赖当前服务的应用

func (*TenantServiceRelationDaoImpl) HaveRelations Uses

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

HaveRelations 是否有依赖

func (*TenantServiceRelationDaoImpl) UpdateModel Uses

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

UpdateModel 更新应用依赖关系

type TenantServiceScalingRecordsDaoImpl Uses

type TenantServiceScalingRecordsDaoImpl struct {
    DB *gorm.DB
}

TenantServiceScalingRecordsDaoImpl -

func (*TenantServiceScalingRecordsDaoImpl) AddModel Uses

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

AddModel -

func (*TenantServiceScalingRecordsDaoImpl) CountByServiceID Uses

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

CountByServiceID -

func (*TenantServiceScalingRecordsDaoImpl) ListByServiceID Uses

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

ListByServiceID -

func (*TenantServiceScalingRecordsDaoImpl) UpdateModel Uses

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

UpdateModel -

func (*TenantServiceScalingRecordsDaoImpl) UpdateOrCreate Uses

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

UpdateOrCreate -

type TenantServiceVolumeDaoImpl Uses

type TenantServiceVolumeDaoImpl struct {
    DB *gorm.DB
}

TenantServiceVolumeDaoImpl 应用存储

func (*TenantServiceVolumeDaoImpl) AddModel Uses

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

AddModel 添加应用挂载

func (*TenantServiceVolumeDaoImpl) DelShareableBySID Uses

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

DelShareableBySID deletes shareable volumes based on sid(service_id)

func (*TenantServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath Uses

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

DeleteByServiceIDAndVolumePath 删除挂载通过挂载的目录

func (*TenantServiceVolumeDaoImpl) DeleteModel Uses

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

DeleteModel 删除挂载

func (*TenantServiceVolumeDaoImpl) DeleteTenantServiceVolumesByServiceID Uses

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

DeleteTenantServiceVolumesByServiceID 删除挂载

func (*TenantServiceVolumeDaoImpl) GetAllVolumes Uses

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

GetAllVolumes 获取全部存储信息

func (*TenantServiceVolumeDaoImpl) GetTenantServiceVolumesByServiceID Uses

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

GetTenantServiceVolumesByServiceID 获取应用挂载

func (*TenantServiceVolumeDaoImpl) GetVolumeByID Uses

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

GetVolumeByID get volume by id

func (*TenantServiceVolumeDaoImpl) GetVolumeByServiceIDAndName Uses

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

GetVolumeByServiceIDAndName 获取存储信息

func (*TenantServiceVolumeDaoImpl) UpdateModel Uses

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

UpdateModel 更��应用挂载

type TenantServicesDaoImpl Uses

type TenantServicesDaoImpl struct {
    DB *gorm.DB
}

TenantServicesDaoImpl 租户应用dao

func (*TenantServicesDaoImpl) AddModel Uses

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

AddModel 添加租户应用

func (*TenantServicesDaoImpl) DeleteServiceByServiceID Uses

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

DeleteServiceByServiceID DeleteServiceByServiceID

func (*TenantServicesDaoImpl) GetAllServicesID Uses

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

GetAllServicesID get all service sample info

func (*TenantServicesDaoImpl) GetPagedTenantService Uses

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

GetPagedTenantService GetPagedTenantResource

func (*TenantServicesDaoImpl) GetServiceAliasByIDs Uses

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

GetServiceAliasByIDs 获取应用别名

func (*TenantServicesDaoImpl) GetServiceByID Uses

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

GetServiceByID 获取服务通过服务id

func (*TenantServicesDaoImpl) GetServiceByIDs Uses

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

GetServiceByIDs get some service by service ids

func (*TenantServicesDaoImpl) GetServiceByServiceAlias Uses

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

GetServiceByServiceAlias 获取服务通过服务别名

func (*TenantServicesDaoImpl) GetServiceByTenantIDAndServiceAlias Uses

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

GetServiceByTenantIDAndServiceAlias 根据租户名和服务名

func (*TenantServicesDaoImpl) GetServiceMemoryByServiceIDs Uses

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

GetServiceMemoryByServiceIDs get service memory by service ids

func (*TenantServicesDaoImpl) GetServiceMemoryByTenantIDs Uses

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

GetServiceMemoryByTenantIDs get service memory by tenant ids

func (*TenantServicesDaoImpl) GetServicesAllInfoByTenantID Uses

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

GetServicesAllInfoByTenantID GetServicesAllInfoByTenantID

func (*TenantServicesDaoImpl) GetServicesByTenantID Uses

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

GetServicesByTenantID GetServicesByTenantID

func (*TenantServicesDaoImpl) GetServicesByTenantIDs Uses

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

GetServicesByTenantIDs GetServicesByTenantIDs

func (*TenantServicesDaoImpl) ListServicesByTenantID Uses

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

ListServicesByTenantID -

func (*TenantServicesDaoImpl) ListThirdPartyServices Uses

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

ListThirdPartyServices lists all third party services

func (*TenantServicesDaoImpl) SetTenantServiceStatus Uses

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

SetTenantServiceStatus SetTenantServiceStatus

func (*TenantServicesDaoImpl) UpdateDeployVersion Uses

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

UpdateDeployVersion update service current deploy version

func (*TenantServicesDaoImpl) UpdateModel Uses

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

UpdateModel 更新租户应用

type TenantServicesDeleteImpl Uses

type TenantServicesDeleteImpl struct {
    DB *gorm.DB
}

TenantServicesDeleteImpl TenantServiceDeleteImpl

func (*TenantServicesDeleteImpl) AddModel Uses

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

AddModel 添加已删除的应用

func (*TenantServicesDeleteImpl) DeleteTenantServicesDelete Uses

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

DeleteTenantServicesDelete -

func (*TenantServicesDeleteImpl) GetTenantServicesDeleteByCreateTime Uses

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

GetTenantServicesDeleteByCreateTime -

func (*TenantServicesDeleteImpl) UpdateModel Uses

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

UpdateModel 更新租户应用

type TenantServicesPortDaoImpl Uses

type TenantServicesPortDaoImpl struct {
    DB *gorm.DB
}

TenantServicesPortDaoImpl 租户应用端口操作

func (*TenantServicesPortDaoImpl) AddModel Uses

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

AddModel 添加应用端口

func (*TenantServicesPortDaoImpl) DELPortsByServiceID Uses

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

DELPortsByServiceID DELPortsByServiceID

func (*TenantServicesPortDaoImpl) DelByServiceID Uses

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

DelByServiceID deletes TenantServicesPort matching sid(service_id).

func (*TenantServicesPortDaoImpl) DeleteModel Uses

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

DeleteModel 删除端口

func (*TenantServicesPortDaoImpl) GetDepUDPPort Uses

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

GetDepUDPPort get all depend service udp port

func (*TenantServicesPortDaoImpl) GetInnerPorts Uses

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

GetInnerPorts 获取对内端口

func (*TenantServicesPortDaoImpl) GetOpenedPorts Uses

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

GetOpenedPorts returns opened ports.

func (*TenantServicesPortDaoImpl) GetOuterPorts Uses

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

GetOuterPorts 获取对外端口

func (*TenantServicesPortDaoImpl) GetPort Uses

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

GetPort get port

func (*TenantServicesPortDaoImpl) GetPortsByServiceID Uses

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

GetPortsByServiceID 通过服务获取port

func (*TenantServicesPortDaoImpl) HasOpenPort Uses

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

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

func (*TenantServicesPortDaoImpl) UpdateModel Uses

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

UpdateModel 更新租户

type TenantServicesStreamPluginPortDaoImpl Uses

type TenantServicesStreamPluginPortDaoImpl struct {
    DB *gorm.DB
}

TenantServicesStreamPluginPortDaoImpl TenantServicesStreamPluginPortDaoImpl

func (*TenantServicesStreamPluginPortDaoImpl) AddModel Uses

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

AddModel 添加插件端口映射信息

func (*TenantServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID Uses

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

DeleteAllPluginMappingPortByServiceID DeleteAllPluginMappingPortByServiceID

func (*TenantServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort Uses

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

DeletePluginMappingPortByContainerPort DeletePluginMappingPortByContainerPort

func (*TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort Uses

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

GetPluginMappingPortByServiceIDAndContainerPort GetPluginMappingPortByServiceIDAndContainerPort

func (*TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPorts Uses

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

GetPluginMappingPorts GetPluginMappingPorts 降序排列

func (*TenantServicesStreamPluginPortDaoImpl) ListByServiceID Uses

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

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

func (*TenantServicesStreamPluginPortDaoImpl) SetPluginMappingPort Uses

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

SetPluginMappingPort SetPluginMappingPort

func (*TenantServicesStreamPluginPortDaoImpl) UpdateModel Uses

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

UpdateModel 更新插件端口映射信息

type ThirdPartySvcDiscoveryCfgDaoImpl Uses

type ThirdPartySvcDiscoveryCfgDaoImpl struct {
    DB *gorm.DB
}

ThirdPartySvcDiscoveryCfgDaoImpl implements ThirdPartySvcDiscoveryCfgDao

func (*ThirdPartySvcDiscoveryCfgDaoImpl) AddModel Uses

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

AddModel add one record for table 3rd_party_svc_discovery_cfg.

func (*ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID Uses

func (t *ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID(sid string) error

DeleteByServiceID delete discovery config based on service id.

func (*ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID Uses

func (t *ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID(sid string) (*model.ThirdPartySvcDiscoveryCfg, error)

GetByServiceID return third-party service discovery configuration according to service_id.

func (*ThirdPartySvcDiscoveryCfgDaoImpl) UpdateModel Uses

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

UpdateModel blabla

type VersionInfoDaoImpl Uses

type VersionInfoDaoImpl struct {
    DB *gorm.DB
}

VersionInfoDaoImpl VersionInfoDaoImpl

func (*VersionInfoDaoImpl) AddModel Uses

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

AddModel AddModel

func (*VersionInfoDaoImpl) DeleteFailureVersionInfo Uses

func (c *VersionInfoDaoImpl) DeleteFailureVersionInfo(timePoint time.Time, status string, serviceIDs []string) error

DeleteFailureVersionInfo delete failure version

func (*VersionInfoDaoImpl) DeleteVersionByEventID Uses

func (c *VersionInfoDaoImpl) DeleteVersionByEventID(eventID string) error

DeleteVersionByEventID DeleteVersionByEventID

func (*VersionInfoDaoImpl) DeleteVersionByServiceID Uses

func (c *VersionInfoDaoImpl) DeleteVersionByServiceID(serviceID string) error

DeleteVersionByServiceID DeleteVersionByServiceID

func (*VersionInfoDaoImpl) DeleteVersionInfo Uses

func (c *VersionInfoDaoImpl) DeleteVersionInfo(obj *model.VersionInfo) error

DeleteVersionInfo delete version

func (*VersionInfoDaoImpl) GetAllVersionByServiceID Uses

func (c *VersionInfoDaoImpl) GetAllVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)

GetAllVersionByServiceID get all versions by service id, not only successful

func (*VersionInfoDaoImpl) GetLatestScsVersion Uses

func (c *VersionInfoDaoImpl) GetLatestScsVersion(sid string) (*model.VersionInfo, error)

GetLatestScsVersion returns the latest versoin that the final_status is 'success'.

func (*VersionInfoDaoImpl) GetVersionByDeployVersion Uses

func (c *VersionInfoDaoImpl) GetVersionByDeployVersion(version, serviceID string) (*model.VersionInfo, error)

GetVersionByDeployVersion get version by deploy version

func (*VersionInfoDaoImpl) GetVersionByEventID Uses

func (c *VersionInfoDaoImpl) GetVersionByEventID(eventID string) (*model.VersionInfo, error)

GetVersionByEventID get version by event id

func (*VersionInfoDaoImpl) GetVersionByServiceID Uses

func (c *VersionInfoDaoImpl) GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)

GetVersionByServiceID get versions by service id only return success version info

func (*VersionInfoDaoImpl) GetVersionInfo Uses

func (c *VersionInfoDaoImpl) GetVersionInfo(timePoint time.Time, serviceIDs []string) ([]*model.VersionInfo, error)

GetVersionInfo get version info by service ids

func (*VersionInfoDaoImpl) SearchVersionInfo Uses

func (c *VersionInfoDaoImpl) SearchVersionInfo() ([]*model.VersionInfo, error)

SearchVersionInfo query version count >5

func (*VersionInfoDaoImpl) UpdateModel Uses

func (c *VersionInfoDaoImpl) UpdateModel(mo model.Interface) error

UpdateModel UpdateModel

Package dao imports 12 packages (graph) and is imported by 1 packages. Updated 2019-11-22. Refresh now. Tools for package owners.