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

package dao

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

Index

Package Files

dao.go dao_mock.go

Variables

var (
    // VolumeNotFound volume not found error, happens when haven't find any matched data
    VolumeNotFound = errors.New("Volume not found.")
)

type AppBackupDao Uses

type AppBackupDao interface {
    Dao
    CheckHistory(groupID, version string) bool
    GetAppBackups(groupID string) ([]*model.AppBackup, error)
    DeleteAppBackup(backupID string) error
    GetAppBackup(backupID string) (*model.AppBackup, error)
    GetDeleteAppBackup(backupID string) (*model.AppBackup, error)
    GetDeleteAppBackups() ([]*model.AppBackup, error)
}

AppBackupDao group app backup history

type AppDao Uses

type AppDao interface {
    Dao
    GetByEventId(eventID string) (*model.AppStatus, error)
    DeleteModelByEventId(eventID string) error
}

AppDao tenant dao

type CertificateDao Uses

type CertificateDao interface {
    Dao
    AddOrUpdate(mo model.Interface) error
    GetCertificateByID(certificateID string) (*model.Certificate, error)
    DeleteCertificateByID(certificateID string) error
}

CertificateDao -

type CodeCheckResultDao Uses

type CodeCheckResultDao interface {
    Dao
    GetCodeCheckResult(serviceID string) (*model.CodeCheckResult, error)
}

CodeCheckResultDao CodeCheckResultDao

type Dao Uses

type Dao interface {
    AddModel(model.Interface) error
    UpdateModel(model.Interface) error
}

Dao 数据持久化层接口

type DelDao Uses

type DelDao interface {
    DeleteModel(serviceID string, arg ...interface{}) error
}

DelDao 删除接口

type EndpointsDao Uses

type EndpointsDao interface {
    Dao
    GetByUUID(uuid string) (*model.Endpoint, error)
    DelByUUID(uuid string) error
    List(sid string) ([]*model.Endpoint, error)
    ListIsOnline(sid string) ([]*model.Endpoint, error)
    DeleteByServiceID(sid string) error
}

EndpointsDao is an interface for defining method for operating table 3rd_party_svc_endpoints.

type EventDao Uses

type EventDao interface {
    Dao
    GetEventByEventID(eventID string) (*model.ServiceEvent, error)
    GetEventByEventIDs(eventIDs []string) ([]*model.ServiceEvent, error)
    GetEventByServiceID(serviceID string) ([]*model.ServiceEvent, error)
    DelEventByServiceID(serviceID string) error
}

EventDao EventDao

type GwRuleConfigDao Uses

type GwRuleConfigDao interface {
    Dao
    DeleteByRuleID(rid string) error
    ListByRuleID(rid string) ([]*model.GwRuleConfig, error)
}

GwRuleConfigDao is the interface that wraps the required methods to execute curd for table gateway_rule_config.

type HTTPRuleDao Uses

type HTTPRuleDao interface {
    Dao
    GetHTTPRuleByID(id string) (*model.HTTPRule, error)
    GetHTTPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.HTTPRule, error)
    DeleteHTTPRuleByID(id string) error
    DeleteHTTPRuleByServiceID(serviceID string) error
    ListByServiceID(serviceID string) ([]*model.HTTPRule, error)
}

HTTPRuleDao -

type IPPoolDao Uses

type IPPoolDao interface {
    Dao
    GetIPPoolByEID(eid string) (*model.IPPool, error)
}

IPPoolDao ip pool dao interface

type IPPortDao Uses

type IPPortDao interface {
    Dao
    DeleteByIPAndPort(ip string, port int) error
    GetIPByPort(port int) ([]*model.IPPort, error)
    GetIPPortByIPAndPort(ip string, port int) (*model.IPPort, error)
}

IPPortDao -

type LicenseDao Uses

type LicenseDao interface {
    Dao
    //DeleteLicense(token string) error
    ListLicenses() ([]*model.LicenseInfo, error)
}

LicenseDao LicenseDao

type LocalSchedulerDao Uses

type LocalSchedulerDao interface {
    Dao
    GetLocalScheduler(serviceID string) ([]*model.LocalScheduler, error)
}

LocalSchedulerDao 本地调度信息

type MockAppBackupDao Uses

type MockAppBackupDao struct {
    // contains filtered or unexported fields
}

Mock of AppBackupDao interface

func NewMockAppBackupDao Uses

func NewMockAppBackupDao(ctrl *gomock.Controller) *MockAppBackupDao

func (*MockAppBackupDao) AddModel Uses

func (_m *MockAppBackupDao) AddModel(_param0 model.Interface) error

func (*MockAppBackupDao) CheckHistory Uses

func (_m *MockAppBackupDao) CheckHistory(groupID string, version string) bool

func (*MockAppBackupDao) DeleteAppBackup Uses

func (_m *MockAppBackupDao) DeleteAppBackup(backupID string) error

func (*MockAppBackupDao) EXPECT Uses

func (_m *MockAppBackupDao) EXPECT() *_MockAppBackupDaoRecorder

func (*MockAppBackupDao) GetAppBackup Uses

func (_m *MockAppBackupDao) GetAppBackup(backupID string) (*model.AppBackup, error)

func (*MockAppBackupDao) GetAppBackups Uses

func (_m *MockAppBackupDao) GetAppBackups(groupID string) ([]*model.AppBackup, error)

func (*MockAppBackupDao) GetDeleteAppBackup Uses

func (_m *MockAppBackupDao) GetDeleteAppBackup(backupID string) (*model.AppBackup, error)

func (*MockAppBackupDao) GetDeleteAppBackups Uses

func (_m *MockAppBackupDao) GetDeleteAppBackups() ([]*model.AppBackup, error)

func (*MockAppBackupDao) UpdateModel Uses

func (_m *MockAppBackupDao) UpdateModel(_param0 model.Interface) error

type MockAppDao Uses

type MockAppDao struct {
    // contains filtered or unexported fields
}

Mock of AppDao interface

func NewMockAppDao Uses

func NewMockAppDao(ctrl *gomock.Controller) *MockAppDao

func (*MockAppDao) AddModel Uses

func (_m *MockAppDao) AddModel(_param0 model.Interface) error

func (*MockAppDao) DeleteModelByEventId Uses

func (_m *MockAppDao) DeleteModelByEventId(eventID string) error

func (*MockAppDao) EXPECT Uses

func (_m *MockAppDao) EXPECT() *_MockAppDaoRecorder

func (*MockAppDao) GetByEventId Uses

func (_m *MockAppDao) GetByEventId(eventID string) (*model.AppStatus, error)

func (*MockAppDao) UpdateModel Uses

func (_m *MockAppDao) UpdateModel(_param0 model.Interface) error

type MockCertificateDao Uses

type MockCertificateDao struct {
    // contains filtered or unexported fields
}

Mock of CertificateDao interface

func NewMockCertificateDao Uses

func NewMockCertificateDao(ctrl *gomock.Controller) *MockCertificateDao

func (*MockCertificateDao) AddModel Uses

func (_m *MockCertificateDao) AddModel(_param0 model.Interface) error

func (*MockCertificateDao) AddOrUpdate Uses

func (_m *MockCertificateDao) AddOrUpdate(mo model.Interface) error

func (*MockCertificateDao) DeleteCertificateByID Uses

func (_m *MockCertificateDao) DeleteCertificateByID(certificateID string) error

func (*MockCertificateDao) EXPECT Uses

func (_m *MockCertificateDao) EXPECT() *_MockCertificateDaoRecorder

func (*MockCertificateDao) GetCertificateByID Uses

func (_m *MockCertificateDao) GetCertificateByID(certificateID string) (*model.Certificate, error)

func (*MockCertificateDao) UpdateModel Uses

func (_m *MockCertificateDao) UpdateModel(_param0 model.Interface) error

type MockCodeCheckResultDao Uses

type MockCodeCheckResultDao struct {
    // contains filtered or unexported fields
}

Mock of CodeCheckResultDao interface

func NewMockCodeCheckResultDao Uses

func NewMockCodeCheckResultDao(ctrl *gomock.Controller) *MockCodeCheckResultDao

func (*MockCodeCheckResultDao) AddModel Uses

func (_m *MockCodeCheckResultDao) AddModel(_param0 model.Interface) error

func (*MockCodeCheckResultDao) EXPECT Uses

func (_m *MockCodeCheckResultDao) EXPECT() *_MockCodeCheckResultDaoRecorder

func (*MockCodeCheckResultDao) GetCodeCheckResult Uses

func (_m *MockCodeCheckResultDao) GetCodeCheckResult(serviceID string) (*model.CodeCheckResult, error)

func (*MockCodeCheckResultDao) UpdateModel Uses

func (_m *MockCodeCheckResultDao) UpdateModel(_param0 model.Interface) error

type MockDao Uses

type MockDao struct {
    // contains filtered or unexported fields
}

Mock of Dao interface

func NewMockDao Uses

func NewMockDao(ctrl *gomock.Controller) *MockDao

func (*MockDao) AddModel Uses

func (_m *MockDao) AddModel(_param0 model.Interface) error

func (*MockDao) EXPECT Uses

func (_m *MockDao) EXPECT() *_MockDaoRecorder

func (*MockDao) UpdateModel Uses

func (_m *MockDao) UpdateModel(_param0 model.Interface) error

type MockDelDao Uses

type MockDelDao struct {
    // contains filtered or unexported fields
}

Mock of DelDao interface

func NewMockDelDao Uses

func NewMockDelDao(ctrl *gomock.Controller) *MockDelDao

func (*MockDelDao) DeleteModel Uses

func (_m *MockDelDao) DeleteModel(serviceID string, arg ...interface{}) error

func (*MockDelDao) EXPECT Uses

func (_m *MockDelDao) EXPECT() *_MockDelDaoRecorder

type MockEndpointsDao Uses

type MockEndpointsDao struct {
    // contains filtered or unexported fields
}

Mock of EndpointsDao interface

func NewMockEndpointsDao Uses

func NewMockEndpointsDao(ctrl *gomock.Controller) *MockEndpointsDao

func (*MockEndpointsDao) AddModel Uses

func (_m *MockEndpointsDao) AddModel(_param0 model.Interface) error

func (*MockEndpointsDao) DelByUUID Uses

func (_m *MockEndpointsDao) DelByUUID(uuid string) error

func (*MockEndpointsDao) DeleteByServiceID Uses

func (_m *MockEndpointsDao) DeleteByServiceID(sid string) error

func (*MockEndpointsDao) EXPECT Uses

func (_m *MockEndpointsDao) EXPECT() *_MockEndpointsDaoRecorder

func (*MockEndpointsDao) GetByUUID Uses

func (_m *MockEndpointsDao) GetByUUID(uuid string) (*model.Endpoint, error)

func (*MockEndpointsDao) List Uses

func (_m *MockEndpointsDao) List(sid string) ([]*model.Endpoint, error)

func (*MockEndpointsDao) ListIsOnline Uses

func (_m *MockEndpointsDao) ListIsOnline(sid string) ([]*model.Endpoint, error)

func (*MockEndpointsDao) UpdateModel Uses

func (_m *MockEndpointsDao) UpdateModel(_param0 model.Interface) error

type MockEventDao Uses

type MockEventDao struct {
    // contains filtered or unexported fields
}

Mock of EventDao interface

func NewMockEventDao Uses

func NewMockEventDao(ctrl *gomock.Controller) *MockEventDao

func (*MockEventDao) AddModel Uses

func (_m *MockEventDao) AddModel(_param0 model.Interface) error

func (*MockEventDao) DelEventByServiceID Uses

func (_m *MockEventDao) DelEventByServiceID(serviceID string) error

func (*MockEventDao) EXPECT Uses

func (_m *MockEventDao) EXPECT() *_MockEventDaoRecorder

func (*MockEventDao) GetEventByEventID Uses

func (_m *MockEventDao) GetEventByEventID(eventID string) (*model.ServiceEvent, error)

func (*MockEventDao) GetEventByEventIDs Uses

func (_m *MockEventDao) GetEventByEventIDs(eventIDs []string) ([]*model.ServiceEvent, error)

func (*MockEventDao) GetEventByServiceID Uses

func (_m *MockEventDao) GetEventByServiceID(serviceID string) ([]*model.ServiceEvent, error)

func (*MockEventDao) UpdateModel Uses

func (_m *MockEventDao) UpdateModel(_param0 model.Interface) error

type MockGwRuleConfigDao Uses

type MockGwRuleConfigDao struct {
    // contains filtered or unexported fields
}

Mock of GwRuleConfigDao interface

func NewMockGwRuleConfigDao Uses

func NewMockGwRuleConfigDao(ctrl *gomock.Controller) *MockGwRuleConfigDao

func (*MockGwRuleConfigDao) AddModel Uses

func (_m *MockGwRuleConfigDao) AddModel(_param0 model.Interface) error

func (*MockGwRuleConfigDao) DeleteByRuleID Uses

func (_m *MockGwRuleConfigDao) DeleteByRuleID(rid string) error

func (*MockGwRuleConfigDao) EXPECT Uses

func (_m *MockGwRuleConfigDao) EXPECT() *_MockGwRuleConfigDaoRecorder

func (*MockGwRuleConfigDao) ListByRuleID Uses

func (_m *MockGwRuleConfigDao) ListByRuleID(rid string) ([]*model.GwRuleConfig, error)

func (*MockGwRuleConfigDao) UpdateModel Uses

func (_m *MockGwRuleConfigDao) UpdateModel(_param0 model.Interface) error

type MockHTTPRuleDao Uses

type MockHTTPRuleDao struct {
    // contains filtered or unexported fields
}

Mock of HTTPRuleDao interface

func NewMockHTTPRuleDao Uses

func NewMockHTTPRuleDao(ctrl *gomock.Controller) *MockHTTPRuleDao

func (*MockHTTPRuleDao) AddModel Uses

func (_m *MockHTTPRuleDao) AddModel(_param0 model.Interface) error

func (*MockHTTPRuleDao) DeleteHTTPRuleByID Uses

func (_m *MockHTTPRuleDao) DeleteHTTPRuleByID(id string) error

func (*MockHTTPRuleDao) DeleteHTTPRuleByServiceID Uses

func (_m *MockHTTPRuleDao) DeleteHTTPRuleByServiceID(serviceID string) error

func (*MockHTTPRuleDao) EXPECT Uses

func (_m *MockHTTPRuleDao) EXPECT() *_MockHTTPRuleDaoRecorder

func (*MockHTTPRuleDao) GetHTTPRuleByID Uses

func (_m *MockHTTPRuleDao) GetHTTPRuleByID(id string) (*model.HTTPRule, error)

func (*MockHTTPRuleDao) GetHTTPRuleByServiceIDAndContainerPort Uses

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

func (*MockHTTPRuleDao) ListByServiceID Uses

func (_m *MockHTTPRuleDao) ListByServiceID(serviceID string) ([]*model.HTTPRule, error)

func (*MockHTTPRuleDao) UpdateModel Uses

func (_m *MockHTTPRuleDao) UpdateModel(_param0 model.Interface) error

type MockIPPoolDao Uses

type MockIPPoolDao struct {
    // contains filtered or unexported fields
}

Mock of IPPoolDao interface

func NewMockIPPoolDao Uses

func NewMockIPPoolDao(ctrl *gomock.Controller) *MockIPPoolDao

func (*MockIPPoolDao) AddModel Uses

func (_m *MockIPPoolDao) AddModel(_param0 model.Interface) error

func (*MockIPPoolDao) EXPECT Uses

func (_m *MockIPPoolDao) EXPECT() *_MockIPPoolDaoRecorder

func (*MockIPPoolDao) GetIPPoolByEID Uses

func (_m *MockIPPoolDao) GetIPPoolByEID(eid string) (*model.IPPool, error)

func (*MockIPPoolDao) UpdateModel Uses

func (_m *MockIPPoolDao) UpdateModel(_param0 model.Interface) error

type MockIPPortDao Uses

type MockIPPortDao struct {
    // contains filtered or unexported fields
}

Mock of IPPortDao interface

func NewMockIPPortDao Uses

func NewMockIPPortDao(ctrl *gomock.Controller) *MockIPPortDao

func (*MockIPPortDao) AddModel Uses

func (_m *MockIPPortDao) AddModel(_param0 model.Interface) error

func (*MockIPPortDao) DeleteByIPAndPort Uses

func (_m *MockIPPortDao) DeleteByIPAndPort(ip string, port int) error

func (*MockIPPortDao) EXPECT Uses

func (_m *MockIPPortDao) EXPECT() *_MockIPPortDaoRecorder

func (*MockIPPortDao) GetIPByPort Uses

func (_m *MockIPPortDao) GetIPByPort(port int) ([]*model.IPPort, error)

func (*MockIPPortDao) GetIPPortByIPAndPort Uses

func (_m *MockIPPortDao) GetIPPortByIPAndPort(ip string, port int) (*model.IPPort, error)

func (*MockIPPortDao) UpdateModel Uses

func (_m *MockIPPortDao) UpdateModel(_param0 model.Interface) error

type MockLicenseDao Uses

type MockLicenseDao struct {
    // contains filtered or unexported fields
}

Mock of LicenseDao interface

func NewMockLicenseDao Uses

func NewMockLicenseDao(ctrl *gomock.Controller) *MockLicenseDao

func (*MockLicenseDao) AddModel Uses

func (_m *MockLicenseDao) AddModel(_param0 model.Interface) error

func (*MockLicenseDao) EXPECT Uses

func (_m *MockLicenseDao) EXPECT() *_MockLicenseDaoRecorder

func (*MockLicenseDao) ListLicenses Uses

func (_m *MockLicenseDao) ListLicenses() ([]*model.LicenseInfo, error)

func (*MockLicenseDao) UpdateModel Uses

func (_m *MockLicenseDao) UpdateModel(_param0 model.Interface) error

type MockLocalSchedulerDao Uses

type MockLocalSchedulerDao struct {
    // contains filtered or unexported fields
}

Mock of LocalSchedulerDao interface

func NewMockLocalSchedulerDao Uses

func NewMockLocalSchedulerDao(ctrl *gomock.Controller) *MockLocalSchedulerDao

func (*MockLocalSchedulerDao) AddModel Uses

func (_m *MockLocalSchedulerDao) AddModel(_param0 model.Interface) error

func (*MockLocalSchedulerDao) EXPECT Uses

func (_m *MockLocalSchedulerDao) EXPECT() *_MockLocalSchedulerDaoRecorder

func (*MockLocalSchedulerDao) GetLocalScheduler Uses

func (_m *MockLocalSchedulerDao) GetLocalScheduler(serviceID string) ([]*model.LocalScheduler, error)

func (*MockLocalSchedulerDao) UpdateModel Uses

func (_m *MockLocalSchedulerDao) UpdateModel(_param0 model.Interface) error

type MockNotificationEventDao Uses

type MockNotificationEventDao struct {
    // contains filtered or unexported fields
}

Mock of NotificationEventDao interface

func NewMockNotificationEventDao Uses

func NewMockNotificationEventDao(ctrl *gomock.Controller) *MockNotificationEventDao

func (*MockNotificationEventDao) AddModel Uses

func (_m *MockNotificationEventDao) AddModel(_param0 model.Interface) error

func (*MockNotificationEventDao) EXPECT Uses

func (_m *MockNotificationEventDao) EXPECT() *_MockNotificationEventDaoRecorder

func (*MockNotificationEventDao) GetNotificationEventByHash Uses

func (_m *MockNotificationEventDao) GetNotificationEventByHash(hash string) (*model.NotificationEvent, error)

func (*MockNotificationEventDao) GetNotificationEventByKind Uses

func (_m *MockNotificationEventDao) GetNotificationEventByKind(kind string, kindID string) ([]*model.NotificationEvent, error)

func (*MockNotificationEventDao) GetNotificationEventByTime Uses

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

func (*MockNotificationEventDao) GetNotificationEventNotHandle Uses

func (_m *MockNotificationEventDao) GetNotificationEventNotHandle() ([]*model.NotificationEvent, error)

func (*MockNotificationEventDao) UpdateModel Uses

func (_m *MockNotificationEventDao) UpdateModel(_param0 model.Interface) error

type MockRegionAPIClassDao Uses

type MockRegionAPIClassDao struct {
    // contains filtered or unexported fields
}

Mock of RegionAPIClassDao interface

func NewMockRegionAPIClassDao Uses

func NewMockRegionAPIClassDao(ctrl *gomock.Controller) *MockRegionAPIClassDao

func (*MockRegionAPIClassDao) AddModel Uses

func (_m *MockRegionAPIClassDao) AddModel(_param0 model.Interface) error

func (*MockRegionAPIClassDao) DeletePrefixInClass Uses

func (_m *MockRegionAPIClassDao) DeletePrefixInClass(apiClass string, prefix string) error

func (*MockRegionAPIClassDao) EXPECT Uses

func (_m *MockRegionAPIClassDao) EXPECT() *_MockRegionAPIClassDaoRecorder

func (*MockRegionAPIClassDao) GetPrefixesByClass Uses

func (_m *MockRegionAPIClassDao) GetPrefixesByClass(apiClass string) ([]*model.RegionAPIClass, error)

func (*MockRegionAPIClassDao) UpdateModel Uses

func (_m *MockRegionAPIClassDao) UpdateModel(_param0 model.Interface) error

type MockRegionProcotolsDao Uses

type MockRegionProcotolsDao struct {
    // contains filtered or unexported fields
}

Mock of RegionProcotolsDao interface

func NewMockRegionProcotolsDao Uses

func NewMockRegionProcotolsDao(ctrl *gomock.Controller) *MockRegionProcotolsDao

func (*MockRegionProcotolsDao) AddModel Uses

func (_m *MockRegionProcotolsDao) AddModel(_param0 model.Interface) error

func (*MockRegionProcotolsDao) EXPECT Uses

func (_m *MockRegionProcotolsDao) EXPECT() *_MockRegionProcotolsDaoRecorder

func (*MockRegionProcotolsDao) GetAllSupportProtocol Uses

func (_m *MockRegionProcotolsDao) GetAllSupportProtocol(version string) ([]*model.RegionProcotols, error)

func (*MockRegionProcotolsDao) GetProtocolGroupByProtocolChild Uses

