dao

package
v3.6.1+incompatible Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2018 License: LGPL-3.0 Imports: 10 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 AppDaoImpl 

type AppDaoImpl struct {
	DB *gorm.DB
}

func (*AppDaoImpl) AddModel 

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

func (*AppDaoImpl) DeleteModelByEventId 

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

func (*AppDaoImpl) GetByEventId 

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

func (*AppDaoImpl) UpdateModel 

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

type AppPublishDaoImpl 

type AppPublishDaoImpl struct {
	DB *gorm.DB
}

AppPublishDaoImpl EventLogMessageDaoImpl

func (*AppPublishDaoImpl) AddModel 

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

AddModel AddModel

func (*AppPublishDaoImpl) GetAppPublish 

func (c *AppPublishDaoImpl) GetAppPublish(serviceKey, appVersion string) (*model.AppPublish, error)

GetAppPublish get event log message

func (*AppPublishDaoImpl) UpdateModel 

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

UpdateModel UpdateModel

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

type EventDaoImpl struct {
	DB *gorm.DB
}

EventDaoImpl EventLogMessageDaoImpl

func (*EventDaoImpl) AddModel 

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

AddModel AddModel

func (*EventDaoImpl) DelEventByServiceID 

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

GetEventByServiceID delete event log

func (*EventDaoImpl) GetEventByEventID 

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

GetEventByEventID get event log message

func (*EventDaoImpl) GetEventByEventIDs 

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

GetEventByEventIDs get event info

func (*EventDaoImpl) GetEventByServiceID 

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

GetEventByServiceID get event log message

func (*EventDaoImpl) UpdateModel 

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

UpdateModel UpdateModel

type EventLogMessageDaoImpl 

type EventLogMessageDaoImpl struct {
	DB *gorm.DB
}

EventLogMessageDaoImpl EventLogMessageDaoImpl

func (*EventLogMessageDaoImpl) AddModel 

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

AddModel AddModel

func (*EventLogMessageDaoImpl) DeleteServiceEventLog 

func (e *EventLogMessageDaoImpl) DeleteServiceEventLog(obj *model.EventLogMessage) error

func (*EventLogMessageDaoImpl) DeleteServiceEventLogByEventId 

func (e *EventLogMessageDaoImpl) DeleteServiceEventLogByEventId(eventId string) error

func (*EventLogMessageDaoImpl) DeleteServiceLog 

func (e *EventLogMessageDaoImpl) DeleteServiceLog(serviceID string) error

DeleteServiceLog TODO:

func (*EventLogMessageDaoImpl) GetAllServiceEventLog 

func (e *EventLogMessageDaoImpl) GetAllServiceEventLog() ([]*model.EventLogMessage, error)

func (*EventLogMessageDaoImpl) GetEventLogMessages 

func (e *EventLogMessageDaoImpl) GetEventLogMessages(eventID string) ([]*model.EventLogMessage, error)

GetEventLogMessages get event log message

func (*EventLogMessageDaoImpl) UpdateModel 

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

UpdateModel UpdateModel

type K8sDeployReplicationDaoImpl 

type K8sDeployReplicationDaoImpl struct {
	DB *gorm.DB
}

func (*K8sDeployReplicationDaoImpl) AddModel 

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

AddModel 添加应用Service 一个应用同时只能有一个部署信息

func (*K8sDeployReplicationDaoImpl) BeachDelete 

func (t *K8sDeployReplicationDaoImpl) BeachDelete(deletelist []uint) error

func (*K8sDeployReplicationDaoImpl) DeleteK8sDeployReplication 

func (t *K8sDeployReplicationDaoImpl) DeleteK8sDeployReplication(replicationID string) error

func (*K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByService 

func (t *K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByService(serviceID string) error

DeleteK8sDeployReplicationByService delete deploy info by service

func (*K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByServiceAndMarked 

func (t *K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByServiceAndMarked(serviceID string) error

func (*K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByServiceAndVersion 

func (t *K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByServiceAndVersion(serviceID, version string) error

func (*K8sDeployReplicationDaoImpl) GetK8sCurrentDeployReplicationByService 

func (t *K8sDeployReplicationDaoImpl) GetK8sCurrentDeployReplicationByService(serviceID string) (*model.K8sDeployReplication, error)

GetK8sCurrentDeployReplicationByService 获取应用当前部署信息

func (*K8sDeployReplicationDaoImpl) GetK8sDeployReplication 

func (t *K8sDeployReplicationDaoImpl) GetK8sDeployReplication(replicationID string) (*model.K8sDeployReplication, error)

func (*K8sDeployReplicationDaoImpl) GetK8sDeployReplicationByIsDelete 

func (t *K8sDeployReplicationDaoImpl) GetK8sDeployReplicationByIsDelete(rcType string, isDelete bool) ([]*model.K8sDeployReplication, error)

func (*K8sDeployReplicationDaoImpl) GetK8sDeployReplicationByService 

func (t *K8sDeployReplicationDaoImpl) GetK8sDeployReplicationByService(serviceID string) ([]*model.K8sDeployReplication, error)

func (*K8sDeployReplicationDaoImpl) GetK8sDeployReplicationIsExist 

func (t *K8sDeployReplicationDaoImpl) GetK8sDeployReplicationIsExist(tenantId string, RcType string, RcId string, isDelete bool) (IsExist bool)

func (*K8sDeployReplicationDaoImpl) GetReplications 

func (t *K8sDeployReplicationDaoImpl) GetReplications() ([]*model.K8sDeployReplication, error)

func (*K8sDeployReplicationDaoImpl) UpdateModel 

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

UpdateModel 更新应用Pod

type K8sPodDaoImpl 

type K8sPodDaoImpl struct {
	DB *gorm.DB
}

K8sPodDaoImpl k8s pod dao

func (*K8sPodDaoImpl) AddModel 

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

AddModel save or update app pod info

func (*K8sPodDaoImpl) DeleteK8sPod 

func (t *K8sPodDaoImpl) DeleteK8sPod(serviceID string) error

DeleteK8sPod delete pod by service

func (*K8sPodDaoImpl) DeleteK8sPodByName 

func (t *K8sPodDaoImpl) DeleteK8sPodByName(podName string) error

DeleteK8sPodByName delete pod by name

func (*K8sPodDaoImpl) GetPodByReplicationID 

func (t *K8sPodDaoImpl) GetPodByReplicationID(replicationID string) ([]*model.K8sPod, error)

GetPodByReplicationID get pod by replication

func (*K8sPodDaoImpl) GetPodByService 

func (t *K8sPodDaoImpl) GetPodByService(serviceID string) ([]*model.K8sPod, error)

GetPodByService get pod from serviceids if serviceID support multiple split from ","

func (*K8sPodDaoImpl) UpdateModel 

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

UpdateModel update pod info

type K8sServiceDaoImpl 

type K8sServiceDaoImpl struct {
	DB *gorm.DB
}

func (*K8sServiceDaoImpl) AddModel 

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

AddModel 添加应用Service

func (*K8sServiceDaoImpl) DeleteK8sServiceByName 

func (t *K8sServiceDaoImpl) DeleteK8sServiceByName(k8sServiceName string) error

func (*K8sServiceDaoImpl) DeleteK8sServiceByReplicationID 

func (t *K8sServiceDaoImpl) DeleteK8sServiceByReplicationID(replicationID string) error

func (*K8sServiceDaoImpl) DeleteK8sServiceByReplicationIDAndPort 

func (t *K8sServiceDaoImpl) DeleteK8sServiceByReplicationIDAndPort(replicationID string, port int, isOut bool) error

func (*K8sServiceDaoImpl) GetAllK8sService 

func (t *K8sServiceDaoImpl) GetAllK8sService() ([]*model.K8sService, error)

func (*K8sServiceDaoImpl) GetK8sService 

func (t *K8sServiceDaoImpl) GetK8sService(serviceID string, containerPort int, isOut bool) (*model.K8sService, error)

GetK8sService 获取k8s service

func (*K8sServiceDaoImpl) GetK8sServiceByReplicationID 

func (t *K8sServiceDaoImpl) GetK8sServiceByReplicationID(replicationID string) (*model.K8sService, error)

func (*K8sServiceDaoImpl) GetK8sServiceByReplicationIDAndPort 

func (t *K8sServiceDaoImpl) GetK8sServiceByReplicationIDAndPort(replicationID string, port int, isOut bool) (*model.K8sService, error)

func (*K8sServiceDaoImpl) GetK8sServiceByTenantServiceID 

func (t *K8sServiceDaoImpl) GetK8sServiceByTenantServiceID(tenantServiceID string) ([]*model.K8sService, error)

func (*K8sServiceDaoImpl) K8sServiceIsExist 

func (t *K8sServiceDaoImpl) K8sServiceIsExist(tenantId string, K8sServiceID string) bool

func (*K8sServiceDaoImpl) UpdateModel 

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

UpdateModel 更新应用Pod

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

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

DeleteBuildVersionByPluginID DeleteBuildVersionByPluginID

func (*PluginBuildVersionDaoImpl) DeleteBuildVersionByVersionID 

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

DeleteBuildVersionByVersionID DeleteBuildVersionByVersionID

func (*PluginBuildVersionDaoImpl) GetBuildVersionByDeployVersion 

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

GetBuildVersionByDeployVersion GetBuildVersionByDeployVersion

func (*PluginBuildVersionDaoImpl) GetBuildVersionByPluginID 

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

GetBuildVersionByPluginID GetBuildVersionByPluginID

func (*PluginBuildVersionDaoImpl) GetBuildVersionByVersionID 

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

GetBuildVersionByVersionID GetBuildVersionByVersionID

func (*PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID 

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

GetLastBuildVersionByVersionID get last success build version

func (*PluginBuildVersionDaoImpl) 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) DeletePluginByID 

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

DeletePluginByID DeletePluginByID

func (*PluginDaoImpl) GetPluginByID 

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

GetPluginByID GetPluginByID

func (*PluginDaoImpl) GetPluginsByTenantID 

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

GetPluginsByTenantID GetPluginsByTenantID

func (*PluginDaoImpl) 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.TenantPluginDefaultENV, error)

GetALLMasterDefultENVs GetALLMasterDefultENVs

func (*PluginDefaultENVDaoImpl) GetDefaultENVByName 

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

GetDefaultENVByName GetDefaultENVByName

func (*PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID 

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

GetDefaultENVSByPluginID GetDefaultENVSByPluginID

func (*PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID 

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

GetDefaultEnvWhichCanBeSetByPluginID GetDefaultEnvWhichCanBeSetByPluginID

func (*PluginDefaultENVDaoImpl) UpdateModel 

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

UpdateModel 更新插件默认变量

type PluginVersionEnvDaoImpl 

type PluginVersionEnvDaoImpl struct {
	DB *gorm.DB
}

PluginVersionEnvDaoImpl PluginVersionEnvDaoImpl

func (*PluginVersionEnvDaoImpl) AddModel 

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

AddModel 添加插件默认变量

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

GetVersionEnvByEnvName GetVersionEnvByEnvName

func (*PluginVersionEnvDaoImpl) GetVersionEnvByServiceID 

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

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

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 RegionProcotolsDaoImpl 

type RegionProcotolsDaoImpl struct {
	DB *gorm.DB
}

RegionProcotolsDaoImpl RegionProcotolsDaoImpl

func (*RegionProcotolsDaoImpl) AddModel 

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

AddModel 添加cloud信息

func (*RegionProcotolsDaoImpl) GetAllSupportProtocol 

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

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

func (*RegionProcotolsDaoImpl) GetProtocolGroupByProtocolChild 

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

GetProtocolGroupByProtocolChild 获取协议族名称

func (*RegionProcotolsDaoImpl) UpdateModel 

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

UpdateModel 更新cloud信息

type RegionUserInfoDaoImpl 

type RegionUserInfoDaoImpl struct {
	DB *gorm.DB
}

RegionUserInfoDaoImpl CloudDaoImpl

func (*RegionUserInfoDaoImpl) AddModel 

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

AddModel 添加cloud信息

func (*RegionUserInfoDaoImpl) GetALLTokenInValidityPeriod 

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

GetALLTokenInValidityPeriod GetALLTokenInValidityPeriod

func (*RegionUserInfoDaoImpl) GetTokenByEid 

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

GetTokenByEid GetTokenByEid

func (*RegionUserInfoDaoImpl) GetTokenByTokenID 

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

GetTokenByTokenID GetTokenByTokenID

func (*RegionUserInfoDaoImpl) UpdateModel 

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

UpdateModel 更新cloud信息

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

func (t *ServiceLabelDaoImpl) DELTenantServiceLabelsByLabelvaluesAndServiceID(serviceID string, labelValues []string) error

DELTenantServiceLabelsByLabelvaluesAndServiceID DELTenantServiceLabelsByLabelvaluesAndServiceID

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

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

GetTenantServiceAffinityLabel GetTenantServiceAffinityLabel

func (*ServiceLabelDaoImpl) GetTenantServiceLabel 

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

GetTenantServiceLabel GetTenantServiceLabel

func (*ServiceLabelDaoImpl) GetTenantServiceNodeSelectorLabel 

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

GetTenantServiceNodeSelectorLabel GetTenantServiceNodeSelectorLabel

func (*ServiceLabelDaoImpl) GetTenantServiceTypeLabel 

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

GetTenantServiceTypeLabel GetTenantServiceTypeLabel

func (*ServiceLabelDaoImpl) UpdateModel 

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

UpdateModel 更新应用Label

type ServiceProbeDaoImpl 

type ServiceProbeDaoImpl struct {
	DB *gorm.DB
}

func (*ServiceProbeDaoImpl) AddModel 

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

AddModel 添加应用Probe

func (*ServiceProbeDaoImpl) DELServiceProbesByServiceID 

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

DELServiceProbesByServiceID DELServiceProbesByServiceID

func (*ServiceProbeDaoImpl) DeleteModel 

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

DeleteModel 删除应用探针

func (*ServiceProbeDaoImpl) GetServiceProbes 

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

GetServiceProbes 获取应用探针

func (*ServiceProbeDaoImpl) GetServiceUsedProbe 

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

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

func (*ServiceProbeDaoImpl) UpdateModel 

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

UpdateModel 更新应用Probe

type ServiceStatusDaoImpl 

type ServiceStatusDaoImpl struct {
	DB *gorm.DB
}

ServiceStatusDaoImpl 更新应用状态

func (*ServiceStatusDaoImpl) AddModel 

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

AddModel 添加应用状态

func (*ServiceStatusDaoImpl) DeleteByServiceID 

func (t *ServiceStatusDaoImpl) DeleteByServiceID(serviceID string) error

DeleteByServiceID 状态删除

func (*ServiceStatusDaoImpl) GetAll 

func (t *ServiceStatusDaoImpl) GetAll() ([]*model.TenantServiceStatus, error)

GetAll get all app status

func (*ServiceStatusDaoImpl) GetNeedBillingService 

func (t *ServiceStatusDaoImpl) GetNeedBillingService() ([]*model.TenantServiceStatus, error)

GetNeedBillingService get need billing service status

func (*ServiceStatusDaoImpl) GetRunningService 

func (t *ServiceStatusDaoImpl) GetRunningService() ([]*model.TenantServiceStatus, error)

GetRunningService GetRunningService

func (*ServiceStatusDaoImpl) GetTenantServiceStatus 

func (t *ServiceStatusDaoImpl) GetTenantServiceStatus(serviceID string) (*model.TenantServiceStatus, error)

GetTenantServiceStatus 获取应用状态

func (*ServiceStatusDaoImpl) GetTenantServicesStatus 

func (t *ServiceStatusDaoImpl) GetTenantServicesStatus(serviceIDs []string) ([]*model.TenantServiceStatus, error)

GetTenantServicesStatus GetTenantServicesStatus

func (*ServiceStatusDaoImpl) GetTenantStatus 

func (t *ServiceStatusDaoImpl) GetTenantStatus(tenantID string) ([]*model.TenantServiceStatus, error)

GetTenantStatus GetTenantStatus

func (*ServiceStatusDaoImpl) SetTenantServiceStatus 

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

SetTenantServiceStatus 设置应用状态

func (*ServiceStatusDaoImpl) UpdateModel 

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

UpdateModel 更新应用状态

type TenantDaoImpl 

type TenantDaoImpl struct {
	DB *gorm.DB
}

TenantDaoImpl 租户信息管理

func (*TenantDaoImpl) AddModel 

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

AddModel 添加租户

func (*TenantDaoImpl) GetALLTenants 

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

GetALLTenants GetALLTenants

func (*TenantDaoImpl) GetPagedTenants 

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

GetALLTenants GetALLTenants

func (*TenantDaoImpl) GetTenantByEid 

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

GetTenantsByEid

func (*TenantDaoImpl) GetTenantByUUID 

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

GetTenantByUUID 获取租户

func (*TenantDaoImpl) GetTenantByUUIDIsExist 

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

GetTenantByUUIDIsExist 获取租户

func (*TenantDaoImpl) GetTenantIDByName 

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

GetTenantIDByName 获取租户

func (*TenantDaoImpl) GetTenantIDsByNames 

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

GetTenantIDsByNames get tenant ids by names

func (*TenantDaoImpl) UpdateModel 

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

UpdateModel 更新租户

type TenantServiceEnvVarDaoImpl 

type TenantServiceEnvVarDaoImpl struct {
	DB *gorm.DB
}

TenantServiceEnvVarDaoImpl TenantServiceEnvVarDaoImpl

func (*TenantServiceEnvVarDaoImpl) AddModel 

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

AddModel 添加应用环境变量

func (*TenantServiceEnvVarDaoImpl) DELServiceEnvsByServiceID 

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

DELServiceEnvsByServiceID 通过serviceID 删除envs

func (*TenantServiceEnvVarDaoImpl) DeleteModel 

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

DeleteModel 删除env

func (*TenantServiceEnvVarDaoImpl) GetDependServiceEnvs 

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

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

func (*TenantServiceEnvVarDaoImpl) GetEnv 

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

GetEnv 获取某个环境变量

func (*TenantServiceEnvVarDaoImpl) GetServiceEnvs 

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

GetServiceEnvs 获取服务环境变量

func (*TenantServiceEnvVarDaoImpl) UpdateModel 

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

UpdateModel 更新应用环境变量,只能更新环境变量值

type TenantServiceLBMappingPortDaoImpl 

type TenantServiceLBMappingPortDaoImpl struct {
	DB *gorm.DB
}

TenantServiceLBMappingPortDaoImpl stream服务映射

func (*TenantServiceLBMappingPortDaoImpl) AddModel 

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

AddModel 添加应用端口映射

func (*TenantServiceLBMappingPortDaoImpl) CreateTenantServiceLBMappingPort 

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

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

func (*TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID 

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

DELServiceLBMappingPortByServiceID DELServiceLBMappingPortByServiceID

func (*TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort 

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

DELServiceLBMappingPortByServiceIDAndPort DELServiceLBMappingPortByServiceIDAndPort

func (*TenantServiceLBMappingPortDaoImpl) GetLBPortByTenantAndPort 

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

GetLBPortByTenantAndPort GetLBPortByTenantAndPort

func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort 

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

GetTenantServiceLBMappingPort 获取端口映射

func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService 

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

GetTenantServiceLBMappingPortByService 获取端口映射

func (*TenantServiceLBMappingPortDaoImpl) UpdateModel 

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

UpdateModel 更新应用端口映射

type TenantServiceMountRelationDaoImpl 

type TenantServiceMountRelationDaoImpl struct {
	DB *gorm.DB
}

TenantServiceMountRelationDaoImpl 依赖存储

func (*TenantServiceMountRelationDaoImpl) AddModel 

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

AddModel 添加应用依赖挂载

func (*TenantServiceMountRelationDaoImpl) DELTenantServiceMountRelationByServiceID 

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

DELTenantServiceMountRelationByServiceID DELTenantServiceMountRelationByServiceID

func (*TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByDepService 

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

DElTenantServiceMountRelationByDepService del mount relation

func (*TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByServiceAndName 

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

DElTenantServiceMountRelationByServiceAndName DElTenantServiceMountRelationByServiceAndName

func (*TenantServiceMountRelationDaoImpl) GetTenantServiceMountRelationsByService 

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

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

func (*TenantServiceMountRelationDaoImpl) UpdateModel 

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

UpdateModel 更新应用依赖挂载

type TenantServicePluginRelationDaoImpl 

type TenantServicePluginRelationDaoImpl struct {
	DB *gorm.DB
}

TenantServicePluginRelationDaoImpl TenantServicePluginRelationDaoImpl

func (*TenantServicePluginRelationDaoImpl) AddModel 

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

AddModel 添加插件默认变量

func (*TenantServicePluginRelationDaoImpl) CheckSomeModelLikePluginByServiceID 

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

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

func (*TenantServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID 

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

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

func (*TenantServicePluginRelationDaoImpl) DeleteALLRelationByPluginID 

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

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

func (*TenantServicePluginRelationDaoImpl) DeleteALLRelationByServiceID 

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

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

func (*TenantServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID 

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

DeleteRelationByServiceIDAndPluginID 删除service plugin 对应关系

func (*TenantServicePluginRelationDaoImpl) GetALLRelationByServiceID 

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

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

func (*TenantServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID 

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

GetRelateionByServiceIDAndPluginID GetRelateionByServiceIDAndPluginID

func (*TenantServicePluginRelationDaoImpl) UpdateModel 

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

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

type TenantServiceRelationDaoImpl 

type TenantServiceRelationDaoImpl struct {
	DB *gorm.DB
}

TenantServiceRelationDaoImpl TenantServiceRelationDaoImpl

func (*TenantServiceRelationDaoImpl) AddModel 

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

AddModel 添加应用依赖关系

func (*TenantServiceRelationDaoImpl) DELRelationsByServiceID 

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

DELRelationsByServiceID DELRelationsByServiceID

func (*TenantServiceRelationDaoImpl) DeleteModel 

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

DeleteModel 删除依赖

func (*TenantServiceRelationDaoImpl) DeleteRelationByDepID 

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

DeleteRelationByDepID DeleteRelationByDepID

func (*TenantServiceRelationDaoImpl) GetTenantServiceRelations 

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

GetTenantServiceRelations 获取应用依赖关系

func (*TenantServiceRelationDaoImpl) GetTenantServiceRelationsByDependServiceID 

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

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

func (*TenantServiceRelationDaoImpl) HaveRelations 

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

HaveRelations 是否有依赖

func (*TenantServiceRelationDaoImpl) UpdateModel 

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

UpdateModel 更新应用依赖关系

type TenantServiceVolumeDaoImpl 

type TenantServiceVolumeDaoImpl struct {
	DB *gorm.DB
}

TenantServiceVolumeDaoImpl 应用存储

func (*TenantServiceVolumeDaoImpl) AddModel 

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

AddModel 添加应用挂载

func (*TenantServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath 

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

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

func (*TenantServiceVolumeDaoImpl) DeleteModel 

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

DeleteModel 删除挂载

func (*TenantServiceVolumeDaoImpl) DeleteTenantServiceVolumesByServiceID 

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

DeleteTenantServiceVolumesByServiceID 删除挂载

func (*TenantServiceVolumeDaoImpl) GetAllVolumes 

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

GetAllVolumes 获取全部存储信息

func (*TenantServiceVolumeDaoImpl) GetTenantServiceVolumesByServiceID 

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

GetTenantServiceVolumesByServiceID 获取应用挂载

func (*TenantServiceVolumeDaoImpl) GetVolumeByServiceIDAndName 

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

GetVolumeByServiceIDAndName 获取存储信息

func (*TenantServiceVolumeDaoImpl) UpdateModel 

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

UpdateModel 更��应用挂载

type TenantServicesDaoImpl 

type TenantServicesDaoImpl struct {
	DB *gorm.DB
}

TenantServicesDaoImpl 租户应用dao

func (*TenantServicesDaoImpl) AddModel 

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

AddModel 添加租户应用

func (*TenantServicesDaoImpl) DeleteServiceByServiceID 

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

DeleteServiceByServiceID DeleteServiceByServiceID

func (*TenantServicesDaoImpl) GetAllServices 

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

GetAllServices 获取全部应用信息的资源相关信息

func (*TenantServicesDaoImpl) GetPagedTenantService 

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

GetPagedTenantService GetPagedTenantResource

func (*TenantServicesDaoImpl) GetServiceAliasByIDs 

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

GetServiceAliasByIDs 获取应用别名

func (*TenantServicesDaoImpl) GetServiceByID 

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

GetServiceByID 获取服务通过服务id

func (*TenantServicesDaoImpl) GetServiceByTenantIDAndServiceAlias 

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

GetServiceByTenantIDAndServiceAlias 根据租户名和服务名

func (*TenantServicesDaoImpl) GetServiceMemoryByServiceIDs 

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

GetServiceMemoryByServiceIDs get service memory by service ids

func (*TenantServicesDaoImpl) GetServiceMemoryByTenantIDs 

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

GetServiceMemoryByTenantIDs get service memory by tenant ids

func (*TenantServicesDaoImpl) GetServicesAllInfoByTenantID 

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

GetServicesAllInfoByTenantID GetServicesAllInfoByTenantID

func (*TenantServicesDaoImpl) GetServicesByTenantID 

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

GetServicesByTenantID GetServicesByTenantID

func (*TenantServicesDaoImpl) GetServicesByTenantIDs 

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

GetServicesByTenantIDs GetServicesByTenantIDs

func (*TenantServicesDaoImpl) SetTenantServiceStatus 

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

SetTenantServiceStatus SetTenantServiceStatus

func (*TenantServicesDaoImpl) UpdateModel 

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

UpdateModel 更新租户应用

type TenantServicesDeleteImpl 

type TenantServicesDeleteImpl struct {
	DB *gorm.DB
}

TenantServicesDeleteImpl TenantServiceDeleteImpl

func (*TenantServicesDeleteImpl) AddModel 

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

AddModel 添加已删除的应用

func (*TenantServicesDeleteImpl) DeleteTenantServicesDelete 

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

func (*TenantServicesDeleteImpl) GetTenantServicesDeleteByCreateTime 

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

func (*TenantServicesDeleteImpl) UpdateModel 

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

UpdateModel 更新租户应用

type TenantServicesPortDaoImpl 

type TenantServicesPortDaoImpl struct {
	DB *gorm.DB
}

TenantServicesPortDaoImpl 租户应用端口操作

func (*TenantServicesPortDaoImpl) AddModel 

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

AddModel 添加应用端口

func (*TenantServicesPortDaoImpl) DELPortsByServiceID 

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

DELPortsByServiceID DELPortsByServiceID

func (*TenantServicesPortDaoImpl) DeleteModel 

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

DeleteModel 删除端口

func (*TenantServicesPortDaoImpl) GetInnerPorts 

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

GetInnerPorts 获取对内端口

func (*TenantServicesPortDaoImpl) GetOuterPorts 

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

GetOuterPorts 获取对外端口

func (*TenantServicesPortDaoImpl) GetPort 

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

GetPort get port

func (*TenantServicesPortDaoImpl) GetPortsByServiceID 

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

GetPortsByServiceID 通过服务获取port

func (*TenantServicesPortDaoImpl) UpdateModel 

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

UpdateModel 更新租户

type TenantServicesStreamPluginPortDaoImpl 

type TenantServicesStreamPluginPortDaoImpl struct {
	DB *gorm.DB
}

TenantServicesStreamPluginPortDaoImpl TenantServicesStreamPluginPortDaoImpl

func (*TenantServicesStreamPluginPortDaoImpl) AddModel 

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

AddModel 添加插件端口映射信息

func (*TenantServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID 

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

DeleteAllPluginMappingPortByServiceID DeleteAllPluginMappingPortByServiceID

func (*TenantServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort 

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

DeletePluginMappingPortByContainerPort DeletePluginMappingPortByContainerPort

func (*TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort 

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

GetPluginMappingPortByServiceIDAndContainerPort GetPluginMappingPortByServiceIDAndContainerPort

func (*TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPorts 

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

GetPluginMappingPorts GetPluginMappingPorts 降序排列

func (*TenantServicesStreamPluginPortDaoImpl) SetPluginMappingPort 

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

SetPluginMappingPort SetPluginMappingPort

func (*TenantServicesStreamPluginPortDaoImpl) UpdateModel 

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

UpdateModel 更新插件端口映射信息

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, serviceIdList []string) error

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

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

func (*VersionInfoDaoImpl) GetVersionInfo 

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

func (*VersionInfoDaoImpl) SearchVersionInfo 

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

func (*VersionInfoDaoImpl) UpdateModel 

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

UpdateModel UpdateModel

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.