cosmo

Jan 7, 2026

Changes in this version

+ const PageUpdateFieldName

type DB

+ func (db *DB) PageUpdateField(field string) (tx *DB)

Dec 17, 2025

Changes in this version

+ const FieldNameUpdate

+ func IsBusinessError(err error) bool

+ func IsNetworkError(err error) bool

type BulkWrite

+ func (this *BulkWrite) String() string

type DB

+ func (db *DB) IsHealthy() bool

Aug 26, 2025

Changes in this version

type DB

+ func (db *DB) UpdateAndModify() (tx *DB)

type Statement

+ func (stmt *Statement) GetIncludeZeroValue() bool

+ func (stmt *Statement) GetReflectValue() reflect.Value

+ func (stmt *Statement) GetSchema() *schema.Schema

+ func (stmt *Statement) GetSelector() *update.Selector

+ func (stmt *Statement) GetValue() any

Jul 24, 2025

Changes in this version

+ type Cursor interface

+ Decode func(val interface{}) error

type DB

+ func (db *DB) Range(f func(Cursor) bool) (tx *DB)

Apr 11, 2025

Changes in this version

type BulkWrite

+ func (this *BulkWrite) SetUpdateFilter(filter BulkWriteUpdateFilter)

+ func (this *BulkWrite) Size() int

+ func (this *BulkWrite) Submit() (err error)

+ type BulkWriteUpdateFilter func(up update.Update)

+ type Cache struct

+ func NewCache(handle CacheHandle) *Cache

+ func (this *Cache) Cursor(update int64, filter CacheFilter) []any

+ func (this *Cache) Delete(id string)

+ func (this *Cache) Get(id string) any

+ func (this *Cache) Has(id string) (ok bool)

+ func (this *Cache) Len() int

+ func (this *Cache) Listener(t CacheEventType, id string, update int64)

+ func (this *Cache) Lock(f func() error) error

+ func (this *Cache) Page(page *Paging, filter CacheFilter) (err error)

+ func (this *Cache) Range(f func(any) bool)

+ func (this *Cache) Reload(ts int64, handle ...CacheHandle) error

+ type CacheData struct

+ func NewCacheData() *CacheData

+ func (this *CacheData) Copy() *CacheData

+ func (this *CacheData) Delete(id any) *CacheData

+ type CacheEventType int8

+ const CacheEventTypeCreate

+ const CacheEventTypeDelete

+ const CacheEventTypeUpdate

+ type CacheFilter func(v CacheModel) any

+ type CacheHandle interface

+ Reload func(ts int64, cb CacheSetter) error

+ type CacheModel interface

+ GetUpdate func() int64

+ type CacheSetter func(k any, v CacheModel)

type DB

+ func (db *DB) First(val any, where ...any) (tx *DB)

+ func (db *DB) Inc(key string, val int) (tx *DB)

+ func (db *DB) IncludeZeroValue() (tx *DB)

+ func (db *DB) Last(val any, where ...any) (tx *DB)

+ func (db *DB) Query(val any, where ...any) (tx *DB)

+ func (db *DB) Save(values any, conds ...any) (tx *DB)

+ func (db *DB) Take(val any, where ...any) (tx *DB)

+ func (db *DB) Updates(values any, conds ...any) (tx *DB)

+ type ModelBulkWriteFilter interface

+ BulkWriteFilter func(up update.Update)

type Paging

+ func (this *Paging) Range(page int, handle func(int))

Apr 26, 2022

Changes in this version

+ var Schema = schema.New()

Mar 27, 2024

Changes in this version

type Paging

+ Record int

+ Rows interface{}

+ Size int

+ Total int

+ Update int64

+ func (this *Paging) Init(size int)

+ func (this *Paging) Result(r int)

type Statement

+ Paging *Paging

Jan 31, 2024

Changes in this version

+ const DBNameUpdate

type Paging

+ func (this *Paging) Reset(page, size int)

Apr 21, 2023

Changes in this version

+ func NewClientOptions() *options.ClientOptions

+ func UpdateOne(tx *DB, coll *mongo.Collection, filter clause.Filter, data update.Update) (err error)

type BulkWrite

+ func (this *BulkWrite) Options(opts ...*options.BulkWriteOptions)

+ func (this *BulkWrite) Result() *mongo.BulkWriteResult

type DB

+ func (db *DB) ObjectID() primitive.ObjectID

+ func (db *DB) Upsert() (tx *DB)

type Statement

+ Selector update.Selector

+ func (stmt *Statement) HasValidModel() bool

Aug 24, 2022

Changes in this version

+ const DefaultPageSize

+ const MongoPrimaryKey

+ const MongoSetOnInsert

+ const MongoTagName

+ var ErrDryRunModeUnsupported = errors.New("dry run mode unsupported")

+ var ErrEmptySlice = errors.New("empty slice found")

+ var ErrInvalidConfig = errors.New("invalid config")

+ var ErrInvalidDB = errors.New("invalid db")

+ var ErrInvalidData = errors.New("unsupported data")

+ var ErrInvalidField = errors.New("invalid field")

+ var ErrInvalidModel = errors.New("invalid model, should be pointer to struct or struct")

+ var ErrInvalidTransaction = errors.New("invalid transaction")

+ var ErrInvalidValue = errors.New("invalid value, should be pointer to struct or slice")

+ var ErrInvalidValueOfLength = errors.New("invalid association values, length doesn't match")

+ var ErrMissingWhereClause = errors.New("WHERE conditions required")

+ var ErrModelValueRequired = errors.New("model value required")

+ var ErrNotImplemented = errors.New("not implemented")

+ var ErrOmitOnSelectsExist = errors.New("omit on selects exist")

+ var ErrPrimaryKeyRequired = errors.New("primary key required")

+ var ErrRegistered = errors.New("registered")

+ var ErrSelectOnOmitsExist = errors.New("select on omits exist")

+ var ErrUnsupportedDriver = errors.New("unsupported driver")

+ var ErrUnsupportedRelation = errors.New("unsupported relations")

+ var Options = schema.New()

+ func NewClient(address string, opts ...*options.ClientOptions) (client *mongo.Client, err error)

+ type BulkWrite struct

+ func (this *BulkWrite) Delete(where ...interface{})

+ func (this *BulkWrite) Insert(documents ...interface{})

+ func (this *BulkWrite) Save() (result *mongo.BulkWriteResult, err error)

+ func (this *BulkWrite) Update(data interface{}, where ...interface{})

+ type Config struct

+ Logger logger.Interface

+ Plugins map[string]Plugin

+ func (c *Config) AfterInitialize(db *DB) error

+ func (c *Config) Register(model interface{})

+ type DB struct

+ Error error

+ RowsAffected int64

+ Statement *Statement

+ func New(configs ...*Config) (db *DB)

+ func (db *DB) AutoMigrator(dst ...interface{}) error

+ func (db *DB) BulkWrite(model interface{}) *BulkWrite

+ func (db *DB) Close() (err error)

+ func (db *DB) Collection(model interface{}) (tx *DB, coll *mongo.Collection)

+ func (db *DB) Count(count interface{}, conds ...interface{}) (tx *DB)

+ func (db *DB) Create(value interface{}) (tx *DB)

+ func (db *DB) Database(dbname string) *DB

+ func (db *DB) Delete(conds ...interface{}) (tx *DB)

+ func (db *DB) Errorf(msg interface{}, args ...interface{}) error

+ func (db *DB) Find(dest interface{}, conds ...interface{}) (tx *DB)

+ func (db *DB) Get(key string) (val interface{}, ok bool)

+ func (db *DB) Limit(limit int) (tx *DB)

+ func (db *DB) Merge(i interface{}) error

+ func (db *DB) Model(value interface{}) (tx *DB)

+ func (db *DB) Multiple() (tx *DB)

+ func (db *DB) Offset(offset int) (tx *DB)

+ func (db *DB) Omit(columns ...string) (tx *DB)

+ func (db *DB) Order(key string, value int) (tx *DB)

+ func (db *DB) Page(page, size int) (tx *DB)

+ func (db *DB) Select(columns ...string) (tx *DB)

+ func (db *DB) Session(session *Session) *DB

+ func (db *DB) Set(key string, value interface{}) *DB

+ func (db *DB) SetColumn(data map[string]interface{}) error

+ func (db *DB) Start(dbname string, address interface{}) (err error)

+ func (db *DB) Table(name string) (tx *DB)

+ func (db *DB) Update(values interface{}, conds ...interface{}) (tx *DB)

+ func (db *DB) Use(plugin Plugin) error

+ func (db *DB) View(paging *values.Paging, conds ...interface{}) (tx *DB)

+ func (db *DB) Where(query interface{}, args ...interface{}) (tx *DB)

+ func (db *DB) WithContext(ctx context.Context) *DB

+ type ExecuteHandle func(db *DB) error

+ type Paging struct

+ func (this *Paging) Limit(limit int)

+ func (this *Paging) Offset(offset int)

+ func (this *Paging) Options() *options.FindOptions

+ func (this *Paging) Order(key string, sort int)

+ func (this *Paging) Page(page, size int)

+ type Plugin interface

+ Initialize func(*DB) error

+ Name func() string

+ type Session struct

+ Context context.Context

+ DBName string

+ Logger logger.Interface

+ NewDB bool

+ NowTime func() time.Time

+ SkipHooks bool

+ type Statement struct

+ Clause *clause.Query

+ Context context.Context

+ Dest interface{}

+ Model interface{}

+ Omits []string

+ ReflectValue reflect.Value

+ Selects []string

+ Table string

+ func NewStatement(db *DB) *Statement

+ func (stmt *Statement) DBName(name string) string

+ func (stmt *Statement) Order() (order bson.D)

+ func (stmt *Statement) Parse() (tx *DB)

+ func (stmt *Statement) Projection() map[string]int

+ func (stmt *Statement) Schema() *schema.Schema