model

package

Go to main page

Versions in this module

v1

v1.0.5-preview.4

Aug 10, 2026

v1.0.5-preview.3

Aug 4, 2026

v1.0.5-preview.2

Jul 25, 2026

v1.0.5-preview.1

Jul 23, 2026

v1.0.4

Jul 18, 2026

Changes in this version

+ const LogFilterEmptyRetry

+ const LogFilterErrorRetry

+ const LogQuotaFilterAbnormal

+ const LogQuotaFilterNegative

+ const LogQuotaFilterZero

+ var ErrEmailAlreadyTaken = errors.New("email already taken")

+ var ErrEmailAmbiguous = errors.New("email matches multiple users")

+ var ErrEmailNotFound = errors.New("email not found")

+ var ErrLogRetryMarkerBackfillIncomplete = errors.New("log retry marker backfill is not completed")

+ var ErrTokenNotFound = errors.New("token not found")

+ var ErrTokenQuotaInsufficient = errors.New("token quota is not enough")

+ var ErrUserDeleted = errors.New("user deleted")

+ var ErrUserNotFound = errors.New("user not found")

+ var ErrUserQuotaInsufficient = errors.New("user quota is not enough")

+ func BindEmailToUser(user *User, email string) error

+ func CountUsersByEmail(email string) (int64, error)

+ func DecreaseTokenAndUserQuota(tokenId, userId int, key string, quota int) error

+ func EnsureEmailAvailable(email string, excludeUserID int) error

+ func IsEmailAvailable(email string, excludeUserID int) (bool, error)

+ func NormalizeEmail(email string) string

+ func UpdateUserSetting(userId int, setting dto.UserSetting) error

+ func WaitPendingLogQuotaData()

+ func WithNormalizedEmailWriteTx(email string, fn func(tx *gorm.DB) error) error

+ func WithUserOAuthIdentityWriteTx(email string, fn func(tx *gorm.DB) error) error

type Log

+ IsEmptyRetry bool

+ IsErrorRetry bool

+ type LogQueryParams struct

+ Channel int

+ EndTimestamp int64

+ Group string

+ LogFilter string

+ LogType int

+ ModelName string

+ Num int

+ QuotaFilter string

+ RequestId string

+ StartIdx int

+ StartTimestamp int64

+ TokenName string

+ UpstreamRequestId string

+ UserId int

+ Username string

type QuotaData

+ AggregateKey *string

+ ChannelID int

+ NodeName string

+ SnapshotID *string

+ TokenID int

+ UseGroup string

+ type QuotaDataLogParams struct

+ ChannelID int

+ CreatedAt int64

+ ModelName string

+ NodeName string

+ Quota int

+ TokenID int

+ TokenUsed int

+ UseGroup string

+ UserID int

+ Username string

+ type QuotaDataSnapshot struct

+ CreatedAt int64

+ SnapshotID string

+ type QuotaDataSnapshotRetry struct

+ RetryUntil int64

+ SnapshotID string

+ UpdatedAt int64

type RecordTaskBillingLogParams

+ NodeName string

+ type SubscriptionResetResult struct

+ AdvanceResetTime bool

+ AffectedUserIds []int

+ MatchedCount int

+ PlanId int

+ PlanTitle string

+ ResetCount int

+ UserCount int

+ func AdminResetPlanSubscriptions(planId int, advanceResetTime bool) (*SubscriptionResetResult, error)

+ func AdminResetUserSubscriptionsByPlan(userId int, planId int, advanceResetTime bool) (*SubscriptionResetResult, error)

type SyncTaskQueryParams

+ QuotaFilter string

type Task

+ func (t *Task) UpdateQuota() error

type TaskPrivateData

+ NodeName string

type TaskQueryParams

+ QuotaFilter string

type User

+ NormalizedEmail string

+ func GetUniqueUserByEmail(email string) (*User, error)

+ func (user *User) BeforeSave(_ *gorm.DB) error

+ func (user *User) UpdateFields(updatePassword bool, fields ...UserUpdateField) error

+ func (user *User) UpdateFieldsWithTx(tx *gorm.DB, updatePassword bool, fields ...UserUpdateField) error

+ func (user *User) UpdateWithTx(tx *gorm.DB, updatePassword bool) error

+ func (user *User) ValidateOAuthIdentityLengths() error

+ type UserUpdateField string

+ const UserUpdateFieldAccessToken

+ const UserUpdateFieldAffCode

+ const UserUpdateFieldAffCount

+ const UserUpdateFieldAffHistoryQuota

+ const UserUpdateFieldAffQuota

+ const UserUpdateFieldDiscordId

+ const UserUpdateFieldDisplayName

+ const UserUpdateFieldEmail

+ const UserUpdateFieldGitHubId

+ const UserUpdateFieldGroup

+ const UserUpdateFieldInviterId

+ const UserUpdateFieldLastLoginAt

+ const UserUpdateFieldLinuxDOId

+ const UserUpdateFieldOidcId

+ const UserUpdateFieldRemark

+ const UserUpdateFieldRole

+ const UserUpdateFieldSetting

+ const UserUpdateFieldStatus

+ const UserUpdateFieldStripeCustomer

+ const UserUpdateFieldTelegramId

+ const UserUpdateFieldUsername

+ const UserUpdateFieldWeChatId

v1.0.4-preview.5

Jul 15, 2026

v1.0.4-preview.4

Jul 13, 2026

v1.0.4-preview.3

Jul 10, 2026

v1.0.4-preview.2

Jul 7, 2026

v1.0.4-preview.1

Jul 3, 2026

v1.0.3

Jun 30, 2026

Changes in this version

+ const LogFilterRetry

+ const LogTypeLogin

+ const SystemInstanceStaleAfterSeconds

+ const SystemInstanceStatusOnline

+ const SystemInstanceStatusStale

+ const SystemTaskStatusFailed

+ const SystemTaskStatusPending

+ const SystemTaskStatusRunning

+ const SystemTaskStatusSucceeded

+ const SystemTaskTypeAsyncTaskPoll

+ const SystemTaskTypeChannelTest

+ const SystemTaskTypeLogCleanup

+ const SystemTaskTypeMidjourneyPoll

+ const SystemTaskTypeModelUpdate

+ const UserQuotaStatusNegative

+ const UserQuotaStatusPositive

+ const UserQuotaStatusZero

+ var ErrSystemInstanceNotFound = errors.New("System instance not found.")

+ var ErrSystemInstanceOnline = errors.New("Instance is still online and cannot be deleted.")

+ var ErrSystemTaskLockLost = errors.New("system task lock lost")

+ func CountOldLog(ctx context.Context, targetTimestamp int64) (int64, error)

+ func DeleteOldLogBatch(ctx context.Context, targetTimestamp int64, limit int) (int64, error)

+ func DeleteStaleSystemInstance(nodeName string, now int64) error

+ func FinishSystemTask(taskID string, lockedBy string, status SystemTaskStatus, resultPayload any, ...) error

+ func GenerateSystemTaskID() (string, error)

+ func RecordLoginLog(userId int, username string, content string, ip string, action string, ...)

+ func RecordOperationAuditLog(logUserId int, content string, ip string, action string, ...)

+ func UpdateSystemTaskState(taskID string, lockedBy string, state any, lockUntil int64) error

+ func UpsertSystemInstance(nodeName string, info any, startedAt int64, lastSeenAt int64) error

type Log

+ IsRetry bool

+ LogId int

+ func GetLogById(id int) (*Log, error)

+ func GetUserLogById(userId int, id int) (*Log, error)

+ func (log *Log) BeforeCreate(*gorm.DB) error

+ func (log *Log) BeforeSave(*gorm.DB) error

+ type SystemInstance struct

+ CreatedAt int64

+ Info string

+ LastSeenAt int64

+ NodeName string

+ StartedAt int64

+ UpdatedAt int64

+ func ListSystemInstances() ([]*SystemInstance, error)

+ func (instance *SystemInstance) BeforeCreate(_ *gorm.DB) error

+ func (instance *SystemInstance) ToResponse(now int64) SystemInstanceResponse

+ type SystemInstanceResponse struct

+ Info any

+ LastSeenAt int64

+ NodeName string

+ StaleAfterSeconds int64

+ StartedAt int64

+ Status string

+ type SystemTask struct

+ ActiveKey *string

+ CreatedAt int64

+ Error string

+ ID int64

+ LockedBy string

+ LockedUntil int64

+ Payload string

+ Result string

+ State string

+ Status SystemTaskStatus

+ TaskID string

+ Type string

+ UpdatedAt int64

+ func ClaimSystemTask(id int64, taskType string, runnerID string, lockUntil int64) (*SystemTask, bool, error)

+ func CreateSystemTask(taskType string, activeKey string, payload any, state any) (*SystemTask, error)

+ func FindRunnableSystemTasks(taskType string, now int64, limit int) ([]*SystemTask, error)

+ func GetActiveSystemTask(taskType string) (*SystemTask, error)

+ func GetSystemTaskByTaskID(taskID string) (*SystemTask, error)

+ func ListSystemTasks(limit int) ([]*SystemTask, error)

+ func (task *SystemTask) BeforeCreate(_ *gorm.DB) error

+ func (task *SystemTask) DecodePayload(v any) error

+ func (task *SystemTask) DecodeState(v any) error

+ func (task *SystemTask) ToResponse() SystemTaskResponse

+ type SystemTaskResponse struct

+ ActiveKey string

+ CreatedAt int64

+ Error string

+ ID int64

+ LockedBy string

+ LockedUntil int64

+ Payload any

+ Result any

+ State any

+ Status SystemTaskStatus

+ TaskID string

+ Type string

+ UpdatedAt int64

+ type SystemTaskStatus string

v1.0.3-preview.2

Jun 27, 2026

v1.0.3-preview

Jun 24, 2026

v1.0.2

Jun 22, 2026

Changes in this version

type Token

+ func ValidateUserTokenForReadOnly(key string) (token *Token, err error)

type UserBase

+ Role int

v1.0.1

Jun 20, 2026

v1.0.0

Jun 19, 2026

Changes in this version

+ const BatchUpdateTypeChannelUsedQuota

+ const BatchUpdateTypeCount

+ const BatchUpdateTypeRequestCount

+ const BatchUpdateTypeTokenQuota

+ const BatchUpdateTypeUsedQuota

+ const BatchUpdateTypeUserQuota

+ const LogTypeConsume

+ const LogTypeError

+ const LogTypeManage

+ const LogTypeRefund

+ const LogTypeSystem

+ const LogTypeTopup

+ const LogTypeUnknown

+ const NameRuleContains

+ const NameRuleExact

+ const NameRulePrefix

+ const NameRuleSuffix

+ const PaymentMethodBalance

+ const PaymentMethodCreem

+ const PaymentMethodStripe

+ const PaymentMethodWaffo

+ const PaymentMethodWaffoPancake

+ const PaymentProviderBalance

+ const PaymentProviderCreem

+ const PaymentProviderEpay

+ const PaymentProviderStripe

+ const PaymentProviderWaffo

+ const PaymentProviderWaffoPancake

+ const SubscriptionDurationCustom

+ const SubscriptionDurationDay

+ const SubscriptionDurationHour

+ const SubscriptionDurationMonth

+ const SubscriptionDurationYear

+ const SubscriptionResetCustom

+ const SubscriptionResetDaily

+ const SubscriptionResetMonthly

+ const SubscriptionResetNever

+ const SubscriptionResetWeekly

+ const TaskStatusFailure

+ const TaskStatusInProgress

+ const TaskStatusNotStart

+ const TaskStatusQueued

+ const TaskStatusSubmitted

+ const TaskStatusSuccess

+ const TaskStatusUnknown

+ const UserNameMaxLength

+ var CacheQuotaData = make(map[string]*QuotaData)

+ var CacheQuotaDataLock = sync.Mutex

+ var DB *gorm.DB

+ var ErrDatabase = errors.New("database error")

+ var ErrFriendlyPasskeyNotFound = errors.New("Passkey 验证失败，请重试或联系管理员")

+ var ErrInvalidCredentials = errors.New("invalid credentials")

+ var ErrPasskeyNotFound = errors.New("passkey credential not found")

+ var ErrPaymentMethodMismatch = errors.New("payment method mismatch")

+ var ErrRedeemFailed = errors.New("redeem.failed")

+ var ErrSubscriptionOrderNotFound = errors.New("subscription order not found")

+ var ErrSubscriptionOrderStatusInvalid = errors.New("subscription order status invalid")

+ var ErrTokenInvalid = errors.New("token invalid")

+ var ErrTokenNotProvided = errors.New("token not provided")

+ var ErrTopUpNotFound = errors.New("topup not found")

+ var ErrTopUpStatusInvalid = errors.New("topup status invalid")

+ var ErrTwoFANotEnabled = errors.New("2fa not enabled")

+ var ErrUserEmptyCredentials = errors.New("empty credentials")

+ var LOG_DB *gorm.DB

+ func AdminBindSubscription(userId int, planId int, sourceNote string) (string, error)

+ func AdminDeleteUserSubscription(userSubscriptionId int) (string, error)

+ func AdminInvalidateUserSubscription(userSubscriptionId int) (string, error)

+ func ApplyChannelGroupFilter(query *gorm.DB, group string) *gorm.DB

+ func BatchDeleteChannels(ids []int) error

+ func BatchDeleteTokens(ids []int, userId int) (int, error)

+ func BatchInsertChannels(channels []Channel) error

+ func BatchSetChannelTag(ids []int, tag *string) error

+ func CacheUpdateChannel(channel *Channel)

+ func CacheUpdateChannelStatus(id int, status int)

+ func ChannelSupportsRequestPath(channel *Channel, requestPath string) bool

+ func CheckSetup()

+ func CheckUserExistOrDeleted(username string, email string) (bool, error)

+ func CleanupChannelPollingLocks()

+ func CleanupSubscriptionPreConsumeRecords(olderThanSeconds int64) (int64, error)

+ func CloseDB() error

+ func CompleteSubscriptionOrder(tradeNo string, providerPayload string, expectedPaymentProvider string, ...) error

+ func CountAllChannels() (int64, error)

+ func CountAllTags() (int64, error)

+ func CountAllTasks(queryParams TaskQueryParams) int64

+ func CountAllUserTask(userId int, queryParams TaskQueryParams) int64

+ func CountChannelTags(query *gorm.DB) (int64, error)

+ func CountChannelsByType(channelType int) (int64, error)

+ func CountChannelsGroupByType() (map[int64]int64, error)

+ func CountUserSubscriptionsByPlan(userId int, planId int) (int64, error)

+ func CountUserTokens(userId int) (int64, error)

+ func CreateBackupCodes(userId int, codes []string) error

+ func CreateCustomOAuthProvider(provider *CustomOAuthProvider) error

+ func CreateUserOAuthBinding(binding *UserOAuthBinding) error

+ func CreateUserOAuthBindingWithTx(tx *gorm.DB, binding *UserOAuthBinding) error

+ func DecreaseTokenQuota(id int, key string, quota int) (err error)

+ func DecreaseUserQuota(id int, quota int, db bool) (err error)

+ func DeleteChannelByStatus(status int64) (int64, error)

+ func DeleteCustomOAuthProvider(id int) error

+ func DeleteDisabledChannel() (int64, error)

+ func DeleteInvalidRedemptions() (int64, error)

+ func DeleteOldLog(ctx context.Context, targetTimestamp int64, limit int) (int64, error)

+ func DeletePasskeyByUserID(userID int) error

+ func DeletePerfMetricsBefore(cutoffTs int64) error

+ func DeletePrefillGroupByID(id int) error

+ func DeleteRedemptionById(id int) (err error)

+ func DeleteTokenById(id int, userId int) (err error)

+ func DeleteUserById(id int) (err error)

+ func DeleteUserOAuthBinding(userId, providerId int) error

+ func DeleteUserOAuthBindingsByUserId(userId int) error

+ func DeltaUpdateUserQuota(id int, delta int) (err error)

+ func DisableChannelByTag(tag string) error

+ func DisableModelLimits(tokenId int) error

+ func DisableTwoFA(userId int) error

+ func EditChannelByTag(tag string, newTag *string, modelMapping *string, models *string, ...) error

+ func EnableChannelByTag(tag string) error

+ func ExpireDueSubscriptions(limit int) (int, error)

+ func ExpireSubscriptionOrder(tradeNo string, expectedPaymentProvider string) error

+ func FixAbility() (int, int, error)

+ func GenerateTaskID() string

+ func GetBindingCountByProviderId(providerId int) (int64, error)

+ func GetBoundChannelsByModelsMap(modelNames []string) (map[string][]BoundChannel, error)

+ func GetChannelPollingLock(channelId int) *sync.Mutex

+ func GetDBTimestamp() int64

+ func GetEnabledModels() []string

+ func GetGroupEnabledModels(group string) []string

+ func GetMaxUserId() int

+ func GetMissingModels() ([]string, error)

+ func GetModelEnableGroups(modelName string) []string

+ func GetModelQuotaTypes(modelName string) []int

+ func GetModelSupportEndpointTypes(model string) []constant.EndpointType

+ func GetPaginatedChannelTags(query *gorm.DB, offset int, limit int) ([]*string, error)

+ func GetPaginatedTags(offset int, limit int) ([]*string, error)

+ func GetPreferredModelOwnerChannelTypes(modelNames []string, groups []string) (map[string]int, error)

+ func GetSupportedEndpointMap() map[string]common.EndpointInfo

+ func GetTwoFAStats() (map[string]interface{}, error)

+ func GetUnusedBackupCodeCount(userId int) (int, error)

+ func GetUserCheckinStats(userId int, month string) (map[string]interface{}, error)

+ func GetUserEmail(id int) (email string, err error)

+ func GetUserGroup(id int, fromDB bool) (group string, err error)

+ func GetUserIdByAffCode(affCode string) (int, error)

+ func GetUserLanguage(userId int) string

+ func GetUserQuota(id int, fromDB bool) (quota int, err error)

+ func GetUserSetting(id int, fromDB bool) (settingMap dto.UserSetting, err error)

+ func GetUserUsedQuota(id int) (quota int, err error)

+ func GetUsernameById(id int, fromDB bool) (username string, err error)

+ func GetVendorModelCounts() (map[int64]int64, error)

+ func HardDeleteUserById(id int) error

+ func HasActiveUserSubscription(userId int) (bool, error)

+ func HasCheckedInToday(userId int) (bool, error)

+ func IncreaseTokenQuota(tokenId int, key string, quota int) (err error)

+ func IncreaseUserQuota(id int, quota int, db bool) (err error)

+ func InitBatchUpdater()

+ func InitChannelCache()

+ func InitDB() (err error)

+ func InitLogDB() (err error)

+ func InitOptionMap()

+ func InvalidatePricingCache()

+ func InvalidateSubscriptionPlanCache(planId int)

+ func InvalidateUserCache(userId int) error

+ func InvalidateUserTokensCache(userId int) error

+ func IsAdmin(userId int) bool

+ func IsChannelEnabledForAnyGroupModel(groups []string, modelName string, channelID int) bool

+ func IsChannelEnabledForGroupModel(group string, modelName string, channelID int) bool

+ func IsDiscordIdAlreadyTaken(discordId string) bool

+ func IsEmailAlreadyTaken(email string) bool

+ func IsGitHubIdAlreadyTaken(githubId string) bool

+ func IsLinuxDOIdAlreadyTaken(linuxDOId string) bool

+ func IsModelNameDuplicated(id int, name string) (bool, error)

+ func IsOidcIdAlreadyTaken(oidcId string) bool

+ func IsPrefillGroupNameDuplicated(id int, name string) (bool, error)

+ func IsProviderUserIdTaken(providerId int, providerUserId string) bool

+ func IsSlugTaken(slug string, excludeId int) bool

+ func IsTelegramIdAlreadyTaken(telegramId string) bool

+ func IsTwoFAEnabled(userId int) bool

+ func IsVendorNameDuplicated(id int, name string) (bool, error)

+ func IsWeChatIdAlreadyTaken(wechatId string) bool

+ func LogQuotaData(userId int, username string, modelName string, quota int, createdAt int64, ...)

+ func ManualCompleteTopUp(tradeNo string, callerIp string) error

+ func MaskTokenKey(key string) string

+ func MjBulkUpdate(mjIds []string, params map[string]any) error

+ func MjBulkUpdateByTaskIds(taskIDs []int, params map[string]any) error

+ func NormalizeChannelGroupFilter(group string) string

+ func NormalizeResetPeriod(period string) string

+ func PerfMetricStartTime(hours int) int64

+ func PingDB() error

+ func PostConsumeUserSubscriptionDelta(userSubscriptionId int, delta int64) error

+ func PurchaseSubscriptionWithBalance(userId int, planId int) error

+ func Recharge(referenceId string, customerId string, callerIp string) (err error)

+ func RechargeCreem(referenceId string, customerEmail string, customerName string, callerIp string) (err error)

+ func RechargeWaffo(tradeNo string, callerIp string) (err error)

+ func RechargeWaffoPancake(tradeNo string) (err error)

+ func RecordConsumeLog(c *gin.Context, userId int, params RecordConsumeLogParams)

+ func RecordErrorLog(c *gin.Context, userId int, channelId int, modelName string, tokenName string, ...)

+ func RecordExist(err error) (bool, error)

+ func RecordLog(userId int, logType int, content string)

+ func RecordLogWithAdminInfo(userId int, logType int, content string, adminInfo map[string]interface{})

+ func RecordTaskBillingLog(params RecordTaskBillingLogParams)

+ func RecordTopupLog(userId int, content string, callerIp string, paymentMethod string, ...)

+ func Redeem(key string, userId int) (quota int, err error)

+ func RefreshPricing()

+ func RefundSubscriptionPreConsume(requestId string) error

+ func ResetDueSubscriptions(limit int) (int, error)

+ func ResetUserPasswordByEmail(email string, password string) error

+ func RootUserExists() bool

+ func SaveQuotaDataCache()

+ func SearchTags(keyword string, group string, model string, idSort bool) ([]*string, error)

+ func SumUsedToken(logType int, startTimestamp int64, endTimestamp int64, modelName string, ...) (token int)

+ func SyncChannelCache(frequency int)

+ func SyncOptions(frequency int)

+ func TaskBulkUpdate(taskIds []string, params map[string]any) error

+ func TaskBulkUpdateByID(ids []int64, params map[string]any) error

+ func TaskCountAllTasks(queryParams SyncTaskQueryParams) int64

+ func TaskCountAllUserTask(userId int, queryParams SyncTaskQueryParams) int64

+ func UpdateAbilityByTag(tag string, newTag *string, priority *int64, weight *uint) error

+ func UpdateAbilityStatus(channelId int, status bool) error

+ func UpdateAbilityStatusByTag(tag string, status bool) error

+ func UpdateChannelStatus(channelId int, usingKey string, status int, reason string) bool

+ func UpdateChannelUsedQuota(id int, quota int)

+ func UpdateCustomOAuthProvider(provider *CustomOAuthProvider) error

+ func UpdateOption(key string, value string) error

+ func UpdateOptionsBulk(values map[string]string) error

+ func UpdatePendingTopUpStatus(tradeNo string, expectedPaymentProvider string, targetStatus string) error

+ func UpdateProgress(id int, progress string) error

+ func UpdateQuotaData()

+ func UpdateUserGroupCache(userId int, group string) error

+ func UpdateUserLastLoginAt(id int)

+ func UpdateUserOAuthBinding(userId, providerId int, newProviderUserId string) error

+ func UpdateUserUsedQuotaAndRequestCount(id int, quota int)

+ func UpsertPasskeyCredential(credential *PasskeyCredential) error

+ func UpsertPerfMetric(metric *PerfMetric) error

+ func ValidateBackupCode(userId int, code string) (bool, error)

+ type Ability struct

+ ChannelId int

+ Enabled bool

+ Group string

+ Model string

+ Priority *int64

+ Tag *string

+ Weight uint

+ func GetAllEnableAbilities() []Ability

+ type AbilityWithChannel struct

+ ChannelType int

+ func GetAllEnableAbilityWithChannels() ([]AbilityWithChannel, error)

+ type BoundChannel struct

+ Name string

+ Type int

+ type Channel struct

+ AutoBan *int

+ Balance float64

+ BalanceUpdatedTime int64

+ BaseURL *string

+ ChannelInfo ChannelInfo

+ CreatedTime int64

+ Group string

+ HeaderOverride *string

+ Id int

+ Key string

+ Keys []string

+ ModelMapping *string

+ Models string

+ Name string

+ OpenAIOrganization *string

+ Other string

+ OtherInfo string

+ OtherSettings string

+ ParamOverride *string

+ Priority *int64

+ Remark *string

+ ResponseTime int

+ Setting *string

+ Status int

+ StatusCodeMapping *string

+ Tag *string

+ TestModel *string

+ TestTime int64

+ Type int

+ UsedQuota int64

+ Weight *uint

+ func CacheGetChannel(id int) (*Channel, error)

+ func GetAllChannels(startIdx int, num int, selectAll bool, idSort bool, ...) ([]*Channel, error)

+ func GetChannel(group string, model string, retry int, requestPath string) (*Channel, error)

+ func GetChannelById(id int, selectAll bool) (*Channel, error)

+ func GetChannelsByIds(ids []int) ([]*Channel, error)

+ func GetChannelsByTag(tag string, idSort bool, selectAll bool, sortOptions ...ChannelSortOptions) ([]*Channel, error)

+ func GetChannelsByType(startIdx int, num int, idSort bool, channelType int) ([]*Channel, error)

+ func GetRandomSatisfiedChannel(group string, model string, retry int, requestPath string) (*Channel, error)

+ func SearchChannels(keyword string, group string, model string, idSort bool, ...) ([]*Channel, error)

+ func (channel *Channel) AddAbilities(tx *gorm.DB) error

+ func (channel *Channel) Delete() error

+ func (channel *Channel) DeleteAbilities() error

+ func (channel *Channel) GetAutoBan() bool

+ func (channel *Channel) GetBaseURL() string

+ func (channel *Channel) GetGroups() []string

+ func (channel *Channel) GetHeaderOverride() map[string]interface{}

+ func (channel *Channel) GetKeys() []string

+ func (channel *Channel) GetModelMapping() string

+ func (channel *Channel) GetModels() []string

+ func (channel *Channel) GetNextEnabledKey() (string, int, *types.MaxAPIError)

+ func (channel *Channel) GetOtherInfo() map[string]interface{}

