Documentation
¶
Index ¶
- type AppBackupDaoImpl
- func (a *AppBackupDaoImpl) AddModel(mo model.Interface) error
- func (a *AppBackupDaoImpl) CheckHistory(groupID, version string) bool
- func (a *AppBackupDaoImpl) DeleteAppBackup(backupID string) error
- func (a *AppBackupDaoImpl) GetAppBackup(backupID string) (*model.AppBackup, error)
- func (a *AppBackupDaoImpl) GetAppBackups(groupID string) ([]*model.AppBackup, error)
- func (a *AppBackupDaoImpl) GetDeleteAppBackup(backupID string) (*model.AppBackup, error)
- func (a *AppBackupDaoImpl) GetDeleteAppBackups() ([]*model.AppBackup, error)
- func (a *AppBackupDaoImpl) UpdateModel(mo model.Interface) error
- type AppDaoImpl
- type CertificateDaoImpl
- func (c *CertificateDaoImpl) AddModel(mo model.Interface) error
- func (c *CertificateDaoImpl) AddOrUpdate(mo model.Interface) error
- func (c *CertificateDaoImpl) DeleteCertificateByID(certificateID string) error
- func (c *CertificateDaoImpl) GetCertificateByID(certificateID string) (*model.Certificate, error)
- func (c *CertificateDaoImpl) UpdateModel(mo model.Interface) error
- type CodeCheckResultDaoImpl
- type EndpointDaoImpl
- func (e *EndpointDaoImpl) AddModel(mo model.Interface) error
- func (e *EndpointDaoImpl) DelByUUID(uuid string) error
- func (e *EndpointDaoImpl) DeleteByServiceID(sid string) error
- func (e *EndpointDaoImpl) GetByUUID(uuid string) (*model.Endpoint, error)
- func (e *EndpointDaoImpl) List(sid string) ([]*model.Endpoint, error)
- func (e *EndpointDaoImpl) ListIsOnline(sid string) ([]*model.Endpoint, error)
- func (e *EndpointDaoImpl) UpdateModel(mo model.Interface) error
- type EventDaoImpl
- func (c *EventDaoImpl) AddModel(mo model.Interface) error
- func (c *EventDaoImpl) DelEventByServiceID(serviceID string) error
- func (c *EventDaoImpl) GetEventByEventID(eventID string) (*model.ServiceEvent, error)
- func (c *EventDaoImpl) GetEventByEventIDs(eventIDs []string) ([]*model.ServiceEvent, error)
- func (c *EventDaoImpl) GetEventByServiceID(serviceID string) ([]*model.ServiceEvent, error)
- func (c *EventDaoImpl) UpdateModel(mo model.Interface) error
- type GwRuleConfigDaoImpl
- type HTTPRuleDaoImpl
- func (h *HTTPRuleDaoImpl) AddModel(mo model.Interface) error
- func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByID(id string) error
- func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID(serviceID string) error
- func (h *HTTPRuleDaoImpl) GetHTTPRuleByID(id string) (*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) ListByServiceID(serviceID string) ([]*model.HTTPRule, error)
- func (h *HTTPRuleDaoImpl) UpdateModel(mo model.Interface) error
- type IPPoolImpl
- type IPPortImpl
- func (i *IPPortImpl) AddModel(mo model.Interface) error
- func (i *IPPortImpl) DeleteByIPAndPort(ip string, port int) error
- func (i *IPPortImpl) GetIPByPort(port int) ([]*model.IPPort, error)
- func (i *IPPortImpl) GetIPPortByIPAndPort(ip string, port int) (*model.IPPort, error)
- func (i *IPPortImpl) UpdateModel(mo model.Interface) error
- type LicenseDaoImpl
- type LocalSchedulerDaoImpl
- type NotificationEventDaoImpl
- func (c *NotificationEventDaoImpl) AddModel(mo model.Interface) error
- func (c *NotificationEventDaoImpl) GetNotificationEventByHash(hash string) (*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) GetNotificationEventByKind(kind, kindID string) ([]*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) GetNotificationEventByTime(start, end time.Time) ([]*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) GetNotificationEventNotHandle() ([]*model.NotificationEvent, error)
- func (c *NotificationEventDaoImpl) UpdateModel(mo model.Interface) error
- 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) GetBuildVersionByDeployVersion(pluginID, versionID, deployVersion string) (*model.TenantPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) GetBuildVersionByPluginID(pluginID string) ([]*model.TenantPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) GetBuildVersionByVersionID(pluginID, versionID string) (*model.TenantPluginBuildVersion, error)
- func (t *PluginBuildVersionDaoImpl) GetLastBuildVersionByVersionID(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 PluginVersionConfigDaoImpl
- func (t *PluginVersionConfigDaoImpl) AddModel(mo model.Interface) error
- func (t *PluginVersionConfigDaoImpl) DeletePluginConfig(serviceID, pluginID string) error
- func (t *PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID(serviceID string) error
- func (t *PluginVersionConfigDaoImpl) GetPluginConfig(serviceID, pluginID string) (*model.TenantPluginVersionDiscoverConfig, error)
- func (t *PluginVersionConfigDaoImpl) GetPluginConfigs(serviceID string) ([]*model.TenantPluginVersionDiscoverConfig, error)
- func (t *PluginVersionConfigDaoImpl) 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) GetTokenByTokenID(token string) (*model.RegionUserInfo, error)
- func (t *RegionUserInfoDaoImpl) UpdateModel(mo model.Interface) error
- type RuleExtensionDaoImpl
- func (c *RuleExtensionDaoImpl) AddModel(mo model.Interface) error
- func (c *RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID(ruleID string) error
- func (c *RuleExtensionDaoImpl) GetRuleExtensionByRuleID(ruleID string) ([]*model.RuleExtension, error)
- func (c *RuleExtensionDaoImpl) UpdateModel(model.Interface) error
- type ServiceLabelDaoImpl
- func (t *ServiceLabelDaoImpl) AddModel(mo model.Interface) error
- func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByLabelValuesAndServiceID(serviceID string) error
- func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKey(serviceID string, labelKey string) error
- func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKeyValue(serviceID string, labelKey string, labelValue string) error
- func (t *ServiceLabelDaoImpl) DeleteLabelByServiceID(serviceID string) error
- func (t *ServiceLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
- func (t *ServiceLabelDaoImpl) GetLabelByNodeSelectorKey(serviceID string, labelValue string) (*model.TenantServiceLable, error)
- func (t *ServiceLabelDaoImpl) GetTenantNodeAffinityLabel(serviceID string) (*model.TenantServiceLable, 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.TenantServiceProbe, error)
- func (t *ServiceProbeDaoImpl) GetServiceUsedProbe(serviceID, mode string) (*model.TenantServiceProbe, error)
- func (t *ServiceProbeDaoImpl) UpdateModel(mo model.Interface) error
- type ServiceSourceImpl
- type TCPRuleDaoTmpl
- func (t *TCPRuleDaoTmpl) AddModel(mo model.Interface) error
- func (t *TCPRuleDaoTmpl) DeleteByID(uuid string) error
- func (t *TCPRuleDaoTmpl) DeleteTCPRuleByServiceID(serviceID string) error
- func (t *TCPRuleDaoTmpl) GetTCPRuleByID(id string) (*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceID(sid string) ([]*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) ListByServiceID(serviceID string) ([]*model.TCPRule, error)
- func (t *TCPRuleDaoTmpl) 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) GetTenantByEid(eid string) ([]*model.Tenants, error)
- func (t *TenantDaoImpl) GetTenantByUUID(uuid string) (*model.Tenants, error)
- func (t *TenantDaoImpl) GetTenantByUUIDIsExist(uuid string) bool
- func (t *TenantDaoImpl) GetTenantIDByName(name string) (*model.Tenants, error)
- func (t *TenantDaoImpl) GetTenantIDsByNames(names []string) (re []string, err error)
- func (t *TenantDaoImpl) GetTenantLimitsByNames(names []string) (limit map[string]int, err error)
- func (t *TenantDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServiceConfigFileDaoImpl
- func (t *TenantServiceConfigFileDaoImpl) AddModel(mo model.Interface) error
- func (t *TenantServiceConfigFileDaoImpl) DelByServiceID(sid string) error
- func (t *TenantServiceConfigFileDaoImpl) DelByVolumeID(sid, volumeName string) error
- func (t *TenantServiceConfigFileDaoImpl) GetByVolumeName(sid string, volumeName string) (*model.TenantServiceConfigFile, error)
- func (t *TenantServiceConfigFileDaoImpl) 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) DELServiceLBMappingPortByServiceIDAndPort(serviceID string, lbport int) error
- func (t *TenantServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort(serviceID string, port int) (*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) GetLBPortByTenantAndPort(tenantID string, lbport int) (*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) GetLBPortsASC() ([]*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService(serviceID string) ([]*model.TenantServiceLBMappingPort, error)
- func (t *TenantServiceLBMappingPortDaoImpl) PortExists(port int) bool
- 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) GetVolumeByID(id int) (*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) GetAllServicesID() ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetPagedTenantService(offset, length int, serviceIDs []string) ([]map[string]interface{}, int, error)
- func (t *TenantServicesDaoImpl) GetServiceAliasByIDs(uids []string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServiceByID(serviceID string) (*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServiceByIDs(uids []string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServiceByServiceAlias(serviceAlias string) (*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServiceByTenantIDAndServiceAlias(tenantID, serviceName string) (*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServiceMemoryByServiceIDs(serviceIDs []string) (map[string]map[string]interface{}, error)
- func (t *TenantServicesDaoImpl) GetServiceMemoryByTenantIDs(tenantIDs []string, runningServiceIDs []string) (map[string]map[string]interface{}, error)
- func (t *TenantServicesDaoImpl) GetServicesAllInfoByTenantID(tenantID string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServicesByTenantID(tenantID string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) GetServicesByTenantIDs(tenantIDs []string) ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) ListThirdPartyServices() ([]*model.TenantServices, error)
- func (t *TenantServicesDaoImpl) SetTenantServiceStatus(serviceID, status string) error
- func (t *TenantServicesDaoImpl) UpdateDeployVersion(serviceID, deployversion string) error
- func (t *TenantServicesDaoImpl) UpdateModel(mo model.Interface) error
- type TenantServicesDeleteImpl
- func (t *TenantServicesDeleteImpl) AddModel(mo model.Interface) error
- func (t *TenantServicesDeleteImpl) DeleteTenantServicesDelete(record *model.TenantServicesDelete) error
- func (t *TenantServicesDeleteImpl) GetTenantServicesDeleteByCreateTime(createTime time.Time) ([]*model.TenantServicesDelete, error)
- func (t *TenantServicesDeleteImpl) UpdateModel(mo model.Interface) error
- 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) GetDepUDPPort(serviceID string) ([]*model.TenantServicesPort, error)
- func (t *TenantServicesPortDaoImpl) GetInnerPorts(serviceID string) ([]*model.TenantServicesPort, error)
- func (t *TenantServicesPortDaoImpl) GetOpenedPorts(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) HasOpenPort(sid string) bool
- 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 ThirdPartySvcDiscoveryCfgDaoImpl
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) AddModel(mo model.Interface) error
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID(sid string) error
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID(sid string) (*model.ThirdPartySvcDiscoveryCfg, error)
- func (t *ThirdPartySvcDiscoveryCfgDaoImpl) UpdateModel(mo model.Interface) error
- type VersionInfoDaoImpl
- func (c *VersionInfoDaoImpl) AddModel(mo model.Interface) error
- func (c *VersionInfoDaoImpl) DeleteFailureVersionInfo(timePoint time.Time, status string, serviceIDs []string) error
- func (c *VersionInfoDaoImpl) DeleteVersionByEventID(eventID string) error
- func (c *VersionInfoDaoImpl) DeleteVersionByServiceID(serviceID string) error
- func (c *VersionInfoDaoImpl) DeleteVersionInfo(obj *model.VersionInfo) error
- func (c *VersionInfoDaoImpl) GetAllVersionByServiceID(serviceID string) ([]*model.VersionInfo, 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) GetVersionInfo(timePoint time.Time, serviceIDs []string) ([]*model.VersionInfo, error)
- func (c *VersionInfoDaoImpl) SearchVersionInfo() ([]*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 AppBackupDaoImpl ¶
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 ¶
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 CertificateDaoImpl ¶
CertificateDaoImpl -
func (*CertificateDaoImpl) AddModel ¶
func (c *CertificateDaoImpl) AddModel(mo model.Interface) error
AddModel add model
func (*CertificateDaoImpl) AddOrUpdate ¶
func (c *CertificateDaoImpl) AddOrUpdate(mo model.Interface) error
AddOrUpdate add or update Certificate
func (*CertificateDaoImpl) DeleteCertificateByID ¶
func (c *CertificateDaoImpl) DeleteCertificateByID(certificateID string) error
DeleteCertificateByID delete certificate
func (*CertificateDaoImpl) GetCertificateByID ¶
func (c *CertificateDaoImpl) GetCertificateByID(certificateID string) (*model.Certificate, error)
GetCertificateByID gets a certificate by matching id
func (*CertificateDaoImpl) UpdateModel ¶
func (c *CertificateDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel update Certificate
type CodeCheckResultDaoImpl ¶
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 EndpointDaoImpl ¶
EndpointDaoImpl implements EndpintDao
func (*EndpointDaoImpl) AddModel ¶
func (e *EndpointDaoImpl) AddModel(mo model.Interface) error
AddModel add one record for table 3rd_party_svc_endpoint
func (*EndpointDaoImpl) DelByUUID ¶
func (e *EndpointDaoImpl) DelByUUID(uuid string) error
DelByUUID deletes endpoints matching uuid.
func (*EndpointDaoImpl) DeleteByServiceID ¶
func (e *EndpointDaoImpl) DeleteByServiceID(sid string) error
DeleteByServiceID delete endpoints based on service id.
func (*EndpointDaoImpl) GetByUUID ¶
func (e *EndpointDaoImpl) GetByUUID(uuid string) (*model.Endpoint, error)
GetByUUID returns endpints matching the given uuid.
func (*EndpointDaoImpl) List ¶
func (e *EndpointDaoImpl) List(sid string) ([]*model.Endpoint, error)
List list all endpints matching the given serivce_id(sid).
func (*EndpointDaoImpl) ListIsOnline ¶
func (e *EndpointDaoImpl) ListIsOnline(sid string) ([]*model.Endpoint, error)
ListIsOnline lists *model.Endpoint according to sid, and filter out the ones that are not online.
func (*EndpointDaoImpl) UpdateModel ¶
func (e *EndpointDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel updates one record for table 3rd_party_svc_endpoint
type EventDaoImpl ¶
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 GwRuleConfigDaoImpl ¶
GwRuleConfigDaoImpl is a implementation of GwRuleConfigDao.
func (*GwRuleConfigDaoImpl) AddModel ¶
func (t *GwRuleConfigDaoImpl) AddModel(mo model.Interface) error
AddModel creates a new gateway rule config.
func (*GwRuleConfigDaoImpl) DeleteByRuleID ¶
func (t *GwRuleConfigDaoImpl) DeleteByRuleID(rid string) error
DeleteByRuleID deletes gateway rule configs by rule id.
func (*GwRuleConfigDaoImpl) ListByRuleID ¶
func (t *GwRuleConfigDaoImpl) ListByRuleID(rid string) ([]*model.GwRuleConfig, error)
ListByRuleID lists GwRuleConfig by rule id.
func (*GwRuleConfigDaoImpl) UpdateModel ¶
func (t *GwRuleConfigDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel updates a gateway rule config.
type HTTPRuleDaoImpl ¶
HTTPRuleDaoImpl http rule
func (*HTTPRuleDaoImpl) AddModel ¶
func (h *HTTPRuleDaoImpl) AddModel(mo model.Interface) error
AddModel -
func (*HTTPRuleDaoImpl) DeleteHTTPRuleByID ¶
func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByID(id string) error
DeleteHTTPRuleByID delete http rule by rule id
func (*HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID ¶
func (h *HTTPRuleDaoImpl) DeleteHTTPRuleByServiceID(serviceID string) error
DeleteHTTPRuleByServiceID delete http rule by service id
func (*HTTPRuleDaoImpl) GetHTTPRuleByID ¶
func (h *HTTPRuleDaoImpl) GetHTTPRuleByID(id string) (*model.HTTPRule, error)
GetHTTPRuleByID gets a HTTPRule based on uuid
func (*HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort ¶
func (h *HTTPRuleDaoImpl) GetHTTPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.HTTPRule, error)
GetHTTPRuleByServiceIDAndContainerPort gets a HTTPRule based on serviceID and containerPort
func (*HTTPRuleDaoImpl) ListByServiceID ¶
func (h *HTTPRuleDaoImpl) ListByServiceID(serviceID string) ([]*model.HTTPRule, error)
ListByServiceID lists all HTTPRules matching serviceID
func (*HTTPRuleDaoImpl) UpdateModel ¶
func (h *HTTPRuleDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel -
type IPPoolImpl ¶
IPPoolImpl is an implementation of dao.IPPoolDao
func (*IPPoolImpl) AddModel ¶
func (i *IPPoolImpl) AddModel(mo model.Interface) error
AddModel adds model.IPPool
func (*IPPoolImpl) GetIPPoolByEID ¶
func (i *IPPoolImpl) GetIPPoolByEID(eid string) (*model.IPPool, error)
GetIPPoolByEID returns model.IPPool that matches eid.
func (*IPPoolImpl) UpdateModel ¶
func (i *IPPoolImpl) UpdateModel(mo model.Interface) error
UpdateModel updates model.IPPool
type IPPortImpl ¶
IPPortImpl is an implementation of dao.IPPortDao
func (*IPPortImpl) AddModel ¶
func (i *IPPortImpl) AddModel(mo model.Interface) error
AddModel adds model.IPPort
func (*IPPortImpl) DeleteByIPAndPort ¶
func (i *IPPortImpl) DeleteByIPAndPort(ip string, port int) error
DeleteByIPAndPort deletes an IPPort that matches ip and port
func (*IPPortImpl) GetIPByPort ¶
func (i *IPPortImpl) GetIPByPort(port int) ([]*model.IPPort, error)
GetIPByPort returns an array of ip by port
func (*IPPortImpl) GetIPPortByIPAndPort ¶
GetIPPortByIPAndPort returns an IPPort that matches ip and port
func (*IPPortImpl) UpdateModel ¶
func (i *IPPortImpl) UpdateModel(mo model.Interface) error
UpdateModel updates model.IPPort
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 NotificationEventDaoImpl ¶
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 ¶
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 ¶
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 PluginVersionConfigDaoImpl ¶
PluginVersionConfigDaoImpl PluginVersionEnvDaoImpl
func (*PluginVersionConfigDaoImpl) AddModel ¶
func (t *PluginVersionConfigDaoImpl) AddModel(mo model.Interface) error
AddModel add or update service plugin config
func (*PluginVersionConfigDaoImpl) DeletePluginConfig ¶
func (t *PluginVersionConfigDaoImpl) DeletePluginConfig(serviceID, pluginID string) error
DeletePluginConfig delete service plugin config
func (*PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID ¶
func (t *PluginVersionConfigDaoImpl) DeletePluginConfigByServiceID(serviceID string) error
DeletePluginConfigByServiceID Batch delete config by service id
func (*PluginVersionConfigDaoImpl) GetPluginConfig ¶
func (t *PluginVersionConfigDaoImpl) GetPluginConfig(serviceID, pluginID string) (*model.TenantPluginVersionDiscoverConfig, error)
GetPluginConfig get service plugin config
func (*PluginVersionConfigDaoImpl) GetPluginConfigs ¶
func (t *PluginVersionConfigDaoImpl) GetPluginConfigs(serviceID string) ([]*model.TenantPluginVersionDiscoverConfig, error)
GetPluginConfigs get plugin configs
func (*PluginVersionConfigDaoImpl) UpdateModel ¶
func (t *PluginVersionConfigDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel update service plugin config
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) 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 RuleExtensionDaoImpl ¶
RuleExtensionDaoImpl rule extension dao
func (*RuleExtensionDaoImpl) AddModel ¶
func (c *RuleExtensionDaoImpl) AddModel(mo model.Interface) error
AddModel add
func (*RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID ¶
func (c *RuleExtensionDaoImpl) DeleteRuleExtensionByRuleID(ruleID string) error
DeleteRuleExtensionByRuleID delete rule extensions by ruleID
func (*RuleExtensionDaoImpl) GetRuleExtensionByRuleID ¶
func (c *RuleExtensionDaoImpl) GetRuleExtensionByRuleID(ruleID string) ([]*model.RuleExtension, error)
GetRuleExtensionByRuleID get extension by rule
func (*RuleExtensionDaoImpl) UpdateModel ¶
func (c *RuleExtensionDaoImpl) UpdateModel(model.Interface) error
UpdateModel update model,do not impl
type ServiceLabelDaoImpl ¶
ServiceLabelDaoImpl ServiceLabelDaoImpl
func (*ServiceLabelDaoImpl) AddModel ¶
func (t *ServiceLabelDaoImpl) AddModel(mo model.Interface) error
AddModel 添加应用Label
func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByLabelValuesAndServiceID ¶
func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByLabelValuesAndServiceID(serviceID string) error
DELTenantServiceLabelsByLabelvaluesAndServiceID DELTenantServiceLabelsByLabelvaluesAndServiceID
func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKey ¶
func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKey(serviceID string, labelKey string) error
DelTenantServiceLabelsByServiceIDKey deletes labels by serviceID and labelKey
func (*ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKeyValue ¶
func (t *ServiceLabelDaoImpl) DelTenantServiceLabelsByServiceIDKeyValue(serviceID string, labelKey string, labelValue string) error
DelTenantServiceLabels deletes labels
func (*ServiceLabelDaoImpl) DeleteLabelByServiceID ¶
func (t *ServiceLabelDaoImpl) DeleteLabelByServiceID(serviceID string) error
DeleteLabelByServiceID 删除应用全部label
func (*ServiceLabelDaoImpl) DeleteModel ¶
func (t *ServiceLabelDaoImpl) DeleteModel(serviceID string, args ...interface{}) error
DeleteModel 删除应用label
func (*ServiceLabelDaoImpl) GetLabelByNodeSelectorKey ¶
func (t *ServiceLabelDaoImpl) GetLabelByNodeSelectorKey(serviceID string, labelValue string) (*model.TenantServiceLable, error)
GetLabelByNodeSelectorKey returns a label by node-selector and label_value
func (*ServiceLabelDaoImpl) GetTenantNodeAffinityLabel ¶
func (t *ServiceLabelDaoImpl) GetTenantNodeAffinityLabel(serviceID string) (*model.TenantServiceLable, error)
GetTenantNodeAffinityLabel returns TenantServiceLable matching serviceID and LabelKeyNodeAffinity
func (*ServiceLabelDaoImpl) GetTenantServiceAffinityLabel ¶
func (t *ServiceLabelDaoImpl) GetTenantServiceAffinityLabel(serviceID string) ([]*model.TenantServiceLable, error)
GetTenantServiceAffinityLabel GetTenantServiceAffinityLabel
func (*ServiceLabelDaoImpl) GetTenantServiceLabel ¶
func (t *ServiceLabelDaoImpl) GetTenantServiceLabel(serviceID string) ([]*model.TenantServiceLable, error)
GetTenantServiceLabel GetTenantServiceLabel
func (*ServiceLabelDaoImpl) GetTenantServiceNodeSelectorLabel ¶
func (t *ServiceLabelDaoImpl) GetTenantServiceNodeSelectorLabel(serviceID string) ([]*model.TenantServiceLable, error)
GetTenantServiceNodeSelectorLabel GetTenantServiceNodeSelectorLabel
func (*ServiceLabelDaoImpl) GetTenantServiceTypeLabel ¶
func (t *ServiceLabelDaoImpl) GetTenantServiceTypeLabel(serviceID string) (*model.TenantServiceLable, error)
GetTenantServiceTypeLabel GetTenantServiceTypeLabel
func (*ServiceLabelDaoImpl) UpdateModel ¶
func (t *ServiceLabelDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用Label
type ServiceProbeDaoImpl ¶
ServiceProbeDaoImpl probe dao impl
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.TenantServiceProbe, error)
GetServiceProbes 获取应用探针
func (*ServiceProbeDaoImpl) GetServiceUsedProbe ¶
func (t *ServiceProbeDaoImpl) GetServiceUsedProbe(serviceID, mode string) (*model.TenantServiceProbe, error)
GetServiceUsedProbe 获取指定模式的可用探针定义
func (*ServiceProbeDaoImpl) UpdateModel ¶
func (t *ServiceProbeDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用Probe
type ServiceSourceImpl ¶
ServiceSourceImpl service source
func (*ServiceSourceImpl) AddModel ¶
func (t *ServiceSourceImpl) AddModel(mo model.Interface) error
AddModel add service source
func (*ServiceSourceImpl) GetServiceSource ¶
func (t *ServiceSourceImpl) GetServiceSource(serviceID string) ([]*model.ServiceSourceConfig, error)
GetServiceSource get services source
func (*ServiceSourceImpl) UpdateModel ¶
func (t *ServiceSourceImpl) UpdateModel(mo model.Interface) error
UpdateModel update service source
type TCPRuleDaoTmpl ¶
TCPRuleDaoTmpl is a implementation of TcpRuleDao
func (*TCPRuleDaoTmpl) AddModel ¶
func (t *TCPRuleDaoTmpl) AddModel(mo model.Interface) error
AddModel adds model.TCPRule
func (*TCPRuleDaoTmpl) DeleteByID ¶
func (t *TCPRuleDaoTmpl) DeleteByID(uuid string) error
DeleteByID deletes model.TCPRule
func (*TCPRuleDaoTmpl) DeleteTCPRuleByServiceID ¶
func (t *TCPRuleDaoTmpl) DeleteTCPRuleByServiceID(serviceID string) error
DeleteTCPRuleByServiceID deletes model.TCPRule
func (*TCPRuleDaoTmpl) GetTCPRuleByID ¶
func (t *TCPRuleDaoTmpl) GetTCPRuleByID(id string) (*model.TCPRule, error)
GetTCPRuleByID gets a TCPRule based on tcpRuleID
func (*TCPRuleDaoTmpl) GetTCPRuleByServiceID ¶
func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceID(sid string) ([]*model.TCPRule, error)
GetTCPRuleByServiceID gets a TCPRules based on service id.
func (*TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort ¶
func (t *TCPRuleDaoTmpl) GetTCPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.TCPRule, error)
GetTCPRuleByServiceIDAndContainerPort gets a TCPRule based on serviceID and containerPort
func (*TCPRuleDaoTmpl) ListByServiceID ¶
func (t *TCPRuleDaoTmpl) ListByServiceID(serviceID string) ([]*model.TCPRule, error)
ListByServiceID lists all TCPRules matching serviceID
func (*TCPRuleDaoTmpl) UpdateModel ¶
func (t *TCPRuleDaoTmpl) UpdateModel(mo model.Interface) error
UpdateModel updates model.TCPRule
type 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) 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) GetTenantLimitsByNames ¶
func (t *TenantDaoImpl) GetTenantLimitsByNames(names []string) (limit map[string]int, err error)
GetTenantLimitsByNames get tenants memory limit
func (*TenantDaoImpl) UpdateModel ¶
func (t *TenantDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户
type TenantServiceConfigFileDaoImpl ¶
TenantServiceConfigFileDaoImpl is a implementation of TenantServiceConfigFileDao
func (*TenantServiceConfigFileDaoImpl) AddModel ¶
func (t *TenantServiceConfigFileDaoImpl) AddModel(mo model.Interface) error
func (*TenantServiceConfigFileDaoImpl) DelByServiceID ¶
func (t *TenantServiceConfigFileDaoImpl) DelByServiceID(sid string) error
DelByServiceID deletes config files according to service id.
func (*TenantServiceConfigFileDaoImpl) DelByVolumeID ¶
func (t *TenantServiceConfigFileDaoImpl) DelByVolumeID(sid, volumeName string) error
DelByVolumeID deletes config files according to service id and volume id.
func (*TenantServiceConfigFileDaoImpl) GetByVolumeName ¶
func (t *TenantServiceConfigFileDaoImpl) GetByVolumeName(sid string, volumeName string) (*model.TenantServiceConfigFile, error)
GetByVolumeName get config file by volume name
func (*TenantServiceConfigFileDaoImpl) UpdateModel ¶
func (t *TenantServiceConfigFileDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel updates config file
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) DELServiceLBMappingPortByServiceIDAndPort ¶
func (t *TenantServiceLBMappingPortDaoImpl) DELServiceLBMappingPortByServiceIDAndPort(serviceID string, lbport int) error
DELServiceLBMappingPortByServiceIDAndPort DELServiceLBMappingPortByServiceIDAndPort
func (*TenantServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort ¶
func (t *TenantServiceLBMappingPortDaoImpl) GetLBMappingPortByServiceIDAndPort(serviceID string, port int) (*model.TenantServiceLBMappingPort, error)
GetLBMappingPortByServiceIDAndPort returns a LBMappingPort by serviceID and port
func (*TenantServiceLBMappingPortDaoImpl) GetLBPortByTenantAndPort ¶
func (t *TenantServiceLBMappingPortDaoImpl) GetLBPortByTenantAndPort(tenantID string, lbport int) (*model.TenantServiceLBMappingPort, error)
GetLBPortByTenantAndPort GetLBPortByTenantAndPort
func (*TenantServiceLBMappingPortDaoImpl) GetLBPortsASC ¶
func (t *TenantServiceLBMappingPortDaoImpl) GetLBPortsASC() ([]*model.TenantServiceLBMappingPort, error)
GetLBPortsASC gets all LBMappingPorts ascending
func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort ¶
func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)
GetTenantServiceLBMappingPort 获取端口映射
func (*TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService ¶
func (t *TenantServiceLBMappingPortDaoImpl) GetTenantServiceLBMappingPortByService(serviceID string) ([]*model.TenantServiceLBMappingPort, error)
GetTenantServiceLBMappingPortByService 获取端口映射
func (*TenantServiceLBMappingPortDaoImpl) PortExists ¶
func (t *TenantServiceLBMappingPortDaoImpl) PortExists(port int) bool
PortExists checks if the port exists
func (*TenantServiceLBMappingPortDaoImpl) UpdateModel ¶
func (t *TenantServiceLBMappingPortDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新应用端口映射
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) GetVolumeByID ¶
func (t *TenantServiceVolumeDaoImpl) GetVolumeByID(id int) (*model.TenantServiceVolume, error)
GetVolumeByID get volume by id
func (*TenantServiceVolumeDaoImpl) GetVolumeByServiceIDAndName ¶
func (t *TenantServiceVolumeDaoImpl) GetVolumeByServiceIDAndName(serviceID, name string) (*model.TenantServiceVolume, error)
GetVolumeByServiceIDAndName 获取存储信息
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) GetAllServicesID ¶
func (t *TenantServicesDaoImpl) GetAllServicesID() ([]*model.TenantServices, error)
GetAllServicesID get all service sample info
func (*TenantServicesDaoImpl) GetPagedTenantService ¶
func (t *TenantServicesDaoImpl) GetPagedTenantService(offset, length int, serviceIDs []string) ([]map[string]interface{}, int, error)
GetPagedTenantService GetPagedTenantResource
func (*TenantServicesDaoImpl) GetServiceAliasByIDs ¶
func (t *TenantServicesDaoImpl) GetServiceAliasByIDs(uids []string) ([]*model.TenantServices, error)
GetServiceAliasByIDs 获取应用别名
func (*TenantServicesDaoImpl) GetServiceByID ¶
func (t *TenantServicesDaoImpl) GetServiceByID(serviceID string) (*model.TenantServices, error)
GetServiceByID 获取服务通过服务id
func (*TenantServicesDaoImpl) GetServiceByIDs ¶
func (t *TenantServicesDaoImpl) GetServiceByIDs(uids []string) ([]*model.TenantServices, error)
GetServiceByIDs get some service by service ids
func (*TenantServicesDaoImpl) GetServiceByServiceAlias ¶
func (t *TenantServicesDaoImpl) GetServiceByServiceAlias(serviceAlias string) (*model.TenantServices, error)
GetServiceByID 获取服务通过服务别名
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) ListThirdPartyServices ¶
func (t *TenantServicesDaoImpl) ListThirdPartyServices() ([]*model.TenantServices, error)
ListThirdPartyService lists all third party services
func (*TenantServicesDaoImpl) SetTenantServiceStatus ¶
func (t *TenantServicesDaoImpl) SetTenantServiceStatus(serviceID, status string) error
SetTenantServiceStatus SetTenantServiceStatus
func (*TenantServicesDaoImpl) UpdateDeployVersion ¶
func (t *TenantServicesDaoImpl) UpdateDeployVersion(serviceID, deployversion string) error
UpdateDeployVersion update service current deploy version
func (*TenantServicesDaoImpl) UpdateModel ¶
func (t *TenantServicesDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel 更新租户应用
type TenantServicesDeleteImpl ¶
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 ¶
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) GetDepUDPPort ¶
func (t *TenantServicesPortDaoImpl) GetDepUDPPort(serviceID string) ([]*model.TenantServicesPort, error)
GetDepUDPPort get all depend service udp port
func (*TenantServicesPortDaoImpl) GetInnerPorts ¶
func (t *TenantServicesPortDaoImpl) GetInnerPorts(serviceID string) ([]*model.TenantServicesPort, error)
GetInnerPorts 获取对内端口
func (*TenantServicesPortDaoImpl) GetOpenedPorts ¶
func (t *TenantServicesPortDaoImpl) GetOpenedPorts(serviceID string) ([]*model.TenantServicesPort, error)
GetEnablePort returns opened ports.
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) HasOpenPort ¶
func (t *TenantServicesPortDaoImpl) HasOpenPort(sid string) bool
HasOpenPort checks if the given service(according to sid) has open 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 ThirdPartySvcDiscoveryCfgDaoImpl ¶
ThirdPartySvcDiscoveryCfgDaoImpl implements ThirdPartySvcDiscoveryCfgDao
func (*ThirdPartySvcDiscoveryCfgDaoImpl) AddModel ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) AddModel(mo model.Interface) error
AddModel add one record for table 3rd_party_svc_discovery_cfg.
func (*ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) DeleteByServiceID(sid string) error
DeleteByServiceID delete discovery config based on service id.
func (*ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) GetByServiceID(sid string) (*model.ThirdPartySvcDiscoveryCfg, error)
GetByServiceID return third-party service discovery configuration according to service_id.
func (*ThirdPartySvcDiscoveryCfgDaoImpl) UpdateModel ¶
func (t *ThirdPartySvcDiscoveryCfgDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel blabla
type VersionInfoDaoImpl ¶
VersionInfoDaoImpl VersionInfoDaoImpl
func (*VersionInfoDaoImpl) AddModel ¶
func (c *VersionInfoDaoImpl) AddModel(mo model.Interface) error
AddModel AddModel
func (*VersionInfoDaoImpl) DeleteFailureVersionInfo ¶
func (c *VersionInfoDaoImpl) DeleteFailureVersionInfo(timePoint time.Time, status string, serviceIDs []string) error
DeleteFailureVersionInfo delete failure version
func (*VersionInfoDaoImpl) DeleteVersionByEventID ¶
func (c *VersionInfoDaoImpl) DeleteVersionByEventID(eventID string) error
DeleteVersionByEventID DeleteVersionByEventID
func (*VersionInfoDaoImpl) DeleteVersionByServiceID ¶
func (c *VersionInfoDaoImpl) DeleteVersionByServiceID(serviceID string) error
DeleteVersionByServiceID DeleteVersionByServiceID
func (*VersionInfoDaoImpl) DeleteVersionInfo ¶
func (c *VersionInfoDaoImpl) DeleteVersionInfo(obj *model.VersionInfo) error
DeleteVersionInfo delete version
func (*VersionInfoDaoImpl) GetAllVersionByServiceID ¶
func (c *VersionInfoDaoImpl) GetAllVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
GetAllVersionByServiceID get all versions by service id, not only successful
func (*VersionInfoDaoImpl) GetVersionByDeployVersion ¶
func (c *VersionInfoDaoImpl) GetVersionByDeployVersion(version, serviceID string) (*model.VersionInfo, error)
GetVersionByDeployVersion get version by deploy version
func (*VersionInfoDaoImpl) GetVersionByEventID ¶
func (c *VersionInfoDaoImpl) GetVersionByEventID(eventID string) (*model.VersionInfo, error)
GetVersionByEventID get version by event id
func (*VersionInfoDaoImpl) GetVersionByServiceID ¶
func (c *VersionInfoDaoImpl) GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
GetVersionByServiceID get versions by service id only return success version info
func (*VersionInfoDaoImpl) GetVersionInfo ¶
func (c *VersionInfoDaoImpl) GetVersionInfo(timePoint time.Time, serviceIDs []string) ([]*model.VersionInfo, error)
GetVersionInfo get version info by service ids
func (*VersionInfoDaoImpl) SearchVersionInfo ¶
func (c *VersionInfoDaoImpl) SearchVersionInfo() ([]*model.VersionInfo, error)
SearchVersionInfo query version count >5
func (*VersionInfoDaoImpl) UpdateModel ¶
func (c *VersionInfoDaoImpl) UpdateModel(mo model.Interface) error
UpdateModel UpdateModel