Documentation ¶
Index ¶
- type AppPublishDaoImpl
- type CodeCheckResultDaoImpl
- type EventDaoImpl
- type EventLogMessageDaoImpl
- func (e *EventLogMessageDaoImpl) AddModel(mo model.Interface) error
- func (e *EventLogMessageDaoImpl) DeleteServiceLog(serviceID string) error
- func (e *EventLogMessageDaoImpl) GetEventLogMessages(eventID string) ([]*model.EventLogMessage, error)
- func (e *EventLogMessageDaoImpl) UpdateModel(mo model.Interface) error
- type K8sDeployReplicationDaoImpl
- func (t *K8sDeployReplicationDaoImpl) AddModel(mo model.Interface) error
- func (t *K8sDeployReplicationDaoImpl) BeachDelete(deletelist []uint) error
- func (t *K8sDeployReplicationDaoImpl) DeleteK8sDeployReplication(replicationID string) error
- func (t *K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByService(serviceID string) error
- func (t *K8sDeployReplicationDaoImpl) DeleteK8sDeployReplicationByServiceAndVersion(serviceID, version string) error
- func (t *K8sDeployReplicationDaoImpl) GetK8sCurrentDeployReplicationByService(serviceID string) (*model.K8sDeployReplication, error)
- func (t *K8sDeployReplicationDaoImpl) GetK8sDeployReplication(replicationID string) (*model.K8sDeployReplication, error)
- func (t *K8sDeployReplicationDaoImpl) GetK8sDeployReplicationByService(serviceID string) ([]*model.K8sDeployReplication, error)
- func (t *K8sDeployReplicationDaoImpl) GetReplications() ([]*model.K8sDeployReplication, error)
- func (t *K8sDeployReplicationDaoImpl) UpdateModel(mo model.Interface) error
- type K8sPodDaoImpl
- func (t *K8sPodDaoImpl) AddModel(mo model.Interface) error
- func (t *K8sPodDaoImpl) DeleteK8sPod(serviceID string) error
- func (t *K8sPodDaoImpl) DeleteK8sPodByName(podName string) error
- func (t *K8sPodDaoImpl) GetPodByReplicationID(replicationID string) ([]*model.K8sPod, error)
- func (t *K8sPodDaoImpl) GetPodByService(serviceID string) ([]*model.K8sPod, error)
- func (t *K8sPodDaoImpl) UpdateModel(mo model.Interface) error
- type K8sServiceDaoImpl
- func (t *K8sServiceDaoImpl) AddModel(mo model.Interface) error
- func (t *K8sServiceDaoImpl) DeleteK8sServiceByName(k8sServiceName string) error
- func (t *K8sServiceDaoImpl) DeleteK8sServiceByReplicationID(replicationID string) error
- func (t *K8sServiceDaoImpl) DeleteK8sServiceByReplicationIDAndPort(replicationID string, port int, isOut bool) error
- func (t *K8sServiceDaoImpl) GetK8sService(serviceID string, containerPort int, isOut bool) (*model.K8sService, error)
- func (t *K8sServiceDaoImpl) GetK8sServiceByReplicationID(replicationID string) (*model.K8sService, error)
- func (t *K8sServiceDaoImpl) GetK8sServiceByReplicationIDAndPort(replicationID string, port int, isOut bool) (*model.K8sService, error)
- func (t *K8sServiceDaoImpl) GetK8sServiceByTenantServiceID(tenantServiceID string) ([]*model.K8sService, error)
- func (t *K8sServiceDaoImpl) UpdateModel(mo model.Interface) error
- type LicenseDaoImpl
- type LocalSchedulerDaoImpl
- type PluginBuildVersionDaoImpl
- func (t *PluginBuildVersionDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByPluginID(pluginID string) error
- func (t *PluginBuildVersionDaoImpl) DeleteBuildVersionByVersionID(versionID string) error
- func (t *PluginBuildVersionDaoImpl) GetBuildVersionByPluginID(pluginID string) ([]*model.TenantPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) GetBuildVersionByVersionID(pluginID, versionID string) (*model.TenantPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) UpdateModel(mo model.Interface) error
- type PluginDaoImpl
- func (t *PluginDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginDaoImpl) DeletePluginByID(id, tenantID string) error
- func (t *PluginDaoImpl) GetPluginByID(id, tenantID string) (*model.TenantPlugin, error)
- func (t *PluginDaoImpl) GetPluginsByTenantID(tenantID string) ([]*model.TenantPlugin, error)
- func (t *PluginDaoImpl) UpdateModel(mo model.Interface) error
- type PluginDefaultENVDaoImpl
- func (t *PluginDefaultENVDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginDefaultENVDaoImpl) DeleteAllDefaultENVByPluginID(pluginID string) error
- func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByName(pluginID, name, versionID string) error
- func (t *PluginDefaultENVDaoImpl) DeleteDefaultENVByPluginIDAndVersionID(pluginID, versionID string) error
- func (t *PluginDefaultENVDaoImpl) GetALLMasterDefultENVs(pluginID string) ([]*model.TenantPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) GetDefaultENVByName(pluginID, name, versionID string) (*model.TenantPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) GetDefaultENVSByPluginID(pluginID, versionID string) ([]*model.TenantPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) GetDefaultEnvWhichCanBeSetByPluginID(pluginID, versionID string) ([]*model.TenantPluginDefaultENV, error)
- func (t *PluginDefaultENVDaoImpl) UpdateModel(mo model.Interface) error
- type PluginVersionEnvDaoImpl
- func (t *PluginVersionEnvDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginVersionEnvDaoImpl) DeleteEnvByEnvName(envName, pluginID, serviceID string) error
- func (t *PluginVersionEnvDaoImpl) DeleteEnvByPluginID(serviceID, pluginID string) error
- func (t *PluginVersionEnvDaoImpl) DeleteEnvByServiceID(serviceID string) error
- func (t *PluginVersionEnvDaoImpl) GetVersionEnvByEnvName(serviceID, pluginID, envName string) (*model.TenantPluginVersionEnv, error)
- func (t *PluginVersionEnvDaoImpl) GetVersionEnvByServiceID(serviceID string, pluginID string) ([]*model.TenantPluginVersionEnv, error)
- func (t *PluginVersionEnvDaoImpl) UpdateModel(mo model.Interface) error
- type RegionAPIClassDaoImpl
- func (t *RegionAPIClassDaoImpl) AddModel(mo model.Interface) error
- func (t *RegionAPIClassDaoImpl) DeletePrefixInClass(apiClass, prefix string) error
- func (t *RegionAPIClassDaoImpl) GetPrefixesByClass(apiClass string) ([]*model.RegionAPIClass, error)
- func (t *RegionAPIClassDaoImpl) UpdateModel(mo model.Interface) error
- type RegionProcotolsDaoImpl
- func (t *RegionProcotolsDaoImpl) AddModel(mo model.Interface) error
- func (t *RegionProcotolsDaoImpl) GetAllSupportProtocol(version string) ([]*model.RegionProcotols, error)
- func (t *RegionProcotolsDaoImpl) GetProtocolGroupByProtocolChild(version, protocolChild string) (*model.RegionProcotols, error)
- func (t *RegionProcotolsDaoImpl) UpdateModel(mo model.Interface) error
- type RegionUserInfoDaoImpl
- func (t *RegionUserInfoDaoImpl) AddModel(mo model.Interface) error
- func (t *RegionUserInfoDaoImpl) GetALLTokenInValidityPeriod() ([]*model.RegionUserInfo, error)
- func (t *RegionUserInfoDaoImpl) GetTokenByEid(eid string) (*model.RegionUserInfo, error)
- func (t *RegionUserInfoDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceLabelDaoImpl
- func (t *ServiceLabelDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceLabelDaoImpl) DELTenantServiceLabelsByLabelvaluesAndServiceID(serviceID string, labelValues []string) error
- func (t *ServiceLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceLabelDaoImpl) GetTenantServiceAffinityLabel(serviceID string) ([]*model.TenantServiceLable, error)
- func (t *ServiceLabelDaoImpl) GetTenantServiceLabel(serviceID string) ([]*model.TenantServiceLable, error)
- func (t *ServiceLabelDaoImpl) GetTenantServiceNodeSelectorLabel(serviceID string) ([]*model.TenantServiceLable, error)
- func (t *ServiceLabelDaoImpl) GetTenantServiceTypeLabel(serviceID string) (*model.TenantServiceLable, error)
- func (t *ServiceLabelDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceProbeDaoImpl
- func (t *ServiceProbeDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceProbeDaoImpl) DELServiceProbesByServiceID(serviceID string) error
- func (t *ServiceProbeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceProbeDaoImpl) GetServiceProbes(serviceID string) ([]*model.ServiceProbe, error)
- func (t *ServiceProbeDaoImpl) GetServiceUsedProbe(serviceID, mode string) (*model.ServiceProbe, error)
- func (t *ServiceProbeDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceStatusDaoImpl
- func (t *ServiceStatusDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceStatusDaoImpl) GetRunningService() ([]*model.TenantServiceStatus, error)
- func (t *ServiceStatusDaoImpl) GetTenantServiceStatus(serviceID string) (*model.TenantServiceStatus, error)
- func (t *ServiceStatusDaoImpl) GetTenantServicesStatus(serviceIDs []string) ([]*model.TenantServiceStatus, error)
- func (t *ServiceStatusDaoImpl) GetTenantStatus(tenantID string) ([]*model.TenantServiceStatus, error)
- func (t *ServiceStatusDaoImpl) SetTenantServiceStatus(serviceID, status string) error
- func (t *ServiceStatusDaoImpl) UpdateModel(mo model.Interface) error
- type TenantDaoImpl
- func (t *TenantDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantDaoImpl) GetALLTenants() ([]*model.Tenants, error)
- func (t *TenantDaoImpl) GetPagedTenants(offset, len int) ([]*model.Tenants, error)
- func (t *TenantDaoImpl) GetTenantByUUID(uuid string) (*model.Tenants, error)
- func (t *TenantDaoImpl) GetTenantIDByName(name string) (*model.Tenants, error)
- func (t *TenantDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServiceEnvVarDaoImpl
- func (t *TenantServiceEnvVarDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServiceEnvVarDaoImpl) DELServiceEnvsByServiceID(serviceID string) error
- func (t *TenantServiceEnvVarDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantServiceEnvVarDaoImpl) GetDependServiceEnvs(serviceIDs []string, scopes []string) ([]*model.TenantServiceEnvVar, error)
- func (t *TenantServiceEnvVarDaoImpl) GetEnv(serviceID, envName string) (*model.TenantServiceEnvVar, error)
- func (t *TenantServiceEnvVarDaoImpl) GetServiceEnvs(serviceID string, scopes []string) ([]*model.TenantServiceEnvVar, error)
- func (t *TenantServiceEnvVarDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServiceLBMappingPortDaoImpl
- func (t *TenantServiceLBMappingPortDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServiceLBMappingPortDaoImpl) CreateTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceID(serviceID string) error
- func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService(serviceID string) (*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServiceMountRelationDaoImpl
- func (t *TenantServiceMountRelationDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServiceMountRelationDaoImpl) DELTenantServiceMountRelationByServiceID(serviceID string) error
- func (t *TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByDepService(serviceID, depServiceID string) error
- func (t *TenantServiceMountRelationDaoImpl) DElTenantServiceMountRelationByServiceAndName(serviceID, name string) error
- func (t *TenantServiceMountRelationDaoImpl) GetTenantServiceMountRelationsByService(serviceID string) ([]*model.TenantServiceMountRelation, error)
- func (t *TenantServiceMountRelationDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServicePluginRelationDaoImpl
- func (t *TenantServicePluginRelationDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServicePluginRelationDaoImpl) CheckSomeModelLikePluginByServiceID(serviceID, pluginModel string) (bool, error)
- func (t *TenantServicePluginRelationDaoImpl) CheckSomeModelPluginByServiceID(serviceID, pluginModel string) (bool, error)
- func (t *TenantServicePluginRelationDaoImpl) DeleteALLRelationByPluginID(pluginID string) error
- func (t *TenantServicePluginRelationDaoImpl) DeleteALLRelationByServiceID(serviceID string) error
- func (t *TenantServicePluginRelationDaoImpl) DeleteRelationByServiceIDAndPluginID(serviceID, pluginID string) error
- func (t *TenantServicePluginRelationDaoImpl) GetALLRelationByServiceID(serviceID string) ([]*model.TenantServicePluginRelation, error)
- func (t *TenantServicePluginRelationDaoImpl) GetRelateionByServiceIDAndPluginID(serviceID, pluginID string) (*model.TenantServicePluginRelation, error)
- func (t *TenantServicePluginRelationDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServiceRelationDaoImpl
- func (t *TenantServiceRelationDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServiceRelationDaoImpl) DELRelationsByServiceID(serviceID string) error
- func (t *TenantServiceRelationDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantServiceRelationDaoImpl) DeleteRelationByDepID(serviceID, depID string) error
- func (t *TenantServiceRelationDaoImpl) GetTenantServiceRelations(serviceID string) ([]*model.TenantServiceRelation, error)
- func (t *TenantServiceRelationDaoImpl) GetTenantServiceRelationsByDependServiceID(dependServiceID string) ([]*model.TenantServiceRelation, error)
- func (t *TenantServiceRelationDaoImpl) HaveRelations(serviceID string) bool
- func (t *TenantServiceRelationDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServiceVolumeDaoImpl
- func (t *TenantServiceVolumeDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServiceVolumeDaoImpl) DeleteByServiceIDAndVolumePath(serviceID string, volumePath string) error
- func (t *TenantServiceVolumeDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantServiceVolumeDaoImpl) DeleteTenantServiceVolumesByServiceID(serviceID string) error
- func (t *TenantServiceVolumeDaoImpl) GetAllVolumes() ([]*model.TenantServiceVolume, error)
- func (t *TenantServiceVolumeDaoImpl) GetTenantServiceVolumesByServiceID(serviceID string) ([]*model.TenantServiceVolume, error)
- func (t *TenantServiceVolumeDaoImpl) GetVolumeByServiceIDAndName(serviceID, name string) (*model.TenantServiceVolume, error)
- func (t *TenantServiceVolumeDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServicesDaoImpl
- func (t *TenantServicesDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServicesDaoImpl) DeleteServiceByServiceID(serviceID string) error
- func (t *TenantServicesDaoImpl) GetAllServices() ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetCPUAndMEM(tenantName []string) ([]map[string]interface{}, error)
- func (t *TenantServicesDaoImpl) GetPagedTenantService(offset, len int) ([]map[string]interface{}, error)
- func (t *TenantServicesDaoImpl) GetServiceAliasByIDs(uids []string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServiceByID(serviceID string) (*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServiceByTenantIDAndServiceAlias(tenantID, serviceName string) (*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServicesAllInfoByTenantID(tenantID string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServicesByTenantID(tenantID string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetTenantServiceRes(uuid string) (map[string]interface{}, error)
- func (t *TenantServicesDaoImpl) SetTenantServiceStatus(serviceID, status string) error
- func (t *TenantServicesDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServicesDeleteImpl
- type TenantServicesPortDaoImpl
- func (t *TenantServicesPortDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServicesPortDaoImpl) DELPortsByServiceID(serviceID string) error
- func (t *TenantServicesPortDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *TenantServicesPortDaoImpl) GetInnerPorts(serviceID string) ([]*model.TenantServicesPort, error)
- func (t *TenantServicesPortDaoImpl) GetOuterPorts(serviceID string) ([]*model.TenantServicesPort, error)
- func (t *TenantServicesPortDaoImpl) GetPort(serviceID string, port int) (*model.TenantServicesPort, error)
- func (t *TenantServicesPortDaoImpl) GetPortsByServiceID(serviceID string) ([]*model.TenantServicesPort, error)
- func (t *TenantServicesPortDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServicesStreamPluginPortDaoImpl
- func (t *TenantServicesStreamPluginPortDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServicesStreamPluginPortDaoImpl) DeleteAllPluginMappingPortByServiceID(serviceID string) error
- func (t *TenantServicesStreamPluginPortDaoImpl) DeletePluginMappingPortByContainerPort(serviceID string, pluginModel string, containerPort int) error
- func (t *TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPortByServiceIDAndContainerPort(serviceID string, pluginModel string, containerPort int) (*model.TenantServicesStreamPluginPort, error)
- func (t *TenantServicesStreamPluginPortDaoImpl) GetPluginMappingPorts(serviceID string, pluginModel string) ([]*model.TenantServicesStreamPluginPort, error)
- func (t *TenantServicesStreamPluginPortDaoImpl) SetPluginMappingPort(tenantID string, serviceID string, pluginModel string, containerPort int) (int, error)
- func (t *TenantServicesStreamPluginPortDaoImpl) UpdateModel(mo model.Interface) error
- type VersionInfoDaoImpl
- func (c *VersionInfoDaoImpl) AddModel(mo model.Interface) error
- func (c *VersionInfoDaoImpl) DeleteVersionByEventID(eventID string) error
- func (c *VersionInfoDaoImpl) GetVersionByDeployVersion(version, serviceID string) (*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) GetVersionByEventID(eventID string) (*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) UpdateModel(mo model.Interface) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppPublishDaoImpl ¶
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 ¶
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 ¶
EventDaoImpl EventLogMessageDaoImpl
func (*EventDaoImpl) AddModel ¶
func (c *EventDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*EventDaoImpl) GetEventByEventID ¶
func (c *EventDaoImpl) GetEventByEventID(eventID string) (*model.ServiceEvent, error)
GetEventByEventID get event log message
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 ¶
EventLogMessageDaoImpl EventLogMessageDaoImpl
func (*EventLogMessageDaoImpl) AddModel ¶
func (e *EventLogMessageDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*EventLogMessageDaoImpl) DeleteServiceLog ¶
func (e *EventLogMessageDaoImpl) DeleteServiceLog(serviceID string) error
DeleteServiceLog TODO:
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 ¶
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
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) GetK8sDeployReplicationByService ¶
func (t *K8sDeployReplicationDaoImpl) GetK8sDeployReplicationByService(serviceID string) ([]*model.K8sDeployReplication, error)
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 ¶
K8sPodDaoImpl k8s pod dao
func (*K8sPodDaoImpl) AddModel ¶
func (t *K8sPodDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用Pod
func (*K8sPodDaoImpl) DeleteK8sPod ¶
func (t *K8sPodDaoImpl) DeleteK8sPod(serviceID string) error
func (*K8sPodDaoImpl) DeleteK8sPodByName ¶
func (t *K8sPodDaoImpl) DeleteK8sPodByName(podName string) error
func (*K8sPodDaoImpl) GetPodByReplicationID ¶
func (t *K8sPodDaoImpl) GetPodByReplicationID(replicationID string) ([]*model.K8sPod, error)
func (*K8sPodDaoImpl) GetPodByService ¶
func (t *K8sPodDaoImpl) GetPodByService(serviceID string) ([]*model.K8sPod, error)
func (*K8sPodDaoImpl) UpdateModel ¶
func (t *K8sPodDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用Pod
type K8sServiceDaoImpl ¶
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) 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) UpdateModel ¶
func (t *K8sServiceDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用Pod
type LicenseDaoImpl ¶
LicenseDaoImpl license model 管理
func (*LicenseDaoImpl) AddModel ¶
func (l *LicenseDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*LicenseDaoImpl) DeleteLicense ¶
func (l *LicenseDaoImpl) DeleteLicense(token string) error
DeleteLicense DeleteLicense
func (*LicenseDaoImpl) ListLicenses ¶
func (l *LicenseDaoImpl) ListLicenses() ([]*model.LicenseInfo, error)
ListLicenses ListLicenses
func (*LicenseDaoImpl) UpdateModel ¶
func (l *LicenseDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel
type LocalSchedulerDaoImpl ¶
LocalSchedulerDaoImpl 本地调度存储mysql实现
func (*LocalSchedulerDaoImpl) AddModel ¶
func (t *LocalSchedulerDaoImpl) AddModel(mo model.Interface) error
AddModel 添加本地调度信息
func (*LocalSchedulerDaoImpl) GetLocalScheduler ¶
func (t *LocalSchedulerDaoImpl) GetLocalScheduler(serviceID string) ([]*model.LocalScheduler, error)
GetLocalScheduler 获取应用本地调度信息
func (*LocalSchedulerDaoImpl) UpdateModel ¶
func (t *LocalSchedulerDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新调度信息
type PluginBuildVersionDaoImpl ¶
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) 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) UpdateModel ¶
func (t *PluginBuildVersionDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新插件默认变量 主体信息一般不变更,仅构建的本地镜像名与status需要变更
type PluginDaoImpl ¶
PluginDaoImpl PluginDaoImpl
func (*PluginDaoImpl) AddModel ¶
func (t *PluginDaoImpl) AddModel(mo model.Interface) error
AddModel 创建插件
func (*PluginDaoImpl) 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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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) UpdateModel ¶
func (t *RegionUserInfoDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新cloud信息
type ServiceLabelDaoImpl ¶
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) 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 ¶
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 ¶
ServiceStatusDaoImpl 更新应用状态
func (*ServiceStatusDaoImpl) AddModel ¶
func (t *ServiceStatusDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用状态
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 ¶
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) GetTenantByUUID ¶
func (t *TenantDaoImpl) GetTenantByUUID(uuid string) (*model.Tenants, error)
GetTenantByUUID 获取租户
func (*TenantDaoImpl) GetTenantIDByName ¶
func (t *TenantDaoImpl) GetTenantIDByName(name string) (*model.Tenants, error)
GetTenantIDByName 获取租户
func (*TenantDaoImpl) UpdateModel ¶
func (t *TenantDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户
type TenantServiceEnvVarDaoImpl ¶
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 ¶
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) 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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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) GetCPUAndMEM ¶
func (t *TenantServicesDaoImpl) GetCPUAndMEM(tenantName []string) ([]map[string]interface{}, error)
GetCPUAndMEM GetCPUAndMEM
func (*TenantServicesDaoImpl) GetPagedTenantService ¶
func (t *TenantServicesDaoImpl) GetPagedTenantService(offset, len int) ([]map[string]interface{}, error)
GetPagedTenantResource 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) 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) GetTenantServiceRes ¶
func (t *TenantServicesDaoImpl) GetTenantServiceRes(uuid string) (map[string]interface{}, error)
GetTenantServiceRes GetTenantServiceRes
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 ¶
TenantServicesDeleteImpl TenantServiceDeleteImpl
func (*TenantServicesDeleteImpl) AddModel ¶
func (t *TenantServicesDeleteImpl) AddModel(mo model.Interface) error
AddModel 添加已删除的应用
func (*TenantServicesDeleteImpl) UpdateModel ¶
func (t *TenantServicesDeleteImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户应用
type TenantServicesPortDaoImpl ¶
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 ¶
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 ¶
EventLogMessageDaoImpl EventLogMessageDaoImpl
func (*VersionInfoDaoImpl) AddModel ¶
func (c *VersionInfoDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*VersionInfoDaoImpl) DeleteVersionByEventID ¶
func (c *VersionInfoDaoImpl) DeleteVersionByEventID(eventID string) error
func (*VersionInfoDaoImpl) GetVersionByDeployVersion ¶
func (c *VersionInfoDaoImpl) GetVersionByDeployVersion(version, serviceID string) (*model.VersionInfo, error)
GetEventLogMessages get event log message
func (*VersionInfoDaoImpl) GetVersionByEventID ¶
func (c *VersionInfoDaoImpl) GetVersionByEventID(eventID string) (*model.VersionInfo, error)
GetEventLogMessages get event log message
func (*VersionInfoDaoImpl) GetVersionByServiceID ¶
func (c *VersionInfoDaoImpl) GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
GetEventLogMessages get event log message
func (*VersionInfoDaoImpl) UpdateModel ¶
func (c *VersionInfoDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel