store

package
v0.0.0-...-9970c52 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2026 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Q               = new(Query)
	AlertChannel    *alertChannel
	AlertHistory    *alertHistory
	AlertSendRecord *alertSendRecord
	AlertSilence    *alertSilence
	AlertTemplate   *alertTemplate
	Api             *api
	CasbinRule      *casbinRule
	Oauth2User      *oauth2User
	Role            *role
	Tenant          *tenant
	User            *user
)
View Source
var (
	NeverExpires time.Duration = 0
)

Functions

func SetDefault

func SetDefault(db *gorm.DB, opts ...gen.DOOption)

Types

type CacheLocker

type CacheLocker interface {
	SetNX(ctx context.Context, cacheType CacheType, cacheKey any, value any, expiration time.Duration) (bool, error)
}

type CacheSeter

type CacheSeter interface {
	GetSet(ctx context.Context, cacheType CacheType, cacheKey any) ([]string, error)
	SetSet(ctx context.Context, cacheType CacheType, cacheKey any, cacheValue []any, expireTime *time.Duration) error
}

type CacheStore

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

func NewCacheStore

func NewCacheStore(redisClient *redis.Client) (*CacheStore, func(), error)

func (*CacheStore) DelKey

func (c *CacheStore) DelKey(ctx context.Context, cacheType CacheType, cacheKey any) error

func (*CacheStore) GetObject

func (c *CacheStore) GetObject(ctx context.Context, cacheType CacheType, cacheKey any, target any) (bool, error)

GetObject 获取并反序列化对象

func (*CacheStore) GetSet

func (c *CacheStore) GetSet(ctx context.Context, cacheType CacheType, cacheKey any) ([]string, error)

func (*CacheStore) NormalizeCacheKey

func (c *CacheStore) NormalizeCacheKey(cacheKey any) (string, error)

NormalizeCacheKey 将常用类型的 cacheKey 转换为 string cacheKey 的值有可能是 int 等

func (*CacheStore) Publish

func (c *CacheStore) Publish(ctx context.Context, channel string, msg string) error

func (*CacheStore) SetNX

func (c *CacheStore) SetNX(ctx context.Context, cacheType CacheType, cacheKey any, value any, expiration time.Duration) (bool, error)

SetNX 封装 Redis 的 SET IF NOT EXISTS 逻辑,用于分布式锁 返回值 bool: true 表示获取锁成功,false 表示锁已被占用

func (*CacheStore) SetObject

func (c *CacheStore) SetObject(ctx context.Context, cacheType CacheType, cacheKey any, value any, expiration time.Duration) error

SetObject 序列化对象并存入 Redis

func (*CacheStore) SetSet

func (c *CacheStore) SetSet(ctx context.Context, cacheType CacheType, cacheKey any, cacheValue []any, expireTime *time.Duration) error

func (*CacheStore) Subscribe

func (c *CacheStore) Subscribe(ctx context.Context, channel string, handler func(msg string))

type CacheStorer

type CacheStorer interface {
	DelKey(ctx context.Context, cacheType CacheType, cacheKey any) error
	CacheSeter
	CacheStringer
	CacheSuber
	CacheLocker
}

type CacheStringer

type CacheStringer interface {
	SetObject(ctx context.Context, cacheType CacheType, cacheKey any, value any, expiration time.Duration) error
	GetObject(ctx context.Context, cacheType CacheType, cacheKey any, target any) (bool, error)
}

type CacheSuber

type CacheSuber interface {
	Publish(ctx context.Context, channel string, msg string) error
	Subscribe(ctx context.Context, channel string, handler func(msg string))
}

type CacheType

type CacheType string
const (
	RoleType   CacheType = "role"
	AlertType  CacheType = "alert"
	LockType   CacheType = "lock"
	TenantType CacheType = "tenant"
)

type IAlertChannelDo