+ func (channel *Channel) GetOtherSettings() dto.ChannelOtherSettings

+ func (channel *Channel) GetParamOverride() map[string]interface{}

+ func (channel *Channel) GetPriority() int64

+ func (channel *Channel) GetSetting() dto.ChannelSettings

+ func (channel *Channel) GetStatusCodeMapping() string

+ func (channel *Channel) GetTag() string

+ func (channel *Channel) GetWeight() int

+ func (channel *Channel) Insert() error

+ func (channel *Channel) ParseOtherSettings() (dto.ChannelOtherSettings, error)

+ func (channel *Channel) Save() error

+ func (channel *Channel) SaveChannelInfo() error

+ func (channel *Channel) SaveWithoutKey() error

+ func (channel *Channel) SetOtherInfo(otherInfo map[string]interface{})

+ func (channel *Channel) SetOtherSettings(setting dto.ChannelOtherSettings)

+ func (channel *Channel) SetSetting(setting dto.ChannelSettings)

+ func (channel *Channel) SetTag(tag string)

+ func (channel *Channel) Update() error

+ func (channel *Channel) UpdateAbilities(tx *gorm.DB) error

+ func (channel *Channel) UpdateBalance(balance float64)

+ func (channel *Channel) UpdateResponseTime(responseTime int64)

+ func (channel *Channel) ValidateSettings() error

+ type ChannelInfo struct

+ IsMultiKey bool

+ MultiKeyDisabledReason map[int]string

+ MultiKeyDisabledTime map[int]int64

+ MultiKeyMode constant.MultiKeyMode

+ MultiKeyPollingIndex int

+ MultiKeySize int

+ MultiKeyStatusList map[int]int

+ func CacheGetChannelInfo(id int) (*ChannelInfo, error)

+ func (c *ChannelInfo) Scan(value interface{}) error

+ func (c ChannelInfo) Value() (driver.Value, error)

+ type ChannelSortOptions struct

+ IDSort bool

+ SortBy string

+ SortOrder string

+ func NewChannelSortOptions(sortBy string, sortOrder string, idSort bool) ChannelSortOptions

+ func (options ChannelSortOptions) Apply(query *gorm.DB) *gorm.DB

+ type Checkin struct

+ CheckinDate string

+ CreatedAt int64

+ Id int

+ QuotaAwarded int

+ UserId int

+ func GetUserCheckinRecords(userId int, startDate, endDate string) ([]Checkin, error)

+ func UserCheckin(userId int) (*Checkin, error)

+ func (Checkin) TableName() string

+ type CheckinRecord struct

+ CheckinDate string

+ QuotaAwarded int

+ type CustomOAuthProvider struct

+ AccessDeniedMessage string

+ AccessPolicy string

+ AuthStyle int

+ AuthorizationEndpoint string

+ ClientId string

+ ClientSecret string

+ CreatedAt time.Time

+ DisplayNameField string

+ EmailField string

+ Enabled bool

+ Icon string

+ Id int

+ Name string

+ Scopes string

+ Slug string

+ TokenEndpoint string

+ UpdatedAt time.Time

+ UserIdField string

+ UserInfoEndpoint string

+ UsernameField string

+ WellKnown string

+ func GetAllCustomOAuthProviders() ([]*CustomOAuthProvider, error)

+ func GetCustomOAuthProviderById(id int) (*CustomOAuthProvider, error)

+ func GetCustomOAuthProviderBySlug(slug string) (*CustomOAuthProvider, error)

+ func GetEnabledCustomOAuthProviders() ([]*CustomOAuthProvider, error)

+ func (CustomOAuthProvider) TableName() string

+ type JSONValue json.RawMessage

+ func (j *JSONValue) Scan(value interface{}) error

+ func (j *JSONValue) UnmarshalJSON(data []byte) error

+ func (j JSONValue) MarshalJSON() ([]byte, error)

+ func (j JSONValue) Value() (driver.Value, error)

+ type Log struct

+ ChannelId int

+ ChannelName string

+ CompletionTokens int

+ Content string

+ CreatedAt int64

+ Group string

+ Id int

+ Ip string

+ IsStream bool

+ ModelName string

+ Other string

+ PromptTokens int

+ Quota int

+ RequestId string

+ TokenId int

+ TokenName string

+ Type int

+ UpstreamRequestId string

+ UseTime int

+ UserId int

+ Username string

+ func GetAllLogs(logType int, startTimestamp int64, endTimestamp int64, modelName string, ...) (logs []*Log, total int64, err error)

+ func GetLogByTokenId(tokenId int) (logs []*Log, err error)

+ func GetUserLogs(userId int, logType int, startTimestamp int64, endTimestamp int64, ...) (logs []*Log, total int64, err error)

+ type Midjourney struct

+ Action string

+ Buttons string

+ ChannelId int

+ Code int

+ Description string

+ FailReason string

+ FinishTime int64

+ Id int

+ ImageUrl string

+ MjId string

+ Progress string

+ Prompt string

+ PromptEn string

+ Properties string

+ Quota int

+ StartTime int64

+ State string

+ Status string

+ SubmitTime int64

+ UserId int

+ VideoUrl string

+ VideoUrls string

+ func GetAllTasks(startIdx int, num int, queryParams TaskQueryParams) []*Midjourney

+ func GetAllUnFinishTasks() []*Midjourney

+ func GetAllUserTask(userId int, startIdx int, num int, queryParams TaskQueryParams) []*Midjourney

+ func GetByMJId(userId int, mjId string) *Midjourney

+ func GetByMJIds(userId int, mjIds []string) []*Midjourney

+ func GetByOnlyMJId(mjId string) *Midjourney

+ func GetMjByuId(id int) *Midjourney

+ func (midjourney *Midjourney) Insert() error

+ func (midjourney *Midjourney) Update() error

+ func (midjourney *Midjourney) UpdateWithStatus(fromStatus string) (bool, error)

+ type Model struct

+ BoundChannels []BoundChannel

+ CreatedTime int64

+ DeletedAt gorm.DeletedAt

+ Description string

+ EnableGroups []string

+ Endpoints string

+ Icon string

+ Id int

+ MatchedCount int

+ MatchedModels []string

+ ModelName string

+ NameRule int

+ QuotaTypes []int

+ Status int

+ SyncOfficial int

+ Tags string

+ UpdatedTime int64

+ VendorID int

+ func GetAllModels(offset int, limit int) ([]*Model, error)

+ func SearchModels(keyword string, vendor string, offset int, limit int) ([]*Model, int64, error)

+ func (mi *Model) Delete() error

+ func (mi *Model) Insert() error

+ func (mi *Model) Update() error

+ type Option struct

+ Key string

+ Value string

+ func AllOption() ([]*Option, error)