func (_m *MockRegionProcotolsDao) GetProtocolGroupByProtocolChild(version string, protocolChild string) (*model.RegionProcotols, error)

func (*MockRegionProcotolsDao) UpdateModel Uses

func (_m *MockRegionProcotolsDao) UpdateModel(_param0 model.Interface) error

type MockRegionUserInfoDao Uses

type MockRegionUserInfoDao struct {
    // contains filtered or unexported fields
}

Mock of RegionUserInfoDao interface

func NewMockRegionUserInfoDao Uses

func NewMockRegionUserInfoDao(ctrl *gomock.Controller) *MockRegionUserInfoDao

func (*MockRegionUserInfoDao) AddModel Uses

func (_m *MockRegionUserInfoDao) AddModel(_param0 model.Interface) error

func (*MockRegionUserInfoDao) EXPECT Uses

func (_m *MockRegionUserInfoDao) EXPECT() *_MockRegionUserInfoDaoRecorder

func (*MockRegionUserInfoDao) GetALLTokenInValidityPeriod Uses

func (_m *MockRegionUserInfoDao) GetALLTokenInValidityPeriod() ([]*model.RegionUserInfo, error)

func (*MockRegionUserInfoDao) GetTokenByEid Uses

func (_m *MockRegionUserInfoDao) GetTokenByEid(eid string) (*model.RegionUserInfo, error)

func (*MockRegionUserInfoDao) GetTokenByTokenID Uses

func (_m *MockRegionUserInfoDao) GetTokenByTokenID(token string) (*model.RegionUserInfo, error)

func (*MockRegionUserInfoDao) UpdateModel Uses

func (_m *MockRegionUserInfoDao) UpdateModel(_param0 model.Interface) error

type MockRuleExtensionDao Uses

type MockRuleExtensionDao struct {
    // contains filtered or unexported fields
}

Mock of RuleExtensionDao interface

func NewMockRuleExtensionDao Uses

func NewMockRuleExtensionDao(ctrl *gomock.Controller) *MockRuleExtensionDao

func (*MockRuleExtensionDao) AddModel Uses

func (_m *MockRuleExtensionDao) AddModel(_param0 model.Interface) error

func (*MockRuleExtensionDao) DeleteRuleExtensionByRuleID Uses

func (_m *MockRuleExtensionDao) DeleteRuleExtensionByRuleID(ruleID string) error

func (*MockRuleExtensionDao) EXPECT Uses

func (_m *MockRuleExtensionDao) EXPECT() *_MockRuleExtensionDaoRecorder

func (*MockRuleExtensionDao) GetRuleExtensionByRuleID Uses

func (_m *MockRuleExtensionDao) GetRuleExtensionByRuleID(ruleID string) ([]*model.RuleExtension, error)

func (*MockRuleExtensionDao) UpdateModel Uses

func (_m *MockRuleExtensionDao) UpdateModel(_param0 model.Interface) error

type MockServiceProbeDao Uses

type MockServiceProbeDao struct {
    // contains filtered or unexported fields
}

Mock of ServiceProbeDao interface

func NewMockServiceProbeDao Uses

func NewMockServiceProbeDao(ctrl *gomock.Controller) *MockServiceProbeDao

func (*MockServiceProbeDao) AddModel Uses

func (_m *MockServiceProbeDao) AddModel(_param0 model.Interface) error

func (*MockServiceProbeDao) DELServiceProbesByServiceID Uses

func (_m *MockServiceProbeDao) DELServiceProbesByServiceID(serviceID string) error

func (*MockServiceProbeDao) DelByServiceID Uses

func (_m *MockServiceProbeDao) DelByServiceID(sid string) error

func (*MockServiceProbeDao) DeleteModel Uses

func (_m *MockServiceProbeDao) DeleteModel(serviceID string, arg ...interface{}) error

func (*MockServiceProbeDao) EXPECT Uses

func (_m *MockServiceProbeDao) EXPECT() *_MockServiceProbeDaoRecorder

func (*MockServiceProbeDao) GetServiceProbes Uses

func (_m *MockServiceProbeDao) GetServiceProbes(serviceID string) ([]*model.TenantServiceProbe, error)

func (*MockServiceProbeDao) GetServiceUsedProbe Uses

func (_m *MockServiceProbeDao) GetServiceUsedProbe(serviceID string, mode string) (*model.TenantServiceProbe, error)

func (*MockServiceProbeDao) UpdateModel Uses

func (_m *MockServiceProbeDao) UpdateModel(_param0 model.Interface) error

type MockServiceSourceDao Uses

type MockServiceSourceDao struct {
    // contains filtered or unexported fields
}

Mock of ServiceSourceDao interface

func NewMockServiceSourceDao Uses

func NewMockServiceSourceDao(ctrl *gomock.Controller) *MockServiceSourceDao

func (*MockServiceSourceDao) AddModel Uses

func (_m *MockServiceSourceDao) AddModel(_param0 model.Interface) error

func (*MockServiceSourceDao) EXPECT Uses

func (_m *MockServiceSourceDao) EXPECT() *_MockServiceSourceDaoRecorder

func (*MockServiceSourceDao) GetServiceSource Uses

func (_m *MockServiceSourceDao) GetServiceSource(serviceID string) ([]*model.ServiceSourceConfig, error)

func (*MockServiceSourceDao) UpdateModel Uses

func (_m *MockServiceSourceDao) UpdateModel(_param0 model.Interface) error

type MockTCPRuleDao Uses

type MockTCPRuleDao struct {
    // contains filtered or unexported fields
}

Mock of TCPRuleDao interface

func NewMockTCPRuleDao Uses

func NewMockTCPRuleDao(ctrl *gomock.Controller) *MockTCPRuleDao

func (*MockTCPRuleDao) AddModel Uses

func (_m *MockTCPRuleDao) AddModel(_param0 model.Interface) error

func (*MockTCPRuleDao) DeleteByID Uses

func (_m *MockTCPRuleDao) DeleteByID(uuid string) error

func (*MockTCPRuleDao) DeleteTCPRuleByServiceID Uses

func (_m *MockTCPRuleDao) DeleteTCPRuleByServiceID(serviceID string) error

func (*MockTCPRuleDao) EXPECT Uses

func (_m *MockTCPRuleDao) EXPECT() *_MockTCPRuleDaoRecorder

func (*MockTCPRuleDao) GetTCPRuleByID Uses

func (_m *MockTCPRuleDao) GetTCPRuleByID(id string) (*model.TCPRule, error)

func (*MockTCPRuleDao) GetTCPRuleByServiceID Uses

func (_m *MockTCPRuleDao) GetTCPRuleByServiceID(sid string) ([]*model.TCPRule, error)

func (*MockTCPRuleDao) GetTCPRuleByServiceIDAndContainerPort Uses

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

func (*MockTCPRuleDao) ListByServiceID Uses

func (_m *MockTCPRuleDao) ListByServiceID(serviceID string) ([]*model.TCPRule, error)

func (*MockTCPRuleDao) UpdateModel Uses

func (_m *MockTCPRuleDao) UpdateModel(_param0 model.Interface) error

type MockTenantDao Uses

type MockTenantDao struct {
    // contains filtered or unexported fields
}

Mock of TenantDao interface

func NewMockTenantDao Uses

func NewMockTenantDao(ctrl *gomock.Controller) *MockTenantDao

func (*MockTenantDao) AddModel Uses

func (_m *MockTenantDao) AddModel(_param0 model.Interface) error

func (*MockTenantDao) EXPECT Uses

func (_m *MockTenantDao) EXPECT() *_MockTenantDaoRecorder

func (*MockTenantDao) GetALLTenants Uses

func (_m *MockTenantDao) GetALLTenants() ([]*model.Tenants, error)

func (*MockTenantDao) GetPagedTenants Uses

func (_m *MockTenantDao) GetPagedTenants(offset int, len int) ([]*model.Tenants, error)

func (*MockTenantDao) GetTenantByEid Uses

func (_m *MockTenantDao) GetTenantByEid(eid string) ([]*model.Tenants, error)

func (*MockTenantDao) GetTenantByUUID Uses

func (_m *MockTenantDao) GetTenantByUUID(uuid string) (*model.Tenants, error)

func (*MockTenantDao) GetTenantByUUIDIsExist Uses

func (_m *MockTenantDao) GetTenantByUUIDIsExist(uuid string) bool

func (*MockTenantDao) GetTenantIDByName Uses

func (_m *MockTenantDao) GetTenantIDByName(tenantName string) (*model.Tenants, error)

func (*MockTenantDao) GetTenantIDsByNames Uses

func (_m *MockTenantDao) GetTenantIDsByNames(names []string) ([]string, error)

func (*MockTenantDao) GetTenantLimitsByNames Uses

func (_m *MockTenantDao) GetTenantLimitsByNames(names []string) (map[string]int, error)

func (*MockTenantDao) UpdateModel Uses

func (_m *MockTenantDao) UpdateModel(_param0 model.Interface) error

type MockTenantPluginBuildVersionDao Uses

type MockTenantPluginBuildVersionDao struct {
    // contains filtered or unexported fields
}

Mock of TenantPluginBuildVersionDao interface

func NewMockTenantPluginBuildVersionDao Uses

func NewMockTenantPluginBuildVersionDao(ctrl *gomock.Controller) *MockTenantPluginBuildVersionDao

func (*MockTenantPluginBuildVersionDao) AddModel Uses

func (_m *MockTenantPluginBuildVersionDao) AddModel(_param0 model.Interface) error

func (*MockTenantPluginBuildVersionDao) DeleteBuildVersionByPluginID Uses

func (_m *MockTenantPluginBuildVersionDao) DeleteBuildVersionByPluginID(pluginID string) error

func (*MockTenantPluginBuildVersionDao) DeleteBuildVersionByVersionID Uses

func (_m *MockTenantPluginBuildVersionDao) DeleteBuildVersionByVersionID(versionID string) error

func (*MockTenantPluginBuildVersionDao) EXPECT Uses

func (_m *MockTenantPluginBuildVersionDao) EXPECT() *_MockTenantPluginBuildVersionDaoRecorder

func (*MockTenantPluginBuildVersionDao) GetBuildVersionByDeployVersion Uses

func (_m *MockTenantPluginBuildVersionDao) GetBuildVersionByDeployVersion(pluginID string, versionID string, deployVersion string) (*model.TenantPluginBuildVersion, error)

func (*MockTenantPluginBuildVersionDao) GetBuildVersionByPluginID Uses

func (_m *MockTenantPluginBuildVersionDao) GetBuildVersionByPluginID(pluginID string) ([]*model.TenantPluginBuildVersion, error)

func (*MockTenantPluginBuildVersionDao) GetBuildVersionByVersionID Uses

func (_m *MockTenantPluginBuildVersionDao) GetBuildVersionByVersionID(pluginID string, versionID string) (*model.TenantPluginBuildVersion, error)

func (*MockTenantPluginBuildVersionDao) GetLastBuildVersionByVersionID Uses

func (_m *MockTenantPluginBuildVersionDao) GetLastBuildVersionByVersionID(pluginID string, versionID string) (*model.TenantPluginBuildVersion, error)

func (*MockTenantPluginBuildVersionDao) UpdateModel Uses

func (_m *MockTenantPluginBuildVersionDao) UpdateModel(_param0 model.Interface) error

type MockTenantPluginDao Uses

type MockTenantPluginDao struct {
    // contains filtered or unexported fields
}

Mock of TenantPluginDao interface

func NewMockTenantPluginDao Uses

func NewMockTenantPluginDao(ctrl *gomock.Controller) *MockTenantPluginDao

func (*MockTenantPluginDao) AddModel Uses

func (_m *MockTenantPluginDao) AddModel(_param0 model.Interface) error

func (*MockTenantPluginDao) DeletePluginByID Uses

func (_m *MockTenantPluginDao) DeletePluginByID(pluginID string, tenantID string) error

func (*MockTenantPluginDao) EXPECT Uses

func (_m *MockTenantPluginDao) EXPECT() *_MockTenantPluginDaoRecorder

func (*MockTenantPluginDao) GetPluginByID Uses

func (_m *MockTenantPluginDao) GetPluginByID(pluginID string, tenantID string) (*model.TenantPlugin, error)

func (*MockTenantPluginDao) GetPluginsByTenantID Uses

func (_m *MockTenantPluginDao) GetPluginsByTenantID(tenantID string) ([]*model.TenantPlugin, error)

func (*MockTenantPluginDao) UpdateModel Uses

func (_m *MockTenantPluginDao) UpdateModel(_param0 model.Interface) error

type MockTenantPluginDefaultENVDao Uses

type MockTenantPluginDefaultENVDao struct {
    // contains filtered or unexported fields
}

Mock of TenantPluginDefaultENVDao interface

func NewMockTenantPluginDefaultENVDao Uses

func NewMockTenantPluginDefaultENVDao(ctrl *gomock.Controller) *MockTenantPluginDefaultENVDao

func (*MockTenantPluginDefaultENVDao) AddModel Uses

func (_m *MockTenantPluginDefaultENVDao) AddModel(_param0 model.Interface) error

func (*MockTenantPluginDefaultENVDao) DeleteAllDefaultENVByPluginID Uses

func (_m *MockTenantPluginDefaultENVDao) DeleteAllDefaultENVByPluginID(PluginID string) error

func (*MockTenantPluginDefaultENVDao) DeleteDefaultENVByName Uses

func (_m *MockTenantPluginDefaultENVDao) DeleteDefaultENVByName(pluginID string, name string, versionID string) error

func (*MockTenantPluginDefaultENVDao) DeleteDefaultENVByPluginIDAndVersionID Uses

func (_m *MockTenantPluginDefaultENVDao) DeleteDefaultENVByPluginIDAndVersionID(pluginID string, versionID string) error

func (*MockTenantPluginDefaultENVDao) EXPECT Uses

func (_m *MockTenantPluginDefaultENVDao) EXPECT() *_MockTenantPluginDefaultENVDaoRecorder

func (*MockTenantPluginDefaultENVDao) GetALLMasterDefultENVs Uses

func (_m *MockTenantPluginDefaultENVDao) GetALLMasterDefultENVs(pluginID string) ([]*model.TenantPluginDefaultENV, error)

func (*MockTenantPluginDefaultENVDao) GetDefaultENVByName Uses

func (_m *MockTenantPluginDefaultENVDao) GetDefaultENVByName(pluginID string, name string, versionID string) (*model.TenantPluginDefaultENV, error)

func (*MockTenantPluginDefaultENVDao) GetDefaultENVSByPluginID Uses

func (_m *MockTenantPluginDefaultENVDao) GetDefaultENVSByPluginID(pluginID string, versionID string) ([]*model.TenantPluginDefaultENV, error)

func (*MockTenantPluginDefaultENVDao) GetDefaultEnvWhichCanBeSetByPluginID Uses

func (_m *MockTenantPluginDefaultENVDao) GetDefaultEnvWhichCanBeSetByPluginID(pluginID string, versionID string) ([]*model.TenantPluginDefaultENV, error)

func (*MockTenantPluginDefaultENVDao) UpdateModel Uses

func (_m *MockTenantPluginDefaultENVDao) UpdateModel(_param0 model.Interface) error

type MockTenantPluginVersionConfigDao Uses

type MockTenantPluginVersionConfigDao struct {
    // contains filtered or unexported fields
}

Mock of TenantPluginVersionConfigDao interface

func NewMockTenantPluginVersionConfigDao Uses

func NewMockTenantPluginVersionConfigDao(ctrl *gomock.Controller) *MockTenantPluginVersionConfigDao

func (*MockTenantPluginVersionConfigDao) AddModel Uses

func (_m *MockTenantPluginVersionConfigDao) AddModel(_param0 model.Interface) error

func (*MockTenantPluginVersionConfigDao) DeletePluginConfig Uses

func (_m *MockTenantPluginVersionConfigDao) DeletePluginConfig(serviceID string, pluginID string) error

func (*MockTenantPluginVersionConfigDao) DeletePluginConfigByServiceID Uses

func (_m *MockTenantPluginVersionConfigDao) DeletePluginConfigByServiceID(serviceID string) error

func (*MockTenantPluginVersionConfigDao) EXPECT Uses

func (_m *MockTenantPluginVersionConfigDao) EXPECT() *_MockTenantPluginVersionConfigDaoRecorder

func (*MockTenantPluginVersionConfigDao) GetPluginConfig Uses

func (_m *MockTenantPluginVersionConfigDao) GetPluginConfig(serviceID string, pluginID string) (*model.TenantPluginVersionDiscoverConfig, error)

func (*MockTenantPluginVersionConfigDao) GetPluginConfigs Uses

func (_m *MockTenantPluginVersionConfigDao) GetPluginConfigs(serviceID string) ([]*model.TenantPluginVersionDiscoverConfig, error)

func (*MockTenantPluginVersionConfigDao) UpdateModel Uses

func (_m *MockTenantPluginVersionConfigDao) UpdateModel(_param0 model.Interface) error

type MockTenantPluginVersionEnvDao Uses

type MockTenantPluginVersionEnvDao struct {
    // contains filtered or unexported fields
}

Mock of TenantPluginVersionEnvDao interface

func NewMockTenantPluginVersionEnvDao Uses

func NewMockTenantPluginVersionEnvDao(ctrl *gomock.Controller) *MockTenantPluginVersionEnvDao

func (*MockTenantPluginVersionEnvDao) AddModel Uses

func (_m *MockTenantPluginVersionEnvDao) AddModel(_param0 model.Interface) error

func (*MockTenantPluginVersionEnvDao) DeleteEnvByEnvName Uses

func (_m *MockTenantPluginVersionEnvDao) DeleteEnvByEnvName(envName string, pluginID string, serviceID string) error

func (*MockTenantPluginVersionEnvDao) DeleteEnvByPluginID Uses

func (_m *MockTenantPluginVersionEnvDao) DeleteEnvByPluginID(serviceID string, pluginID string) error

func (*MockTenantPluginVersionEnvDao) DeleteEnvByServiceID Uses

func (_m *MockTenantPluginVersionEnvDao) DeleteEnvByServiceID(serviceID string) error

func (*MockTenantPluginVersionEnvDao) EXPECT Uses

func (_m *MockTenantPluginVersionEnvDao) EXPECT() *_MockTenantPluginVersionEnvDaoRecorder

func (*MockTenantPluginVersionEnvDao) GetVersionEnvByEnvName Uses

func (_m *MockTenantPluginVersionEnvDao) GetVersionEnvByEnvName(serviceID string, pluginID string, envName string) (*model.TenantPluginVersionEnv, error)

func (*MockTenantPluginVersionEnvDao) GetVersionEnvByServiceID Uses

func (_m *MockTenantPluginVersionEnvDao) GetVersionEnvByServiceID(serviceID string, pluginID string) ([]*model.TenantPluginVersionEnv, error)

func (*MockTenantPluginVersionEnvDao) UpdateModel Uses

func (_m *MockTenantPluginVersionEnvDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceConfigFileDao Uses

type MockTenantServiceConfigFileDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceConfigFileDao interface

func NewMockTenantServiceConfigFileDao Uses

func NewMockTenantServiceConfigFileDao(ctrl *gomock.Controller) *MockTenantServiceConfigFileDao

func (*MockTenantServiceConfigFileDao) AddModel Uses

func (_m *MockTenantServiceConfigFileDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceConfigFileDao) DelByServiceID Uses

func (_m *MockTenantServiceConfigFileDao) DelByServiceID(sid string) error

func (*MockTenantServiceConfigFileDao) DelByVolumeID Uses

func (_m *MockTenantServiceConfigFileDao) DelByVolumeID(sid string, volumeName string) error

func (*MockTenantServiceConfigFileDao) EXPECT Uses

func (_m *MockTenantServiceConfigFileDao) EXPECT() *_MockTenantServiceConfigFileDaoRecorder

func (*MockTenantServiceConfigFileDao) GetByVolumeName Uses

func (_m *MockTenantServiceConfigFileDao) GetByVolumeName(sid string, volumeName string) (*model.TenantServiceConfigFile, error)

func (*MockTenantServiceConfigFileDao) UpdateModel Uses

func (_m *MockTenantServiceConfigFileDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceDao Uses

type MockTenantServiceDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceDao interface

func NewMockTenantServiceDao Uses

func NewMockTenantServiceDao(ctrl *gomock.Controller) *MockTenantServiceDao

func (*MockTenantServiceDao) AddModel Uses

func (_m *MockTenantServiceDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceDao) DeleteServiceByServiceID Uses

func (_m *MockTenantServiceDao) DeleteServiceByServiceID(serviceID string) error

func (*MockTenantServiceDao) EXPECT Uses

func (_m *MockTenantServiceDao) EXPECT() *_MockTenantServiceDaoRecorder

func (*MockTenantServiceDao) GetAllServicesID Uses

func (_m *MockTenantServiceDao) GetAllServicesID() ([]*model.TenantServices, error)

func (*MockTenantServiceDao) GetPagedTenantService Uses

func (_m *MockTenantServiceDao) GetPagedTenantService(offset int, len int, serviceIDs []string) ([]map[string]interface{}, int, error)

func (*MockTenantServiceDao) GetServiceAliasByIDs Uses

func (_m *MockTenantServiceDao) GetServiceAliasByIDs(uids []string) ([]*model.TenantServices, error)

func (*MockTenantServiceDao) GetServiceByID Uses

func (_m *MockTenantServiceDao) GetServiceByID(serviceID string) (*model.TenantServices, error)

func (*MockTenantServiceDao) GetServiceByIDs Uses

func (_m *MockTenantServiceDao) GetServiceByIDs(serviceIDs []string) ([]*model.TenantServices, error)

func (*MockTenantServiceDao) GetServiceByServiceAlias Uses

func (_m *MockTenantServiceDao) GetServiceByServiceAlias(serviceAlias string) (*model.TenantServices, error)

func (*MockTenantServiceDao) GetServiceByTenantIDAndServiceAlias Uses

func (_m *MockTenantServiceDao) GetServiceByTenantIDAndServiceAlias(tenantID string, serviceName string) (*model.TenantServices, error)

func (*MockTenantServiceDao) GetServiceMemoryByServiceIDs Uses

func (_m *MockTenantServiceDao) GetServiceMemoryByServiceIDs(serviceIDs []string) (map[string]map[string]interface{}, error)

func (*MockTenantServiceDao) GetServiceMemoryByTenantIDs Uses

func (_m *MockTenantServiceDao) GetServiceMemoryByTenantIDs(tenantIDs []string, serviceIDs []string) (map[string]map[string]interface{}, error)

func (*MockTenantServiceDao) GetServicesAllInfoByTenantID Uses

func (_m *MockTenantServiceDao) GetServicesAllInfoByTenantID(tenantID string) ([]*model.TenantServices, error)

func (*MockTenantServiceDao) GetServicesByTenantID Uses

func (_m *MockTenantServiceDao) GetServicesByTenantID(tenantID string) ([]*model.TenantServices, error)

func (*MockTenantServiceDao) GetServicesByTenantIDs Uses

func (_m *MockTenantServiceDao) GetServicesByTenantIDs(tenantIDs []string) ([]*model.TenantServices, error)

func (*MockTenantServiceDao) ListThirdPartyServices Uses

func (_m *MockTenantServiceDao) ListThirdPartyServices() ([]*model.TenantServices, error)

func (*MockTenantServiceDao) SetTenantServiceStatus Uses

func (_m *MockTenantServiceDao) SetTenantServiceStatus(serviceID string, status string) error

func (*MockTenantServiceDao) UpdateDeployVersion Uses

func (_m *MockTenantServiceDao) UpdateDeployVersion(serviceID string, deployversion string) error

func (*MockTenantServiceDao) UpdateModel Uses

func (_m *MockTenantServiceDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceDeleteDao Uses

type MockTenantServiceDeleteDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceDeleteDao interface

func NewMockTenantServiceDeleteDao Uses

func NewMockTenantServiceDeleteDao(ctrl *gomock.Controller) *MockTenantServiceDeleteDao

func (*MockTenantServiceDeleteDao) AddModel Uses

func (_m *MockTenantServiceDeleteDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceDeleteDao) DeleteTenantServicesDelete Uses

func (_m *MockTenantServiceDeleteDao) DeleteTenantServicesDelete(record *model.TenantServicesDelete) error

func (*MockTenantServiceDeleteDao) EXPECT Uses

func (_m *MockTenantServiceDeleteDao) EXPECT() *_MockTenantServiceDeleteDaoRecorder

func (*MockTenantServiceDeleteDao) GetTenantServicesDeleteByCreateTime Uses

func (_m *MockTenantServiceDeleteDao) GetTenantServicesDeleteByCreateTime(createTime time.Time) ([]*model.TenantServicesDelete, error)

func (*MockTenantServiceDeleteDao) UpdateModel Uses

func (_m *MockTenantServiceDeleteDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceEnvVarDao Uses

type MockTenantServiceEnvVarDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceEnvVarDao interface

func NewMockTenantServiceEnvVarDao Uses

func NewMockTenantServiceEnvVarDao(ctrl *gomock.Controller) *MockTenantServiceEnvVarDao

func (*MockTenantServiceEnvVarDao) AddModel Uses

func (_m *MockTenantServiceEnvVarDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceEnvVarDao) DELServiceEnvsByServiceID Uses

func (_m *MockTenantServiceEnvVarDao) DELServiceEnvsByServiceID(serviceID string) error

func (*MockTenantServiceEnvVarDao) DelByServiceIDAndScope Uses

func (_m *MockTenantServiceEnvVarDao) DelByServiceIDAndScope(sid string, scope string) error

func (*MockTenantServiceEnvVarDao) DeleteModel Uses

func (_m *MockTenantServiceEnvVarDao) DeleteModel(serviceID string, arg ...interface{}) error

func (*MockTenantServiceEnvVarDao) EXPECT Uses

func (_m *MockTenantServiceEnvVarDao) EXPECT() *_MockTenantServiceEnvVarDaoRecorder

func (*MockTenantServiceEnvVarDao) GetDependServiceEnvs Uses

func (_m *MockTenantServiceEnvVarDao) GetDependServiceEnvs(serviceIDs []string, scopes []string) ([]*model.TenantServiceEnvVar, error)

func (*MockTenantServiceEnvVarDao) GetEnv Uses

func (_m *MockTenantServiceEnvVarDao) GetEnv(serviceID string, envName string) (*model.TenantServiceEnvVar, error)

func (*MockTenantServiceEnvVarDao) GetServiceEnvs Uses

func (_m *MockTenantServiceEnvVarDao) GetServiceEnvs(serviceID string, scopes []string) ([]*model.TenantServiceEnvVar, error)

func (*MockTenantServiceEnvVarDao) UpdateModel Uses

func (_m *MockTenantServiceEnvVarDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceLBMappingPortDao Uses

type MockTenantServiceLBMappingPortDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceLBMappingPortDao interface

func NewMockTenantServiceLBMappingPortDao Uses

func NewMockTenantServiceLBMappingPortDao(ctrl *gomock.Controller) *MockTenantServiceLBMappingPortDao

func (*MockTenantServiceLBMappingPortDao) AddModel Uses

func (_m *MockTenantServiceLBMappingPortDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceLBMappingPortDao) CreateTenantServiceLBMappingPort Uses

func (_m *MockTenantServiceLBMappingPortDao) CreateTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)

func (*MockTenantServiceLBMappingPortDao) DELServiceLBMappingPortByServiceID Uses

func (_m *MockTenantServiceLBMappingPortDao) DELServiceLBMappingPortByServiceID(serviceID string) error

func (*MockTenantServiceLBMappingPortDao) DELServiceLBMappingPortByServiceIDAndPort Uses

func (_m *MockTenantServiceLBMappingPortDao) DELServiceLBMappingPortByServiceIDAndPort(serviceID string, lbPort int) error

func (*MockTenantServiceLBMappingPortDao) EXPECT Uses

func (_m *MockTenantServiceLBMappingPortDao) EXPECT() *_MockTenantServiceLBMappingPortDaoRecorder

func (*MockTenantServiceLBMappingPortDao) GetLBMappingPortByServiceIDAndPort Uses

func (_m *MockTenantServiceLBMappingPortDao) GetLBMappingPortByServiceIDAndPort(serviceID string, port int) (*model.TenantServiceLBMappingPort, error)

func (*MockTenantServiceLBMappingPortDao) GetLBPortByTenantAndPort Uses

func (_m *MockTenantServiceLBMappingPortDao) GetLBPortByTenantAndPort(tenantID string, lbport int) (*model.TenantServiceLBMappingPort, error)

func (*MockTenantServiceLBMappingPortDao) GetLBPortsASC Uses

func (_m *MockTenantServiceLBMappingPortDao) GetLBPortsASC() ([]*model.TenantServiceLBMappingPort, error)

func (*MockTenantServiceLBMappingPortDao) GetTenantServiceLBMappingPort Uses

func (_m *MockTenantServiceLBMappingPortDao) GetTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)

func (*MockTenantServiceLBMappingPortDao) GetTenantServiceLBMappingPortByService Uses

func (_m *MockTenantServiceLBMappingPortDao) GetTenantServiceLBMappingPortByService(serviceID string) ([]*model.TenantServiceLBMappingPort, error)

func (*MockTenantServiceLBMappingPortDao) PortExists Uses

func (_m *MockTenantServiceLBMappingPortDao) PortExists(port int) bool

func (*MockTenantServiceLBMappingPortDao) UpdateModel Uses

func (_m *MockTenantServiceLBMappingPortDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceLabelDao Uses

type MockTenantServiceLabelDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceLabelDao interface

func NewMockTenantServiceLabelDao Uses

func NewMockTenantServiceLabelDao(ctrl *gomock.Controller) *MockTenantServiceLabelDao

func (*MockTenantServiceLabelDao) AddModel Uses

func (_m *MockTenantServiceLabelDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceLabelDao) DelTenantServiceLabelsByLabelValuesAndServiceID Uses

func (_m *MockTenantServiceLabelDao) DelTenantServiceLabelsByLabelValuesAndServiceID(serviceID string) error

func (*MockTenantServiceLabelDao) DelTenantServiceLabelsByServiceIDKey Uses

func (_m *MockTenantServiceLabelDao) DelTenantServiceLabelsByServiceIDKey(serviceID string, labelKey string) error

func (*MockTenantServiceLabelDao) DelTenantServiceLabelsByServiceIDKeyValue Uses

func (_m *MockTenantServiceLabelDao) DelTenantServiceLabelsByServiceIDKeyValue(serviceID string, labelKey string, labelValue string) error

func (*MockTenantServiceLabelDao) DeleteLabelByServiceID Uses

func (_m *MockTenantServiceLabelDao) DeleteLabelByServiceID(serviceID string) error

func (*MockTenantServiceLabelDao) DeleteModel Uses

func (_m *MockTenantServiceLabelDao) DeleteModel(serviceID string, arg ...interface{}) error

func (*MockTenantServiceLabelDao) EXPECT Uses

func (_m *MockTenantServiceLabelDao) EXPECT() *_MockTenantServiceLabelDaoRecorder

func (*MockTenantServiceLabelDao) GetLabelByNodeSelectorKey Uses

func (_m *MockTenantServiceLabelDao) GetLabelByNodeSelectorKey(serviceID string, labelValue string) (*model.TenantServiceLable, error)

func (*MockTenantServiceLabelDao) GetTenantNodeAffinityLabel Uses

func (_m *MockTenantServiceLabelDao) GetTenantNodeAffinityLabel(serviceID string) (*model.TenantServiceLable, error)

func (*MockTenantServiceLabelDao) GetTenantServiceAffinityLabel Uses

func (_m *MockTenantServiceLabelDao) GetTenantServiceAffinityLabel(serviceID string) ([]*model.TenantServiceLable, error)

func (*MockTenantServiceLabelDao) GetTenantServiceLabel Uses

func (_m *MockTenantServiceLabelDao) GetTenantServiceLabel(serviceID string) ([]*model.TenantServiceLable, error)

func (*MockTenantServiceLabelDao) GetTenantServiceNodeSelectorLabel Uses

func (_m *MockTenantServiceLabelDao) GetTenantServiceNodeSelectorLabel(serviceID string) ([]*model.TenantServiceLable, error)

func (*MockTenantServiceLabelDao) GetTenantServiceTypeLabel Uses

func (_m *MockTenantServiceLabelDao) GetTenantServiceTypeLabel(serviceID string) (*model.TenantServiceLable, error)

func (*MockTenantServiceLabelDao) UpdateModel Uses

func (_m *MockTenantServiceLabelDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceMountRelationDao Uses

type MockTenantServiceMountRelationDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceMountRelationDao interface

func NewMockTenantServiceMountRelationDao Uses

func NewMockTenantServiceMountRelationDao(ctrl *gomock.Controller) *MockTenantServiceMountRelationDao

func (*MockTenantServiceMountRelationDao) AddModel Uses

func (_m *MockTenantServiceMountRelationDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceMountRelationDao) DELTenantServiceMountRelationByServiceID Uses

func (_m *MockTenantServiceMountRelationDao) DELTenantServiceMountRelationByServiceID(serviceID string) error

func (*MockTenantServiceMountRelationDao) DElTenantServiceMountRelationByDepService Uses

func (_m *MockTenantServiceMountRelationDao) DElTenantServiceMountRelationByDepService(serviceID string, depServiceID string) error

func (*MockTenantServiceMountRelationDao) DElTenantServiceMountRelationByServiceAndName Uses

func (_m *MockTenantServiceMountRelationDao) DElTenantServiceMountRelationByServiceAndName(serviceID string, mntDir string) error

func (*MockTenantServiceMountRelationDao) EXPECT Uses

func (_m *MockTenantServiceMountRelationDao) EXPECT() *_MockTenantServiceMountRelationDaoRecorder

func (*MockTenantServiceMountRelationDao) GetTenantServiceMountRelationsByService Uses

func (_m *MockTenantServiceMountRelationDao) GetTenantServiceMountRelationsByService(serviceID string) ([]*model.TenantServiceMountRelation, error)

func (*MockTenantServiceMountRelationDao) UpdateModel Uses

func (_m *MockTenantServiceMountRelationDao) UpdateModel(_param0 model.Interface) error

type MockTenantServicePluginRelationDao Uses

type MockTenantServicePluginRelationDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServicePluginRelationDao interface

func NewMockTenantServicePluginRelationDao Uses

func NewMockTenantServicePluginRelationDao(ctrl *gomock.Controller) *MockTenantServicePluginRelationDao

func (*MockTenantServicePluginRelationDao) AddModel Uses

func (_m *MockTenantServicePluginRelationDao) AddModel(_param0 model.Interface) error

func (*MockTenantServicePluginRelationDao) CheckSomeModelLikePluginByServiceID Uses

func (_m *MockTenantServicePluginRelationDao) CheckSomeModelLikePluginByServiceID(serviceID string, pluginModel string) (bool, error)

func (*MockTenantServicePluginRelationDao) CheckSomeModelPluginByServiceID Uses

func (_m *MockTenantServicePluginRelationDao) CheckSomeModelPluginByServiceID(serviceID string, pluginModel string) (bool, error)

func (*MockTenantServicePluginRelationDao) DeleteALLRelationByPluginID Uses

func (_m *MockTenantServicePluginRelationDao) DeleteALLRelationByPluginID(pluginID string) error

func (*MockTenantServicePluginRelationDao) DeleteALLRelationByServiceID Uses

func (_m *MockTenantServicePluginRelationDao) DeleteALLRelationByServiceID(serviceID string) error

func (*MockTenantServicePluginRelationDao) DeleteRelationByServiceIDAndPluginID Uses

func (_m *MockTenantServicePluginRelationDao) DeleteRelationByServiceIDAndPluginID(serviceID string, pluginID string) error

func (*MockTenantServicePluginRelationDao) EXPECT Uses

func (_m *MockTenantServicePluginRelationDao) EXPECT() *_MockTenantServicePluginRelationDaoRecorder

func (*MockTenantServicePluginRelationDao) GetALLRelationByServiceID Uses

func (_m *MockTenantServicePluginRelationDao) GetALLRelationByServiceID(serviceID string) ([]*model.TenantServicePluginRelation, error)

func (*MockTenantServicePluginRelationDao) GetRelateionByServiceIDAndPluginID Uses

func (_m *MockTenantServicePluginRelationDao) GetRelateionByServiceIDAndPluginID(serviceID string, pluginID string) (*model.TenantServicePluginRelation, error)

func (*MockTenantServicePluginRelationDao) UpdateModel Uses

func (_m *MockTenantServicePluginRelationDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceRelationDao Uses

type MockTenantServiceRelationDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceRelationDao interface

func NewMockTenantServiceRelationDao Uses

func NewMockTenantServiceRelationDao(ctrl *gomock.Controller) *MockTenantServiceRelationDao

func (*MockTenantServiceRelationDao) AddModel Uses

func (_m *MockTenantServiceRelationDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceRelationDao) DELRelationsByServiceID Uses

func (_m *MockTenantServiceRelationDao) DELRelationsByServiceID(serviceID string) error

func (*MockTenantServiceRelationDao) DeleteModel Uses

func (_m *MockTenantServiceRelationDao) DeleteModel(serviceID string, arg ...interface{}) error

func (*MockTenantServiceRelationDao) DeleteRelationByDepID Uses

func (_m *MockTenantServiceRelationDao) DeleteRelationByDepID(serviceID string, depID string) error

func (*MockTenantServiceRelationDao) EXPECT Uses

func (_m *MockTenantServiceRelationDao) EXPECT() *_MockTenantServiceRelationDaoRecorder

func (*MockTenantServiceRelationDao) GetTenantServiceRelations Uses

func (_m *MockTenantServiceRelationDao) GetTenantServiceRelations(serviceID string) ([]*model.TenantServiceRelation, error)

func (*MockTenantServiceRelationDao) GetTenantServiceRelationsByDependServiceID Uses

func (_m *MockTenantServiceRelationDao) GetTenantServiceRelationsByDependServiceID(dependServiceID string) ([]*model.TenantServiceRelation, error)

func (*MockTenantServiceRelationDao) HaveRelations Uses

func (_m *MockTenantServiceRelationDao) HaveRelations(serviceID string) bool

func (*MockTenantServiceRelationDao) UpdateModel Uses

func (_m *MockTenantServiceRelationDao) UpdateModel(_param0 model.Interface) error

type MockTenantServiceVolumeDao Uses

type MockTenantServiceVolumeDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServiceVolumeDao interface

func NewMockTenantServiceVolumeDao Uses

func NewMockTenantServiceVolumeDao(ctrl *gomock.Controller) *MockTenantServiceVolumeDao

func (*MockTenantServiceVolumeDao) AddModel Uses

func (_m *MockTenantServiceVolumeDao) AddModel(_param0 model.Interface) error

func (*MockTenantServiceVolumeDao) DeleteByServiceIDAndVolumePath Uses

func (_m *MockTenantServiceVolumeDao) DeleteByServiceIDAndVolumePath(serviceID string, volumePath string) error

func (*MockTenantServiceVolumeDao) DeleteModel Uses

func (_m *MockTenantServiceVolumeDao) DeleteModel(serviceID string, arg ...interface{}) error

func (*MockTenantServiceVolumeDao) DeleteTenantServiceVolumesByServiceID Uses

func (_m *MockTenantServiceVolumeDao) DeleteTenantServiceVolumesByServiceID(serviceID string) error

func (*MockTenantServiceVolumeDao) EXPECT Uses

func (_m *MockTenantServiceVolumeDao) EXPECT() *_MockTenantServiceVolumeDaoRecorder

func (*MockTenantServiceVolumeDao) GetAllVolumes Uses

func (_m *MockTenantServiceVolumeDao) GetAllVolumes() ([]*model.TenantServiceVolume, error)

func (*MockTenantServiceVolumeDao) GetTenantServiceVolumesByServiceID Uses

func (_m *MockTenantServiceVolumeDao) GetTenantServiceVolumesByServiceID(serviceID string) ([]*model.TenantServiceVolume, error)

func (*MockTenantServiceVolumeDao) GetVolumeByID Uses

func (_m *MockTenantServiceVolumeDao) GetVolumeByID(id int) (*model.TenantServiceVolume, error)

func (*MockTenantServiceVolumeDao) GetVolumeByServiceIDAndName Uses

func (_m *MockTenantServiceVolumeDao) GetVolumeByServiceIDAndName(serviceID string, name string) (*model.TenantServiceVolume, error)

func (*MockTenantServiceVolumeDao) UpdateModel Uses

func (_m *MockTenantServiceVolumeDao) UpdateModel(_param0 model.Interface) error

type MockTenantServicesPortDao Uses

type MockTenantServicesPortDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServicesPortDao interface

func NewMockTenantServicesPortDao Uses

func NewMockTenantServicesPortDao(ctrl *gomock.Controller) *MockTenantServicesPortDao

func (*MockTenantServicesPortDao) AddModel Uses

func (_m *MockTenantServicesPortDao) AddModel(_param0 model.Interface) error

func (*MockTenantServicesPortDao) DELPortsByServiceID Uses

func (_m *MockTenantServicesPortDao) DELPortsByServiceID(serviceID string) error

func (*MockTenantServicesPortDao) DelByServiceID Uses

func (_m *MockTenantServicesPortDao) DelByServiceID(sid string) error

func (*MockTenantServicesPortDao) DeleteModel Uses

func (_m *MockTenantServicesPortDao) DeleteModel(serviceID string, arg ...interface{}) error

func (*MockTenantServicesPortDao) EXPECT Uses

func (_m *MockTenantServicesPortDao) EXPECT() *_MockTenantServicesPortDaoRecorder

func (*MockTenantServicesPortDao) GetDepUDPPort Uses

func (_m *MockTenantServicesPortDao) GetDepUDPPort(serviceID string) ([]*model.TenantServicesPort, error)

func (*MockTenantServicesPortDao) GetInnerPorts Uses

func (_m *MockTenantServicesPortDao) GetInnerPorts(serviceID string) ([]*model.TenantServicesPort, error)

func (*MockTenantServicesPortDao) GetOpenedPorts Uses

func (_m *MockTenantServicesPortDao) GetOpenedPorts(serviceID string) ([]*model.TenantServicesPort, error)

func (*MockTenantServicesPortDao) GetOuterPorts Uses

func (_m *MockTenantServicesPortDao) GetOuterPorts(serviceID string) ([]*model.TenantServicesPort, error)

func (*MockTenantServicesPortDao) GetPort Uses

func (_m *MockTenantServicesPortDao) GetPort(serviceID string, port int) (*model.TenantServicesPort, error)

func (*MockTenantServicesPortDao) GetPortsByServiceID Uses

func (_m *MockTenantServicesPortDao) GetPortsByServiceID(serviceID string) ([]*model.TenantServicesPort, error)

func (*MockTenantServicesPortDao) HasOpenPort Uses

func (_m *MockTenantServicesPortDao) HasOpenPort(sid string) bool

func (*MockTenantServicesPortDao) UpdateModel Uses

func (_m *MockTenantServicesPortDao) UpdateModel(_param0 model.Interface) error

type MockTenantServicesStreamPluginPortDao Uses

type MockTenantServicesStreamPluginPortDao struct {
    // contains filtered or unexported fields
}

Mock of TenantServicesStreamPluginPortDao interface

func NewMockTenantServicesStreamPluginPortDao Uses

func NewMockTenantServicesStreamPluginPortDao(ctrl *gomock.Controller) *MockTenantServicesStreamPluginPortDao

func (*MockTenantServicesStreamPluginPortDao) AddModel Uses

func (_m *MockTenantServicesStreamPluginPortDao) AddModel(_param0 model.Interface) error

func (*MockTenantServicesStreamPluginPortDao) DeleteAllPluginMappingPortByServiceID Uses

func (_m *MockTenantServicesStreamPluginPortDao) DeleteAllPluginMappingPortByServiceID(serviceID string) error

func (*MockTenantServicesStreamPluginPortDao) DeletePluginMappingPortByContainerPort Uses

func (_m *MockTenantServicesStreamPluginPortDao) DeletePluginMappingPortByContainerPort(serviceID string, pluginModel string, containerPort int) error

func (*MockTenantServicesStreamPluginPortDao) EXPECT Uses

func (_m *MockTenantServicesStreamPluginPortDao) EXPECT() *_MockTenantServicesStreamPluginPortDaoRecorder

func (*MockTenantServicesStreamPluginPortDao) GetPluginMappingPortByServiceIDAndContainerPort Uses

func (_m *MockTenantServicesStreamPluginPortDao) GetPluginMappingPortByServiceIDAndContainerPort(serviceID string, pluginModel string, containerPort int) (*model.TenantServicesStreamPluginPort, error)

func (*MockTenantServicesStreamPluginPortDao) GetPluginMappingPorts Uses

func (_m *MockTenantServicesStreamPluginPortDao) GetPluginMappingPorts(serviceID string) ([]*model.TenantServicesStreamPluginPort, error)

func (*MockTenantServicesStreamPluginPortDao) SetPluginMappingPort Uses

func (_m *MockTenantServicesStreamPluginPortDao) SetPluginMappingPort(tenantID string, serviceID string, pluginModel string, containerPort int) (int, error)

func (*MockTenantServicesStreamPluginPortDao) UpdateModel Uses

func (_m *MockTenantServicesStreamPluginPortDao) UpdateModel(_param0 model.Interface) error

type MockThirdPartySvcDiscoveryCfgDao Uses

type MockThirdPartySvcDiscoveryCfgDao struct {
    // contains filtered or unexported fields
}

Mock of ThirdPartySvcDiscoveryCfgDao interface

func NewMockThirdPartySvcDiscoveryCfgDao Uses

func NewMockThirdPartySvcDiscoveryCfgDao(ctrl *gomock.Controller) *MockThirdPartySvcDiscoveryCfgDao

func (*MockThirdPartySvcDiscoveryCfgDao) AddModel Uses

func (_m *MockThirdPartySvcDiscoveryCfgDao) AddModel(_param0 model.Interface) error

func (*MockThirdPartySvcDiscoveryCfgDao) DeleteByServiceID Uses

func (_m *MockThirdPartySvcDiscoveryCfgDao) DeleteByServiceID(sid string) error

func (*MockThirdPartySvcDiscoveryCfgDao) EXPECT Uses

func (_m *MockThirdPartySvcDiscoveryCfgDao) EXPECT() *_MockThirdPartySvcDiscoveryCfgDaoRecorder

func (*MockThirdPartySvcDiscoveryCfgDao) GetByServiceID Uses

func (_m *MockThirdPartySvcDiscoveryCfgDao) GetByServiceID(sid string) (*model.ThirdPartySvcDiscoveryCfg, error)

func (*MockThirdPartySvcDiscoveryCfgDao) UpdateModel Uses

func (_m *MockThirdPartySvcDiscoveryCfgDao) UpdateModel(_param0 model.Interface) error

type MockVersionInfoDao Uses

type MockVersionInfoDao struct {
    // contains filtered or unexported fields
}

Mock of VersionInfoDao interface

func NewMockVersionInfoDao Uses

func NewMockVersionInfoDao(ctrl *gomock.Controller) *MockVersionInfoDao

func (*MockVersionInfoDao) AddModel Uses

func (_m *MockVersionInfoDao) AddModel(_param0 model.Interface) error

func (*MockVersionInfoDao) DeleteFailureVersionInfo Uses

func (_m *MockVersionInfoDao) DeleteFailureVersionInfo(timePoint time.Time, status string, serviceIDList []string) error

func (*MockVersionInfoDao) DeleteVersionByEventID Uses

func (_m *MockVersionInfoDao) DeleteVersionByEventID(eventID string) error

func (*MockVersionInfoDao) DeleteVersionByServiceID Uses

func (_m *MockVersionInfoDao) DeleteVersionByServiceID(serviceID string) error

func (*MockVersionInfoDao) DeleteVersionInfo Uses

func (_m *MockVersionInfoDao) DeleteVersionInfo(obj *model.VersionInfo) error

func (*MockVersionInfoDao) EXPECT Uses

func (_m *MockVersionInfoDao) EXPECT() *_MockVersionInfoDaoRecorder

func (*MockVersionInfoDao) GetAllVersionByServiceID Uses

func (_m *MockVersionInfoDao) GetAllVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)

func (*MockVersionInfoDao) GetVersionByDeployVersion Uses

func (_m *MockVersionInfoDao) GetVersionByDeployVersion(version string, serviceID string) (*model.VersionInfo, error)

func (*MockVersionInfoDao) GetVersionByEventID Uses

func (_m *MockVersionInfoDao) GetVersionByEventID(eventID string) (*model.VersionInfo, error)

func (*MockVersionInfoDao) GetVersionByServiceID Uses

func (_m *MockVersionInfoDao) GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)

func (*MockVersionInfoDao) GetVersionInfo Uses

func (_m *MockVersionInfoDao) GetVersionInfo(timePoint time.Time, serviceIDList []string) ([]*model.VersionInfo, error)

func (*MockVersionInfoDao) SearchVersionInfo Uses

func (_m *MockVersionInfoDao) SearchVersionInfo() ([]*model.VersionInfo, error)

func (*MockVersionInfoDao) UpdateModel Uses

func (_m *MockVersionInfoDao) UpdateModel(_param0 model.Interface) error

type NotificationEventDao Uses

type NotificationEventDao interface {
    Dao
    GetNotificationEventByHash(hash string) (*model.NotificationEvent, error)
    GetNotificationEventByKind(kind, kindID string) ([]*model.NotificationEvent, error)
    GetNotificationEventByTime(start, end time.Time) ([]*model.NotificationEvent, error)
    GetNotificationEventNotHandle() ([]*model.NotificationEvent, error)
}

NotificationEventDao NotificationEventDao

type RegionAPIClassDao Uses

type RegionAPIClassDao interface {
    Dao
    GetPrefixesByClass(apiClass string) ([]*model.RegionAPIClass, error)
    DeletePrefixInClass(apiClass, prefix string) error
}

RegionAPIClassDao RegionAPIClassDao

type RegionProcotolsDao Uses

type RegionProcotolsDao interface {
    Dao
    GetAllSupportProtocol(version string) ([]*model.RegionProcotols, error)
    GetProtocolGroupByProtocolChild(version, protocolChild string) (*model.RegionProcotols, error)
}

RegionProcotolsDao RegionProcotolsDao

type RegionUserInfoDao Uses

type RegionUserInfoDao interface {
    Dao
    GetALLTokenInValidityPeriod() ([]*model.RegionUserInfo, error)
    GetTokenByEid(eid string) (*model.RegionUserInfo, error)
    GetTokenByTokenID(token string) (*model.RegionUserInfo, error)
}

RegionUserInfoDao UserRegionInfoDao

type RuleExtensionDao Uses

type RuleExtensionDao interface {
    Dao
    GetRuleExtensionByRuleID(ruleID string) ([]*model.RuleExtension, error)
    DeleteRuleExtensionByRuleID(ruleID string) error
}

RuleExtensionDao -

type ServiceProbeDao Uses

type ServiceProbeDao interface {
    Dao
    DelDao
    GetServiceProbes(serviceID string) ([]*model.TenantServiceProbe, error)
    GetServiceUsedProbe(serviceID, mode string) (*model.TenantServiceProbe, error)
    DELServiceProbesByServiceID(serviceID string) error
    DelByServiceID(sid string) error
}

ServiceProbeDao ServiceProbeDao

type ServiceSourceDao Uses

type ServiceSourceDao interface {
    Dao
    GetServiceSource(serviceID string) ([]*model.ServiceSourceConfig, error)
}

ServiceSourceDao service source dao

type TCPRuleDao Uses

type TCPRuleDao interface {
    Dao
    GetTCPRuleByServiceIDAndContainerPort(serviceID string, containerPort int) ([]*model.TCPRule, error)
    GetTCPRuleByID(id string) (*model.TCPRule, error)
    GetTCPRuleByServiceID(sid string) ([]*model.TCPRule, error)
    DeleteByID(uuid string) error
    DeleteTCPRuleByServiceID(serviceID string) error
    ListByServiceID(serviceID string) ([]*model.TCPRule, error)
}

TCPRuleDao -

type TenantDao Uses

type TenantDao interface {
    Dao
    GetTenantByUUID(uuid string) (*model.Tenants, error)
    GetTenantIDByName(tenantName string) (*model.Tenants, error)
    GetALLTenants() ([]*model.Tenants, error)
    GetTenantByEid(eid string) ([]*model.Tenants, error)
    GetPagedTenants(offset, len int) ([]*model.Tenants, error)
    GetTenantIDsByNames(names []string) ([]string, error)
    GetTenantLimitsByNames(names []string) (map[string]int, error)
    GetTenantByUUIDIsExist(uuid string) bool
}

TenantDao tenant dao

type TenantPluginBuildVersionDao Uses

type TenantPluginBuildVersionDao interface {
    Dao
    DeleteBuildVersionByVersionID(versionID string) error
    DeleteBuildVersionByPluginID(pluginID string) error
    GetBuildVersionByPluginID(pluginID string) ([]*model.TenantPluginBuildVersion, error)
    GetBuildVersionByVersionID(pluginID, versionID string) (*model.TenantPluginBuildVersion, error)
    GetLastBuildVersionByVersionID(pluginID, versionID string) (*model.TenantPluginBuildVersion, error)
    GetBuildVersionByDeployVersion(pluginID, versionID, deployVersion string) (*model.TenantPluginBuildVersion, error)
}

TenantPluginBuildVersionDao TenantPluginBuildVersionDao

type TenantPluginDao Uses

type TenantPluginDao interface {
    Dao
    GetPluginByID(pluginID, tenantID string) (*model.TenantPlugin, error)
    DeletePluginByID(pluginID, tenantID string) error
    GetPluginsByTenantID(tenantID string) ([]*model.TenantPlugin, error)
}

TenantPluginDao TenantPluginDao

type TenantPluginDefaultENVDao Uses

type TenantPluginDefaultENVDao interface {
    Dao
    GetDefaultENVByName(pluginID, name, versionID string) (*model.TenantPluginDefaultENV, error)
    GetDefaultENVSByPluginID(pluginID, versionID string) ([]*model.TenantPluginDefaultENV, error)
    //GetDefaultENVSByPluginIDCantBeSet(pluginID string) ([]*model.TenantPluginDefaultENV, error)
    DeleteDefaultENVByName(pluginID, name, versionID string) error
    DeleteAllDefaultENVByPluginID(PluginID string) error
    DeleteDefaultENVByPluginIDAndVersionID(pluginID, versionID string) error
    GetALLMasterDefultENVs(pluginID string) ([]*model.TenantPluginDefaultENV, error)
    GetDefaultEnvWhichCanBeSetByPluginID(pluginID, versionID string) ([]*model.TenantPluginDefaultENV, error)
}

TenantPluginDefaultENVDao TenantPluginDefaultENVDao

type TenantPluginVersionConfigDao Uses

type TenantPluginVersionConfigDao interface {
    Dao
    GetPluginConfig(serviceID, pluginID string) (*model.TenantPluginVersionDiscoverConfig, error)
    GetPluginConfigs(serviceID string) ([]*model.TenantPluginVersionDiscoverConfig, error)
    DeletePluginConfig(serviceID, pluginID string) error
    DeletePluginConfigByServiceID(serviceID string) error
}

TenantPluginVersionConfigDao service plugin config that can be dynamic discovery dao interface

type TenantPluginVersionEnvDao Uses

type TenantPluginVersionEnvDao interface {
    Dao
    DeleteEnvByEnvName(envName, pluginID, serviceID string) error
    DeleteEnvByPluginID(serviceID, pluginID string) error
    DeleteEnvByServiceID(serviceID string) error
    GetVersionEnvByServiceID(serviceID string, pluginID string) ([]*model.TenantPluginVersionEnv, error)
    GetVersionEnvByEnvName(serviceID, pluginID, envName string) (*model.TenantPluginVersionEnv, error)
}

TenantPluginVersionEnvDao TenantPluginVersionEnvDao

type TenantServiceConfigFileDao Uses

type TenantServiceConfigFileDao interface {
    Dao
    GetByVolumeName(sid, volumeName string) (*model.TenantServiceConfigFile, error)
    DelByVolumeID(sid string, volumeName string) error
    DelByServiceID(sid string) error
}

TenantServiceConfigFileDao tenant service config file dao interface

type TenantServiceDao Uses

type TenantServiceDao interface {
    Dao
    GetServiceByID(serviceID string) (*model.TenantServices, error)
    GetServiceByServiceAlias(serviceAlias string) (*model.TenantServices, error)
    GetServiceByIDs(serviceIDs []string) ([]*model.TenantServices, error)
    GetServiceAliasByIDs(uids []string) ([]*model.TenantServices, error)
    GetServiceByTenantIDAndServiceAlias(tenantID, serviceName string) (*model.TenantServices, error)
    SetTenantServiceStatus(serviceID, status string) error
    GetServicesByTenantID(tenantID string) ([]*model.TenantServices, error)
    GetServicesByTenantIDs(tenantIDs []string) ([]*model.TenantServices, error)
    GetServicesAllInfoByTenantID(tenantID string) ([]*model.TenantServices, error)
    DeleteServiceByServiceID(serviceID string) error
    GetServiceMemoryByTenantIDs(tenantIDs, serviceIDs []string) (map[string]map[string]interface{}, error)
    GetServiceMemoryByServiceIDs(serviceIDs []string) (map[string]map[string]interface{}, error)
    GetPagedTenantService(offset, len int, serviceIDs []string) ([]map[string]interface{}, int, error)
    GetAllServicesID() ([]*model.TenantServices, error)
    UpdateDeployVersion(serviceID, deployversion string) error
    ListThirdPartyServices() ([]*model.TenantServices, error)
}

TenantServiceDao TenantServiceDao

type TenantServiceDeleteDao Uses

type TenantServiceDeleteDao interface {
    Dao
    GetTenantServicesDeleteByCreateTime(createTime time.Time) ([]*model.TenantServicesDelete, error)
    DeleteTenantServicesDelete(record *model.TenantServicesDelete) error
}

TenantServiceDeleteDao TenantServiceDeleteDao

type TenantServiceEnvVarDao Uses

type TenantServiceEnvVarDao interface {
    Dao
    DelDao
    //service_id__in=sids, scope__in=("outer", "both")
    GetDependServiceEnvs(serviceIDs []string, scopes []string) ([]*model.TenantServiceEnvVar, error)
    GetServiceEnvs(serviceID string, scopes []string) ([]*model.TenantServiceEnvVar, error)
    GetEnv(serviceID, envName string) (*model.TenantServiceEnvVar, error)
    DELServiceEnvsByServiceID(serviceID string) error
    DelByServiceIDAndScope(sid, scope string) error
}

TenantServiceEnvVarDao TenantServiceEnvVarDao

type TenantServiceLBMappingPortDao Uses

type TenantServiceLBMappingPortDao interface {
    Dao
    GetTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)
    GetLBMappingPortByServiceIDAndPort(serviceID string, port int) (*model.TenantServiceLBMappingPort, error)
    GetTenantServiceLBMappingPortByService(serviceID string) ([]*model.TenantServiceLBMappingPort, error)
    GetLBPortsASC() ([]*model.TenantServiceLBMappingPort, error)
    CreateTenantServiceLBMappingPort(serviceID string, containerPort int) (*model.TenantServiceLBMappingPort, error)
    DELServiceLBMappingPortByServiceID(serviceID string) error
    DELServiceLBMappingPortByServiceIDAndPort(serviceID string, lbPort int) error
    GetLBPortByTenantAndPort(tenantID string, lbport int) (*model.TenantServiceLBMappingPort, error)
    PortExists(port int) bool
}

TenantServiceLBMappingPortDao vs lb mapping port dao

type TenantServiceLabelDao Uses

type TenantServiceLabelDao interface {
    Dao
    DelDao
    GetTenantServiceLabel(serviceID string) ([]*model.TenantServiceLable, error)
    DeleteLabelByServiceID(serviceID string) error
    GetTenantServiceNodeSelectorLabel(serviceID string) ([]*model.TenantServiceLable, error)
    GetTenantNodeAffinityLabel(serviceID string) (*model.TenantServiceLable, error)
    GetTenantServiceAffinityLabel(serviceID string) ([]*model.TenantServiceLable, error)
    GetTenantServiceTypeLabel(serviceID string) (*model.TenantServiceLable, error)
    DelTenantServiceLabelsByLabelValuesAndServiceID(serviceID string) error
    DelTenantServiceLabelsByServiceIDKey(serviceID string, labelKey string) error
    DelTenantServiceLabelsByServiceIDKeyValue(serviceID string, labelKey string, labelValue string) error
    GetLabelByNodeSelectorKey(serviceID string, labelValue string) (*model.TenantServiceLable, error)
}

TenantServiceLabelDao TenantServiceLabelDao

type TenantServiceMountRelationDao Uses

type TenantServiceMountRelationDao interface {
    Dao
    GetTenantServiceMountRelationsByService(serviceID string) ([]*model.TenantServiceMountRelation, error)
    DElTenantServiceMountRelationByServiceAndName(serviceID, mntDir string) error
    DELTenantServiceMountRelationByServiceID(serviceID string) error
    DElTenantServiceMountRelationByDepService(serviceID, depServiceID string) error
}

TenantServiceMountRelationDao TenantServiceMountRelationDao

type TenantServicePluginRelationDao Uses

type TenantServicePluginRelationDao interface {
    Dao
    DeleteRelationByServiceIDAndPluginID(serviceID, pluginID string) error
    DeleteALLRelationByServiceID(serviceID string) error
    DeleteALLRelationByPluginID(pluginID string) error
    GetALLRelationByServiceID(serviceID string) ([]*model.TenantServicePluginRelation, error)
    GetRelateionByServiceIDAndPluginID(serviceID, pluginID string) (*model.TenantServicePluginRelation, error)
    CheckSomeModelPluginByServiceID(serviceID, pluginModel string) (bool, error)
    CheckSomeModelLikePluginByServiceID(serviceID, pluginModel string) (bool, error)
}

TenantServicePluginRelationDao TenantServicePluginRelationDao

type TenantServiceRelationDao Uses

type TenantServiceRelationDao interface {
    Dao
    DelDao
    GetTenantServiceRelations(serviceID string) ([]*model.TenantServiceRelation, error)
    GetTenantServiceRelationsByDependServiceID(dependServiceID string) ([]*model.TenantServiceRelation, error)
    HaveRelations(serviceID string) bool
    DELRelationsByServiceID(serviceID string) error
    DeleteRelationByDepID(serviceID, depID string) error
}

TenantServiceRelationDao TenantServiceRelationDao

type TenantServiceVolumeDao Uses

type TenantServiceVolumeDao interface {
    Dao
    DelDao
    GetTenantServiceVolumesByServiceID(serviceID string) ([]*model.TenantServiceVolume, error)
    DeleteTenantServiceVolumesByServiceID(serviceID string) error
    DeleteByServiceIDAndVolumePath(serviceID string, volumePath string) error
    GetVolumeByServiceIDAndName(serviceID, name string) (*model.TenantServiceVolume, error)
    GetAllVolumes() ([]*model.TenantServiceVolume, error)
    GetVolumeByID(id int) (*model.TenantServiceVolume, error)
    DelShareableBySID(sid string) error
}

TenantServiceVolumeDao TenantServiceVolumeDao

type TenantServicesPortDao Uses

type TenantServicesPortDao interface {
    Dao
    DelDao
    GetPortsByServiceID(serviceID string) ([]*model.TenantServicesPort, error)
    GetOuterPorts(serviceID string) ([]*model.TenantServicesPort, error)
    GetInnerPorts(serviceID string) ([]*model.TenantServicesPort, error)
    GetPort(serviceID string, port int) (*model.TenantServicesPort, error)
    GetOpenedPorts(serviceID string) ([]*model.TenantServicesPort, error)
    //GetDepUDPPort get all depend service udp port info
    GetDepUDPPort(serviceID string) ([]*model.TenantServicesPort, error)
    DELPortsByServiceID(serviceID string) error
    HasOpenPort(sid string) bool
    DelByServiceID(sid string) error
}

TenantServicesPortDao TenantServicesPortDao

type TenantServicesStreamPluginPortDao Uses

type TenantServicesStreamPluginPortDao interface {
    Dao
    GetPluginMappingPorts(serviceID string) ([]*model.TenantServicesStreamPluginPort, error)
    SetPluginMappingPort(
        tenantID string,
        serviceID string,
        pluginModel string,
        containerPort int,
    ) (int, error)
    DeletePluginMappingPortByContainerPort(
        serviceID string,
        pluginModel string,
        containerPort int,
    ) error
    DeleteAllPluginMappingPortByServiceID(serviceID string) error
    GetPluginMappingPortByServiceIDAndContainerPort(
        serviceID string,
        pluginModel string,
        containerPort int,
    ) (*model.TenantServicesStreamPluginPort, error)
}

TenantServicesStreamPluginPortDao TenantServicesStreamPluginPortDao

type ThirdPartySvcDiscoveryCfgDao Uses

type ThirdPartySvcDiscoveryCfgDao interface {
    Dao
    GetByServiceID(sid string) (*model.ThirdPartySvcDiscoveryCfg, error)
    DeleteByServiceID(sid string) error
}

ThirdPartySvcDiscoveryCfgDao is an interface for defining method for operating table 3rd_party_svc_discovery_cfg.

type VersionInfoDao Uses

type VersionInfoDao interface {
    Dao
    GetVersionByEventID(eventID string) (*model.VersionInfo, error)
    GetVersionByDeployVersion(version, serviceID string) (*model.VersionInfo, error)
    GetVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
    GetLatestScsVersion(sid string) (*model.VersionInfo, error)
    GetAllVersionByServiceID(serviceID string) ([]*model.VersionInfo, error)
    DeleteVersionByEventID(eventID string) error
    DeleteVersionByServiceID(serviceID string) error
    GetVersionInfo(timePoint time.Time, serviceIDList []string) ([]*model.VersionInfo, error)
    DeleteVersionInfo(obj *model.VersionInfo) error
    DeleteFailureVersionInfo(timePoint time.Time, status string, serviceIDList []string) error
    SearchVersionInfo() ([]*model.VersionInfo, error)
}

VersionInfoDao VersionInfoDao

Package dao imports 4 packages (graph) and is imported by 6 packages. Updated 2019-06-25. Refresh now. Tools for package owners.