dorm

Apr 1, 2024

Changes in this version

type RedisClient

+ func NewRedisClientURL(redisURL string) (*RedisClient, error)

Feb 17, 2024

Changes in this version

type GormClient

+ func (c *GormClient) Close() error

+ func (c *GormClient) GetSqlDb() *sql.DB

+ func (c *GormClient) Ping() error

+ func (c *GormClient) Stats() sql.DBStats

Dec 20, 2023

Changes in this version

+ type GormGenClient struct

+ func NewGormGenMysqlClient(ctx context.Context, config *GormGenClientConfig) (*GormGenClient, error)

+ func NewGormGenPostgresClient(ctx context.Context, config *GormGenClientConfig) (*GormGenClient, error)

+ func NewGormGenPostgresqlClient(ctx context.Context, config *GormGenClientConfig) (*GormGenClient, error)

+ func (c *GormGenClient) GetDb() *gorm.DB

+ func (c *GormGenClient) GetGenerator() *gen.Generator

+ type GormGenClientConfig struct

+ Config gen.Config

+ Db *gorm.DB

+ Dns string

+ type GormGenClientFun func() *GormGenClient

+ type GormGenClientTableFun func() (*GormGenClient, string)

type RedisClient

+ func (r *RedisClient) AddKeyToSet(ctx context.Context, setKey string, value interface{}) error

+ func (r *RedisClient) DeleteKeysWithPrefix(ctx context.Context, prefix string) error

+ func (r *RedisClient) DeleteScanWithPrefix(ctx context.Context, prefix string) error

+ func (r *RedisClient) DoesKeyExistInSet(ctx context.Context, setKey string, targetKey interface{}) (bool, error)

+ func (r *RedisClient) GetAllKeysInSet(ctx context.Context, setKey string) ([]string, error)

+ func (r *RedisClient) RemoveKeyFromSet(ctx context.Context, setKey string, targetKey interface{}) error

Oct 27, 2022

Changes in this version

type MongoCollectionOptions

+ func (cc *MongoCollectionOptions) CountDocuments(ctx context.Context, filter interface{}, opts ...*options.CountOptions) (int64, error)

+ func (cc *MongoCollectionOptions) Distinct(ctx context.Context, fieldName string, filter interface{}, ...) ([]interface{}, error)

+ func (cc *MongoCollectionOptions) Drop(ctx context.Context) error

+ func (cc *MongoCollectionOptions) EstimatedDocumentCount(ctx context.Context, opts ...*options.EstimatedDocumentCountOptions) (int64, error)

+ func (cc *MongoCollectionOptions) FindOneAndDelete(ctx context.Context, filter interface{}, ...) *mongo.SingleResult

+ func (cc *MongoCollectionOptions) FindOneAndReplace(ctx context.Context, filter interface{}, replacement interface{}, ...) *mongo.SingleResult

+ func (cc *MongoCollectionOptions) FindOneAndUpdate(ctx context.Context, filter interface{}, replacement interface{}, ...) *mongo.SingleResult

+ func (cc *MongoCollectionOptions) Indexes(ctx context.Context) mongo.IndexView

+ func (cc *MongoCollectionOptions) UpdateByID(ctx context.Context, id interface{}, update interface{}, ...) (*mongo.UpdateResult, error)

+ func (cc *MongoCollectionOptions) Watch(ctx context.Context, pipeline interface{}, ...) (*mongo.ChangeStream, error)

type MongoSessionCollectionOptions

+ func (csc *MongoSessionCollectionOptions) CountDocuments(filter interface{}, opts ...*options.CountOptions) (int64, error)

+ func (csc *MongoSessionCollectionOptions) Distinct(fieldName string, filter interface{}, opts ...*options.DistinctOptions) ([]interface{}, error)

+ func (csc *MongoSessionCollectionOptions) Drop() error

+ func (csc *MongoSessionCollectionOptions) EstimatedDocumentCount(opts ...*options.EstimatedDocumentCountOptions) (int64, error)

+ func (csc *MongoSessionCollectionOptions) FindOneAndDelete(filter interface{}, opts ...*options.FindOneAndDeleteOptions) *mongo.SingleResult

+ func (csc *MongoSessionCollectionOptions) FindOneAndReplace(filter interface{}, replacement interface{}, ...) *mongo.SingleResult

+ func (csc *MongoSessionCollectionOptions) FindOneAndUpdate(filter interface{}, replacement interface{}, ...) *mongo.SingleResult

+ func (csc *MongoSessionCollectionOptions) Indexes() mongo.IndexView

+ func (csc *MongoSessionCollectionOptions) UpdateByID(id interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ func (csc *MongoSessionCollectionOptions) Watch(pipeline interface{}, opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)

Sep 29, 2022

Changes in this version

+ func Any(a any) any

+ func Int(i int) int

+ func Int16(i int16) int16

+ func Int8(i int8) int8

+ func Uint(ui uint) uint

+ func Uint16(ui uint16) uint16

+ func Uint32(ui uint32) uint32

+ func Uint64(ui uint64) uint64

+ func Uint8(ui uint8) uint8

Sep 29, 2022

Changes in this version

+ func Bool(b bool) bool

+ func Float32(f float32) float32

+ func Float64(f float64) float64

+ func Int32(i int32) int32

+ func Int64(i int64) int64

+ func String(s string) string

Sep 29, 2022

Changes in this version

type MongoSessionOptions

+ func (cs *MongoSessionOptions) GetDb() *mongo.Client

Sep 23, 2022

Changes in this version

+ type BunClientConfig struct

+ Dns string

+ type GormClientConfig struct

+ ConnSetConnMaxLifetime int64

+ ConnSetMaxIdle int

+ ConnSetMaxOpen int

+ Dns string

+ LogLevel string

+ LogPath string

+ LogSlow int64

+ LogStatus bool

type MongoCollectionOptions

+ func (cc *MongoCollectionOptions) Aggregate(ctx context.Context, pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)

+ func (cc *MongoCollectionOptions) ReplaceOne(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)

type MongoSessionCollectionOptions

+ func (csc *MongoSessionCollectionOptions) Aggregate(pipeline interface{}, opts ...*options.AggregateOptions) (*mongo.Cursor, error)

+ func (csc *MongoSessionCollectionOptions) ReplaceOne(filter interface{}, update interface{}, opts ...*options.ReplaceOptions) (*mongo.UpdateResult, error)

+ type RedisClientConfig struct

+ Addr string

+ DB int

+ Password string

+ PoolSize int

+ ReadTimeout time.Duration

+ type XormClientConfigXorm struct

+ Dns string

Sep 21, 2022

Changes in this version

type MongoSessionOptions

+ func (cs *MongoSessionOptions) GetSession(ctx context.Context) mongo.Session

+ func (cs *MongoSessionOptions) GetSessionContext(ctx context.Context) mongo.SessionContext

Sep 21, 2022

Changes in this version

+ type MongoClientConfig struct

+ DatabaseName string

+ Dns string

+ Opts *options.ClientOptions

Sep 21, 2022

Changes in this version

+ var NoConfigCollectionName = errors.New("没有配置集合名")

+ var NoConfigDatabaseName = errors.New("没有配置库名")

type MongoSessionOptions

+ func (cs *MongoSessionOptions) Model(value interface{}) *MongoSessionCollectionOptions

Sep 19, 2022

Changes in this version

+ type GormClientTableFun func() (*GormClient, string)

+ type MongoClientCollectionFun func() (*MongoClient, string, string)

Sep 19, 2022

Changes in this version

+ type GormClientFun func() *GormClient

+ type MongoClientFun func() (*MongoClient, string)

+ type RedisClientFun func() *RedisClient

Sep 17, 2022

Changes in this version

type BsonTime

+ func NewBsonTimeCurrent() BsonTime

Sep 17, 2022

Changes in this version

type BsonTime

+ func NewBsonTimeFromString(t string) BsonTime

+ func NewBsonTimeFromTime(t time.Time) BsonTime

+ func (bt BsonTime) Format() string

+ func (bt BsonTime) Time() time.Time

+ func (bt BsonTime) TimePro() gotime.Pro

+ type MongoSessionCollectionOptions struct

+ func (csc *MongoSessionCollectionOptions) DeleteMany(filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ func (csc *MongoSessionCollectionOptions) DeleteOne(filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ func (csc *MongoSessionCollectionOptions) Find(filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error)

+ func (csc *MongoSessionCollectionOptions) FindOne(filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult

+ func (csc *MongoSessionCollectionOptions) InsertMany(document []interface{}, opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)

+ func (csc *MongoSessionCollectionOptions) InsertOne(document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

+ func (csc *MongoSessionCollectionOptions) UpdateMany(filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ func (csc *MongoSessionCollectionOptions) UpdateOne(filter interface{}, update interface{}, opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

+ type MongoSessionDatabaseOptions struct

+ func (csd *MongoSessionDatabaseOptions) Collection(name string, opts ...*options.CollectionOptions) *MongoSessionCollectionOptions

+ type MongoSessionOptions struct

+ Db *mongo.Client

+ Session mongo.SessionContext

+ func (cs *MongoSessionOptions) Close(ctx context.Context)

+ func (cs *MongoSessionOptions) Commit(ctx context.Context) error

+ func (cs *MongoSessionOptions) Database(name string, opts ...*options.DatabaseOptions) *MongoSessionDatabaseOptions

+ func (cs *MongoSessionOptions) Rollback(ctx context.Context) error

Sep 17, 2022

Changes in this version

+ type MongoCollectionOptions struct

+ func (cc *MongoCollectionOptions) CreateManyIndexes(ctx context.Context, models []mongo.IndexModel) ([]string, error)

+ func (cc *MongoCollectionOptions) CreateOneIndexes(ctx context.Context, key string, value string) (string, error)

+ func (cc *MongoCollectionOptions) CreateOneUniqueIndexes(ctx context.Context, key string, value string) (string, error)

+ func (cc *MongoCollectionOptions) CreateOneUniqueIndexesOpts(ctx context.Context, key string, value string, opts *options.IndexOptions) (string, error)

+ func (cc *MongoCollectionOptions) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ func (cc *MongoCollectionOptions) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

+ func (cc *MongoCollectionOptions) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*mongo.Cursor, error)

+ func (cc *MongoCollectionOptions) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *mongo.SingleResult

+ func (cc *MongoCollectionOptions) InsertMany(ctx context.Context, document []interface{}, ...) (*mongo.InsertManyResult, error)

+ func (cc *MongoCollectionOptions) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

+ func (cc *MongoCollectionOptions) UpdateMany(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)

+ func (cc *MongoCollectionOptions) UpdateOne(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)

+ type MongoDatabaseOptions struct

+ func (cd *MongoDatabaseOptions) Collection(name string, opts ...*options.CollectionOptions) *MongoCollectionOptions

+ func (cd *MongoDatabaseOptions) CreateCollection(ctx context.Context, name string, opts ...*options.CreateCollectionOptions) error

+ func (cd *MongoDatabaseOptions) CreateTimeSeriesCollection(ctx context.Context, name string, timeField string) error

Sep 6, 2022

Changes in this version

type ConfigGormClient

+ ConnSetConnMaxLifetime int64

+ ConnSetMaxIdle int

+ ConnSetMaxOpen int

+ LogColorful bool

+ LogLevel string

+ LogNotFoundError bool

+ LogPath string

+ LogSlow int64

+ LogStatus bool

Sep 6, 2022

Changes in this version

+ func XmlEncodeNoError(data interface{}) string

Aug 29, 2022

Changes in this version

+ func JsonEncodeNoError(data interface{}) string

Aug 24, 2022

Changes in this version

type BeegoClient

+ func NewBeegoPostgresClient(dns string) (*BeegoClient, error)

Aug 16, 2022

Changes in this version

type ConfigRedisClient

+ ReadTimeout time.Duration

Aug 15, 2022

Changes in this version

type RedisClient

+ func (r *RedisClient) KeysValue(ctx context.Context, prefix string) *redis.SliceCmd

Aug 13, 2022

Changes in this version

+ var GormNotFound = gorm.ErrRecordNotFound

+ var RedisKeysNotFound = errors.New("ERR wrong number of arguments for 'mget' command")

+ var RedisNotFound = errors.New("redis: nil")

Aug 13, 2022

Changes in this version

type RedisClientLock

+ func (rl *RedisClientLock) Lock(ctx context.Context, key string, val string, ttl time.Duration) (resp string, err error)

+ func (rl *RedisClientLock) LockForever(ctx context.Context, key string, val string) (resp string, err error)

+ func (rl *RedisClientLock) Unlock(ctx context.Context, key string) error

Aug 13, 2022

Changes in this version

type RedisClient

+ func (r *RedisClient) Lock(ctx context.Context, key string, val string, ttl time.Duration) (resp string, err error)

+ func (r *RedisClient) LockForever(ctx context.Context, key string, val string) (resp string, err error)

+ func (r *RedisClient) NewLock() *RedisClientLock

+ func (r *RedisClient) Unlock(ctx context.Context, key string) error

+ type RedisClientLock struct

Aug 13, 2022

Changes in this version

+ type GttInterfaceFunc func() interface

+ type GttStringFunc func() string

type RedisCacheConfig

+ Expiration time.Duration

Aug 13, 2022

Changes in this version

type RedisClientCache

+ func (rc *RedisClientCache) GetInterfaceKey(ctx context.Context, key string, result interface{}) error

+ func (rc *RedisClientCache) SetInterfaceKey(ctx context.Context, key string, value interface{}) (string, error)

Aug 12, 2022

Changes in this version

+ type RedisCacheConfig struct

+ DefaultExpiration time.Duration

type RedisClient

+ func (c *RedisClient) NewCache(config *RedisCacheConfig) *RedisClientCache

+ func (c *RedisClient) NewCacheDefaultExpiration() *RedisClientCache

+ type RedisClientCache struct

+ GetterInterface func() interface{}

+ GetterString func() string

+ func (rc *RedisClientCache) GetInterface(ctx context.Context, key string, result interface{})

+ func (rc *RedisClientCache) GetString(ctx context.Context, key string) (ret string)

Aug 11, 2022

Changes in this version

type RedisClient

+ func (c *RedisClient) Decr(ctx context.Context, key string) *redis.IntCmd

+ func (c *RedisClient) DecrBy(ctx context.Context, key string, value int64) *redis.IntCmd

+ func (c *RedisClient) Del(ctx context.Context, keys ...string) *redis.IntCmd

+ func (c *RedisClient) Get(ctx context.Context, key string) *redis.StringCmd

+ func (c *RedisClient) GetSet(ctx context.Context, key string, value interface{}) *redis.StringCmd

+ func (c *RedisClient) Incr(ctx context.Context, key string) *redis.IntCmd

+ func (c *RedisClient) IncrBy(ctx context.Context, key string, value int64) *redis.IntCmd

+ func (c *RedisClient) Keys(ctx context.Context, prefix string) *redis.SliceCmd

+ func (c *RedisClient) MGet(ctx context.Context, keys ...string) *redis.SliceCmd

+ func (c *RedisClient) MSet(ctx context.Context, values map[string]interface{}) *redis.StatusCmd

+ func (c *RedisClient) PSubscribe(ctx context.Context, channels ...string) *redis.PubSub

+ func (c *RedisClient) PubSubChannels(ctx context.Context, pattern string) *redis.StringSliceCmd

+ func (c *RedisClient) PubSubNumSub(ctx context.Context, channels ...string) *redis.StringIntMapCmd

+ func (c *RedisClient) Publish(ctx context.Context, channel string, message interface{}) *redis.IntCmd

+ func (c *RedisClient) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd

+ func (c *RedisClient) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.BoolCmd

+ func (c *RedisClient) Subscribe(ctx context.Context, channels ...string) *redis.PubSub

Aug 9, 2022

Changes in this version

type BeegoClient

+ func (c *BeegoClient) GetDb() *orm.Ormer

type BunClient

+ func (c *BunClient) GetDb() *bun.DB

type UpperClient

+ func (c *UpperClient) GetDb() *db.Session

type XormClient

+ func (c *XormClient) GetDb() *xorm.Engine

type ZormClient

+ func (c *ZormClient) GetDb() *zorm.DBDao

Aug 4, 2022

Changes in this version

type BunClient

+ func NewBunSqliteClient(config *ConfigBunClient) (*BunClient, error)

Aug 3, 2022

Changes in this version

type ConfigGormClient

+ Conn struct{ ... }

type GormClient

+ func NewGormSqliteCgoClient(config *ConfigGormClient) (*GormClient, error)

+ func NewGormSqliteClient(config *ConfigGormClient) (*GormClient, error)

Jul 27, 2022

Changes in this version

+ const AttrExpr

+ const AttrNx

+ const SerializerJson

+ const SerializerString

+ const Version

+ func JsonDecodeNoError(b []byte) map[string]interface

+ func XmlDecodeNoError(b []byte) map[string]interface

+ type BeegoClient struct

+ Db *orm.Ormer

+ func NewBeegoMysqlClient(config *ConfigBeegoClient) (*BeegoClient, error)

+ func NewBeegoOracleClient(config *ConfigBeegoClient) (*BeegoClient, error)

+ func NewBeegoPgsqlClient(config *ConfigBeegoClient) (*BeegoClient, error)

+ func NewBeegoTidbClient(config *ConfigBeegoClient) (*BeegoClient, error)

+ type BsonTime time.Time

+ func (t *BsonTime) UnmarshalBSONValue(t2 bsontype.Type, data []byte) error

+ func (t *BsonTime) UnmarshalJSON(data []byte) (err error)

+ func (t BsonTime) MarshalBSONValue() (bsontype.Type, []byte, error)

+ func (t BsonTime) MarshalJSON() ([]byte, error)

+ func (t BsonTime) Value() string

+ type BunClient struct

+ Db *bun.DB

+ func NewBunMssqlClient(config *ConfigBunClient) (*BunClient, error)

+ func NewBunMysqlClient(config *ConfigBunClient) (*BunClient, error)

+ func NewBunPgsqlClient(config *ConfigBunClient) (*BunClient, error)

+ type ConfigBeegoClient struct

+ Dns string

+ type ConfigBunClient struct

+ Dns string

+ type ConfigGormClient struct

+ Dns string

+ Log bool

+ LogUrl string

+ type ConfigMongoClient struct

+ DatabaseName string

+ Dns string

+ Opts *options.ClientOptions

+ type ConfigRedisClient struct

+ Addr string

+ DB int

+ Password string

+ PoolSize int

+ type ConfigXormClient struct

+ Dns string

+ type ConfigZormClient struct

+ Dns string

+ type DBGttFunc func() string

+ type DBGttInterfaceFunc func() interface

+ type DBGttJsonFunc func() interface

+ type DBGttStringFunc func() string

+ type FindManyResult struct

+ func (f *FindManyResult) Many(result interface{}) error

+ type FindManyResultI interface

+ Many func(result interface{}) error

+ type FindOneResult struct

+ func (f *FindOneResult) One(result interface{}) error

+ type FindOneResultI interface

+ One func(result interface{}) error

+ type FindResult struct

+ func (f *FindResult) Many(result interface{}) error

+ type FindResultI interface

+ Many func(result interface{}) error

+ type GormClient struct

+ Db *gorm.DB

+ func NewGormMysqlClient(config *ConfigGormClient) (*GormClient, error)

+ func NewGormPostgresClient(config *ConfigGormClient) (*GormClient, error)

+ func NewGormPostgresqlClient(config *ConfigGormClient) (*GormClient, error)

+ func NewGormSqlServerClient(config *ConfigGormClient) (*GormClient, error)

+ func (c *GormClient) Begin() *gorm.DB

+ func (c *GormClient) Commit() *gorm.DB

+ func (c *GormClient) GetDb() *gorm.DB

+ func (c *GormClient) Rollback() *gorm.DB

+ type HashOperation struct

+ func NewHashOperation(db *redis.Client, ctx context.Context) *HashOperation

+ func (cl *HashOperation) Get(key, field string) *redis.StringCmd

+ func (cl *HashOperation) Set(key string, value interface{}) *redis.IntCmd

+ type Iterator struct

+ func NewIterator(data []interface{}) *Iterator

+ func (i *Iterator) HasNext() bool

+ func (i *Iterator) Next() (Ret interface{})

+ type JsonGttFunc func() interface

+ type ListOperation struct

+ func (cl *ListOperation) Index(key string, index int64) *redis.StringCmd

+ func (cl *ListOperation) Insert(key, op string, pivot, value interface{}) *redis.IntCmd

+ func (cl *ListOperation) LPop(key string) *redis.StringCmd

+ func (cl *ListOperation) LPush(key string, value interface{}) *redis.IntCmd

+ func (cl *ListOperation) LPushX(key string, value interface{}) *redis.IntCmd

+ func (cl *ListOperation) Len(key string) *redis.IntCmd

+ func (cl *ListOperation) RPop(key string) *redis.StringCmd

+ func (cl *ListOperation) RPush(key string, value interface{}) *redis.IntCmd

+ func (cl *ListOperation) RPushX(key string, value interface{}) *redis.IntCmd

+ func (cl *ListOperation) Range(key string, start, stop int64) *redis.StringSliceCmd

+ func (cl *ListOperation) RangeAli(key string) *redis.StringSliceCmd

+ func (cl *ListOperation) Rem(key string, count int64, value interface{}) *redis.IntCmd

+ type MongoClient struct

+ Db *mongo.Client

+ func NewMongoClient(config *ConfigMongoClient) (*MongoClient, error)

+ func (c *MongoClient) AggregateByFiltersSort(pipeline interface{}) (result *mongo.Cursor, err error)

+ func (c *MongoClient) Begin() (ms MongoTransaction, err error)

+ func (c *MongoClient) Close() error

+ func (c *MongoClient) Collection(collectionName string) *MongoClient

+ func (c *MongoClient) CollectionCount() (name string, size int64)

+ func (c *MongoClient) CollectionDocuments(Skip, Limit int64, sort int, key string, value interface{}) (result *mongo.Cursor, err error)

+ func (c *MongoClient) CountDocumentsByFilters(filter interface{}) (count int64, err error)

+ func (c *MongoClient) Database(databaseName string) *MongoClient

+ func (c *MongoClient) Delete(filter interface{}) (err error)

+ func (c *MongoClient) DeleteId(id interface{}) (err error)

+ func (c *MongoClient) DeleteMany(filter interface{}) (result *mongo.DeleteResult, err error)

+ func (c *MongoClient) Find(filter interface{}) (*mongo.Cursor, error)

+ func (c *MongoClient) FindCollection(Limit int64) (result *mongo.Cursor, err error)

+ func (c *MongoClient) FindCollectionSort(Sort interface{}, Limit int64) (result *mongo.Cursor, err error)

+ func (c *MongoClient) FindMany(filter interface{}) (*mongo.Cursor, error)

+ func (c *MongoClient) FindManyByFilters(filter interface{}) (result *mongo.Cursor, err error)

+ func (c *MongoClient) FindManyByFiltersSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

+ func (c *MongoClient) FindManyCollectionSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

+ func (c *MongoClient) FindOne(filter interface{}) *mongo.SingleResult

+ func (c *MongoClient) GetDb() *mongo.Client

+ func (c *MongoClient) InsertMany(documents []interface{}) (result *mongo.InsertManyResult, err error)

+ func (c *MongoClient) InsertOne(document interface{}) (result *mongo.InsertOneResult, err error)

+ func (c *MongoClient) Model(value interface{}) *MongoClient

+ func (c *MongoClient) UpdateId(id interface{}, update interface{}) (err error)

+ func (c *MongoClient) UpdateMany(filter interface{}, update interface{}) (result *mongo.UpdateResult, err error)

+ func (c *MongoClient) UpdateOne(filter interface{}, update interface{}) (err error)

+ type MongoTransaction struct

+ Session mongo.SessionContext

+ func (ms *MongoTransaction) AggregateByFiltersSort(pipeline interface{}) (result *mongo.Cursor, err error)

+ func (ms *MongoTransaction) Close()

+ func (ms *MongoTransaction) Collection(collectionName string) *MongoTransaction

+ func (ms *MongoTransaction) CollectionCount(ctx context.Context) (name string, size int64)

+ func (ms *MongoTransaction) CollectionDocuments(Skip, Limit int64, sort int, key string, value interface{}) (result *mongo.Cursor, err error)

+ func (ms *MongoTransaction) Commit() error

+ func (ms *MongoTransaction) CountDocumentsByFilters(filter interface{}) (count int64, err error)

+ func (ms *MongoTransaction) Database(databaseName string) *MongoTransaction

+ func (ms *MongoTransaction) Delete(filter interface{}) (err error)

+ func (ms *MongoTransaction) DeleteId(id interface{}) (err error)

+ func (ms *MongoTransaction) DeleteMany(key string, value interface{}) (result *mongo.DeleteResult, err error)

+ func (ms *MongoTransaction) Find(filter interface{}) (*mongo.Cursor, error)

+ func (ms *MongoTransaction) FindCollection(Limit int64) (result *mongo.Cursor, err error)

+ func (ms *MongoTransaction) FindCollectionSort(Sort interface{}, Limit int64) (result *mongo.Cursor, err error)

+ func (ms *MongoTransaction) FindMany(filter interface{}) (*mongo.Cursor, error)

+ func (ms *MongoTransaction) FindManyByFilters(filter interface{}) (result *mongo.Cursor, err error)

+ func (ms *MongoTransaction) FindManyByFiltersSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

+ func (ms *MongoTransaction) FindManyCollectionSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

+ func (ms *MongoTransaction) FindOne(filter interface{}) *mongo.SingleResult

+ func (ms *MongoTransaction) InsertMany(documents []interface{}) (result *mongo.InsertManyResult, err error)

+ func (ms *MongoTransaction) InsertOne(document interface{}) (result *mongo.InsertOneResult, err error)

+ func (ms *MongoTransaction) Model(value interface{}) *MongoTransaction

+ func (ms *MongoTransaction) Rollback() error

+ func (ms *MongoTransaction) UpdateId(id interface{}, update interface{}) (err error)

+ func (ms *MongoTransaction) UpdateMany(filter interface{}, update interface{}) (result *mongo.UpdateResult, err error)

+ func (ms *MongoTransaction) UpdateOne(filter interface{}, update interface{}) (err error)

+ type OperationAttr struct

+ Name string

+ Value interface{}

+ func WithExpire(t time.Duration) *OperationAttr

+ func WithNX() *OperationAttr

+ type OperationAttrs []*OperationAttr

+ func (a OperationAttrs) Find(name string) interface{}

+ type RedisClient struct

+ Db *redis.Client

+ func NewRedisClient(config *ConfigRedisClient) (*RedisClient, error)

+ func (c *RedisClient) GetDb() *redis.Client

+ func (c *RedisClient) NewListOperation() *ListOperation

+ func (c *RedisClient) NewSimpleCache(operation *StringOperation, expire time.Duration, serializer string) *SimpleCache

+ func (c *RedisClient) NewSimpleInterfaceCache(operation *SimpleOperation, expire time.Duration) *SimpleInterfaceCache

+ func (c *RedisClient) NewSimpleJsonCache(operation *StringOperation, expire time.Duration) *SimpleJsonCache

+ func (c *RedisClient) NewSimpleOperation() *SimpleOperation

+ func (c *RedisClient) NewSimpleStringCache(operation *StringOperation, expire time.Duration) *SimpleStringCache

+ func (c *RedisClient) NewStringOperation() *StringOperation

+ type RedisClient6 struct

+ Db *redis.Client

+ func NewRedisClient6(config *ConfigRedisClient) (*RedisClient6, error)

+ func (c *RedisClient6) GetDb() *redis.Client

+ type RedisClient7 struct

+ Db *redis.Client

+ func NewRedisClient7(config *ConfigRedisClient) (*RedisClient7, error)

+ func (c *RedisClient7) GetDb() *redis.Client

+ type SimpleCache struct

+ DBGetter DBGttFunc

+ Expire time.Duration

+ JsonGetter JsonGttFunc

+ Operation *StringOperation

+ Serializer string

+ func (c *SimpleCache) GetCache(key string) (ret interface{})

+ func (c *SimpleCache) SetCache(key string, value interface{})

+ type SimpleInterfaceCache struct

+ DBGetter DBGttInterfaceFunc

+ Expire time.Duration

+ Operation *SimpleOperation

+ func (c *SimpleInterfaceCache) GetCache(key string) (ret interface{})

+ func (c *SimpleInterfaceCache) SetCache(key string, value interface{})

+ type SimpleJsonCache struct

+ DBGetter DBGttJsonFunc

+ Expire time.Duration

+ Operation *StringOperation

+ func (c *SimpleJsonCache) GetCache(key string) (ret interface{})

+ func (c *SimpleJsonCache) SetCache(key string, value interface{})

+ type SimpleOperation struct

+ func (o *SimpleOperation) Del(keys ...string) *redis.IntCmd

+ func (o *SimpleOperation) Get(key string) *SimpleResult

+ func (o *SimpleOperation) Set(key string, value interface{}, attrs ...*OperationAttr) *SimpleResult

+ type SimpleResult struct

+ Err error

+ Result interface{}

+ func NewSimpleResult(result interface{}, err error) *SimpleResult

+ func (r *SimpleResult) Unwrap() interface{}

+ func (r *SimpleResult) UnwrapOr(defaults interface{}) interface{}

+ func (r *SimpleResult) UnwrapOrElse(f func() interface{}) interface{}

+ type SimpleStringCache struct

+ DBGetter DBGttStringFunc

+ Expire time.Duration

+ Operation *StringOperation

+ func (c *SimpleStringCache) GetCache(key string) (ret string)

+ func (c *SimpleStringCache) SetCache(key string, value string)

+ type SliceResult struct

+ Err error

+ Result []interface{}

+ func NewSliceResult(result []interface{}, err error) *SliceResult

+ func (r *SliceResult) Iter() *Iterator

+ func (r *SliceResult) Unwrap() []interface{}

+ func (r *SliceResult) UnwrapOr(defaults []interface{}) []interface{}

+ type StringOperation struct

+ func (o *StringOperation) Del(keys ...string) *redis.IntCmd

+ func (o *StringOperation) Get(key string) *StringResult

+ func (o *StringOperation) MGet(keys ...string) *SliceResult

+ func (o *StringOperation) Set(key string, value interface{}, attrs ...*OperationAttr) *StringResult

+ type StringResult struct

+ Err error

+ Result string

+ func NewStringResult(result string, err error) *StringResult

+ func (r *StringResult) Unwrap() string

+ func (r *StringResult) UnwrapOr(defaults string) string

+ func (r *StringResult) UnwrapOrElse(f func() string) string

+ type UpperClient struct

+ Db *db.Session

+ func NewUpperCockroachdbClient(settings cockroachdb.ConnectionURL) (*UpperClient, error)

+ func NewUpperMongodbClient(settings mongo.ConnectionURL) (*UpperClient, error)

+ func NewUpperMssqlClient(settings mssql.ConnectionURL) (*UpperClient, error)

+ func NewUpperMysqlClient(settings mysql.ConnectionURL) (*UpperClient, error)

+ func NewUpperPostgresqlClient(settings postgresql.ConnectionURL) (*UpperClient, error)

+ func NewUpperQlClient(settings ql.ConnectionURL) (*UpperClient, error)

+ type XormClient struct

+ Db *xorm.Engine

+ func NewXormMysqlClient(config *ConfigXormClient) (*XormClient, error)

+ func NewXormPostgresClient(config *ConfigXormClient) (*XormClient, error)

+ type XormClientSession struct

+ type ZormClient struct

+ Db *zorm.DBDao

+ func NewZormClickhouseClient(config *ConfigZormClient) (*ZormClient, error)

+ func NewZormDmClient(config *ConfigZormClient) (*ZormClient, error)

+ func NewZormMysqlClient(config *ConfigZormClient) (*ZormClient, error)