+ type PasskeyCredential struct

+ AAGUID string

+ Attachment string

+ AttestationType string

+ BackupEligible bool

+ BackupState bool

+ CloneWarning bool

+ CreatedAt time.Time

+ CredentialID string

+ DeletedAt gorm.DeletedAt

+ ID int

+ LastUsedAt *time.Time

+ PublicKey string

+ SignCount uint32

+ Transports string

+ UpdatedAt time.Time

+ UserID int

+ UserPresent bool

+ UserVerified bool

+ func GetPasskeyByCredentialID(credentialID []byte) (*PasskeyCredential, error)

+ func GetPasskeyByUserID(userID int) (*PasskeyCredential, error)

+ func NewPasskeyCredentialFromWebAuthn(userID int, credential *webauthn.Credential) *PasskeyCredential

+ func (p *PasskeyCredential) ApplyValidatedCredential(credential *webauthn.Credential)

+ func (p *PasskeyCredential) SetTransports(list []protocol.AuthenticatorTransport)

+ func (p *PasskeyCredential) ToWebAuthnCredential() webauthn.Credential

+ func (p *PasskeyCredential) TransportList() []protocol.AuthenticatorTransport

+ type PerfMetric struct

+ BucketTs int64

+ GenerationMs int64

+ Group string

+ Id int

+ ModelName string

+ OutputTokens int64

+ RequestCount int64

+ SuccessCount int64

+ TotalLatencyMs int64

+ TtftCount int64

+ TtftSumMs int64

+ func GetPerfMetrics(modelName string, group string, startTs int64, endTs int64) ([]PerfMetric, error)

+ func (PerfMetric) TableName() string

+ type PerfMetricSummary struct

+ GenerationMs int64

+ ModelName string

+ OutputTokens int64

+ RequestCount int64

+ SuccessCount int64

+ TotalLatencyMs int64

+ func GetPerfMetricsSummaryAll(startTs int64, endTs int64, groups []string) ([]PerfMetricSummary, error)

+ type PrefillGroup struct

+ CreatedTime int64

+ DeletedAt gorm.DeletedAt

+ Description string

+ Id int

+ Items JSONValue

+ Name string

+ Type string

+ UpdatedTime int64

+ func GetAllPrefillGroups(groupType string) ([]*PrefillGroup, error)

+ func (g *PrefillGroup) Insert() error

+ func (g *PrefillGroup) Update() error

+ type Pricing struct

+ AudioCompletionRatio *float64

+ AudioRatio *float64

+ BillingExpr string

+ BillingMode string

+ CacheRatio *float64

+ CompletionRatio float64

+ CreateCacheRatio *float64

+ Description string

+ EnableGroup []string

+ Icon string

+ ImageRatio *float64

+ ModelName string

+ ModelPrice float64

+ ModelRatio float64

+ OwnerBy string

+ PricingVersion string

+ QuotaType int

+ SupportedEndpointTypes []constant.EndpointType

+ Tags string

+ TaskRateCard *TaskRateCardPricing

+ VendorID int

+ func GetPricing() []Pricing

+ type PricingVendor struct

+ Description string

+ ID int

+ Icon string

+ Name string

+ func GetVendors() []PricingVendor

+ type Properties struct

+ Input string

+ OriginModelName string

+ UpstreamModelName string

+ func (m *Properties) Scan(val interface{}) error

+ func (m Properties) Value() (driver.Value, error)

+ type QuotaData struct

+ Count int

+ CreatedAt int64

+ Id int

+ ModelName string

+ Quota int

+ TokenUsed int

+ UserID int

+ Username string

+ func GetAllQuotaDates(startTime int64, endTime int64, username string) (quotaData []*QuotaData, err error)

+ func GetQuotaDataByUserId(userId int, startTime int64, endTime int64) (quotaData []*QuotaData, err error)

+ func GetQuotaDataByUsername(username string, startTime int64, endTime int64) (quotaData []*QuotaData, err error)

+ func GetQuotaDataGroupByUser(startTime int64, endTime int64) (quotaData []*QuotaData, err error)

+ type RankingQuotaBucket struct

+ Bucket int64

+ ModelName string

+ Tokens int64

+ func GetRankingQuotaBuckets(startTime int64, endTime int64, bucketSize int64) ([]RankingQuotaBucket, error)

+ type RankingQuotaTotal struct

+ ModelName string

+ TotalTokens int64

+ func GetRankingQuotaTotals(startTime int64, endTime int64) ([]RankingQuotaTotal, error)

+ type RecordConsumeLogParams struct

+ ChannelId int

+ CompletionTokens int

+ Content string

+ Group string

+ IsStream bool

+ ModelName string

+ Other map[string]interface{}

+ PromptTokens int

+ Quota int

+ TokenId int

+ TokenName string

+ UseTimeSeconds int

+ type RecordTaskBillingLogParams struct

+ ChannelId int

+ Content string

+ Group string

+ LogType int

+ ModelName string

+ Other map[string]interface{}

+ Quota int

+ TokenId int

+ UserId int

+ type Redemption struct

+ Count int

+ CreatedTime int64

+ DeletedAt gorm.DeletedAt

+ ExpiredTime int64

+ Id int

+ Key string

+ Name string

+ Quota int

+ RedeemedTime int64

+ Status int

+ UsedUserId int

+ UserId int

+ func GetAllRedemptions(startIdx int, num int) (redemptions []*Redemption, total int64, err error)

+ func GetRedemptionById(id int) (*Redemption, error)

+ func SearchRedemptions(keyword string, startIdx int, num int) (redemptions []*Redemption, total int64, err error)

+ func (redemption *Redemption) Delete() error

+ func (redemption *Redemption) Insert() error

+ func (redemption *Redemption) SelectUpdate() error

+ func (redemption *Redemption) Update() error

+ type Setup struct

+ ID uint

+ InitializedAt int64

+ Version string

+ func GetSetup() *Setup

+ type Stat struct

+ Quota int

+ Rpm int

+ Tpm int

+ func SumUsedQuota(logType int, startTimestamp int64, endTimestamp int64, modelName string, ...) (stat Stat, err error)

+ type SubscriptionOrder struct

+ CompleteTime int64

+ CreateTime int64

+ Id int

+ Money float64

+ PaymentMethod string

+ PaymentProvider string

+ PlanId int

+ ProviderPayload string

+ Status string

+ TradeNo string

+ UserId int

+ func GetSubscriptionOrderByTradeNo(tradeNo string) *SubscriptionOrder

+ func (o *SubscriptionOrder) Insert() error

+ func (o *SubscriptionOrder) Update() error

+ type SubscriptionPlan struct

+ AllowBalancePay *bool

+ CreatedAt int64

+ CreemProductId string

+ Currency string

+ CustomSeconds int64

+ DurationUnit string

+ DurationValue int

+ Enabled bool

+ Id int

+ MaxPurchasePerUser int

+ PriceAmount float64

+ QuotaResetCustomSeconds int64

+ QuotaResetPeriod string

+ SortOrder int

+ StripePriceId string

+ Subtitle string

+ Title string

+ TotalAmount int64

+ UpdatedAt int64

+ UpgradeGroup string

+ WaffoPancakeProductId string

+ func GetSubscriptionPlanById(id int) (*SubscriptionPlan, error)

+ func (p *SubscriptionPlan) BeforeCreate(tx *gorm.DB) error

+ func (p *SubscriptionPlan) BeforeUpdate(tx *gorm.DB) error

+ func (p *SubscriptionPlan) NormalizeDefaults()

+ type SubscriptionPlanInfo struct

+ PlanId int

+ PlanTitle string

+ func GetSubscriptionPlanInfoByUserSubscriptionId(userSubscriptionId int) (*SubscriptionPlanInfo, error)

+ type SubscriptionPreConsumeRecord struct

+ CreatedAt int64

+ Id int

+ PreConsumed int64

+ RequestId string

+ Status string

+ UpdatedAt int64

+ UserId int

+ UserSubscriptionId int

+ func (r *SubscriptionPreConsumeRecord) BeforeCreate(tx *gorm.DB) error

+ func (r *SubscriptionPreConsumeRecord) BeforeUpdate(tx *gorm.DB) error

+ type SubscriptionPreConsumeResult struct

+ AmountTotal int64

+ AmountUsedAfter int64

+ AmountUsedBefore int64

+ PreConsumed int64

+ UserSubscriptionId int

+ func PreConsumeUserSubscription(requestId string, userId int, modelName string, quotaType int, amount int64) (*SubscriptionPreConsumeResult, error)

+ type SubscriptionSummary struct

+ Subscription *UserSubscription

+ func GetAllActiveUserSubscriptions(userId int) ([]SubscriptionSummary, error)

+ func GetAllUserSubscriptions(userId int) ([]SubscriptionSummary, error)

+ type SyncTaskQueryParams struct

+ Action string

+ ChannelID string

+ EndTimestamp int64

+ Platform constant.TaskPlatform

+ StartTimestamp int64

+ Status string

+ TaskID string

+ UserID string

+ UserIDs []int

+ type Task struct

+ Action string

+ ChannelId int

+ CreatedAt int64

+ Data json.RawMessage

+ FailReason string

+ FinishTime int64

+ Group string

+ ID int64

+ Platform constant.TaskPlatform

+ PrivateData TaskPrivateData

+ Progress string

+ Properties Properties

+ Quota int

+ StartTime int64

+ Status TaskStatus

+ SubmitTime int64

+ TaskID string

+ UpdatedAt int64

+ UserId int

+ Username string

+ func GetAllUnFinishSyncTasks(limit int) []*Task

+ func GetByOnlyTaskId(taskId string) (*Task, bool, error)

+ func GetByTaskId(userId int, taskId string) (*Task, bool, error)

+ func GetByTaskIds(userId int, taskIds []any) ([]*Task, error)

+ func GetTimedOutUnfinishedTasks(cutoffUnix int64, limit int) []*Task

+ func InitTask(platform constant.TaskPlatform, relayInfo *commonRelay.RelayInfo) *Task

+ func TaskGetAllTasks(startIdx int, num int, queryParams SyncTaskQueryParams) []*Task

+ func TaskGetAllUserTask(userId int, startIdx int, num int, queryParams SyncTaskQueryParams) []*Task

+ func (Task *Task) Insert() error

+ func (Task *Task) Update() error

+ func (t *Task) GetData(v any) error

+ func (t *Task) GetResultURL() string

+ func (t *Task) GetUpstreamTaskID() string

+ func (t *Task) SetData(data any)

+ func (t *Task) Snapshot() taskSnapshot

+ func (t *Task) ToOpenAIVideo() *dto.OpenAIVideo

+ func (t *Task) UpdateWithStatus(fromStatus TaskStatus) (bool, error)

+ type TaskBillingContext struct

+ GroupRatio float64

+ ModelPrice float64

+ ModelRatio float64

+ OriginModelName string

+ OtherRatios map[string]float64

+ PerCallBilling bool

+ TaskBilling *types.TaskBillingResult

+ type TaskPrivateData struct

+ BillingContext *TaskBillingContext

+ BillingSource string

+ Key string

+ ResultURL string

+ SubscriptionId int

+ TokenId int

+ UpstreamTaskID string

+ func (p *TaskPrivateData) Scan(val interface{}) error

+ func (p TaskPrivateData) Value() (driver.Value, error)

+ type TaskQueryParams struct

+ ChannelID string

+ EndTimestamp string

+ MjID string

+ StartTimestamp string

+ type TaskQuotaUsage struct

+ Count float64

+ Mode string

+ type TaskRateCardPricing struct

+ DefaultQuantity float64

+ Defaults map[string]string

+ MaxUnitPrice float64

+ MinUnitPrice float64

+ QuantityField string

+ Rows []TaskRateCardPricingRow

+ RuleKey string

+ Strict bool

+ Unit string

+ Vendor string

+ type TaskRateCardPricingRow struct

+ ID string

+ Match map[string]string

+ UnitPrice float64

+ type TaskStatus string

+ func (t TaskStatus) ToVideoStatus() string

+ type Token struct

+ AccessedTime int64

+ AllowIps *string

+ CreatedTime int64

+ CrossGroupRetry bool

+ DeletedAt gorm.DeletedAt

+ ExpiredTime int64

+ Group string

+ Id int

+ Key string

+ ModelLimits string

+ ModelLimitsEnabled bool

+ Name string

+ RemainQuota int

+ Status int

+ UnlimitedQuota bool

+ UsedQuota int

+ UserId int

+ func GetAllUserTokens(userId int, startIdx int, num int) ([]*Token, error)

+ func GetTokenById(id int) (*Token, error)

+ func GetTokenByIds(id int, userId int) (*Token, error)

+ func GetTokenByKey(key string, fromDB bool) (token *Token, err error)

+ func GetTokenKeysByIds(ids []int, userId int) ([]Token, error)

+ func SearchUserTokens(userId int, keyword string, token string, offset int, limit int) (tokens []*Token, total int64, err error)

+ func ValidateUserToken(key string) (token *Token, err error)

+ func (token *Token) Clean()

+ func (token *Token) Delete() (err error)

+ func (token *Token) GetFullKey() string

+ func (token *Token) GetIpLimits() []string

+ func (token *Token) GetMaskedKey() string

+ func (token *Token) GetModelLimits() []string

+ func (token *Token) GetModelLimitsMap() map[string]bool

+ func (token *Token) Insert() error

+ func (token *Token) IsModelLimitsEnabled() bool

+ func (token *Token) SelectUpdate() (err error)

+ func (token *Token) Update() (err error)

+ type TopUp struct

+ Amount int64

+ CompleteTime int64

+ CreateTime int64

+ Id int

+ Money float64

+ PaymentMethod string

+ PaymentProvider string

+ Status string

+ TradeNo string

+ UserId int

+ func GetAllTopUps(pageInfo *common.PageInfo) (topups []*TopUp, total int64, err error)

+ func GetTopUpById(id int) *TopUp

+ func GetTopUpByTradeNo(tradeNo string) *TopUp

+ func GetUserTopUps(userId int, pageInfo *common.PageInfo) (topups []*TopUp, total int64, err error)

+ func SearchAllTopUps(keyword string, pageInfo *common.PageInfo) (topups []*TopUp, total int64, err error)

+ func SearchUserTopUps(userId int, keyword string, pageInfo *common.PageInfo) (topups []*TopUp, total int64, err error)

+ func (topUp *TopUp) Insert() error

+ func (topUp *TopUp) Update() error

+ type TwoFA struct

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ FailedAttempts int

+ Id int

+ IsEnabled bool

+ LastUsedAt *time.Time

+ LockedUntil *time.Time

+ Secret string

+ UpdatedAt time.Time

+ UserId int

+ func GetTwoFAByUserId(userId int) (*TwoFA, error)

+ func (t *TwoFA) Create() error

+ func (t *TwoFA) Delete() error

+ func (t *TwoFA) Enable() error

+ func (t *TwoFA) IncrementFailedAttempts() error

+ func (t *TwoFA) IsLocked() bool

+ func (t *TwoFA) ResetFailedAttempts() error

+ func (t *TwoFA) Update() error

+ func (t *TwoFA) ValidateBackupCodeAndUpdateUsage(code string) (bool, error)

+ func (t *TwoFA) ValidateTOTPAndUpdateUsage(code string) (bool, error)

+ type TwoFABackupCode struct

+ CodeHash string

+ CreatedAt time.Time

+ DeletedAt gorm.DeletedAt

+ Id int

+ IsUsed bool

+ UsedAt *time.Time

+ UserId int

+ type User struct

+ AccessToken *string

+ AffCode string

+ AffCount int

+ AffHistoryQuota int

+ AffQuota int

+ CreatedAt int64

+ DeletedAt gorm.DeletedAt

+ DiscordId string

+ DisplayName string

+ Email string

+ GitHubId string

+ Group string

+ Id int

+ InviterId int

+ LastLoginAt int64

+ LinuxDOId string

+ OidcId string

+ OriginalPassword string

+ Password string

+ Quota int

+ Remark string

+ RequestCount int

+ Role int

+ Setting string

+ Status int

+ StripeCustomer string

+ TelegramId string

+ UsedQuota int

+ Username string

+ VerificationCode string

+ WeChatId string

+ func GetAllUsers(pageInfo *common.PageInfo) (users []*User, total int64, err error)

+ func GetRootUser() (user *User)

+ func GetUserById(id int, selectAll bool) (*User, error)

+ func GetUserByOAuthBinding(providerId int, providerUserId string) (*User, error)

+ func SearchUsers(keyword string, group string, role *int, status *int, startIdx int, num int) ([]*User, int64, error)

+ func ValidateAccessToken(token string) (*User, error)

+ func (user *User) ClearBinding(bindingType string) error

+ func (user *User) Delete() error

+ func (user *User) Edit(updatePassword bool) error

+ func (user *User) FillUserByDiscordId() error

+ func (user *User) FillUserByEmail() error

+ func (user *User) FillUserByGitHubId() error

+ func (user *User) FillUserById() error

+ func (user *User) FillUserByLinuxDOId() error

+ func (user *User) FillUserByOidcId() error

+ func (user *User) FillUserByTelegramId() error

+ func (user *User) FillUserByWeChatId() error

+ func (user *User) FinalizeOAuthUserCreation(inviterId int)

+ func (user *User) GetAccessToken() string

+ func (user *User) GetSetting() dto.UserSetting

+ func (user *User) HardDelete() error

+ func (user *User) Insert(inviterId int) error

+ func (user *User) InsertWithTx(tx *gorm.DB, inviterId int) error

+ func (user *User) SetAccessToken(token string)

+ func (user *User) SetSetting(setting dto.UserSetting)

+ func (user *User) ToBaseUser() *UserBase

+ func (user *User) TransferAffQuotaToQuota(quota int) error

+ func (user *User) Update(updatePassword bool) error

+ func (user *User) UpdateGitHubId(newGitHubId string) error

+ func (user *User) ValidateAndFill() (err error)

+ type UserBase struct

+ Email string

+ Group string

+ Id int

+ Quota int

+ Setting string

+ Status int

+ Username string

+ func GetUserCache(userId int) (userCache *UserBase, err error)

+ func (user *UserBase) GetSetting() dto.UserSetting

+ func (user *UserBase) WriteContext(c *gin.Context)

+ type UserOAuthBinding struct

+ CreatedAt time.Time

+ Id int

+ ProviderId int

+ ProviderUserId string

+ UserId int

+ func GetUserOAuthBinding(userId, providerId int) (*UserOAuthBinding, error)

+ func GetUserOAuthBindingsByUserId(userId int) ([]*UserOAuthBinding, error)

+ func (UserOAuthBinding) TableName() string

+ type UserSubscription struct

+ AmountTotal int64

+ AmountUsed int64

+ CreatedAt int64

+ EndTime int64

+ Id int

+ LastResetTime int64

+ NextResetTime int64

+ PlanId int

+ PrevUserGroup string

+ Source string

+ StartTime int64

+ Status string

+ UpdatedAt int64

+ UpgradeGroup string

+ UserId int

+ func CreateUserSubscriptionFromPlanTx(tx *gorm.DB, userId int, plan *SubscriptionPlan, source string) (*UserSubscription, error)

+ func (s *UserSubscription) BeforeCreate(tx *gorm.DB) error

+ func (s *UserSubscription) BeforeUpdate(tx *gorm.DB) error

+ type Vendor struct

+ CreatedTime int64

+ DeletedAt gorm.DeletedAt

+ Description string

+ Icon string

+ Id int

+ Name string

+ Status int

+ UpdatedTime int64

+ func GetAllVendors(offset int, limit int) ([]*Vendor, error)

+ func GetVendorByID(id int) (*Vendor, error)

+ func SearchVendors(keyword string, offset int, limit int) ([]*Vendor, int64, error)

+ func (v *Vendor) Delete() error

+ func (v *Vendor) Insert() error

+ func (v *Vendor) Update() error

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