type IAlertChannelDo interface {
	gen.SubQuery
	Debug() IAlertChannelDo
	WithContext(ctx context.Context) IAlertChannelDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IAlertChannelDo
	WriteDB() IAlertChannelDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IAlertChannelDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IAlertChannelDo
	Not(conds ...gen.Condition) IAlertChannelDo
	Or(conds ...gen.Condition) IAlertChannelDo
	Select(conds ...field.Expr) IAlertChannelDo
	Where(conds ...gen.Condition) IAlertChannelDo
	Order(conds ...field.Expr) IAlertChannelDo
	Distinct(cols ...field.Expr) IAlertChannelDo
	Omit(cols ...field.Expr) IAlertChannelDo
	Join(table schema.Tabler, on ...field.Expr) IAlertChannelDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IAlertChannelDo
	RightJoin(table schema.Tabler, on ...field.Expr) IAlertChannelDo
	Group(cols ...field.Expr) IAlertChannelDo
	Having(conds ...gen.Condition) IAlertChannelDo
	Limit(limit int) IAlertChannelDo
	Offset(offset int) IAlertChannelDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IAlertChannelDo
	Unscoped() IAlertChannelDo
	Create(values ...*model.AlertChannel) error
	CreateInBatches(values []*model.AlertChannel, batchSize int) error
	Save(values ...*model.AlertChannel) error
	First() (*model.AlertChannel, error)
	Take() (*model.AlertChannel, error)
	Last() (*model.AlertChannel, error)
	Find() ([]*model.AlertChannel, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.AlertChannel, err error)
	FindInBatches(result *[]*model.AlertChannel, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.AlertChannel) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IAlertChannelDo
	Assign(attrs ...field.AssignExpr) IAlertChannelDo
	Joins(fields ...field.RelationField) IAlertChannelDo
	Preload(fields ...field.RelationField) IAlertChannelDo
	FirstOrInit() (*model.AlertChannel, error)
	FirstOrCreate() (*model.AlertChannel, error)
	FindByPage(offset int, limit int) (result []*model.AlertChannel, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IAlertChannelDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IAlertHistoryDo

type IAlertHistoryDo interface {
	gen.SubQuery
	Debug() IAlertHistoryDo
	WithContext(ctx context.Context) IAlertHistoryDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IAlertHistoryDo
	WriteDB() IAlertHistoryDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IAlertHistoryDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IAlertHistoryDo
	Not(conds ...gen.Condition) IAlertHistoryDo
	Or(conds ...gen.Condition) IAlertHistoryDo
	Select(conds ...field.Expr) IAlertHistoryDo
	Where(conds ...gen.Condition) IAlertHistoryDo
	Order(conds ...field.Expr) IAlertHistoryDo
	Distinct(cols ...field.Expr) IAlertHistoryDo
	Omit(cols ...field.Expr) IAlertHistoryDo
	Join(table schema.Tabler, on ...field.Expr) IAlertHistoryDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IAlertHistoryDo
	RightJoin(table schema.Tabler, on ...field.Expr) IAlertHistoryDo
	Group(cols ...field.Expr) IAlertHistoryDo
	Having(conds ...gen.Condition) IAlertHistoryDo
	Limit(limit int) IAlertHistoryDo
	Offset(offset int) IAlertHistoryDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IAlertHistoryDo
	Unscoped() IAlertHistoryDo
	Create(values ...*model.AlertHistory) error
	CreateInBatches(values []*model.AlertHistory, batchSize int) error
	Save(values ...*model.AlertHistory) error
	First() (*model.AlertHistory, error)
	Take() (*model.AlertHistory, error)
	Last() (*model.AlertHistory, error)
	Find() ([]*model.AlertHistory, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.AlertHistory, err error)
	FindInBatches(result *[]*model.AlertHistory, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.AlertHistory) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IAlertHistoryDo
	Assign(attrs ...field.AssignExpr) IAlertHistoryDo
	Joins(fields ...field.RelationField) IAlertHistoryDo
	Preload(fields ...field.RelationField) IAlertHistoryDo
	FirstOrInit() (*model.AlertHistory, error)
	FirstOrCreate() (*model.AlertHistory, error)
	FindByPage(offset int, limit int) (result []*model.AlertHistory, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IAlertHistoryDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IAlertSendRecordDo

type IAlertSendRecordDo interface {
	gen.SubQuery
	Debug() IAlertSendRecordDo
	WithContext(ctx context.Context) IAlertSendRecordDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IAlertSendRecordDo
	WriteDB() IAlertSendRecordDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IAlertSendRecordDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IAlertSendRecordDo
	Not(conds ...gen.Condition) IAlertSendRecordDo
	Or(conds ...gen.Condition) IAlertSendRecordDo
	Select(conds ...field.Expr) IAlertSendRecordDo
	Where(conds ...gen.Condition) IAlertSendRecordDo
	Order(conds ...field.Expr) IAlertSendRecordDo
	Distinct(cols ...field.Expr) IAlertSendRecordDo
	Omit(cols ...field.Expr) IAlertSendRecordDo
	Join(table schema.Tabler, on ...field.Expr) IAlertSendRecordDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IAlertSendRecordDo
	RightJoin(table schema.Tabler, on ...field.Expr) IAlertSendRecordDo
	Group(cols ...field.Expr) IAlertSendRecordDo
	Having(conds ...gen.Condition) IAlertSendRecordDo
	Limit(limit int) IAlertSendRecordDo
	Offset(offset int) IAlertSendRecordDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IAlertSendRecordDo
	Unscoped() IAlertSendRecordDo
	Create(values ...*model.AlertSendRecord) error
	CreateInBatches(values []*model.AlertSendRecord, batchSize int) error
	Save(values ...*model.AlertSendRecord) error
	First() (*model.AlertSendRecord, error)
	Take() (*model.AlertSendRecord, error)
	Last() (*model.AlertSendRecord, error)
	Find() ([]*model.AlertSendRecord, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.AlertSendRecord, err error)
	FindInBatches(result *[]*model.AlertSendRecord, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.AlertSendRecord) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IAlertSendRecordDo
	Assign(attrs ...field.AssignExpr) IAlertSendRecordDo
	Joins(fields ...field.RelationField) IAlertSendRecordDo
	Preload(fields ...field.RelationField) IAlertSendRecordDo
	FirstOrInit() (*model.AlertSendRecord, error)
	FirstOrCreate() (*model.AlertSendRecord, error)
	FindByPage(offset int, limit int) (result []*model.AlertSendRecord, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IAlertSendRecordDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IAlertSilenceDo

type IAlertSilenceDo interface {
	gen.SubQuery
	Debug() IAlertSilenceDo
	WithContext(ctx context.Context) IAlertSilenceDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IAlertSilenceDo
	WriteDB() IAlertSilenceDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IAlertSilenceDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IAlertSilenceDo
	Not(conds ...gen.Condition) IAlertSilenceDo
	Or(conds ...gen.Condition) IAlertSilenceDo
	Select(conds ...field.Expr) IAlertSilenceDo
	Where(conds ...gen.Condition) IAlertSilenceDo
	Order(conds ...field.Expr) IAlertSilenceDo
	Distinct(cols ...field.Expr) IAlertSilenceDo
	Omit(cols ...field.Expr) IAlertSilenceDo
	Join(table schema.Tabler, on ...field.Expr) IAlertSilenceDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IAlertSilenceDo
	RightJoin(table schema.Tabler, on ...field.Expr) IAlertSilenceDo
	Group(cols ...field.Expr) IAlertSilenceDo
	Having(conds ...gen.Condition) IAlertSilenceDo
	Limit(limit int) IAlertSilenceDo
	Offset(offset int) IAlertSilenceDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IAlertSilenceDo
	Unscoped() IAlertSilenceDo
	Create(values ...*model.AlertSilence) error
	CreateInBatches(values []*model.AlertSilence, batchSize int) error
	Save(values ...*model.AlertSilence) error
	First() (*model.AlertSilence, error)
	Take() (*model.AlertSilence, error)
	Last() (*model.AlertSilence, error)
	Find() ([]*model.AlertSilence, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.AlertSilence, err error)
	FindInBatches(result *[]*model.AlertSilence, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.AlertSilence) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IAlertSilenceDo
	Assign(attrs ...field.AssignExpr) IAlertSilenceDo
	Joins(fields ...field.RelationField) IAlertSilenceDo
	Preload(fields ...field.RelationField) IAlertSilenceDo
	FirstOrInit() (*model.AlertSilence, error)
	FirstOrCreate() (*model.AlertSilence, error)
	FindByPage(offset int, limit int) (result []*model.AlertSilence, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IAlertSilenceDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IAlertTemplateDo

type IAlertTemplateDo interface {
	gen.SubQuery
	Debug() IAlertTemplateDo
	WithContext(ctx context.Context) IAlertTemplateDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IAlertTemplateDo
	WriteDB() IAlertTemplateDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IAlertTemplateDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IAlertTemplateDo
	Not(conds ...gen.Condition) IAlertTemplateDo
	Or(conds ...gen.Condition) IAlertTemplateDo
	Select(conds ...field.Expr) IAlertTemplateDo
	Where(conds ...gen.Condition) IAlertTemplateDo
	Order(conds ...field.Expr) IAlertTemplateDo
	Distinct(cols ...field.Expr) IAlertTemplateDo
	Omit(cols ...field.Expr) IAlertTemplateDo
	Join(table schema.Tabler, on ...field.Expr) IAlertTemplateDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IAlertTemplateDo
	RightJoin(table schema.Tabler, on ...field.Expr) IAlertTemplateDo
	Group(cols ...field.Expr) IAlertTemplateDo
	Having(conds ...gen.Condition) IAlertTemplateDo
	Limit(limit int) IAlertTemplateDo
	Offset(offset int) IAlertTemplateDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IAlertTemplateDo
	Unscoped() IAlertTemplateDo
	Create(values ...*model.AlertTemplate) error
	CreateInBatches(values []*model.AlertTemplate, batchSize int) error
	Save(values ...*model.AlertTemplate) error
	First() (*model.AlertTemplate, error)
	Take() (*model.AlertTemplate, error)
	Last() (*model.AlertTemplate, error)
	Find() ([]*model.AlertTemplate, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.AlertTemplate, err error)
	FindInBatches(result *[]*model.AlertTemplate, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.AlertTemplate) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IAlertTemplateDo
	Assign(attrs ...field.AssignExpr) IAlertTemplateDo
	Joins(fields ...field.RelationField) IAlertTemplateDo
	Preload(fields ...field.RelationField) IAlertTemplateDo
	FirstOrInit() (*model.AlertTemplate, error)
	FirstOrCreate() (*model.AlertTemplate, error)
	FindByPage(offset int, limit int) (result []*model.AlertTemplate, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IAlertTemplateDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IApiDo

type IApiDo interface {
	gen.SubQuery
	Debug() IApiDo
	WithContext(ctx context.Context) IApiDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IApiDo
	WriteDB() IApiDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IApiDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IApiDo
	Not(conds ...gen.Condition) IApiDo
	Or(conds ...gen.Condition) IApiDo
	Select(conds ...field.Expr) IApiDo
	Where(conds ...gen.Condition) IApiDo
	Order(conds ...field.Expr) IApiDo
	Distinct(cols ...field.Expr) IApiDo
	Omit(cols ...field.Expr) IApiDo
	Join(table schema.Tabler, on ...field.Expr) IApiDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IApiDo
	RightJoin(table schema.Tabler, on ...field.Expr) IApiDo
	Group(cols ...field.Expr) IApiDo
	Having(conds ...gen.Condition) IApiDo
	Limit(limit int) IApiDo
	Offset(offset int) IApiDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IApiDo
	Unscoped() IApiDo
	Create(values ...*model.Api) error
	CreateInBatches(values []*model.Api, batchSize int) error
	Save(values ...*model.Api) error
	First() (*model.Api, error)
	Take() (*model.Api, error)
	Last() (*model.Api, error)
	Find() ([]*model.Api, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.Api, err error)
	FindInBatches(result *[]*model.Api, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.Api) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IApiDo
	Assign(attrs ...field.AssignExpr) IApiDo
	Joins(fields ...field.RelationField) IApiDo
	Preload(fields ...field.RelationField) IApiDo
	FirstOrInit() (*model.Api, error)
	FirstOrCreate() (*model.Api, error)
	FindByPage(offset int, limit int) (result []*model.Api, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IApiDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type ICasbinRuleDo

type ICasbinRuleDo interface {
	gen.SubQuery
	Debug() ICasbinRuleDo
	WithContext(ctx context.Context) ICasbinRuleDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() ICasbinRuleDo
	WriteDB() ICasbinRuleDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) ICasbinRuleDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) ICasbinRuleDo
	Not(conds ...gen.Condition) ICasbinRuleDo
	Or(conds ...gen.Condition) ICasbinRuleDo
	Select(conds ...field.Expr) ICasbinRuleDo
	Where(conds ...gen.Condition) ICasbinRuleDo
	Order(conds ...field.Expr) ICasbinRuleDo
	Distinct(cols ...field.Expr) ICasbinRuleDo
	Omit(cols ...field.Expr) ICasbinRuleDo
	Join(table schema.Tabler, on ...field.Expr) ICasbinRuleDo
	LeftJoin(table schema.Tabler, on ...field.Expr) ICasbinRuleDo
	RightJoin(table schema.Tabler, on ...field.Expr) ICasbinRuleDo
	Group(cols ...field.Expr) ICasbinRuleDo
	Having(conds ...gen.Condition) ICasbinRuleDo
	Limit(limit int) ICasbinRuleDo
	Offset(offset int) ICasbinRuleDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) ICasbinRuleDo
	Unscoped() ICasbinRuleDo
	Create(values ...*model.CasbinRule) error
	CreateInBatches(values []*model.CasbinRule, batchSize int) error
	Save(values ...*model.CasbinRule) error
	First() (*model.CasbinRule, error)
	Take() (*model.CasbinRule, error)
	Last() (*model.CasbinRule, error)
	Find() ([]*model.CasbinRule, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.CasbinRule, err error)
	FindInBatches(result *[]*model.CasbinRule, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.CasbinRule) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) ICasbinRuleDo
	Assign(attrs ...field.AssignExpr) ICasbinRuleDo
	Joins(fields ...field.RelationField) ICasbinRuleDo
	Preload(fields ...field.RelationField) ICasbinRuleDo
	FirstOrInit() (*model.CasbinRule, error)
	FirstOrCreate() (*model.CasbinRule, error)
	FindByPage(offset int, limit int) (result []*model.CasbinRule, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) ICasbinRuleDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IClusterDo

type IClusterDo interface {
	gen.SubQuery
	Debug() IClusterDo
	WithContext(ctx context.Context) IClusterDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IClusterDo
	WriteDB() IClusterDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IClusterDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IClusterDo
	Not(conds ...gen.Condition) IClusterDo
	Or(conds ...gen.Condition) IClusterDo
	Select(conds ...field.Expr) IClusterDo
	Where(conds ...gen.Condition) IClusterDo
	Order(conds ...field.Expr) IClusterDo
	Distinct(cols ...field.Expr) IClusterDo
	Omit(cols ...field.Expr) IClusterDo
	Join(table schema.Tabler, on ...field.Expr) IClusterDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IClusterDo
	RightJoin(table schema.Tabler, on ...field.Expr) IClusterDo
	Group(cols ...field.Expr) IClusterDo
	Having(conds ...gen.Condition) IClusterDo
	Limit(limit int) IClusterDo
	Offset(offset int) IClusterDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IClusterDo
	Unscoped() IClusterDo
	Create(values ...*model.Tenant) error
	CreateInBatches(values []*model.Tenant, batchSize int) error
	Save(values ...*model.Tenant) error
	First() (*model.Tenant, error)
	Take() (*model.Tenant, error)
	Last() (*model.Tenant, error)
	Find() ([]*model.Tenant, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.Tenant, err error)
	FindInBatches(result *[]*model.Tenant, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.Tenant) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IClusterDo
	Assign(attrs ...field.AssignExpr) IClusterDo
	Joins(fields ...field.RelationField) IClusterDo
	Preload(fields ...field.RelationField) IClusterDo
	FirstOrInit() (*model.Tenant, error)
	FirstOrCreate() (*model.Tenant, error)
	FindByPage(offset int, limit int) (result []*model.Tenant, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IClusterDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IOauth2UserDo

type IOauth2UserDo interface {
	gen.SubQuery
	Debug() IOauth2UserDo
	WithContext(ctx context.Context) IOauth2UserDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IOauth2UserDo
	WriteDB() IOauth2UserDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IOauth2UserDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IOauth2UserDo
	Not(conds ...gen.Condition) IOauth2UserDo
	Or(conds ...gen.Condition) IOauth2UserDo
	Select(conds ...field.Expr) IOauth2UserDo
	Where(conds ...gen.Condition) IOauth2UserDo
	Order(conds ...field.Expr) IOauth2UserDo
	Distinct(cols ...field.Expr) IOauth2UserDo
	Omit(cols ...field.Expr) IOauth2UserDo
	Join(table schema.Tabler, on ...field.Expr) IOauth2UserDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IOauth2UserDo
	RightJoin(table schema.Tabler, on ...field.Expr) IOauth2UserDo
	Group(cols ...field.Expr) IOauth2UserDo
	Having(conds ...gen.Condition) IOauth2UserDo
	Limit(limit int) IOauth2UserDo
	Offset(offset int) IOauth2UserDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IOauth2UserDo
	Unscoped() IOauth2UserDo
	Create(values ...*model.Oauth2User) error
	CreateInBatches(values []*model.Oauth2User, batchSize int) error
	Save(values ...*model.Oauth2User) error
	First() (*model.Oauth2User, error)
	Take() (*model.Oauth2User, error)
	Last() (*model.Oauth2User, error)
	Find() ([]*model.Oauth2User, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.Oauth2User, err error)
	FindInBatches(result *[]*model.Oauth2User, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.Oauth2User) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IOauth2UserDo
	Assign(attrs ...field.AssignExpr) IOauth2UserDo
	Joins(fields ...field.RelationField) IOauth2UserDo
	Preload(fields ...field.RelationField) IOauth2UserDo
	FirstOrInit() (*model.Oauth2User, error)
	FirstOrCreate() (*model.Oauth2User, error)
	FindByPage(offset int, limit int) (result []*model.Oauth2User, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IOauth2UserDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IRoleDo

type IRoleDo interface {
	gen.SubQuery
	Debug() IRoleDo
	WithContext(ctx context.Context) IRoleDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IRoleDo
	WriteDB() IRoleDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IRoleDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IRoleDo
	Not(conds ...gen.Condition) IRoleDo
	Or(conds ...gen.Condition) IRoleDo
	Select(conds ...field.Expr) IRoleDo
	Where(conds ...gen.Condition) IRoleDo
	Order(conds ...field.Expr) IRoleDo
	Distinct(cols ...field.Expr) IRoleDo
	Omit(cols ...field.Expr) IRoleDo
	Join(table schema.Tabler, on ...field.Expr) IRoleDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IRoleDo
	RightJoin(table schema.Tabler, on ...field.Expr) IRoleDo
	Group(cols ...field.Expr) IRoleDo
	Having(conds ...gen.Condition) IRoleDo
	Limit(limit int) IRoleDo
	Offset(offset int) IRoleDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IRoleDo
	Unscoped() IRoleDo
	Create(values ...*model.Role) error
	CreateInBatches(values []*model.Role, batchSize int) error
	Save(values ...*model.Role) error
	First() (*model.Role, error)
	Take() (*model.Role, error)
	Last() (*model.Role, error)
	Find() ([]*model.Role, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.Role, err error)
	FindInBatches(result *[]*model.Role, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.Role) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IRoleDo
	Assign(attrs ...field.AssignExpr) IRoleDo
	Joins(fields ...field.RelationField) IRoleDo
	Preload(fields ...field.RelationField) IRoleDo
	FirstOrInit() (*model.Role, error)
	FirstOrCreate() (*model.Role, error)
	FindByPage(offset int, limit int) (result []*model.Role, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IRoleDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type ITenantDo

type ITenantDo interface {
	gen.SubQuery
	Debug() ITenantDo
	WithContext(ctx context.Context) ITenantDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() ITenantDo
	WriteDB() ITenantDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) ITenantDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) ITenantDo
	Not(conds ...gen.Condition) ITenantDo
	Or(conds ...gen.Condition) ITenantDo
	Select(conds ...field.Expr) ITenantDo
	Where(conds ...gen.Condition) ITenantDo
	Order(conds ...field.Expr) ITenantDo
	Distinct(cols ...field.Expr) ITenantDo
	Omit(cols ...field.Expr) ITenantDo
	Join(table schema.Tabler, on ...field.Expr) ITenantDo
	LeftJoin(table schema.Tabler, on ...field.Expr) ITenantDo
	RightJoin(table schema.Tabler, on ...field.Expr) ITenantDo
	Group(cols ...field.Expr) ITenantDo
	Having(conds ...gen.Condition) ITenantDo
	Limit(limit int) ITenantDo
	Offset(offset int) ITenantDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) ITenantDo
	Unscoped() ITenantDo
	Create(values ...*model.Tenant) error
	CreateInBatches(values []*model.Tenant, batchSize int) error
	Save(values ...*model.Tenant) error
	First() (*model.Tenant, error)
	Take() (*model.Tenant, error)
	Last() (*model.Tenant, error)
	Find() ([]*model.Tenant, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.Tenant, err error)
	FindInBatches(result *[]*model.Tenant, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.Tenant) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) ITenantDo
	Assign(attrs ...field.AssignExpr) ITenantDo
	Joins(fields ...field.RelationField) ITenantDo
	Preload(fields ...field.RelationField) ITenantDo
	FirstOrInit() (*model.Tenant, error)
	FirstOrCreate() (*model.Tenant, error)
	FindByPage(offset int, limit int) (result []*model.Tenant, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) ITenantDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type IUserDo

type IUserDo interface {
	gen.SubQuery
	Debug() IUserDo
	WithContext(ctx context.Context) IUserDo
	WithResult(fc func(tx gen.Dao)) gen.ResultInfo
	ReplaceDB(db *gorm.DB)
	ReadDB() IUserDo
	WriteDB() IUserDo
	As(alias string) gen.Dao
	Session(config *gorm.Session) IUserDo
	Columns(cols ...field.Expr) gen.Columns
	Clauses(conds ...clause.Expression) IUserDo
	Not(conds ...gen.Condition) IUserDo
	Or(conds ...gen.Condition) IUserDo
	Select(conds ...field.Expr) IUserDo
	Where(conds ...gen.Condition) IUserDo
	Order(conds ...field.Expr) IUserDo
	Distinct(cols ...field.Expr) IUserDo
	Omit(cols ...field.Expr) IUserDo
	Join(table schema.Tabler, on ...field.Expr) IUserDo
	LeftJoin(table schema.Tabler, on ...field.Expr) IUserDo
	RightJoin(table schema.Tabler, on ...field.Expr) IUserDo
	Group(cols ...field.Expr) IUserDo
	Having(conds ...gen.Condition) IUserDo
	Limit(limit int) IUserDo
	Offset(offset int) IUserDo
	Count() (count int64, err error)
	Scopes(funcs ...func(gen.Dao) gen.Dao) IUserDo
	Unscoped() IUserDo
	Create(values ...*model.User) error
	CreateInBatches(values []*model.User, batchSize int) error
	Save(values ...*model.User) error
	First() (*model.User, error)
	Take() (*model.User, error)
	Last() (*model.User, error)
	Find() ([]*model.User, error)
	FindInBatch(batchSize int, fc func(tx gen.Dao, batch int) error) (results []*model.User, err error)
	FindInBatches(result *[]*model.User, batchSize int, fc func(tx gen.Dao, batch int) error) error
	Pluck(column field.Expr, dest interface{}) error
	Delete(...*model.User) (info gen.ResultInfo, err error)
	Update(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	Updates(value interface{}) (info gen.ResultInfo, err error)
	UpdateColumn(column field.Expr, value interface{}) (info gen.ResultInfo, err error)
	UpdateColumnSimple(columns ...field.AssignExpr) (info gen.ResultInfo, err error)
	UpdateColumns(value interface{}) (info gen.ResultInfo, err error)
	UpdateFrom(q gen.SubQuery) gen.Dao
	Attrs(attrs ...field.AssignExpr) IUserDo
	Assign(attrs ...field.AssignExpr) IUserDo
	Joins(fields ...field.RelationField) IUserDo
	Preload(fields ...field.RelationField) IUserDo
	FirstOrInit() (*model.User, error)
	FirstOrCreate() (*model.User, error)
	FindByPage(offset int, limit int) (result []*model.User, count int64, err error)
	ScanByPage(result interface{}, offset int, limit int) (count int64, err error)
	Rows() (*sql.Rows, error)
	Row() *sql.Row
	Scan(result interface{}) (err error)
	Returning(value interface{}, columns ...string) IUserDo
	UnderlyingDB() *gorm.DB
	schema.Tabler
}

type Query

type Query struct {
	AlertChannel    alertChannel
	AlertHistory    alertHistory
	AlertSendRecord alertSendRecord
	AlertSilence    alertSilence
	AlertTemplate   alertTemplate
	Api             api
	CasbinRule      casbinRule
	Oauth2User      oauth2User
	Role            role
	Tenant          tenant
	User            user
	// contains filtered or unexported fields
}

func Use

func Use(db *gorm.DB, opts ...gen.DOOption) *Query

func (*Query) Available

func (q *Query) Available() bool

func (*Query) Begin

func (q *Query) Begin(opts ...*sql.TxOptions) *QueryTx

func (*Query) ReadDB

func (q *Query) ReadDB() *Query

func (*Query) ReplaceDB

func (q *Query) ReplaceDB(db *gorm.DB) *Query

func (*Query) Transaction

func (q *Query) Transaction(fc func(tx *Query) error, opts ...*sql.TxOptions) error

func (*Query) WithContext

func (q *Query) WithContext(ctx context.Context) *queryCtx

func (*Query) WriteDB

func (q *Query) WriteDB() *Query

type QueryTx

type QueryTx struct {
	*Query
	Error error
}

func (*QueryTx) Commit

func (q *QueryTx) Commit() error

func (*QueryTx) Rollback

func (q *QueryTx) Rollback() error

func (*QueryTx) RollbackTo

func (q *QueryTx) RollbackTo(name string) error

func (*QueryTx) SavePoint

func (q *QueryTx) SavePoint(name string) error

Jump to

Keyboard shortcuts

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