repo

package
v0.0.0-...-6bc9dd9 Latest Latest
Warning

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

 Go to latest Published: Sep 8, 2026 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrAlertConfigRevisionConflict = errors.New("alert config revision conflict")
	ErrAlertConfigRevisionRequired = errors.New("alert config revision is required")
)
View Source 
var (
	ErrFirewallRuleRevisionConflict = errors.New("firewall rule revision conflict")
	ErrFirewallPersistenceInvalid   = errors.New("invalid firewall persistence record")
)

Functions

This section is empty.

Types

type AgentAccountModelRepo 

type AgentAccountModelRepo struct{}

func (AgentAccountModelRepo) Create 

func (a AgentAccountModelRepo) Create(item *model.AgentAccountModel) error

func (AgentAccountModelRepo) Delete 

func (a AgentAccountModelRepo) Delete(opts ...DBOption) error

func (AgentAccountModelRepo) DeleteByID 

func (a AgentAccountModelRepo) DeleteByID(id uint) error

func (AgentAccountModelRepo) GetFirst 

func (a AgentAccountModelRepo) GetFirst(opts ...DBOption) (*model.AgentAccountModel, error)

func (AgentAccountModelRepo) List 

func (a AgentAccountModelRepo) List(opts ...DBOption) ([]model.AgentAccountModel, error)

func (AgentAccountModelRepo) Save 

func (a AgentAccountModelRepo) Save(item *model.AgentAccountModel) error

type AgentAccountRepo 

type AgentAccountRepo struct{}

func (AgentAccountRepo) CountTextByProviders 

func (a AgentAccountRepo) CountTextByProviders(providers []string) (map[string]int64, error)

func (AgentAccountRepo) Create 

func (a AgentAccountRepo) Create(account *model.AgentAccount) error

func (AgentAccountRepo) DeleteByID 

func (a AgentAccountRepo) DeleteByID(id uint) error

func (AgentAccountRepo) GetFirst 

func (a AgentAccountRepo) GetFirst(opts ...DBOption) (*model.AgentAccount, error)

func (AgentAccountRepo) List 

func (a AgentAccountRepo) List(opts ...DBOption) ([]model.AgentAccount, error)

func (AgentAccountRepo) Page 

func (a AgentAccountRepo) Page(page, size int, opts ...DBOption) (int64, []model.AgentAccount, error)

func (AgentAccountRepo) Save 

func (a AgentAccountRepo) Save(account *model.AgentAccount) error

func (AgentAccountRepo) WithByMasterAccountID 

func (a AgentAccountRepo) WithByMasterAccountID(masterID uint) DBOption

type AgentRepo 

type AgentRepo struct{}

func (AgentRepo) ClearWebsiteIDByWebsiteIDWithCtx 

func (a AgentRepo) ClearWebsiteIDByWebsiteIDWithCtx(ctx context.Context, websiteID uint) error

func (AgentRepo) Create 

func (a AgentRepo) Create(agent *model.Agent) error

func (AgentRepo) DeleteByAppInstallID 

func (a AgentRepo) DeleteByAppInstallID(appInstallID uint) error

func (AgentRepo) DeleteByAppInstallIDWithCtx 

func (a AgentRepo) DeleteByAppInstallIDWithCtx(ctx context.Context, appInstallID uint) error

func (AgentRepo) DeleteByID 

func (a AgentRepo) DeleteByID(id uint) error

func (AgentRepo) GetFirst 

func (a AgentRepo) GetFirst(opts ...DBOption) (*model.Agent, error)

func (AgentRepo) List 

func (a AgentRepo) List(opts ...DBOption) ([]model.Agent, error)

func (AgentRepo) Page 

func (a AgentRepo) Page(page, size int, opts ...DBOption) (int64, []model.Agent, error)

func (AgentRepo) Save 

func (a AgentRepo) Save(agent *model.Agent) error

type AiRepo 

type AiRepo struct{}

func (*AiRepo) Create 

func (u *AiRepo) Create(item *model.OllamaModel) error

func (*AiRepo) Delete 

func (u *AiRepo) Delete(opts ...DBOption) error

func (*AiRepo) Get 

func (u *AiRepo) Get(opts ...DBOption) (model.OllamaModel, error)

func (*AiRepo) List 

func (u *AiRepo) List(opts ...DBOption) ([]model.OllamaModel, error)

func (*AiRepo) Page 

func (u *AiRepo) Page(page, size int, opts ...DBOption) (int64, []model.OllamaModel, error)

func (*AiRepo) Update 

func (u *AiRepo) Update(id uint, vars map[string]interface{}) error

type AlertRepo 

type AlertRepo struct{}

func (*AlertRepo) AlertConfigList 

func (a *AlertRepo) AlertConfigList(opts ...DBOption) ([]model.AlertConfig, error)

func (*AlertRepo) BatchUpdateLogBy 

func (a *AlertRepo) BatchUpdateLogBy(maps map[string]interface{}, opts ...DBOption) error

func (*AlertRepo) CleanAlertLogs 

func (a *AlertRepo) CleanAlertLogs() error

func (*AlertRepo) Create 

func (a *AlertRepo) Create(alert *model.Alert) error

func (*AlertRepo) CreateAlertConfig 

func (a *AlertRepo) CreateAlertConfig(config *model.AlertConfig) error

func (*AlertRepo) CreateAlertTask 

func (a *AlertRepo) CreateAlertTask(alertTaskBase *model.AlertTask) error

func (*AlertRepo) CreateLog 

func (a *AlertRepo) CreateLog(log *model.AlertLog) error

func (*AlertRepo) CreatePendingAlertTask 

func (a *AlertRepo) CreatePendingAlertTask(logID, alertID uint, alertTask *model.AlertTask) (bool, error)

func (*AlertRepo) Delete 

func (a *AlertRepo) Delete(opts ...DBOption) error

func (*AlertRepo) DeleteAlertConfig 

func (a *AlertRepo) DeleteAlertConfig(opts ...DBOption) error

func (*AlertRepo) DeleteAlertTask 

func (a *AlertRepo) DeleteAlertTask(opts ...DBOption) error

func (*AlertRepo) DeleteLog 

func (a *AlertRepo) DeleteLog(opts ...DBOption) error

func (*AlertRepo) FinalizePendingAlertTask 

func (a *AlertRepo) FinalizePendingAlertTask(logID uint, succeeded bool, message string, fallback *model.AlertTask) (bool, error)

func (*AlertRepo) Get 

func (a *AlertRepo) Get(opts ...DBOption) (model.Alert, error)

func (*AlertRepo) GetAlertTask 

func (a *AlertRepo) GetAlertTask(opts ...DBOption) (model.AlertTask, error)

func (*AlertRepo) GetConfig 

func (a *AlertRepo) GetConfig(opts ...DBOption) (model.AlertConfig, error)

func (*AlertRepo) GetConfigById 

func (a *AlertRepo) GetConfigById(id uint) (model.AlertConfig, error)

func (*AlertRepo) GetLicensePushCount 

func (a *AlertRepo) GetLicensePushCount(method string) (uint, error)

func (*AlertRepo) GetLog 

func (a *AlertRepo) GetLog(opts ...DBOption) (model.AlertLog, error)

func (*AlertRepo) GetTaskLog 

func (a *AlertRepo) GetTaskLog(alertType string, alertId uint) (time.Time, error)

func (*AlertRepo) List 

func (a *AlertRepo) List(opts ...DBOption) ([]model.Alert, error)

func (*AlertRepo) ListLog 

func (a *AlertRepo) ListLog(opts ...DBOption) ([]model.AlertLog, error)

func (*AlertRepo) LoadTaskCount 

func (a *AlertRepo) LoadTaskCount(alertType string, project string, method string) (uint, uint, error)

func (*AlertRepo) Page 

func (a *AlertRepo) Page(page, size int, opts ...DBOption) (int64, []model.Alert, error)

func (*AlertRepo) PageAlertConfig 

func (a *AlertRepo) PageAlertConfig(page, size int, opts ...DBOption) (int64, []model.AlertConfig, error)

func (*AlertRepo) PageLog 

func (a *AlertRepo) PageLog(page, size int, opts ...DBOption) (int64, []model.AlertLog, error)

func (*AlertRepo) Save 

func (a *AlertRepo) Save(alert *model.Alert) error

func (*AlertRepo) SyncAll 

func (a *AlertRepo) SyncAll(data []model.AlertConfig) error

func (*AlertRepo) Update 

func (a *AlertRepo) Update(maps map[string]interface{}, opts ...DBOption) error

func (*AlertRepo) UpdateAlertConfig 

func (a *AlertRepo) UpdateAlertConfig(maps map[string]interface{}, opts ...DBOption) error

func (*AlertRepo) UpdateAlertConfigWithRevision 

func (a *AlertRepo) UpdateAlertConfigWithRevision(maps map[string]interface{}, revision *time.Time, opts ...DBOption) error

func (*AlertRepo) UpdateLog 

func (a *AlertRepo) UpdateLog(id uint, maps map[string]interface{}) error

func (*AlertRepo) WithByAlertId 

func (a *AlertRepo) WithByAlertId(alertId uint) DBOption

func (*AlertRepo) WithByAlertMethodContainsConfigID 

func (a *AlertRepo) WithByAlertMethodContainsConfigID(id uint) DBOption

func (*AlertRepo) WithByCount 

func (a *AlertRepo) WithByCount(count uint) DBOption

func (*AlertRepo) WithByCreateAt 

func (a *AlertRepo) WithByCreateAt(createAt *date.Date) DBOption

func (*AlertRepo) WithByDeliveryLogID 

func (a *AlertRepo) WithByDeliveryLogID(logID uint) DBOption

func (*AlertRepo) WithByLicenseId 

func (a *AlertRepo) WithByLicenseId(licenseId string) DBOption

func (*AlertRepo) WithByMethodConfigIDs 

func (a *AlertRepo) WithByMethodConfigIDs(ids []uint) DBOption

func (*AlertRepo) WithByProject 

func (a *AlertRepo) WithByProject(project string) DBOption

func (*AlertRepo) WithByRecordId 

func (a *AlertRepo) WithByRecordId(recordId uint) DBOption

func (*AlertRepo) WithByStatusIn 

func (a *AlertRepo) WithByStatusIn(status []string) DBOption

func (*AlertRepo) WithByType 

func (a *AlertRepo) WithByType(alertType string) DBOption

func (*AlertRepo) WithByTypeNotIn 

func (a *AlertRepo) WithByTypeNotIn(types []string) DBOption

type AppDetailRepo 

type AppDetailRepo struct {
}

func (AppDetailRepo) BatchCreate 

func (a AppDetailRepo) BatchCreate(ctx context.Context, details []model.AppDetail) error

func (AppDetailRepo) BatchDelete 

func (a AppDetailRepo) BatchDelete(ctx context.Context, appDetails []model.AppDetail) error

func (AppDetailRepo) BatchUpdateBy 

func (a AppDetailRepo) BatchUpdateBy(maps map[string]interface{}, opts ...DBOption) error

func (AppDetailRepo) DeleteByAppIds 

func (a AppDetailRepo) DeleteByAppIds(ctx context.Context, appIds []uint) error

func (AppDetailRepo) DeleteByIDs 

func (a AppDetailRepo) DeleteByIDs(ctx context.Context, appIds []uint) error

func (AppDetailRepo) GetBy 

func (a AppDetailRepo) GetBy(opts ...DBOption) ([]model.AppDetail, error)

func (AppDetailRepo) GetFirst 

func (a AppDetailRepo) GetFirst(opts ...DBOption) (model.AppDetail, error)

func (AppDetailRepo) Update 

func (a AppDetailRepo) Update(ctx context.Context, detail model.AppDetail) error

func (AppDetailRepo) WithAppId 

func (a AppDetailRepo) WithAppId(id uint) DBOption

func (AppDetailRepo) WithIgnored 

func (a AppDetailRepo) WithIgnored() DBOption

func (AppDetailRepo) WithVersion 

func (a AppDetailRepo) WithVersion(version string) DBOption

type AppIgnoreUpgradeRepo 

type AppIgnoreUpgradeRepo struct {
}

func (AppIgnoreUpgradeRepo) Create 

func (a AppIgnoreUpgradeRepo) Create(appIgnoreUpgrade *model.AppIgnoreUpgrade) error

func (AppIgnoreUpgradeRepo) Delete 

func (a AppIgnoreUpgradeRepo) Delete(opts ...DBOption) error

func (AppIgnoreUpgradeRepo) List 

func (a AppIgnoreUpgradeRepo) List(opts ...DBOption) ([]model.AppIgnoreUpgrade, error)

func (AppIgnoreUpgradeRepo) WithAppID 

func (a AppIgnoreUpgradeRepo) WithAppID(appID uint) DBOption

func (AppIgnoreUpgradeRepo) WithScope 

func (a AppIgnoreUpgradeRepo) WithScope(scope string) DBOption

type AppInstallRepo 

type AppInstallRepo struct{}

func (*AppInstallRepo) BatchUpdateBy 

func (a *AppInstallRepo) BatchUpdateBy(maps map[string]interface{}, opts ...DBOption) error

func (*AppInstallRepo) Create 

func (a *AppInstallRepo) Create(ctx context.Context, install *model.AppInstall) error

func (*AppInstallRepo) Delete 

func (a *AppInstallRepo) Delete(ctx context.Context, install model.AppInstall) error

func (*AppInstallRepo) DeleteBy 

func (a *AppInstallRepo) DeleteBy(opts ...DBOption) error

func (*AppInstallRepo) GetFirst 

func (a *AppInstallRepo) GetFirst(opts ...DBOption) (model.AppInstall, error)

func (*AppInstallRepo) GetFirstByCtx 

func (a *AppInstallRepo) GetFirstByCtx(ctx context.Context, opts ...DBOption) (model.AppInstall, error)

func (*AppInstallRepo) ListBy 

func (a *AppInstallRepo) ListBy(ctx context.Context, opts ...DBOption) ([]model.AppInstall, error)

func (*AppInstallRepo) LoadBaseInfo 

func (a *AppInstallRepo) LoadBaseInfo(key string, name string) (*RootInfo, error)

func (*AppInstallRepo) LoadInstallAppByKeyAndName 

func (a *AppInstallRepo) LoadInstallAppByKeyAndName(key string, name string) (*model.AppInstall, error)

func (*AppInstallRepo) Page 

func (a *AppInstallRepo) Page(page, size int, opts ...DBOption) (int64, []model.AppInstall, error)

func (*AppInstallRepo) Save 

func (a *AppInstallRepo) Save(ctx context.Context, install *model.AppInstall) error

func (*AppInstallRepo) WithAppId 

func (a *AppInstallRepo) WithAppId(appId uint) DBOption

func (*AppInstallRepo) WithAppIdsIn 

func (a *AppInstallRepo) WithAppIdsIn(appIds []uint) DBOption

func (*AppInstallRepo) WithAppIdsNotIn 

func (a *AppInstallRepo) WithAppIdsNotIn(appIds []uint) DBOption

func (*AppInstallRepo) WithContainerName 

func (a *AppInstallRepo) WithContainerName(containerName string) DBOption

func (*AppInstallRepo) WithDetailIdNotIn 

func (a *AppInstallRepo) WithDetailIdNotIn(detailIds []uint) DBOption

func (*AppInstallRepo) WithDetailIdsIn 

func (a *AppInstallRepo) WithDetailIdsIn(detailIds []uint) DBOption

func (*AppInstallRepo) WithIDNotIs 

func (a *AppInstallRepo) WithIDNotIs(id uint) DBOption

func (*AppInstallRepo) WithIdNotInWebsite 

func (a *AppInstallRepo) WithIdNotInWebsite() DBOption

func (*AppInstallRepo) WithPort 

func (a *AppInstallRepo) WithPort(port int) DBOption

func (*AppInstallRepo) WithServiceName 

func (a *AppInstallRepo) WithServiceName(serviceName string) DBOption

func (*AppInstallRepo) WithStatus 

func (a *AppInstallRepo) WithStatus(status string) DBOption

type AppInstallResourceRpo 

type AppInstallResourceRpo struct {
}

func (AppInstallResourceRpo) BatchUpdateBy 

func (a AppInstallResourceRpo) BatchUpdateBy(maps map[string]interface{}, opts ...DBOption) error

func (AppInstallResourceRpo) Create 

func (a AppInstallResourceRpo) Create(ctx context.Context, resource *model.AppInstallResource) error

func (AppInstallResourceRpo) DeleteBy 

func (a AppInstallResourceRpo) DeleteBy(ctx context.Context, opts ...DBOption) error

func (AppInstallResourceRpo) GetBy 

func (a AppInstallResourceRpo) GetBy(opts ...DBOption) ([]model.AppInstallResource, error)

func (AppInstallResourceRpo) GetFirst 

func (a AppInstallResourceRpo) GetFirst(opts ...DBOption) (model.AppInstallResource, error)

func (AppInstallResourceRpo) WithAppInstallId 

func (a AppInstallResourceRpo) WithAppInstallId(appInstallId uint) DBOption

func (AppInstallResourceRpo) WithLinkId 

func (a AppInstallResourceRpo) WithLinkId(linkId uint) DBOption

func (AppInstallResourceRpo) WithResourceId 

func (a AppInstallResourceRpo) WithResourceId(resourceId uint) DBOption

func (AppInstallResourceRpo) WithResourceIds 

func (a AppInstallResourceRpo) WithResourceIds(resourceIds []uint) DBOption

type AppRepo 

type AppRepo struct {
}

func (AppRepo) BatchCreate 

func (a AppRepo) BatchCreate(ctx context.Context, apps []model.App) error

func (AppRepo) BatchDelete 

func (a AppRepo) BatchDelete(ctx context.Context, apps []model.App) error

func (AppRepo) Create 

func (a AppRepo) Create(ctx context.Context, app *model.App) error

func (AppRepo) DeleteBy 

func (a AppRepo) DeleteBy(opts ...DBOption) error

func (AppRepo) DeleteByIDs 

func (a AppRepo) DeleteByIDs(ctx context.Context, ids []uint) error

func (AppRepo) GetBy 

func (a AppRepo) GetBy(opts ...DBOption) ([]model.App, error)

func (AppRepo) GetFirst 

func (a AppRepo) GetFirst(opts ...DBOption) (model.App, error)

func (AppRepo) GetRecommend 

func (a AppRepo) GetRecommend() DBOption

func (AppRepo) GetTopRecommend 

func (a AppRepo) GetTopRecommend() ([]string, error)

func (AppRepo) OrderByRecommend 

func (a AppRepo) OrderByRecommend() DBOption

func (AppRepo) Page 

func (a AppRepo) Page(page, size int, opts ...DBOption) (int64, []model.App, error)

func (AppRepo) Save 

func (a AppRepo) Save(ctx context.Context, app *model.App) error

func (AppRepo) WithArch 

func (a AppRepo) WithArch(arch string) DBOption

func (AppRepo) WithByLikeName 

func (a AppRepo) WithByLikeName(name string) DBOption

func (AppRepo) WithKey 

func (a AppRepo) WithKey(key string) DBOption

func (AppRepo) WithKeyIn 

func (a AppRepo) WithKeyIn(keys []string) DBOption

func (AppRepo) WithNotLocal 

func (a AppRepo) WithNotLocal() DBOption

func (AppRepo) WithPanelVersion 

func (a AppRepo) WithPanelVersion(panelVersion string) DBOption

func (AppRepo) WithResource 

func (a AppRepo) WithResource(resource string) DBOption

func (AppRepo) WithType 

func (a AppRepo) WithType(typeStr string) DBOption

type AppTagRepo 

type AppTagRepo struct {
}

func (AppTagRepo) BatchCreate 

func (a AppTagRepo) BatchCreate(ctx context.Context, tags []*model.AppTag) error

func (AppTagRepo) DeleteAll 

func (a AppTagRepo) DeleteAll(ctx context.Context) error

func (AppTagRepo) DeleteBy 

func (a AppTagRepo) DeleteBy(ctx context.Context, opts ...DBOption) error

func (AppTagRepo) DeleteByAppIds 

func (a AppTagRepo) DeleteByAppIds(ctx context.Context, appIds []uint) error

func (AppTagRepo) GetByAppId 

func (a AppTagRepo) GetByAppId(appId uint) ([]model.AppTag, error)

func (AppTagRepo) GetByTagIds 

func (a AppTagRepo) GetByTagIds(tagIds []uint) ([]model.AppTag, error)

func (AppTagRepo) GetFirst 

func (a AppTagRepo) GetFirst(ctx context.Context, opts ...DBOption) (*model.AppTag, error)

func (AppTagRepo) WithByAppID 

func (a AppTagRepo) WithByAppID(appId uint) DBOption

func (AppTagRepo) WithByTagID 

func (a AppTagRepo) WithByTagID(tagID uint) DBOption

type BackupRepo 

type BackupRepo struct{}

func (*BackupRepo) Create 

func (u *BackupRepo) Create(backup *model.BackupAccount) error

func (*BackupRepo) CreateRecord 

func (u *BackupRepo) CreateRecord(record *model.BackupRecord) error

func (*BackupRepo) Delete 

func (u *BackupRepo) Delete(opts ...DBOption) error

func (*BackupRepo) DeleteRecord 

func (u *BackupRepo) DeleteRecord(ctx context.Context, opts ...DBOption) error

func (*BackupRepo) Get 

func (u *BackupRepo) Get(opts ...DBOption) (model.BackupAccount, error)

func (*BackupRepo) GetRecord 

func (u *BackupRepo) GetRecord(opts ...DBOption) (*model.BackupRecord, error)

func (*BackupRepo) List 

func (u *BackupRepo) List(opts ...DBOption) ([]model.BackupAccount, error)

func (*BackupRepo) ListRecord 

func (u *BackupRepo) ListRecord(opts ...DBOption) ([]model.BackupRecord, error)

func (*BackupRepo) Page 

func (u *BackupRepo) Page(page, size int, opts ...DBOption) (int64, []model.BackupAccount, error)

func (*BackupRepo) PageRecord 

func (u *BackupRepo) PageRecord(page, size int, opts ...DBOption) (int64, []model.BackupRecord, error)

func (*BackupRepo) Save 

func (u *BackupRepo) Save(backup *model.BackupAccount) error

func (*BackupRepo) SyncAll 

func (u *BackupRepo) SyncAll(data []model.BackupAccount) error

func (*BackupRepo) UpdateRecord 

func (u *BackupRepo) UpdateRecord(record *model.BackupRecord) error

func (*BackupRepo) UpdateRecordByMap 

func (u *BackupRepo) UpdateRecordByMap(id uint, upMap map[string]interface{}) error

func (*BackupRepo) WithByCronID 

func (u *BackupRepo) WithByCronID(cronjobID uint) DBOption

func (*BackupRepo) WithByDetailName 

func (u *BackupRepo) WithByDetailName(detailName string) DBOption

func (*BackupRepo) WithByFileName 

func (u *BackupRepo) WithByFileName(fileName string) DBOption

func (*BackupRepo) WithByPublic 

func (u *BackupRepo) WithByPublic(isPublic bool) DBOption

func (*BackupRepo) WithFileNameStartWith 

func (u *BackupRepo) WithFileNameStartWith(filePrefix string) DBOption

type ClamRepo 

type ClamRepo struct{}

func (*ClamRepo) Create 

func (u *ClamRepo) Create(clam *model.Clam) error

func (*ClamRepo) Delete 

func (u *ClamRepo) Delete(opts ...DBOption) error

func (*ClamRepo) DeleteRecord 

func (u *ClamRepo) DeleteRecord(opts ...DBOption) error

func (*ClamRepo) EndRecords 

func (u *ClamRepo) EndRecords(record model.ClamRecord, status, message string)

func (*ClamRepo) Get 

func (u *ClamRepo) Get(opts ...DBOption) (model.Clam, error)

func (*ClamRepo) List 

func (u *ClamRepo) List(opts ...DBOption) ([]model.Clam, error)

func (*ClamRepo) ListRecord 

func (u *ClamRepo) ListRecord(opts ...DBOption) ([]model.ClamRecord, error)

func (*ClamRepo) Page 

func (u *ClamRepo) Page(page, size int, opts ...DBOption) (int64, []model.Clam, error)

func (*ClamRepo) PageRecords 

func (u *ClamRepo) PageRecords(page, size int, opts ...DBOption) (int64, []model.ClamRecord, error)

func (*ClamRepo) RecordFirst 

func (u *ClamRepo) RecordFirst(id uint) (model.ClamRecord, error)

func (*ClamRepo) StartRecords 

func (u *ClamRepo) StartRecords(clamID uint) model.ClamRecord

func (*ClamRepo) Update 

func (u *ClamRepo) Update(id uint, vars map[string]interface{}) error

func (*ClamRepo) WithByClamID 

func (c *ClamRepo) WithByClamID(id uint) DBOption

type ComposeTemplateRepo 

type ComposeTemplateRepo struct{}

func (*ComposeTemplateRepo) Create 

func (u *ComposeTemplateRepo) Create(compose *model.ComposeTemplate) error

func (*ComposeTemplateRepo) CreateRecord 

func (u *ComposeTemplateRepo) CreateRecord(compose *model.Compose) error

func (*ComposeTemplateRepo) Delete 

func (u *ComposeTemplateRepo) Delete(opts ...DBOption) error

func (*ComposeTemplateRepo) DeleteRecord 

func (u *ComposeTemplateRepo) DeleteRecord(opts ...DBOption) error

func (*ComposeTemplateRepo) Get 

func (u *ComposeTemplateRepo) Get(opts ...DBOption) (model.ComposeTemplate, error)

func (*ComposeTemplateRepo) GetRecord 

func (u *ComposeTemplateRepo) GetRecord(opts ...DBOption) (model.Compose, error)

func (*ComposeTemplateRepo) List 

func (u *ComposeTemplateRepo) List(opts ...DBOption) ([]model.ComposeTemplate, error)

func (*ComposeTemplateRepo) ListRecord 

func (u *ComposeTemplateRepo) ListRecord() ([]model.Compose, error)

func (*ComposeTemplateRepo) Page 

func (u *ComposeTemplateRepo) Page(page, size int, opts ...DBOption) (int64, []model.ComposeTemplate, error)

func (*ComposeTemplateRepo) Update 

func (u *ComposeTemplateRepo) Update(id uint, vars map[string]interface{}) error

func (*ComposeTemplateRepo) UpdateRecord 

func (u *ComposeTemplateRepo) UpdateRecord(name string, vars map[string]interface{}) error

type CronjobRepo 

type CronjobRepo struct{}

func (*CronjobRepo) AddFailedRecord 

func (u *CronjobRepo) AddFailedRecord(cronjobID uint, message string)

func (*CronjobRepo) Create 

func (u *CronjobRepo) Create(cronjob *model.Cronjob) error

func (*CronjobRepo) Delete 

func (u *CronjobRepo) Delete(opts ...DBOption) error

func (*CronjobRepo) DeleteRecord 

func (u *CronjobRepo) DeleteRecord(opts ...DBOption) error

func (*CronjobRepo) EndRecords 

func (u *CronjobRepo) EndRecords(record model.JobRecords, status, message, records string)

func (*CronjobRepo) Get 

func (u *CronjobRepo) Get(opts ...DBOption) (model.Cronjob, error)

func (*CronjobRepo) GetRecord 

func (u *CronjobRepo) GetRecord(opts ...DBOption) (model.JobRecords, error)

func (*CronjobRepo) List 

func (u *CronjobRepo) List(opts ...DBOption) ([]model.Cronjob, error)

func (*CronjobRepo) ListRecord 

func (u *CronjobRepo) ListRecord(opts ...DBOption) ([]model.JobRecords, error)

func (*CronjobRepo) Page 

func (u *CronjobRepo) Page(page, size int, opts ...DBOption) (int64, []model.Cronjob, error)

func (*CronjobRepo) PageRecords 

func (u *CronjobRepo) PageRecords(page, size int, opts ...DBOption) (int64, []model.JobRecords, error)

func (*CronjobRepo) RecordFirst 

func (u *CronjobRepo) RecordFirst(id uint) (model.JobRecords, error)

func (*CronjobRepo) Save 

func (u *CronjobRepo) Save(id uint, cronjob model.Cronjob) error

func (*CronjobRepo) StartRecords 

func (u *CronjobRepo) StartRecords(cronjobID uint) model.JobRecords

func (*CronjobRepo) Update 

func (u *CronjobRepo) Update(id uint, vars map[string]interface{}) error

func (*CronjobRepo) UpdateRecords 

func (u *CronjobRepo) UpdateRecords(id uint, vars map[string]interface{}) error

func (*CronjobRepo) WithByDbName 

func (c *CronjobRepo) WithByDbName(name string) DBOption

func (*CronjobRepo) WithByDownloadAccountID 

func (c *CronjobRepo) WithByDownloadAccountID(id uint) DBOption

func (*CronjobRepo) WithByJobID 

func (c *CronjobRepo) WithByJobID(id int) DBOption

func (*CronjobRepo) WithByRecordDropID 

func (c *CronjobRepo) WithByRecordDropID(id int) DBOption

func (*CronjobRepo) WithByRecordFile 

func (c *CronjobRepo) WithByRecordFile(file string) DBOption

type DBOption 

type DBOption func(*gorm.DB) *gorm.DB

func WithByAPIType 

func WithByAPIType(apiType string) DBOption

func WithByAccountID 

func WithByAccountID(accountID uint) DBOption

func WithByAddr 

func WithByAddr(addr string) DBOption

func WithByAppInstallID 

func WithByAppInstallID(appInstallID uint) DBOption

func WithByCreatedAt 

func WithByCreatedAt(startTime, endTime time.Time) DBOption

func WithByDate 

func WithByDate(startTime, endTime time.Time) DBOption

func WithByDetailName 

func WithByDetailName(detailName string) DBOption

func WithByDetailType 

func WithByDetailType(tp string) DBOption

func WithByFrom 

func WithByFrom(from string) DBOption

func WithByGroupID 

func WithByGroupID(id uint) DBOption

func WithByGroups 

func WithByGroups(groupIDs []uint) DBOption

func WithByID 

func WithByID(id uint) DBOption

func WithByIDNotIn 

func WithByIDNotIn(ids []uint) DBOption

func WithByIDs 

func WithByIDs(ids []uint) DBOption

func WithByKey 

func WithByKey(key string) DBOption

func WithByLikeName 

func WithByLikeName(name string) DBOption

func WithByLowerName 

func WithByLowerName(name string) DBOption

func WithByModel 

func WithByModel(model string) DBOption

func WithByNOTID 

func WithByNOTID(id uint) DBOption

func WithByName 

func WithByName(name string) DBOption

func WithByPath 

func WithByPath(path string) DBOption

func WithByProvider 

func WithByProvider(provider string) DBOption

func WithByStatus 

func WithByStatus(status string) DBOption

func WithByType 

func WithByType(tp string) DBOption

func WithByWebsiteID 

func WithByWebsiteID(websiteID uint) DBOption

func WithFirewallRuleSource 

func WithFirewallRuleSource(kind, id string) DBOption

func WithOrderAsc 

func WithOrderAsc(orderBy string) DBOption

func WithOrderDesc 

func WithOrderDesc(orderBy string) DBOption

func WithOrderRuleBy 

func WithOrderRuleBy(orderBy, order string) DBOption

func WithTextAPIType 

func WithTextAPIType() DBOption

func WithTypes 

func WithTypes(types []string) DBOption

type DatabaseRepo 

type DatabaseRepo struct{}

func (*DatabaseRepo) Create 

func (d *DatabaseRepo) Create(ctx context.Context, database *model.Database) error

func (*DatabaseRepo) Delete 

func (d *DatabaseRepo) Delete(ctx context.Context, opts ...DBOption) error

func (*DatabaseRepo) Get 

func (d *DatabaseRepo) Get(opts ...DBOption) (model.Database, error)

func (*DatabaseRepo) GetList 

func (d *DatabaseRepo) GetList(opts ...DBOption) ([]model.Database, error)

func (*DatabaseRepo) Page 

func (d *DatabaseRepo) Page(page, size int, opts ...DBOption) (int64, []model.Database, error)

func (*DatabaseRepo) Update 

func (d *DatabaseRepo) Update(id uint, vars map[string]interface{}) error

func (*DatabaseRepo) WithAppInstallID 

func (d *DatabaseRepo) WithAppInstallID(appInstallID uint) DBOption

func (*DatabaseRepo) WithTypeList 

func (d *DatabaseRepo) WithTypeList(dbType string) DBOption

func (*DatabaseRepo) WithoutByFrom 

func (d *DatabaseRepo) WithoutByFrom(from string) DBOption

type DatabaseUserGrantRepo 

type DatabaseUserGrantRepo struct{}

func (*DatabaseUserGrantRepo) Delete 

func (u *DatabaseUserGrantRepo) Delete(opts ...DBOption) error

func (*DatabaseUserGrantRepo) DeleteBy 

func (u *DatabaseUserGrantRepo) DeleteBy(ctx context.Context, opts ...DBOption) error

func (*DatabaseUserGrantRepo) Get 

func (u *DatabaseUserGrantRepo) Get(opts ...DBOption) (model.DatabaseUserGrant, error)

func (*DatabaseUserGrantRepo) List 

func (u *DatabaseUserGrantRepo) List(opts ...DBOption) ([]model.DatabaseUserGrant, error)

func (*DatabaseUserGrantRepo) Replace 

func (u *DatabaseUserGrantRepo) Replace(dbType, database string, grants []model.DatabaseUserGrant) error

func (*DatabaseUserGrantRepo) Save 

func (u *DatabaseUserGrantRepo) Save(grant *model.DatabaseUserGrant) error

func (*DatabaseUserGrantRepo) Update 

func (u *DatabaseUserGrantRepo) Update(vars map[string]interface{}, opts ...DBOption) error

func (*DatabaseUserGrantRepo) WithByDBName 

func (u *DatabaseUserGrantRepo) WithByDBName(dbName string) DBOption

func (*DatabaseUserGrantRepo) WithByDBNames 

func (u *DatabaseUserGrantRepo) WithByDBNames(dbNames []string) DBOption

func (*DatabaseUserGrantRepo) WithByDatabase 

func (u *DatabaseUserGrantRepo) WithByDatabase(database string) DBOption

func (*DatabaseUserGrantRepo) WithByUser 

func (u *DatabaseUserGrantRepo) WithByUser(username, host string) DBOption

type DatabaseUserRepo 

type DatabaseUserRepo struct{}

func (*DatabaseUserRepo) Delete 

func (u *DatabaseUserRepo) Delete(opts ...DBOption) error

func (*DatabaseUserRepo) DeleteBy 

func (u *DatabaseUserRepo) DeleteBy(ctx context.Context, opts ...DBOption) error

func (*DatabaseUserRepo) Get 

func (u *DatabaseUserRepo) Get(opts ...DBOption) (model.DatabaseUser, error)

func (*DatabaseUserRepo) List 

func (u *DatabaseUserRepo) List(opts ...DBOption) ([]model.DatabaseUser, error)

func (*DatabaseUserRepo) Save 

func (u *DatabaseUserRepo) Save(user *model.DatabaseUser) error

func (*DatabaseUserRepo) Update 

func (u *DatabaseUserRepo) Update(vars map[string]interface{}, opts ...DBOption) error

func (*DatabaseUserRepo) WithByDatabase 

func (u *DatabaseUserRepo) WithByDatabase(database string) DBOption

func (*DatabaseUserRepo) WithByUser 

func (u *DatabaseUserRepo) WithByUser(username, host string) DBOption

func (*DatabaseUserRepo) WithByUserList 

func (u *DatabaseUserRepo) WithByUserList(users [][2]string) DBOption

type DockerPortGuardRepo 

type DockerPortGuardRepo struct{}

func (*DockerPortGuardRepo) DeleteBatch 

func (r *DockerPortGuardRepo) DeleteBatch(ctx context.Context, uuids []string) error

func (*DockerPortGuardRepo) ListManaged 

func (r *DockerPortGuardRepo) ListManaged(ctx context.Context) ([]model.DockerPortGuardPolicy, error)

func (*DockerPortGuardRepo) ListRuntimeReadOnly 

func (r *DockerPortGuardRepo) ListRuntimeReadOnly(ctx context.Context) ([]model.DockerPortGuardPolicy, error)

func (*DockerPortGuardRepo) ReplaceRuntimeReadOnly 

func (r *DockerPortGuardRepo) ReplaceRuntimeReadOnly(ctx context.Context, policies []model.DockerPortGuardPolicy) error

func (*DockerPortGuardRepo) UpsertBatch 

func (r *DockerPortGuardRepo) UpsertBatch(ctx context.Context, policies []model.DockerPortGuardPolicy) error

type FavoriteRepo 

type FavoriteRepo struct{}

func (*FavoriteRepo) All 

func (f *FavoriteRepo) All() ([]model.Favorite, error)

func (*FavoriteRepo) Create 

func (f *FavoriteRepo) Create(favorite *model.Favorite) error

func (*FavoriteRepo) Delete 

func (f *FavoriteRepo) Delete(opts ...DBOption) error

func (*FavoriteRepo) GetFirst 

func (f *FavoriteRepo) GetFirst(opts ...DBOption) (model.Favorite, error)

func (*FavoriteRepo) Page 

func (f *FavoriteRepo) Page(page, size int, opts ...DBOption) (int64, []model.Favorite, error)

func (*FavoriteRepo) WithByPath 

func (f *FavoriteRepo) WithByPath(path string) DBOption

type FileHistoryRepo 

type FileHistoryRepo struct{}

func (*FileHistoryRepo) Create 

func (r *FileHistoryRepo) Create(history *model.FileHistory) error

func (*FileHistoryRepo) Delete 

func (r *FileHistoryRepo) Delete(opts ...DBOption) error

func (*FileHistoryRepo) DeleteByIDs 

func (r *FileHistoryRepo) DeleteByIDs(ids []uint) error

func (*FileHistoryRepo) Get 

func (r *FileHistoryRepo) Get(opts ...DBOption) (model.FileHistory, error)

func (*FileHistoryRepo) Page 

func (r *FileHistoryRepo) Page(limit, offset int, opts ...DBOption) (int64, []model.FileHistory, error)

func (*FileHistoryRepo) WithByFileID 

func (r *FileHistoryRepo) WithByFileID(fileID string) DBOption

func (*FileHistoryRepo) WithByID 

func (r *FileHistoryRepo) WithByID(id uint) DBOption

func (*FileHistoryRepo) WithByOperation 

func (r *FileHistoryRepo) WithByOperation(operation string) DBOption

func (*FileHistoryRepo) WithByPath 

func (r *FileHistoryRepo) WithByPath(path string) DBOption

func (*FileHistoryRepo) WithByPathHash 

func (r *FileHistoryRepo) WithByPathHash(pathHash string) DBOption

func (*FileHistoryRepo) WithByPathLike 

func (r *FileHistoryRepo) WithByPathLike(path string) DBOption

func (*FileHistoryRepo) WithByRelatedPath 

func (r *FileHistoryRepo) WithByRelatedPath(path string) DBOption

func (*FileHistoryRepo) WithNotOperation 

func (r *FileHistoryRepo) WithNotOperation(operation string) DBOption

type FileShareRepo 

type FileShareRepo struct{}

func (*FileShareRepo) All 

func (r *FileShareRepo) All() ([]model.FileShare, error)

func (*FileShareRepo) Create 

func (r *FileShareRepo) Create(fileShare *model.FileShare) error

func (*FileShareRepo) Delete 

func (r *FileShareRepo) Delete(opts ...DBOption) error

func (*FileShareRepo) GetFirst 

func (r *FileShareRepo) GetFirst(opts ...DBOption) (model.FileShare, error)

func (*FileShareRepo) Page 

func (r *FileShareRepo) Page(page, size int, opts ...DBOption) (int64, []model.FileShare, error)

func (*FileShareRepo) Save 

func (r *FileShareRepo) Save(fileShare *model.FileShare) error

func (*FileShareRepo) WithByCode 

func (r *FileShareRepo) WithByCode(code string) DBOption

func (*FileShareRepo) WithByPath 

func (r *FileShareRepo) WithByPath(path string) DBOption

type FirewallRuleRepo 

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

func NewFirewallRuleRepo 

func NewFirewallRuleRepo(db *gorm.DB) *FirewallRuleRepo

func (*FirewallRuleRepo) Create 

func (r *FirewallRuleRepo) Create(ctx context.Context, rule *model.FirewallRule) error

func (*FirewallRuleRepo) DeleteWithRevision 

func (r *FirewallRuleRepo) DeleteWithRevision(ctx context.Context, ruleUUID string, expectedRevision uint) error

func (*FirewallRuleRepo) GetByUUID 

func (r *FirewallRuleRepo) GetByUUID(ctx context.Context, ruleUUID string) (model.FirewallRule, error)

func (*FirewallRuleRepo) List 

func (r *FirewallRuleRepo) List(ctx context.Context, opts ...DBOption) ([]model.FirewallRule, error)

func (*FirewallRuleRepo) UpdateWithRevision 

func (r *FirewallRuleRepo) UpdateWithRevision(ctx context.Context, ruleUUID string, expectedRevision uint, updates map[string]interface{}) error

type ForwardingRuleRepo 

type ForwardingRuleRepo struct{}

func (*ForwardingRuleRepo) List 

func (r *ForwardingRuleRepo) List(ctx context.Context) ([]model.ForwardingRule, error)

func (*ForwardingRuleRepo) ReplaceAll 

func (r *ForwardingRuleRepo) ReplaceAll(ctx context.Context, rules []model.ForwardingRule) error

type FtpRepo 

type FtpRepo struct{}

func (*FtpRepo) Create 

func (h *FtpRepo) Create(ftp *model.Ftp) error

func (*FtpRepo) Delete 

func (h *FtpRepo) Delete(opts ...DBOption) error

func (*FtpRepo) Get 

func (u *FtpRepo) Get(opts ...DBOption) (model.Ftp, error)

func (*FtpRepo) GetList 

func (u *FtpRepo) GetList(opts ...DBOption) ([]model.Ftp, error)

func (*FtpRepo) Page 

func (h *FtpRepo) Page(page, size int, opts ...DBOption) (int64, []model.Ftp, error)

func (*FtpRepo) Update 

func (h *FtpRepo) Update(id uint, vars map[string]interface{}) error

func (*FtpRepo) WithByUser 

func (h *FtpRepo) WithByUser(user string) DBOption

func (*FtpRepo) WithLikeUser 

func (h *FtpRepo) WithLikeUser(user string) DBOption

type GroupRepo 

type GroupRepo struct{}

func (*GroupRepo) CancelDefault 

func (g *GroupRepo) CancelDefault(groupType string) error

func (*GroupRepo) Create 

func (g *GroupRepo) Create(group *model.Group) error

func (*GroupRepo) Delete 

func (g *GroupRepo) Delete(opts ...DBOption) error

func (*GroupRepo) Get 

func (g *GroupRepo) Get(opts ...DBOption) (model.Group, error)

func (*GroupRepo) GetList 

func (g *GroupRepo) GetList(opts ...DBOption) ([]model.Group, error)

func (*GroupRepo) Update 

func (g *GroupRepo) Update(id uint, vars map[string]interface{}) error

func (*GroupRepo) WithByDefault 

func (g *GroupRepo) WithByDefault(isDefault bool) DBOption

func (*GroupRepo) WithByWebsiteDefault 

func (g *GroupRepo) WithByWebsiteDefault() DBOption

type HostRepo 

type HostRepo struct{}

func (*HostRepo) Create 

func (h *HostRepo) Create(host *model.Host) error

func (*HostRepo) Delete 

func (h *HostRepo) Delete(opts ...DBOption) error

func (*HostRepo) DeleteCert 

func (u *HostRepo) DeleteCert(opts ...DBOption) error

func (*HostRepo) Get 

func (h *HostRepo) Get(opts ...DBOption) (model.Host, error)

func (*HostRepo) GetCert 

func (u *HostRepo) GetCert(opts ...DBOption) (model.RootCert, error)

func (*HostRepo) GetList 

func (h *HostRepo) GetList(opts ...DBOption) ([]model.Host, error)

func (*HostRepo) ListCert 

func (u *HostRepo) ListCert(opts ...DBOption) ([]model.RootCert, error)

func (*HostRepo) Page 

func (h *HostRepo) Page(page, size int, opts ...DBOption) (int64, []model.Host, error)

func (*HostRepo) PageCert 

func (u *HostRepo) PageCert(page, size int, opts ...DBOption) (int64, []model.RootCert, error)

func (*HostRepo) SaveCert 

func (u *HostRepo) SaveCert(cert *model.RootCert) error

func (*HostRepo) SyncCert 

func (u *HostRepo) SyncCert(data []model.RootCert) error

func (*HostRepo) Update 

func (h *HostRepo) Update(id uint, vars map[string]interface{}) error

func (*HostRepo) UpdateCert 

func (u *HostRepo) UpdateCert(id uint, vars map[string]interface{}) error

func (*HostRepo) UpdateGroup 

func (h *HostRepo) UpdateGroup(group, newGroup uint) error

func (*HostRepo) WithByInfo 

func (h *HostRepo) WithByInfo(info string) DBOption

func (*HostRepo) WithByPort 

func (h *HostRepo) WithByPort(port uint) DBOption

func (*HostRepo) WithByUser 

func (h *HostRepo) WithByUser(user string) DBOption

type IAcmeAccountRepo 

type IAcmeAccountRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.WebsiteAcmeAccount, error)
	GetFirst(opts ...DBOption) (*model.WebsiteAcmeAccount, error)
	Create(account model.WebsiteAcmeAccount) error
	Save(account model.WebsiteAcmeAccount) error
	DeleteBy(opts ...DBOption) error
	WithEmail(email string) DBOption
	WithType(acType string) DBOption
}

func NewIAcmeAccountRepo 

func NewIAcmeAccountRepo() IAcmeAccountRepo

type IAgentAccountModelRepo 

type IAgentAccountModelRepo interface {
	List(opts ...DBOption) ([]model.AgentAccountModel, error)
	GetFirst(opts ...DBOption) (*model.AgentAccountModel, error)
	Create(item *model.AgentAccountModel) error
	Save(item *model.AgentAccountModel) error
	DeleteByID(id uint) error
	Delete(opts ...DBOption) error
}

func NewIAgentAccountModelRepo 

func NewIAgentAccountModelRepo() IAgentAccountModelRepo

type IAgentAccountRepo 

type IAgentAccountRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.AgentAccount, error)
	GetFirst(opts ...DBOption) (*model.AgentAccount, error)
	WithByMasterAccountID(masterID uint) DBOption
	Create(account *model.AgentAccount) error
	Save(account *model.AgentAccount) error
	DeleteByID(id uint) error
	List(opts ...DBOption) ([]model.AgentAccount, error)
	CountTextByProviders(providers []string) (map[string]int64, error)
}

func NewIAgentAccountRepo 

func NewIAgentAccountRepo() IAgentAccountRepo

type IAgentRepo 

type IAgentRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.Agent, error)
	GetFirst(opts ...DBOption) (*model.Agent, error)
	Create(agent *model.Agent) error
	Save(agent *model.Agent) error
	DeleteByID(id uint) error
	DeleteByAppInstallID(appInstallID uint) error
	DeleteByAppInstallIDWithCtx(ctx context.Context, appInstallID uint) error
	ClearWebsiteIDByWebsiteIDWithCtx(ctx context.Context, websiteID uint) error
	List(opts ...DBOption) ([]model.Agent, error)
}

func NewIAgentRepo 

func NewIAgentRepo() IAgentRepo

type IAiRepo 

type IAiRepo interface {
	Get(opts ...DBOption) (model.OllamaModel, error)
	List(opts ...DBOption) ([]model.OllamaModel, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.OllamaModel, error)
	Create(cronjob *model.OllamaModel) error
	Update(id uint, vars map[string]interface{}) error
	Delete(opts ...DBOption) error
}

func NewIAiRepo 

func NewIAiRepo() IAiRepo

type IAlertRepo 

type IAlertRepo interface {
	WithByType(alertType string) DBOption
	WithByStatusIn(status []string) DBOption
	WithByProject(project string) DBOption
	WithByCount(count uint) DBOption
	WithByAlertId(alertId uint) DBOption
	WithByCreateAt(date *date.Date) DBOption
	WithByLicenseId(licenseId string) DBOption
	WithByRecordId(recordId uint) DBOption
	WithByDeliveryLogID(logID uint) DBOption
	WithByAlertMethodContainsConfigID(id uint) DBOption
	WithByMethodConfigIDs(ids []uint) DBOption

	Create(alert *model.Alert) error
	Get(opts ...DBOption) (model.Alert, error)
	Page(page, size int, opts ...DBOption) (int64, []model.Alert, error)
	List(opts ...DBOption) ([]model.Alert, error)
	Delete(opts ...DBOption) error
	Save(alert *model.Alert) error
	Update(maps map[string]interface{}, opts ...DBOption) error

	GetLog(opts ...DBOption) (model.AlertLog, error)
	CreateLog(alertLog *model.AlertLog) error
	PageLog(limit, offset int, opts ...DBOption) (int64, []model.AlertLog, error)
	ListLog(opts ...DBOption) ([]model.AlertLog, error)
	UpdateLog(id uint, maps map[string]interface{}) error
	BatchUpdateLogBy(maps map[string]interface{}, opts ...DBOption) error
	DeleteLog(opts ...DBOption) error
	CleanAlertLogs() error

	CreateAlertTask(alertTaskBase *model.AlertTask) error
	CreatePendingAlertTask(logID, alertID uint, alertTask *model.AlertTask) (bool, error)
	FinalizePendingAlertTask(logID uint, succeeded bool, message string, fallback *model.AlertTask) (bool, error)
	DeleteAlertTask(opts ...DBOption) error
	GetAlertTask(opts ...DBOption) (model.AlertTask, error)
	LoadTaskCount(alertType string, project string, method string) (uint, uint, error)
	GetTaskLog(alertType string, alertId uint) (time.Time, error)
	GetLicensePushCount(method string) (uint, error)

	GetConfig(opts ...DBOption) (model.AlertConfig, error)
	GetConfigById(id uint) (model.AlertConfig, error)
	AlertConfigList(opts ...DBOption) ([]model.AlertConfig, error)
	UpdateAlertConfig(maps map[string]interface{}, opts ...DBOption) error
	UpdateAlertConfigWithRevision(maps map[string]interface{}, revision *time.Time, opts ...DBOption) error
	CreateAlertConfig(config *model.AlertConfig) error
	DeleteAlertConfig(opts ...DBOption) error

	WithByTypeNotIn(types []string) DBOption
	PageAlertConfig(page, size int, opts ...DBOption) (int64, []model.AlertConfig, error)

	SyncAll(data []model.AlertConfig) error
}

func NewIAlertRepo 

func NewIAlertRepo() IAlertRepo

type IAppDetailRepo 

type IAppDetailRepo interface {
	WithVersion(version string) DBOption
	WithAppId(id uint) DBOption
	WithIgnored() DBOption
	GetFirst(opts ...DBOption) (model.AppDetail, error)
	Update(ctx context.Context, detail model.AppDetail) error
	BatchCreate(ctx context.Context, details []model.AppDetail) error
	DeleteByAppIds(ctx context.Context, appIds []uint) error
	DeleteByIDs(ctx context.Context, appIds []uint) error
	GetBy(opts ...DBOption) ([]model.AppDetail, error)
	BatchUpdateBy(maps map[string]interface{}, opts ...DBOption) error
	BatchDelete(ctx context.Context, appDetails []model.AppDetail) error
}

func NewIAppDetailRepo 

func NewIAppDetailRepo() IAppDetailRepo

type IAppIgnoreUpgradeRepo 

type IAppIgnoreUpgradeRepo interface {
	WithScope(scope string) DBOption
	WithAppID(appID uint) DBOption
	List(opts ...DBOption) ([]model.AppIgnoreUpgrade, error)
	Create(appIgnoreUpgrade *model.AppIgnoreUpgrade) error
	Delete(opts ...DBOption) error
}

func NewIAppIgnoreUpgradeRepo 

func NewIAppIgnoreUpgradeRepo() IAppIgnoreUpgradeRepo

type IAppInstallRepo 

type IAppInstallRepo interface {
	WithDetailIdsIn(detailIds []uint) DBOption
	WithDetailIdNotIn(detailIds []uint) DBOption
	WithAppId(appId uint) DBOption
	WithAppIdsIn(appIds []uint) DBOption
	WithAppIdsNotIn(appIds []uint) DBOption
	WithStatus(status string) DBOption
	WithServiceName(serviceName string) DBOption
	WithContainerName(containerName string) DBOption
	WithPort(port int) DBOption
	WithIdNotInWebsite() DBOption
	WithIDNotIs(id uint) DBOption
	ListBy(ctx context.Context, opts ...DBOption) ([]model.AppInstall, error)
	GetFirst(opts ...DBOption) (model.AppInstall, error)
	Create(ctx context.Context, install *model.AppInstall) error
	Save(ctx context.Context, install *model.AppInstall) error
	DeleteBy(opts ...DBOption) error
	Delete(ctx context.Context, install model.AppInstall) error
	Page(page, size int, opts ...DBOption) (int64, []model.AppInstall, error)
	BatchUpdateBy(maps map[string]interface{}, opts ...DBOption) error
	LoadBaseInfo(key string, name string) (*RootInfo, error)
	LoadInstallAppByKeyAndName(key string, name string) (*model.AppInstall, error)
	GetFirstByCtx(ctx context.Context, opts ...DBOption) (model.AppInstall, error)
}

func NewIAppInstallRepo 

func NewIAppInstallRepo() IAppInstallRepo

type IAppInstallResourceRpo 

type IAppInstallResourceRpo interface {
	WithAppInstallId(appInstallId uint) DBOption
	WithLinkId(linkId uint) DBOption
	WithResourceId(resourceId uint) DBOption
	WithResourceIds(resourceIds []uint) DBOption
	GetBy(opts ...DBOption) ([]model.AppInstallResource, error)
	GetFirst(opts ...DBOption) (model.AppInstallResource, error)
	Create(ctx context.Context, resource *model.AppInstallResource) error
	DeleteBy(ctx context.Context, opts ...DBOption) error
	BatchUpdateBy(maps map[string]interface{}, opts ...DBOption) error
}

func NewIAppInstallResourceRpo 

func NewIAppInstallResourceRpo() IAppInstallResourceRpo

type IAppRepo 

type IAppRepo interface {
	WithKey(key string) DBOption
	WithType(typeStr string) DBOption
	OrderByRecommend() DBOption
	GetRecommend() DBOption
	WithResource(resource string) DBOption
	WithNotLocal() DBOption
	WithByLikeName(name string) DBOption
	WithKeyIn(keys []string) DBOption
	WithArch(arch string) DBOption
	WithPanelVersion(panelVersion string) DBOption

	Page(page, size int, opts ...DBOption) (int64, []model.App, error)
	GetFirst(opts ...DBOption) (model.App, error)
	GetBy(opts ...DBOption) ([]model.App, error)
	BatchCreate(ctx context.Context, apps []model.App) error
	Create(ctx context.Context, app *model.App) error
	Save(ctx context.Context, app *model.App) error
	BatchDelete(ctx context.Context, apps []model.App) error
	DeleteByIDs(ctx context.Context, ids []uint) error
	DeleteBy(opts ...DBOption) error

	GetTopRecommend() ([]string, error)
}

func NewIAppRepo 

func NewIAppRepo() IAppRepo

type IAppTagRepo 

type IAppTagRepo interface {
	BatchCreate(ctx context.Context, tags []*model.AppTag) error
	DeleteByAppIds(ctx context.Context, appIds []uint) error
	DeleteAll(ctx context.Context) error
	GetByAppId(appId uint) ([]model.AppTag, error)
	GetByTagIds(tagIds []uint) ([]model.AppTag, error)
	DeleteBy(ctx context.Context, opts ...DBOption) error
	GetFirst(ctx context.Context, opts ...DBOption) (*model.AppTag, error)

	WithByTagID(tagID uint) DBOption
	WithByAppID(appId uint) DBOption
}

func NewIAppTagRepo 

func NewIAppTagRepo() IAppTagRepo

type IBackupRepo 

type IBackupRepo interface {
	Get(opts ...DBOption) (model.BackupAccount, error)
	List(opts ...DBOption) ([]model.BackupAccount, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.BackupAccount, error)
	Create(backup *model.BackupAccount) error
	Save(backup *model.BackupAccount) error
	Delete(opts ...DBOption) error
	WithByPublic(isPublic bool) DBOption

	ListRecord(opts ...DBOption) ([]model.BackupRecord, error)
	GetRecord(opts ...DBOption) (*model.BackupRecord, error)
	PageRecord(page, size int, opts ...DBOption) (int64, []model.BackupRecord, error)
	CreateRecord(record *model.BackupRecord) error
	DeleteRecord(ctx context.Context, opts ...DBOption) error
	UpdateRecord(record *model.BackupRecord) error
	UpdateRecordByMap(id uint, upMap map[string]interface{}) error
	WithByDetailName(detailName string) DBOption
	WithByFileName(fileName string) DBOption
	WithByCronID(cronjobID uint) DBOption
	WithFileNameStartWith(filePrefix string) DBOption

	SyncAll(data []model.BackupAccount) error
}

func NewIBackupRepo 

func NewIBackupRepo() IBackupRepo

type IClamRepo 

type IClamRepo interface {
	Page(limit, offset int, opts ...DBOption) (int64, []model.Clam, error)
	Create(clam *model.Clam) error
	Update(id uint, vars map[string]interface{}) error
	Delete(opts ...DBOption) error
	Get(opts ...DBOption) (model.Clam, error)
	List(opts ...DBOption) ([]model.Clam, error)

	WithByClamID(id uint) DBOption
	ListRecord(opts ...DBOption) ([]model.ClamRecord, error)
	RecordFirst(id uint) (model.ClamRecord, error)
	DeleteRecord(opts ...DBOption) error
	StartRecords(clamID uint) model.ClamRecord
	EndRecords(record model.ClamRecord, status, message string)
	PageRecords(page, size int, opts ...DBOption) (int64, []model.ClamRecord, error)
}

func NewIClamRepo 

func NewIClamRepo() IClamRepo

type IComposeTemplateRepo 

type IComposeTemplateRepo interface {
	Get(opts ...DBOption) (model.ComposeTemplate, error)
	List(opts ...DBOption) ([]model.ComposeTemplate, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.ComposeTemplate, error)
	Create(compose *model.ComposeTemplate) error
	Update(id uint, vars map[string]interface{}) error
	Delete(opts ...DBOption) error

	GetRecord(opts ...DBOption) (model.Compose, error)
	CreateRecord(compose *model.Compose) error
	DeleteRecord(opts ...DBOption) error
	ListRecord() ([]model.Compose, error)
	UpdateRecord(name string, vars map[string]interface{}) error
}

func NewIComposeTemplateRepo 

func NewIComposeTemplateRepo() IComposeTemplateRepo

type ICronjobRepo 

type ICronjobRepo interface {
	Get(opts ...DBOption) (model.Cronjob, error)
	GetRecord(opts ...DBOption) (model.JobRecords, error)
	RecordFirst(id uint) (model.JobRecords, error)
	ListRecord(opts ...DBOption) ([]model.JobRecords, error)
	List(opts ...DBOption) ([]model.Cronjob, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.Cronjob, error)
	Create(cronjob *model.Cronjob) error
	WithByJobID(id int) DBOption
	WithByDbName(name string) DBOption
	WithByDownloadAccountID(id uint) DBOption
	WithByRecordDropID(id int) DBOption
	WithByRecordFile(file string) DBOption
	Save(id uint, cronjob model.Cronjob) error
	Update(id uint, vars map[string]interface{}) error
	Delete(opts ...DBOption) error
	DeleteRecord(opts ...DBOption) error
	StartRecords(cronjobID uint) model.JobRecords
	UpdateRecords(id uint, vars map[string]interface{}) error
	EndRecords(record model.JobRecords, status, message, records string)
	AddFailedRecord(cronjobID uint, message string)
	PageRecords(page, size int, opts ...DBOption) (int64, []model.JobRecords, error)
}

func NewICronjobRepo 

func NewICronjobRepo() ICronjobRepo

type IDatabaseRepo 

type IDatabaseRepo interface {
	GetList(opts ...DBOption) ([]model.Database, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.Database, error)
	Create(ctx context.Context, database *model.Database) error
	Update(id uint, vars map[string]interface{}) error
	Delete(ctx context.Context, opts ...DBOption) error
	Get(opts ...DBOption) (model.Database, error)
	WithoutByFrom(from string) DBOption
	WithAppInstallID(appInstallID uint) DBOption
	WithTypeList(dbType string) DBOption
}

func NewIDatabaseRepo 

func NewIDatabaseRepo() IDatabaseRepo

type IDatabaseUserGrantRepo 

type IDatabaseUserGrantRepo interface {
	Get(opts ...DBOption) (model.DatabaseUserGrant, error)
	List(opts ...DBOption) ([]model.DatabaseUserGrant, error)
	Save(grant *model.DatabaseUserGrant) error
	Replace(dbType, database string, grants []model.DatabaseUserGrant) error
	Delete(opts ...DBOption) error
	DeleteBy(ctx context.Context, opts ...DBOption) error
	Update(vars map[string]interface{}, opts ...DBOption) error
	WithByDatabase(database string) DBOption
	WithByDBName(dbName string) DBOption
	WithByDBNames(dbNames []string) DBOption
	WithByUser(username, host string) DBOption
}

func NewIDatabaseUserGrantRepo 

func NewIDatabaseUserGrantRepo() IDatabaseUserGrantRepo

type IDatabaseUserRepo 

type IDatabaseUserRepo interface {
	Get(opts ...DBOption) (model.DatabaseUser, error)
	List(opts ...DBOption) ([]model.DatabaseUser, error)
	Save(user *model.DatabaseUser) error
	Delete(opts ...DBOption) error
	DeleteBy(ctx context.Context, opts ...DBOption) error
	Update(vars map[string]interface{}, opts ...DBOption) error
	WithByDatabase(database string) DBOption
	WithByUser(username, host string) DBOption
	WithByUserList(users [][2]string) DBOption
}

func NewIDatabaseUserRepo 

func NewIDatabaseUserRepo() IDatabaseUserRepo

type IDockerPortGuardRepo 

type IDockerPortGuardRepo interface {
	ListManaged(context.Context) ([]model.DockerPortGuardPolicy, error)
	ListRuntimeReadOnly(context.Context) ([]model.DockerPortGuardPolicy, error)
	DeleteBatch(context.Context, []string) error
	UpsertBatch(context.Context, []model.DockerPortGuardPolicy) error
	ReplaceRuntimeReadOnly(context.Context, []model.DockerPortGuardPolicy) error
}

func NewIDockerPortGuardRepo 

func NewIDockerPortGuardRepo() IDockerPortGuardRepo

type IFavoriteRepo 

type IFavoriteRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.Favorite, error)
	Create(group *model.Favorite) error
	Delete(opts ...DBOption) error
	GetFirst(opts ...DBOption) (model.Favorite, error)
	All() ([]model.Favorite, error)
	WithByPath(path string) DBOption
}

func NewIFavoriteRepo 

func NewIFavoriteRepo() IFavoriteRepo

type IFileHistoryRepo 

type IFileHistoryRepo interface {
	Get(opts ...DBOption) (model.FileHistory, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.FileHistory, error)
	Create(history *model.FileHistory) error
	Delete(opts ...DBOption) error
	DeleteByIDs(ids []uint) error
	WithByID(id uint) DBOption
	WithByFileID(fileID string) DBOption
	WithByPath(path string) DBOption
	WithByPathHash(pathHash string) DBOption
	WithByPathLike(path string) DBOption
	WithByOperation(operation string) DBOption
	WithNotOperation(operation string) DBOption
	WithByRelatedPath(path string) DBOption
}

func NewIFileHistoryRepo 

func NewIFileHistoryRepo() IFileHistoryRepo

type IFileShareRepo 

type IFileShareRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.FileShare, error)
	Create(fileShare *model.FileShare) error
	Save(fileShare *model.FileShare) error
	Delete(opts ...DBOption) error
	GetFirst(opts ...DBOption) (model.FileShare, error)
	All() ([]model.FileShare, error)
	WithByPath(path string) DBOption
	WithByCode(code string) DBOption
}

func NewIFileShareRepo 

func NewIFileShareRepo() IFileShareRepo

type IFirewallRuleRepo 

type IFirewallRuleRepo interface {
	Create(context.Context, *model.FirewallRule) error
	GetByUUID(context.Context, string) (model.FirewallRule, error)
	List(context.Context, ...DBOption) ([]model.FirewallRule, error)
	UpdateWithRevision(context.Context, string, uint, map[string]interface{}) error
	DeleteWithRevision(context.Context, string, uint) error
}

func NewIFirewallRuleRepo 

func NewIFirewallRuleRepo() IFirewallRuleRepo

type IForwardingRuleRepo 

type IForwardingRuleRepo interface {
	List(context.Context) ([]model.ForwardingRule, error)
	ReplaceAll(context.Context, []model.ForwardingRule) error
}

func NewIForwardingRuleRepo 

func NewIForwardingRuleRepo() IForwardingRuleRepo

type IFtpRepo 

type IFtpRepo interface {
	Get(opts ...DBOption) (model.Ftp, error)
	GetList(opts ...DBOption) ([]model.Ftp, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.Ftp, error)
	Create(ftp *model.Ftp) error
	Update(id uint, vars map[string]interface{}) error
	Delete(opts ...DBOption) error
	WithLikeUser(user string) DBOption
	WithByUser(user string) DBOption
}

func NewIFtpRepo 

func NewIFtpRepo() IFtpRepo

type IGroupRepo 

type IGroupRepo interface {
	Get(opts ...DBOption) (model.Group, error)
	GetList(opts ...DBOption) ([]model.Group, error)
	Create(group *model.Group) error
	Update(id uint, vars map[string]interface{}) error
	Delete(opts ...DBOption) error
	CancelDefault(groupType string) error
	WithByDefault(isDefault bool) DBOption
	WithByWebsiteDefault() DBOption
}

func NewIGroupRepo 

func NewIGroupRepo() IGroupRepo

type IHostRepo 

type IHostRepo interface {
	Get(opts ...DBOption) (model.Host, error)
	GetList(opts ...DBOption) ([]model.Host, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.Host, error)
	Create(host *model.Host) error
	Update(id uint, vars map[string]interface{}) error
	UpdateGroup(group, newGroup uint) error
	Delete(opts ...DBOption) error

	WithByInfo(info string) DBOption
	WithByPort(port uint) DBOption
	WithByUser(user string) DBOption

	SyncCert(data []model.RootCert) error
	GetCert(opts ...DBOption) (model.RootCert, error)
	PageCert(limit, offset int, opts ...DBOption) (int64, []model.RootCert, error)
	ListCert(opts ...DBOption) ([]model.RootCert, error)
	SaveCert(cert *model.RootCert) error
	UpdateCert(id uint, vars map[string]interface{}) error
	DeleteCert(opts ...DBOption) error
}

func NewIHostRepo 

func NewIHostRepo() IHostRepo

type IImageRepoRepo 

type IImageRepoRepo interface {
	Get(opts ...DBOption) (model.ImageRepo, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.ImageRepo, error)
	List(opts ...DBOption) ([]model.ImageRepo, error)
	Create(imageRepo *model.ImageRepo) error
	Update(id uint, vars map[string]interface{}) error
	Delete(opts ...DBOption) error
}

func NewIImageRepoRepo 

func NewIImageRepoRepo() IImageRepoRepo

type ILauncherRepo 

type ILauncherRepo interface {
	Get(opts ...DBOption) (model.AppLauncher, error)
	ListName(opts ...DBOption) ([]string, error)
	Create(launcher *model.AppLauncher) error
	Save(launcher *model.AppLauncher) error
	Delete(opts ...DBOption) error

	GetQuickJump(opts ...DBOption) (model.QuickJump, error)
	ListQuickJump(withAll bool) []model.QuickJump
	UpdateQuicks(quicks []model.QuickJump) error
}

func NewILauncherRepo 

func NewILauncherRepo() ILauncherRepo

type IMcpServerRepo 

type IMcpServerRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.McpServer, error)
	GetFirst(opts ...DBOption) (*model.McpServer, error)
	Create(mcpServer *model.McpServer) error
	Save(mcpServer *model.McpServer) error
	DeleteBy(opts ...DBOption) error
	List(opts ...DBOption) ([]model.McpServer, error)
}

func NewIMcpServerRepo 

func NewIMcpServerRepo() IMcpServerRepo

type IMongodbRepo 

type IMongodbRepo interface {
	Get(opts ...DBOption) (model.DatabaseMongodb, error)
	WithByMongodbName(mongodbName string) DBOption
	List(opts ...DBOption) ([]model.DatabaseMongodb, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.DatabaseMongodb, error)
	Create(ctx context.Context, mongodb *model.DatabaseMongodb) error
	Delete(ctx context.Context, opts ...DBOption) error
	Update(id uint, vars map[string]interface{}) error
	DeleteLocal(ctx context.Context) error
}

func NewIMongodbRepo 

func NewIMongodbRepo() IMongodbRepo

type IMonitorRepo 

type IMonitorRepo interface {
	GetBase(opts ...DBOption) ([]model.MonitorBase, error)
	GetGPU(opts ...DBOption) ([]model.MonitorGPU, error)
	GetIO(opts ...DBOption) ([]model.MonitorIO, error)
	GetNetwork(opts ...DBOption) ([]model.MonitorNetwork, error)

	CreateMonitorBase(model model.MonitorBase) error
	BatchCreateMonitorGPU(list []model.MonitorGPU) error
	BatchCreateMonitorIO(ioList []model.MonitorIO) error
	BatchCreateMonitorNet(ioList []model.MonitorNetwork) error
	DelMonitorBase(timeForDelete time.Time) error
	DelMonitorGPU(timeForDelete time.Time) error
	DelMonitorIO(timeForDelete time.Time) error
	DelMonitorNet(timeForDelete time.Time) error

	WithByProductName(name string) DBOption
}

func NewIMonitorRepo 

func NewIMonitorRepo() IMonitorRepo

type IMysqlRepo 

type IMysqlRepo interface {
	Get(opts ...DBOption) (model.DatabaseMysql, error)
	WithByMysqlName(mysqlName string) DBOption
	List(opts ...DBOption) ([]model.DatabaseMysql, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.DatabaseMysql, error)
	Create(ctx context.Context, mysql *model.DatabaseMysql) error
	Delete(ctx context.Context, opts ...DBOption) error
	Update(id uint, vars map[string]interface{}) error
	DeleteLocal(ctx context.Context) error
}

func NewIMysqlRepo 

func NewIMysqlRepo() IMysqlRepo

type IPHPExtensionsRepo 

type IPHPExtensionsRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.PHPExtensions, error)
	Save(extension *model.PHPExtensions) error
	Create(extension *model.PHPExtensions) error
	GetFirst(opts ...DBOption) (model.PHPExtensions, error)
	DeleteBy(opts ...DBOption) error
	List() ([]model.PHPExtensions, error)
}

func NewIPHPExtensionsRepo 

func NewIPHPExtensionsRepo() IPHPExtensionsRepo

type IPostgresqlRepo 

type IPostgresqlRepo interface {
	Get(opts ...DBOption) (model.DatabasePostgresql, error)
	WithByPostgresqlName(postgresqlName string) DBOption
	List(opts ...DBOption) ([]model.DatabasePostgresql, error)
	Page(limit, offset int, opts ...DBOption) (int64, []model.DatabasePostgresql, error)
	Create(ctx context.Context, postgresql *model.DatabasePostgresql) error
	Delete(ctx context.Context, opts ...DBOption) error
	Update(id uint, vars map[string]interface{}) error
	DeleteLocal(ctx context.Context) error
}

func NewIPostgresqlRepo 

func NewIPostgresqlRepo() IPostgresqlRepo

type IRuntimeRepo 

type IRuntimeRepo interface {
	WithImage(image string) DBOption
	WithNotId(id uint) DBOption
	WithStatus(status string) DBOption
	WithDetailId(id uint) DBOption
	WithDetailIdsIn(ids []uint) DBOption
	WithPort(port int) DBOption
	WithNormalStatus(status string) DBOption
	Page(page, size int, opts ...DBOption) (int64, []model.Runtime, error)
	Create(ctx context.Context, runtime *model.Runtime) error
	Save(runtime *model.Runtime) error
	DeleteBy(opts ...DBOption) error
	GetFirst(ctx context.Context, opts ...DBOption) (*model.Runtime, error)
	List(opts ...DBOption) ([]model.Runtime, error)
}

func NewIRunTimeRepo 

func NewIRunTimeRepo() IRuntimeRepo

type ISSLRepo 

type ISSLRepo interface {
	WithByAlias(alias string) DBOption
	WithByAcmeAccountId(acmeAccountId uint) DBOption
	WithByDnsAccountId(dnsAccountId uint) DBOption
	WithByCAID(caID uint) DBOption
	WithByDomain(domain string) DBOption
	WithByMasterSSLID(sslID uint) DBOption
	Page(page, size int, opts ...DBOption) (int64, []model.WebsiteSSL, error)
	GetFirst(opts ...DBOption) (*model.WebsiteSSL, error)
	List(opts ...DBOption) ([]model.WebsiteSSL, error)
	TryMarkApplying(id uint) (bool, error)
	Create(ctx context.Context, ssl *model.WebsiteSSL) error
	Save(ssl *model.WebsiteSSL) error
	DeleteBy(opts ...DBOption) error
	SaveByMap(ssl *model.WebsiteSSL, params map[string]interface{}) error
}

func NewISSLRepo 

func NewISSLRepo() ISSLRepo

type IScriptRepo 

type IScriptRepo interface {
	Get(opts ...DBOption) (model.ScriptLibrary, error)
	List(opts ...DBOption) ([]model.ScriptLibrary, error)

	SyncAll(data []model.ScriptLibrary) error
}

func NewIScriptRepo 

func NewIScriptRepo() IScriptRepo

type ISettingRepo 

type ISettingRepo interface {
	GetList(opts ...DBOption) ([]model.Setting, error)
	Get(opts ...DBOption) (model.Setting, error)
	GetValueByKey(key string) (string, error)
	Create(key, value string) error
	Update(key, value string) error
	WithByKey(key string) DBOption

	UpdateOrCreate(key, value string) error

	GetDescription(opts ...DBOption) (model.CommonDescription, error)
	GetDescriptionList(opts ...DBOption) ([]model.CommonDescription, error)
	CreateDescription(data *model.CommonDescription) error
	UpdateDescription(id string, val map[string]interface{}) error
	DelDescription(id string) error
	WithByDescriptionID(id string) DBOption
}

func NewISettingRepo 

func NewISettingRepo() ISettingRepo

type ISnapshotRepo 

type ISnapshotRepo interface {
	Get(opts ...DBOption) (model.Snapshot, error)
	GetList(opts ...DBOption) ([]model.Snapshot, error)
	Create(snap *model.Snapshot) error
	Update(id uint, vars map[string]interface{}) error
	Page(limit, offset int, opts ...DBOption) (int64, []model.Snapshot, error)
	Delete(opts ...DBOption) error
}

func NewISnapshotRepo 

func NewISnapshotRepo() ISnapshotRepo

type ITagRepo 

type ITagRepo interface {
	BatchCreate(ctx context.Context, tags []*model.Tag) error
	DeleteAll(ctx context.Context) error
	All() ([]model.Tag, error)
	GetByIds(ids []uint) ([]model.Tag, error)
	GetByKeys(keys []string) ([]model.Tag, error)
	GetByAppId(appId uint) ([]model.Tag, error)
	DeleteByID(ctx context.Context, id uint) error
	Create(ctx context.Context, tag *model.Tag) error
	Save(ctx context.Context, tag *model.Tag) error
	GetByKey(key string) (*model.Tag, error)
}

func NewITagRepo 

func NewITagRepo() ITagRepo

type ITaskRepo 

type ITaskRepo interface {
	Save(ctx context.Context, task *model.Task) error
	GetFirst(opts ...DBOption) (model.Task, error)
	Page(page, size int, opts ...DBOption) (int64, []model.Task, error)
	Update(ctx context.Context, task *model.Task) error
	UpdateRunningTaskToFailed() error
	CountExecutingTask() (int64, error)
	Delete(opts ...DBOption) error
	DeleteAll() error

	WithByID(id string) DBOption
	WithByIDNotIn(ids []string) DBOption
	WithResourceID(id uint) DBOption
	WithOperate(taskOperate string) DBOption
	WithByStatus(status string) DBOption
}

func NewITaskRepo 

func NewITaskRepo() ITaskRepo

type ITensorRTLLMRepo 

type ITensorRTLLMRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.TensorRTLLM, error)
	GetFirst(opts ...DBOption) (*model.TensorRTLLM, error)
	Create(tensorrtLLM *model.TensorRTLLM) error
	Save(tensorrtLLM *model.TensorRTLLM) error
	DeleteBy(opts ...DBOption) error
	List(opts ...DBOption) ([]model.TensorRTLLM, error)
}

func NewITensorRTLLMRepo 

func NewITensorRTLLMRepo() ITensorRTLLMRepo

type IWebsiteCARepo 

type IWebsiteCARepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.WebsiteCA, error)
	GetFirst(opts ...DBOption) (model.WebsiteCA, error)
	List(opts ...DBOption) ([]model.WebsiteCA, error)
	Create(ctx context.Context, ca *model.WebsiteCA) error
	DeleteBy(opts ...DBOption) error
}

func NewIWebsiteCARepo 

func NewIWebsiteCARepo() IWebsiteCARepo

type IWebsiteDnsAccountRepo 

type IWebsiteDnsAccountRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.WebsiteDnsAccount, error)
	GetFirst(opts ...DBOption) (*model.WebsiteDnsAccount, error)
	List(opts ...DBOption) ([]model.WebsiteDnsAccount, error)
	Create(account model.WebsiteDnsAccount) error
	Save(account model.WebsiteDnsAccount) error
	DeleteBy(opts ...DBOption) error
}

func NewIWebsiteDnsAccountRepo 

func NewIWebsiteDnsAccountRepo() IWebsiteDnsAccountRepo

type IWebsiteDomainRepo 

type IWebsiteDomainRepo interface {
	WithWebsiteId(websiteId uint) DBOption
	WithWebsiteIds(websiteIds []uint) DBOption
	WithPort(port int) DBOption
	WithDomain(domain string) DBOption
	WithDomainLike(domain string) DBOption
	Page(page, size int, opts ...DBOption) (int64, []model.WebsiteDomain, error)
	GetFirst(opts ...DBOption) (model.WebsiteDomain, error)
	GetBy(opts ...DBOption) ([]model.WebsiteDomain, error)
	BatchCreate(ctx context.Context, domains []model.WebsiteDomain) error
	Create(ctx context.Context, app *model.WebsiteDomain) error
	Save(ctx context.Context, app *model.WebsiteDomain) error
	DeleteBy(ctx context.Context, opts ...DBOption) error
	DeleteAll(ctx context.Context) error
}

func NewIWebsiteDomainRepo 

func NewIWebsiteDomainRepo() IWebsiteDomainRepo

type IWebsiteRepo 

type IWebsiteRepo interface {
	WithAppInstallId(appInstallId uint) DBOption
	WithAppInstallIds(appInstallIds []uint) DBOption
	WithDomain(domain string) DBOption
	WithAlias(alias string) DBOption
	WithWebsiteSSLID(sslId uint) DBOption
	WithGroupID(groupId uint) DBOption
	WithDefaultServer() DBOption
	WithDomainLike(domain string) DBOption
	WithSearchKeyword(keyword string, ids []uint) DBOption
	WithRuntimeID(runtimeID uint) DBOption
	WithParentID(websiteID uint) DBOption
	WithType(websiteType string) DBOption
	WithDBType(dbType string) DBOption
	WithDBTypes(dbTypes []string) DBOption
	WithDBID(dbID uint) DBOption

	Page(page, size int, opts ...DBOption) (int64, []model.Website, error)
	List(opts ...DBOption) ([]model.Website, error)
	GetFirst(opts ...DBOption) (model.Website, error)
	GetBy(opts ...DBOption) ([]model.Website, error)
	Save(ctx context.Context, app *model.Website) error
	SaveWithoutCtx(app *model.Website) error
	DeleteBy(ctx context.Context, opts ...DBOption) error
	Create(ctx context.Context, app *model.Website) error
	DeleteAll(ctx context.Context) error

	UpdateGroup(group, newGroup uint) error
}

func NewIWebsiteRepo 

func NewIWebsiteRepo() IWebsiteRepo

type IWebsiteTemplateOutputRepo 

type IWebsiteTemplateOutputRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.WebsiteTemplateOutput, error)
	GetFirst(opts ...DBOption) (*model.WebsiteTemplateOutput, error)
	List(opts ...DBOption) ([]model.WebsiteTemplateOutput, error)
	Create(output *model.WebsiteTemplateOutput) error
	Save(output *model.WebsiteTemplateOutput) error
	DeleteBy(opts ...DBOption) error
	WithByTemplateID(templateID uint) DBOption
}

func NewIWebsiteTemplateOutputRepo 

func NewIWebsiteTemplateOutputRepo() IWebsiteTemplateOutputRepo

type IWebsiteTemplateRepo 

type IWebsiteTemplateRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.WebsiteTemplate, error)
	GetFirst(opts ...DBOption) (*model.WebsiteTemplate, error)
	List(opts ...DBOption) ([]model.WebsiteTemplate, error)
	Create(template *model.WebsiteTemplate) error
	Save(template *model.WebsiteTemplate) error
	DeleteBy(opts ...DBOption) error
	WithName(name string) DBOption
	WithType(templateType string) DBOption
}

func NewIWebsiteTemplateRepo 

func NewIWebsiteTemplateRepo() IWebsiteTemplateRepo

type ImageRepoRepo 

type ImageRepoRepo struct{}

func (*ImageRepoRepo) Create 

func (u *ImageRepoRepo) Create(imageRepo *model.ImageRepo) error

func (*ImageRepoRepo) Delete 

func (u *ImageRepoRepo) Delete(opts ...DBOption) error

func (*ImageRepoRepo) Get 

func (u *ImageRepoRepo) Get(opts ...DBOption) (model.ImageRepo, error)

func (*ImageRepoRepo) List 

func (u *ImageRepoRepo) List(opts ...DBOption) ([]model.ImageRepo, error)

func (*ImageRepoRepo) Page 

func (u *ImageRepoRepo) Page(page, size int, opts ...DBOption) (int64, []model.ImageRepo, error)

func (*ImageRepoRepo) Update 

func (u *ImageRepoRepo) Update(id uint, vars map[string]interface{}) error

type LauncherRepo 

type LauncherRepo struct{}

func (*LauncherRepo) Create 

func (u *LauncherRepo) Create(launcher *model.AppLauncher) error

func (*LauncherRepo) Delete 

func (u *LauncherRepo) Delete(opts ...DBOption) error

func (*LauncherRepo) Get 

func (u *LauncherRepo) Get(opts ...DBOption) (model.AppLauncher, error)

func (*LauncherRepo) GetQuickJump 

func (u *LauncherRepo) GetQuickJump(opts ...DBOption) (model.QuickJump, error)

func (*LauncherRepo) ListName 

func (u *LauncherRepo) ListName(opts ...DBOption) ([]string, error)

func (*LauncherRepo) ListQuickJump 

func (u *LauncherRepo) ListQuickJump(withAll bool) []model.QuickJump

func (*LauncherRepo) Save 

func (u *LauncherRepo) Save(launcher *model.AppLauncher) error

func (*LauncherRepo) UpdateQuicks 

func (u *LauncherRepo) UpdateQuicks(quicks []model.QuickJump) error

type McpServerRepo 

type McpServerRepo struct {
}

func (McpServerRepo) Create 

func (m McpServerRepo) Create(mcpServer *model.McpServer) error

func (McpServerRepo) DeleteBy 

func (m McpServerRepo) DeleteBy(opts ...DBOption) error

func (McpServerRepo) GetFirst 

func (m McpServerRepo) GetFirst(opts ...DBOption) (*model.McpServer, error)

func (McpServerRepo) List 

func (m McpServerRepo) List(opts ...DBOption) ([]model.McpServer, error)

func (McpServerRepo) Page 

func (m McpServerRepo) Page(page, size int, opts ...DBOption) (int64, []model.McpServer, error)

func (McpServerRepo) Save 

func (m McpServerRepo) Save(mcpServer *model.McpServer) error

type MongodbRepo 

type MongodbRepo struct{}

func (*MongodbRepo) Create 

func (u *MongodbRepo) Create(ctx context.Context, mongodb *model.DatabaseMongodb) error

func (*MongodbRepo) Delete 

func (u *MongodbRepo) Delete(ctx context.Context, opts ...DBOption) error

func (*MongodbRepo) DeleteLocal 

func (u *MongodbRepo) DeleteLocal(ctx context.Context) error

func (*MongodbRepo) Get 

func (u *MongodbRepo) Get(opts ...DBOption) (model.DatabaseMongodb, error)

func (*MongodbRepo) List 

func (u *MongodbRepo) List(opts ...DBOption) ([]model.DatabaseMongodb, error)

func (*MongodbRepo) Page 

func (u *MongodbRepo) Page(page, size int, opts ...DBOption) (int64, []model.DatabaseMongodb, error)

func (*MongodbRepo) Update 

func (u *MongodbRepo) Update(id uint, vars map[string]interface{}) error

func (*MongodbRepo) WithByMongodbName 

func (u *MongodbRepo) WithByMongodbName(mongodbName string) DBOption

type MonitorRepo 

type MonitorRepo struct{}

func (*MonitorRepo) BatchCreateMonitorGPU 

func (s *MonitorRepo) BatchCreateMonitorGPU(list []model.MonitorGPU) error

func (*MonitorRepo) BatchCreateMonitorIO 

func (u *MonitorRepo) BatchCreateMonitorIO(ioList []model.MonitorIO) error

func (*MonitorRepo) BatchCreateMonitorNet 

func (u *MonitorRepo) BatchCreateMonitorNet(ioList []model.MonitorNetwork) error

func (*MonitorRepo) CreateMonitorBase 

func (u *MonitorRepo) CreateMonitorBase(model model.MonitorBase) error

func (*MonitorRepo) DelMonitorBase 

func (u *MonitorRepo) DelMonitorBase(timeForDelete time.Time) error

func (*MonitorRepo) DelMonitorGPU 

func (s *MonitorRepo) DelMonitorGPU(timeForDelete time.Time) error

func (*MonitorRepo) DelMonitorIO 

func (u *MonitorRepo) DelMonitorIO(timeForDelete time.Time) error

func (*MonitorRepo) DelMonitorNet 

func (u *MonitorRepo) DelMonitorNet(timeForDelete time.Time) error

func (*MonitorRepo) GetBase 

func (u *MonitorRepo) GetBase(opts ...DBOption) ([]model.MonitorBase, error)

func (*MonitorRepo) GetGPU 

func (u *MonitorRepo) GetGPU(opts ...DBOption) ([]model.MonitorGPU, error)

func (*MonitorRepo) GetIO 

func (u *MonitorRepo) GetIO(opts ...DBOption) ([]model.MonitorIO, error)

func (*MonitorRepo) GetNetwork 

func (u *MonitorRepo) GetNetwork(opts ...DBOption) ([]model.MonitorNetwork, error)

func (*MonitorRepo) WithByProductName 

func (s *MonitorRepo) WithByProductName(name string) DBOption

type MysqlRepo 

type MysqlRepo struct{}

func (*MysqlRepo) Create 

func (u *MysqlRepo) Create(ctx context.Context, mysql *model.DatabaseMysql) error

func (*MysqlRepo) Delete 

func (u *MysqlRepo) Delete(ctx context.Context, opts ...DBOption) error

func (*MysqlRepo) DeleteLocal 

func (u *MysqlRepo) DeleteLocal(ctx context.Context) error

func (*MysqlRepo) Get 

func (u *MysqlRepo) Get(opts ...DBOption) (model.DatabaseMysql, error)

func (*MysqlRepo) List 

func (u *MysqlRepo) List(opts ...DBOption) ([]model.DatabaseMysql, error)

func (*MysqlRepo) Page 

func (u *MysqlRepo) Page(page, size int, opts ...DBOption) (int64, []model.DatabaseMysql, error)

func (*MysqlRepo) Update 

func (u *MysqlRepo) Update(id uint, vars map[string]interface{}) error

func (*MysqlRepo) WithByMysqlName 

func (u *MysqlRepo) WithByMysqlName(mysqlName string) DBOption

type PHPExtensionsRepo 

type PHPExtensionsRepo struct {
}

func (*PHPExtensionsRepo) Create 

func (p *PHPExtensionsRepo) Create(extension *model.PHPExtensions) error

func (*PHPExtensionsRepo) DeleteBy 

func (p *PHPExtensionsRepo) DeleteBy(opts ...DBOption) error

func (*PHPExtensionsRepo) GetFirst 

func (p *PHPExtensionsRepo) GetFirst(opts ...DBOption) (model.PHPExtensions, error)

func (*PHPExtensionsRepo) List 

func (p *PHPExtensionsRepo) List() ([]model.PHPExtensions, error)

func (*PHPExtensionsRepo) Page 

func (p *PHPExtensionsRepo) Page(page, size int, opts ...DBOption) (int64, []model.PHPExtensions, error)

func (*PHPExtensionsRepo) Save 

func (p *PHPExtensionsRepo) Save(extension *model.PHPExtensions) error

type PostgresqlRepo 

type PostgresqlRepo struct{}

func (*PostgresqlRepo) Create 

func (u *PostgresqlRepo) Create(ctx context.Context, postgresql *model.DatabasePostgresql) error

func (*PostgresqlRepo) Delete 

func (u *PostgresqlRepo) Delete(ctx context.Context, opts ...DBOption) error

func (*PostgresqlRepo) DeleteLocal 

func (u *PostgresqlRepo) DeleteLocal(ctx context.Context) error

func (*PostgresqlRepo) Get 

func (u *PostgresqlRepo) Get(opts ...DBOption) (model.DatabasePostgresql, error)

func (*PostgresqlRepo) List 

func (u *PostgresqlRepo) List(opts ...DBOption) ([]model.DatabasePostgresql, error)

func (*PostgresqlRepo) Page 

func (u *PostgresqlRepo) Page(page, size int, opts ...DBOption) (int64, []model.DatabasePostgresql, error)

func (*PostgresqlRepo) Update 

func (u *PostgresqlRepo) Update(id uint, vars map[string]interface{}) error

func (*PostgresqlRepo) WithByPostgresqlName 

func (u *PostgresqlRepo) WithByPostgresqlName(postgresqlName string) DBOption

type RootInfo 

type RootInfo struct {
	ID            uint   `json:"id"`
	Name          string `json:"name"`
	Status        string `json:"status"`
	Port          int64  `json:"port"`
	HttpsPort     int64  `json:"httpsPort"`
	UserName      string `json:"userName"`
	Password      string `json:"password"`
	UserPassword  string `json:"userPassword"`
	ContainerName string `json:"containerName"`
	ServiceName   string `json:"serviceName"`
	Param         string `json:"param"`
	Env           string `json:"env"`
	Key           string `json:"key"`
	Version       string `json:"version"`
	AppPath       string `json:"app_path"`
}

type RuntimeRepo 

type RuntimeRepo struct {
}

func (*RuntimeRepo) Create 

func (r *RuntimeRepo) Create(ctx context.Context, runtime *model.Runtime) error

func (*RuntimeRepo) DeleteBy 

func (r *RuntimeRepo) DeleteBy(opts ...DBOption) error

func (*RuntimeRepo) GetFirst 

func (r *RuntimeRepo) GetFirst(ctx context.Context, opts ...DBOption) (*model.Runtime, error)

func (*RuntimeRepo) List 

func (r *RuntimeRepo) List(opts ...DBOption) ([]model.Runtime, error)

func (*RuntimeRepo) Page 

func (r *RuntimeRepo) Page(page, size int, opts ...DBOption) (int64, []model.Runtime, error)

func (*RuntimeRepo) Save 

func (r *RuntimeRepo) Save(runtime *model.Runtime) error

func (*RuntimeRepo) WithDetailId 

func (r *RuntimeRepo) WithDetailId(id uint) DBOption

func (*RuntimeRepo) WithDetailIdsIn 

func (r *RuntimeRepo) WithDetailIdsIn(ids []uint) DBOption

func (*RuntimeRepo) WithImage 

func (r *RuntimeRepo) WithImage(image string) DBOption

func (*RuntimeRepo) WithNormalStatus 

func (r *RuntimeRepo) WithNormalStatus(status string) DBOption

func (*RuntimeRepo) WithNotId 

func (r *RuntimeRepo) WithNotId(id uint) DBOption

func (*RuntimeRepo) WithPort 

func (r *RuntimeRepo) WithPort(port int) DBOption

func (*RuntimeRepo) WithStatus 

func (r *RuntimeRepo) WithStatus(status string) DBOption

type ScriptRepo 

type ScriptRepo struct{}

func (*ScriptRepo) Get 

func (u *ScriptRepo) Get(opts ...DBOption) (model.ScriptLibrary, error)

func (*ScriptRepo) List 

func (u *ScriptRepo) List(opts ...DBOption) ([]model.ScriptLibrary, error)

func (*ScriptRepo) SyncAll 

func (u *ScriptRepo) SyncAll(data []model.ScriptLibrary) error

type SettingRepo 

type SettingRepo struct{}

func (*SettingRepo) Create 

func (s *SettingRepo) Create(key, value string) error

func (*SettingRepo) CreateDescription 

func (s *SettingRepo) CreateDescription(data *model.CommonDescription) error

func (*SettingRepo) DelDescription 

func (s *SettingRepo) DelDescription(id string) error

func (*SettingRepo) Get 

func (s *SettingRepo) Get(opts ...DBOption) (model.Setting, error)

func (*SettingRepo) GetDescription 

func (s *SettingRepo) GetDescription(opts ...DBOption) (model.CommonDescription, error)

func (*SettingRepo) GetDescriptionList 

func (s *SettingRepo) GetDescriptionList(opts ...DBOption) ([]model.CommonDescription, error)

func (*SettingRepo) GetList 

func (s *SettingRepo) GetList(opts ...DBOption) ([]model.Setting, error)

func (*SettingRepo) GetValueByKey 

func (s *SettingRepo) GetValueByKey(key string) (string, error)

func (*SettingRepo) Update 

func (s *SettingRepo) Update(key, value string) error

func (*SettingRepo) UpdateDescription 

func (s *SettingRepo) UpdateDescription(id string, val map[string]interface{}) error

func (*SettingRepo) UpdateOrCreate 

func (s *SettingRepo) UpdateOrCreate(key, value string) error

func (*SettingRepo) WithByDescriptionID 

func (s *SettingRepo) WithByDescriptionID(id string) DBOption

func (*SettingRepo) WithByKey 

func (s *SettingRepo) WithByKey(key string) DBOption

type SnapshotRepo 

type SnapshotRepo struct{}

func (*SnapshotRepo) Create 

func (u *SnapshotRepo) Create(Snapshot *model.Snapshot) error

func (*SnapshotRepo) Delete 

func (u *SnapshotRepo) Delete(opts ...DBOption) error

func (*SnapshotRepo) Get 

func (u *SnapshotRepo) Get(opts ...DBOption) (model.Snapshot, error)

func (*SnapshotRepo) GetList 

func (u *SnapshotRepo) GetList(opts ...DBOption) ([]model.Snapshot, error)

func (*SnapshotRepo) Page 

func (u *SnapshotRepo) Page(page, size int, opts ...DBOption) (int64, []model.Snapshot, error)

func (*SnapshotRepo) Update 

func (u *SnapshotRepo) Update(id uint, vars map[string]interface{}) error

type TagRepo 

type TagRepo struct {
}

func (TagRepo) All 

func (t TagRepo) All() ([]model.Tag, error)

func (TagRepo) BatchCreate 

func (t TagRepo) BatchCreate(ctx context.Context, tags []*model.Tag) error

func (TagRepo) Create 

func (t TagRepo) Create(ctx context.Context, tag *model.Tag) error

func (TagRepo) DeleteAll 

func (t TagRepo) DeleteAll(ctx context.Context) error

func (TagRepo) DeleteByID 

func (t TagRepo) DeleteByID(ctx context.Context, id uint) error

func (TagRepo) GetByAppId 

func (t TagRepo) GetByAppId(appId uint) ([]model.Tag, error)

func (TagRepo) GetByIds 

func (t TagRepo) GetByIds(ids []uint) ([]model.Tag, error)

func (TagRepo) GetByKey 

func (t TagRepo) GetByKey(key string) (*model.Tag, error)

func (TagRepo) GetByKeys 

func (t TagRepo) GetByKeys(keys []string) ([]model.Tag, error)

func (TagRepo) Save 

func (t TagRepo) Save(ctx context.Context, tag *model.Tag) error

type TaskRepo 

type TaskRepo struct {
}

func (TaskRepo) CountExecutingTask 

func (t TaskRepo) CountExecutingTask() (int64, error)

func (TaskRepo) Delete 

func (t TaskRepo) Delete(opts ...DBOption) error

func (TaskRepo) DeleteAll 

func (t TaskRepo) DeleteAll() error

func (TaskRepo) GetFirst 

func (t TaskRepo) GetFirst(opts ...DBOption) (model.Task, error)

func (TaskRepo) Page 

func (t TaskRepo) Page(page, size int, opts ...DBOption) (int64, []model.Task, error)

func (TaskRepo) Save 

func (t TaskRepo) Save(ctx context.Context, task *model.Task) error

func (TaskRepo) Update 

func (t TaskRepo) Update(ctx context.Context, task *model.Task) error

func (TaskRepo) UpdateRunningTaskToFailed 

func (t TaskRepo) UpdateRunningTaskToFailed() error

func (TaskRepo) WithByID 

func (t TaskRepo) WithByID(id string) DBOption

func (TaskRepo) WithByIDNotIn 

func (t TaskRepo) WithByIDNotIn(ids []string) DBOption

func (TaskRepo) WithByStatus 

func (t TaskRepo) WithByStatus(status string) DBOption

func (TaskRepo) WithOperate 

func (t TaskRepo) WithOperate(taskOperate string) DBOption

func (TaskRepo) WithResourceID 

func (t TaskRepo) WithResourceID(id uint) DBOption

type TensorRTLLMRepo 

type TensorRTLLMRepo struct {
}

func (TensorRTLLMRepo) Create 

func (t TensorRTLLMRepo) Create(tensorrtLLM *model.TensorRTLLM) error

func (TensorRTLLMRepo) DeleteBy 

func (t TensorRTLLMRepo) DeleteBy(opts ...DBOption) error

func (TensorRTLLMRepo) GetFirst 

func (t TensorRTLLMRepo) GetFirst(opts ...DBOption) (*model.TensorRTLLM, error)

func (TensorRTLLMRepo) List 

func (t TensorRTLLMRepo) List(opts ...DBOption) ([]model.TensorRTLLM, error)

func (TensorRTLLMRepo) Page 

func (t TensorRTLLMRepo) Page(page, size int, opts ...DBOption) (int64, []model.TensorRTLLM, error)

func (TensorRTLLMRepo) Save 

func (t TensorRTLLMRepo) Save(tensorrtLLM *model.TensorRTLLM) error

type WebsiteAcmeAccountRepo 

type WebsiteAcmeAccountRepo struct {
}

func (*WebsiteAcmeAccountRepo) Create 

func (w *WebsiteAcmeAccountRepo) Create(account model.WebsiteAcmeAccount) error

func (*WebsiteAcmeAccountRepo) DeleteBy 

func (w *WebsiteAcmeAccountRepo) DeleteBy(opts ...DBOption) error

func (*WebsiteAcmeAccountRepo) GetFirst 

func (w *WebsiteAcmeAccountRepo) GetFirst(opts ...DBOption) (*model.WebsiteAcmeAccount, error)

func (*WebsiteAcmeAccountRepo) Page 

func (w *WebsiteAcmeAccountRepo) Page(page, size int, opts ...DBOption) (int64, []model.WebsiteAcmeAccount, error)

func (*WebsiteAcmeAccountRepo) Save 

func (w *WebsiteAcmeAccountRepo) Save(account model.WebsiteAcmeAccount) error

func (*WebsiteAcmeAccountRepo) WithEmail 

func (w *WebsiteAcmeAccountRepo) WithEmail(email string) DBOption

func (*WebsiteAcmeAccountRepo) WithType 

func (w *WebsiteAcmeAccountRepo) WithType(acType string) DBOption

type WebsiteCARepo 

type WebsiteCARepo struct {
}

func (WebsiteCARepo) Create 

func (w WebsiteCARepo) Create(ctx context.Context, ca *model.WebsiteCA) error

func (WebsiteCARepo) DeleteBy 

func (w WebsiteCARepo) DeleteBy(opts ...DBOption) error

func (WebsiteCARepo) GetFirst 

func (w WebsiteCARepo) GetFirst(opts ...DBOption) (model.WebsiteCA, error)

func (WebsiteCARepo) List 

func (w WebsiteCARepo) List(opts ...DBOption) ([]model.WebsiteCA, error)

func (WebsiteCARepo) Page 

func (w WebsiteCARepo) Page(page, size int, opts ...DBOption) (int64, []model.WebsiteCA, error)

type WebsiteDnsAccountRepo 

type WebsiteDnsAccountRepo struct {
}

func (WebsiteDnsAccountRepo) Create 

func (w WebsiteDnsAccountRepo) Create(account model.WebsiteDnsAccount) error

func (WebsiteDnsAccountRepo) DeleteBy 

func (w WebsiteDnsAccountRepo) DeleteBy(opts ...DBOption) error

func (WebsiteDnsAccountRepo) GetFirst 

func (w WebsiteDnsAccountRepo) GetFirst(opts ...DBOption) (*model.WebsiteDnsAccount, error)

func (WebsiteDnsAccountRepo) List 

func (w WebsiteDnsAccountRepo) List(opts ...DBOption) ([]model.WebsiteDnsAccount, error)

func (WebsiteDnsAccountRepo) Page 

func (w WebsiteDnsAccountRepo) Page(page, size int, opts ...DBOption) (int64, []model.WebsiteDnsAccount, error)

func (WebsiteDnsAccountRepo) Save 

func (w WebsiteDnsAccountRepo) Save(account model.WebsiteDnsAccount) error

type WebsiteDomainRepo 

type WebsiteDomainRepo struct {
}

func (WebsiteDomainRepo) BatchCreate 

func (w WebsiteDomainRepo) BatchCreate(ctx context.Context, domains []model.WebsiteDomain) error

func (WebsiteDomainRepo) Create 

func (w WebsiteDomainRepo) Create(ctx context.Context, app *model.WebsiteDomain) error

func (WebsiteDomainRepo) DeleteAll 

func (w WebsiteDomainRepo) DeleteAll(ctx context.Context) error

func (WebsiteDomainRepo) DeleteBy 

func (w WebsiteDomainRepo) DeleteBy(ctx context.Context, opts ...DBOption) error

func (WebsiteDomainRepo) GetBy 

func (w WebsiteDomainRepo) GetBy(opts ...DBOption) ([]model.WebsiteDomain, error)

func (WebsiteDomainRepo) GetFirst 

func (w WebsiteDomainRepo) GetFirst(opts ...DBOption) (model.WebsiteDomain, error)

func (WebsiteDomainRepo) Page 

func (w WebsiteDomainRepo) Page(page, size int, opts ...DBOption) (int64, []model.WebsiteDomain, error)

func (WebsiteDomainRepo) Save 

func (w WebsiteDomainRepo) Save(ctx context.Context, app *model.WebsiteDomain) error

func (WebsiteDomainRepo) WithDomain 

func (w WebsiteDomainRepo) WithDomain(domain string) DBOption

func (WebsiteDomainRepo) WithDomainLike 

func (w WebsiteDomainRepo) WithDomainLike(domain string) DBOption

func (WebsiteDomainRepo) WithPort 

func (w WebsiteDomainRepo) WithPort(port int) DBOption

func (WebsiteDomainRepo) WithWebsiteId 

func (w WebsiteDomainRepo) WithWebsiteId(websiteId uint) DBOption

func (WebsiteDomainRepo) WithWebsiteIds 

func (w WebsiteDomainRepo) WithWebsiteIds(websiteIds []uint) DBOption

type WebsiteRepo 

type WebsiteRepo struct {
}

func (*WebsiteRepo) Create 

func (w *WebsiteRepo) Create(ctx context.Context, app *model.Website) error

func (*WebsiteRepo) DeleteAll 

func (w *WebsiteRepo) DeleteAll(ctx context.Context) error

func (*WebsiteRepo) DeleteBy 

func (w *WebsiteRepo) DeleteBy(ctx context.Context, opts ...DBOption) error

func (*WebsiteRepo) GetBy 

func (w *WebsiteRepo) GetBy(opts ...DBOption) ([]model.Website, error)

func (*WebsiteRepo) GetFirst 

func (w *WebsiteRepo) GetFirst(opts ...DBOption) (model.Website, error)

func (*WebsiteRepo) List 

func (w *WebsiteRepo) List(opts ...DBOption) ([]model.Website, error)

func (*WebsiteRepo) Page 

func (w *WebsiteRepo) Page(page, size int, opts ...DBOption) (int64, []model.Website, error)

func (*WebsiteRepo) Save 

func (w *WebsiteRepo) Save(ctx context.Context, app *model.Website) error

func (*WebsiteRepo) SaveWithoutCtx 

func (w *WebsiteRepo) SaveWithoutCtx(website *model.Website) error

func (*WebsiteRepo) UpdateGroup 

func (w *WebsiteRepo) UpdateGroup(group, newGroup uint) error

func (*WebsiteRepo) WithAlias 

func (w *WebsiteRepo) WithAlias(alias string) DBOption

func (*WebsiteRepo) WithAppInstallId 

func (w *WebsiteRepo) WithAppInstallId(appInstallID uint) DBOption

func (*WebsiteRepo) WithAppInstallIds 

func (w *WebsiteRepo) WithAppInstallIds(appInstallIDs []uint) DBOption

func (*WebsiteRepo) WithDBID 

func (w *WebsiteRepo) WithDBID(dbID uint) DBOption

func (*WebsiteRepo) WithDBType 

func (w *WebsiteRepo) WithDBType(dbType string) DBOption

func (*WebsiteRepo) WithDBTypes 

func (w *WebsiteRepo) WithDBTypes(dbTypes []string) DBOption

func (*WebsiteRepo) WithDefaultServer 

func (w *WebsiteRepo) WithDefaultServer() DBOption

func (*WebsiteRepo) WithDomain 

func (w *WebsiteRepo) WithDomain(domain string) DBOption

func (*WebsiteRepo) WithDomainLike 

func (w *WebsiteRepo) WithDomainLike(domain string) DBOption

func (*WebsiteRepo) WithGroupID 

func (w *WebsiteRepo) WithGroupID(groupId uint) DBOption

func (*WebsiteRepo) WithParentID 

func (w *WebsiteRepo) WithParentID(websiteID uint) DBOption

func (*WebsiteRepo) WithRuntimeID 

func (w *WebsiteRepo) WithRuntimeID(runtimeID uint) DBOption

func (*WebsiteRepo) WithSearchKeyword 

func (w *WebsiteRepo) WithSearchKeyword(keyword string, ids []uint) DBOption

func (*WebsiteRepo) WithType 

func (w *WebsiteRepo) WithType(websiteType string) DBOption

func (*WebsiteRepo) WithWebsiteSSLID 

func (w *WebsiteRepo) WithWebsiteSSLID(sslId uint) DBOption

type WebsiteSSLRepo 

type WebsiteSSLRepo struct {
}

func (WebsiteSSLRepo) Create 

func (w WebsiteSSLRepo) Create(ctx context.Context, ssl *model.WebsiteSSL) error

func (WebsiteSSLRepo) DeleteBy 

func (w WebsiteSSLRepo) DeleteBy(opts ...DBOption) error

func (WebsiteSSLRepo) GetFirst 

func (w WebsiteSSLRepo) GetFirst(opts ...DBOption) (*model.WebsiteSSL, error)

func (WebsiteSSLRepo) List 

func (w WebsiteSSLRepo) List(opts ...DBOption) ([]model.WebsiteSSL, error)

func (WebsiteSSLRepo) Page 

func (w WebsiteSSLRepo) Page(page, size int, opts ...DBOption) (int64, []model.WebsiteSSL, error)

func (WebsiteSSLRepo) Save 

func (w WebsiteSSLRepo) Save(ssl *model.WebsiteSSL) error

func (WebsiteSSLRepo) SaveByMap 

func (w WebsiteSSLRepo) SaveByMap(ssl *model.WebsiteSSL, params map[string]interface{}) error

func (WebsiteSSLRepo) TryMarkApplying 

func (w WebsiteSSLRepo) TryMarkApplying(id uint) (bool, error)

func (WebsiteSSLRepo) WithByAcmeAccountId 

func (w WebsiteSSLRepo) WithByAcmeAccountId(acmeAccountId uint) DBOption

func (WebsiteSSLRepo) WithByAlias 

func (w WebsiteSSLRepo) WithByAlias(alias string) DBOption

func (WebsiteSSLRepo) WithByCAID 

func (w WebsiteSSLRepo) WithByCAID(caID uint) DBOption

func (WebsiteSSLRepo) WithByDnsAccountId 

func (w WebsiteSSLRepo) WithByDnsAccountId(dnsAccountId uint) DBOption

func (WebsiteSSLRepo) WithByDomain 

func (w WebsiteSSLRepo) WithByDomain(domain string) DBOption

func (WebsiteSSLRepo) WithByMasterSSLID 

func (w WebsiteSSLRepo) WithByMasterSSLID(sslID uint) DBOption

type WebsiteTemplateOutputRepo 

type WebsiteTemplateOutputRepo struct {
}

func (*WebsiteTemplateOutputRepo) Create 

func (w *WebsiteTemplateOutputRepo) Create(output *model.WebsiteTemplateOutput) error

func (*WebsiteTemplateOutputRepo) DeleteBy 

func (w *WebsiteTemplateOutputRepo) DeleteBy(opts ...DBOption) error

func (*WebsiteTemplateOutputRepo) GetFirst 

func (w *WebsiteTemplateOutputRepo) GetFirst(opts ...DBOption) (*model.WebsiteTemplateOutput, error)

func (*WebsiteTemplateOutputRepo) List 

func (w *WebsiteTemplateOutputRepo) List(opts ...DBOption) ([]model.WebsiteTemplateOutput, error)

func (*WebsiteTemplateOutputRepo) Page 

func (w *WebsiteTemplateOutputRepo) Page(page, size int, opts ...DBOption) (int64, []model.WebsiteTemplateOutput, error)

func (*WebsiteTemplateOutputRepo) Save 

func (w *WebsiteTemplateOutputRepo) Save(output *model.WebsiteTemplateOutput) error

func (*WebsiteTemplateOutputRepo) WithByTemplateID 

func (w *WebsiteTemplateOutputRepo) WithByTemplateID(templateID uint) DBOption

type WebsiteTemplateRepo 

type WebsiteTemplateRepo struct {
}

func (*WebsiteTemplateRepo) Create 

func (w *WebsiteTemplateRepo) Create(template *model.WebsiteTemplate) error

func (*WebsiteTemplateRepo) DeleteBy 

func (w *WebsiteTemplateRepo) DeleteBy(opts ...DBOption) error

func (*WebsiteTemplateRepo) GetFirst 

func (w *WebsiteTemplateRepo) GetFirst(opts ...DBOption) (*model.WebsiteTemplate, error)

func (*WebsiteTemplateRepo) List 

func (w *WebsiteTemplateRepo) List(opts ...DBOption) ([]model.WebsiteTemplate, error)

func (*WebsiteTemplateRepo) Page 

func (w *WebsiteTemplateRepo) Page(page, size int, opts ...DBOption) (int64, []model.WebsiteTemplate, error)

func (*WebsiteTemplateRepo) Save 

func (w *WebsiteTemplateRepo) Save(template *model.WebsiteTemplate) error

func (*WebsiteTemplateRepo) WithName 

func (w *WebsiteTemplateRepo) WithName(name string) DBOption

func (*WebsiteTemplateRepo) WithType 

func (w *WebsiteTemplateRepo) WithType(templateType string) DBOption

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.