repo

package
v0.0.0-...-c7f185a Latest Latest
Warning

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

Go to latest
Published: Feb 13, 2026 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AgentAccountRepo

type AgentAccountRepo struct{}

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

type AgentRepo

type AgentRepo struct{}

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

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

func (*AlertRepo) WithByAlertId

func (a *AlertRepo) WithByAlertId(alertId 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) WithByLicenseId

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

func (*AlertRepo) WithByMethod

func (a *AlertRepo) WithByMethod(method string) 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

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 (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 (AppInstallResourceRpo) DeleteBy

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

func (AppInstallResourceRpo) GetBy

func (AppInstallResourceRpo) GetFirst

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

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 (*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 WithByAccountID

func WithByAccountID(accountID 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 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 WithByProvider

func WithByProvider(provider string) DBOption

func WithByStatus

func WithByStatus(status string) DBOption

func WithByType

func WithByType(tp 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 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 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 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) DeleteCert

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

func (*HostRepo) DeleteFirewallRecordByID

func (h *HostRepo) DeleteFirewallRecordByID(id uint) error

func (*HostRepo) GetCert

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

func (*HostRepo) GetFirewallRecord

func (h *HostRepo) GetFirewallRecord(opts ...DBOption) (model.Firewall, error)

func (*HostRepo) ListCert

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

func (*HostRepo) ListFirewallRecord

func (h *HostRepo) ListFirewallRecord(opts ...DBOption) ([]model.Firewall, 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) SaveFirewallRecord

func (h *HostRepo) SaveFirewallRecord(firewall *model.Firewall) error

func (*HostRepo) SyncCert

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

func (*HostRepo) UpdateCert

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

func (*HostRepo) WithByChain

func (u *HostRepo) WithByChain(chain 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 IAgentAccountRepo

type IAgentAccountRepo interface {
	Page(page, size int, opts ...DBOption) (int64, []model.AgentAccount, error)
	GetFirst(opts ...DBOption) (*model.AgentAccount, error)
	Create(account *model.AgentAccount) error
	Save(account *model.AgentAccount) error
	DeleteByID(id uint) error
	List(opts ...DBOption) ([]model.AgentAccount, 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
	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
	WithByMethod(method string) 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
	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)
	AlertConfigList(opts ...DBOption) ([]model.AlertConfig, error)
	UpdateAlertConfig(maps map[string]interface{}, opts ...DBOption) error
	CreateAlertConfig(config *model.AlertConfig) error
	DeleteAlertConfig(opts ...DBOption) 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
	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 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 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 {
	GetFirewallRecord(opts ...DBOption) (model.Firewall, error)
	ListFirewallRecord(opts ...DBOption) ([]model.Firewall, error)
	SaveFirewallRecord(firewall *model.Firewall) error
	DeleteFirewallRecordByID(id uint) error

	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

	WithByChain(chain string) DBOption
}

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 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)
	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
	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
	WithDomain(domain string) DBOption
	WithAlias(alias string) DBOption
	WithWebsiteSSLID(sslId uint) DBOption
	WithGroupID(groupId uint) DBOption
	WithDefaultServer() DBOption
	WithDomainLike(domain string) DBOption
	WithRuntimeID(runtimeID uint) DBOption
	WithParentID(websiteID uint) DBOption
	WithType(websiteType string) DBOption
	WithDBType(dbType 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 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 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 (*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 (*WebsiteAcmeAccountRepo) DeleteBy

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

func (*WebsiteAcmeAccountRepo) GetFirst

func (*WebsiteAcmeAccountRepo) Page

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

func (*WebsiteAcmeAccountRepo) Save

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 (WebsiteDnsAccountRepo) DeleteBy

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

func (WebsiteDnsAccountRepo) GetFirst

func (WebsiteDnsAccountRepo) List

func (WebsiteDnsAccountRepo) Page

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

func (WebsiteDnsAccountRepo) Save

type WebsiteDomainRepo

type WebsiteDomainRepo struct {
}

func (WebsiteDomainRepo) BatchCreate

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

func (WebsiteDomainRepo) Create

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 (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

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

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

func (*WebsiteRepo) WithDBType

func (w *WebsiteRepo) WithDBType(dbType 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) 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) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL