adapter

Sep 23, 2024

Changes in this version

type IMongodb

+ PipeOne func(pipeline interface{}, result interface{}) error

type Mongodb

+ func (m *Mongodb) PipeOne(pipeline interface{}, result interface{}) error

Sep 23, 2024

Changes in this version

type IMongodb

+ FindAndModify func(query interface{}, change qmgo.Change, result interface{}, options ...bson.M) error

type Mongodb

+ func (m *Mongodb) FindAndModify(query interface{}, change qmgo.Change, result interface{}, options ...bson.M) error

Sep 21, 2024

Changes in this version

type IMongodb

+ Count func(query interface{}) (int, error)

+ DeleteAll func(query interface{}) error

+ DeleteOne func(query interface{}) error

+ FindAll func(query interface{}, doc interface{}, options ...bson.M) error

+ FindOne func(query interface{}, doc interface{}, options ...bson.M) error

+ InsertAll func(docs interface{}) error

+ PipeAll func(query interface{}, desc interface{}) error

+ UpdateOrInsert func(query interface{}, doc interface{}) error

type Mongodb

+ func (m *Mongodb) Count(filter interface{}) (int, error)

+ func (m *Mongodb) DeleteAll(filter interface{}) error

+ func (m *Mongodb) DeleteOne(filter interface{}) error

+ func (m *Mongodb) FindAll(filter interface{}, doc interface{}, options ...bson.M) (err error)

+ func (m *Mongodb) FindOne(filter interface{}, doc interface{}, options ...bson.M) (err error)

+ func (m *Mongodb) InsertAll(docs interface{}) error

+ func (m *Mongodb) PipeAll(query interface{}, doc interface{}) error

+ func (m *Mongodb) UpdateOrInsert(query interface{}, doc interface{}) error

Jan 28, 2021

Changes in this version

+ var EsClass string

+ type Es struct

+ func NewEs(componentId ...string) *Es

+ func (e *Es) Batch(action, head, body string) error

+ func (e *Es) GetClient() *es.Client

+ func (e *Es) Prepare(componentId ...string)

+ func (e *Es) Single(method, uri string, body []byte, timeout time.Duration) ([]byte, error)

+ type IEs interface

+ Batch func(action, head, body string) error

+ GetClient func() *es.Client

+ Single func(method, uri string, body []byte, timeout time.Duration) ([]byte, error)

Jan 7, 2021

Changes in this version

type IRedis

+ IncrBy func(key string, delta int) (int, error)

type Redis

+ func (r *Redis) IncrBy(key string, delta int) (int, error)

Jan 5, 2021

Changes in this version

type IRedis

+ Expire func(key string, expire time.Duration) bool

+ ExpireAt func(key string, timestamp int64) bool

+ HDel func(key string, fields ...interface{}) int

+ HExists func(key, field string) bool

+ HGet func(key, field string) *value.Value

+ HGetAll func(key string) map[string]*value.Value

+ HIncrBy func(key, field string, delta int) int

+ HMGet func(key string, fields ...interface{}) map[string]*value.Value

+ HMSet func(key string, fv ...interface{}) bool

+ HSet func(key string, fv ...interface{}) bool

+ LLen func(key string) int

+ LPop func(key string) *value.Value

+ LPush func(key string, values ...interface{}) bool

+ RPop func(key string) *value.Value

+ RPush func(key string, values ...interface{}) bool

+ ZAdd func(key string, members ...*redis.Z) int

+ ZAddOpt func(key string, opts []string, members ...*redis.Z) (int, error)

+ ZCard func(key string) int

+ ZRange func(key string, start, end int) []*value.Value

+ ZRangeWithScores func(key string, start, end int) []*redis.ZV

+ ZRem func(key string, members ...interface{}) int

+ ZRevRange func(key string, start, end int) []*value.Value

+ ZRevRangeWithScores func(key string, start, end int) []*redis.ZV

type Redis

+ func (r *Redis) Expire(key string, expire time.Duration) bool

+ func (r *Redis) ExpireAt(key string, timestamp int64) bool

+ func (r *Redis) HDel(key string, fields ...interface{}) int

+ func (r *Redis) HExists(key, field string) bool

+ func (r *Redis) HGet(key, field string) *value.Value

+ func (r *Redis) HGetAll(key string) map[string]*value.Value

+ func (r *Redis) HIncrBy(key, field string, delta int) int

+ func (r *Redis) HMGet(key string, fields ...interface{}) map[string]*value.Value

+ func (r *Redis) HMSet(key string, fv ...interface{}) bool

+ func (r *Redis) HSet(key string, fv ...interface{}) bool

+ func (r *Redis) LLen(key string) int

+ func (r *Redis) LPop(key string) *value.Value

+ func (r *Redis) LPush(key string, values ...interface{}) bool

+ func (r *Redis) RPop(key string) *value.Value

+ func (r *Redis) RPush(key string, values ...interface{}) bool

+ func (r *Redis) ZAdd(key string, members ...*redis.Z) int

+ func (r *Redis) ZAddOpt(key string, opts []string, members ...*redis.Z) (int, error)

+ func (r *Redis) ZCard(key string) int

+ func (r *Redis) ZRange(key string, start, end int) []*value.Value

+ func (r *Redis) ZRangeWithScores(key string, start, end int) []*redis.ZV

+ func (r *Redis) ZRem(key string, members ...interface{}) int

+ func (r *Redis) ZRevRange(key string, start, end int) []*value.Value

+ func (r *Redis) ZRevRangeWithScores(key string, start, end int) []*redis.ZV

Dec 25, 2020

Changes in this version

+ var MongodbCAggregate string

+ type CAggregate struct

+ func (c *CAggregate) All(results interface{}) error

+ func (c *CAggregate) One(results interface{}) error

+ func (c *CAggregate) Prepare(q qmgo.AggregateI, dftCtxCancel ...context.CancelFunc)

+ type IMongodbAggregate interface

Dec 24, 2020

Changes in this version

+ const Blue

+ const BlueBold

+ const Cyan

+ const DefaultMongodbId

+ const ErrInvalidMongoDbOpt

+ const Green

+ const Magenta

+ const MagentaBold

+ const Red

+ const RedBold

+ const Reset

+ const White

+ const Yellow

+ const YellowBold

+ var MongodbCQueryClass string

+ var MongodbClass string

+ func FileWithLineNum() string

+ type CQuery struct

+ func (c *CQuery) All(result interface{}) error

+ func (c *CQuery) Apply(change qmgo.Change, result interface{}) error

+ func (c *CQuery) Count() (n int64, err error)

+ func (c *CQuery) Distinct(key string, result interface{}) error

+ func (c *CQuery) Hint(hint interface{}) qmgo.QueryI

+ func (c *CQuery) Limit(n int64) qmgo.QueryI

+ func (c *CQuery) One(result interface{}) error

+ func (c *CQuery) Prepare(q qmgo.QueryI, dftCtxCancel ...context.CancelFunc)

+ func (c *CQuery) Select(selector interface{}) qmgo.QueryI

+ func (c *CQuery) Skip(n int64) qmgo.QueryI

+ func (c *CQuery) Sort(fields ...string) qmgo.QueryI

+ type IMongodb interface

+ Aggregate func(pipeline interface{}) qmgo.AggregateI

+ AggregateCtx func(ctx context.Context, pipeline interface{}) qmgo.AggregateI

+ CloneCollection func() (*mongo.Collection, error)

+ CreateIndexes func(indexes []opts.IndexModel) (err error)

+ CreateIndexesCtx func(ctx context.Context, indexes []opts.IndexModel) (err error)

+ CreateOneIndex func(index opts.IndexModel) error

+ CreateOneIndexCtx func(ctx context.Context, index opts.IndexModel) (err error)

+ DoTransaction func(ctx context.Context, ...) (interface{}, error)

+ DropAllIndexes func() (err error)

+ DropAllIndexesCtx func(ctx context.Context) (err error)

+ DropCollection func() error

+ DropCollectionCtx func(ctx context.Context) error

+ DropIndex func(indexes []string) error

+ DropIndexCtx func(ctx context.Context, indexes []string) error

+ EnsureIndexes func(uniques []string, indexes []string) (err error)

+ EnsureIndexesCtx func(ctx context.Context, uniques []string, indexes []string) (err error)

+ Find func(filter interface{}, options ...opts.FindOptions) IMongodbQuery

+ FindCtx func(ctx context.Context, filter interface{}, options ...opts.FindOptions) IMongodbQuery

+ GetClient func() *mongodb.Client

+ GetCollectionName func() string

+ InsertMany func(docs interface{}, opts ...opts.InsertManyOptions) (result *qmgo.InsertManyResult, err error)

+ InsertManyCtx func(ctx context.Context, docs interface{}, opts ...opts.InsertManyOptions) (result *qmgo.InsertManyResult, err error)

+ InsertOne func(doc interface{}, opts ...opts.InsertOneOptions) (result *qmgo.InsertOneResult, err error)

+ InsertOneCtx func(ctx context.Context, doc interface{}, opts ...opts.InsertOneOptions) (result *qmgo.InsertOneResult, err error)

+ Remove func(filter interface{}, opts ...opts.RemoveOptions) (err error)

+ RemoveAll func(filter interface{}, opts ...opts.RemoveOptions) (result *qmgo.DeleteResult, err error)

+ RemoveAllCtx func(ctx context.Context, filter interface{}, opts ...opts.RemoveOptions) (result *qmgo.DeleteResult, err error)

+ RemoveCtx func(ctx context.Context, filter interface{}, opts ...opts.RemoveOptions) (err error)

+ RemoveId func(id interface{}, opts ...opts.RemoveOptions) (err error)

+ RemoveIdCtx func(ctx context.Context, id interface{}, opts ...opts.RemoveOptions) (err error)

+ ReplaceOne func(filter interface{}, doc interface{}, opts ...opts.ReplaceOptions) (err error)

+ ReplaceOneCtx func(ctx context.Context, filter interface{}, doc interface{}, ...) (err error)

+ Session func() (*qmgo.Session, error)

+ UpdateAll func(filter interface{}, update interface{}, opts ...opts.UpdateOptions) (result *qmgo.UpdateResult, err error)

+ UpdateAllCtx func(ctx context.Context, filter interface{}, update interface{}, ...) (result *qmgo.UpdateResult, err error)

+ UpdateId func(id interface{}, update interface{}, opts ...opts.UpdateOptions) (err error)

+ UpdateIdCtx func(ctx context.Context, id interface{}, update interface{}, ...) (err error)

+ UpdateOne func(filter interface{}, update interface{}, opts ...opts.UpdateOptions) (err error)

+ UpdateOneCtx func(ctx context.Context, filter interface{}, update interface{}, ...) (err error)

+ Upsert func(filter interface{}, replacement interface{}, opts ...opts.UpsertOptions) (result *qmgo.UpdateResult, err error)

+ UpsertCtx func(ctx context.Context, filter interface{}, replacement interface{}, ...) (result *qmgo.UpdateResult, err error)

+ UpsertId func(id interface{}, replacement interface{}, opts ...opts.UpsertOptions) (result *qmgo.UpdateResult, err error)

+ UpsertIdCtx func(ctx context.Context, id interface{}, replacement interface{}, ...) (result *qmgo.UpdateResult, err error)

+ type IMongodbQuery interface

+ type Mongodb struct

+ func NewMongodb(db, coll string, componentId ...string) *Mongodb

+ func (m *Mongodb) Aggregate(pipeline interface{}) qmgo.AggregateI

+ func (m *Mongodb) AggregateCtx(ctx context.Context, pipeline interface{}) qmgo.AggregateI

+ func (m *Mongodb) CloneCollection() (*mongo.Collection, error)

+ func (m *Mongodb) CreateIndexes(indexes []opts.IndexModel) (err error)

+ func (m *Mongodb) CreateIndexesCtx(ctx context.Context, indexes []opts.IndexModel) (err error)

+ func (m *Mongodb) CreateOneIndex(index opts.IndexModel) error

+ func (m *Mongodb) CreateOneIndexCtx(ctx context.Context, index opts.IndexModel) (err error)

+ func (m *Mongodb) DoTransaction(ctx context.Context, ...) (interface{}, error)

+ func (m *Mongodb) DropAllIndexes() (err error)

+ func (m *Mongodb) DropAllIndexesCtx(ctx context.Context) (err error)

+ func (m *Mongodb) DropCollection() error

+ func (m *Mongodb) DropCollectionCtx(ctx context.Context) error

+ func (m *Mongodb) DropIndex(indexes []string) error

+ func (m *Mongodb) DropIndexCtx(ctx context.Context, indexes []string) error

+ func (m *Mongodb) EnsureIndexes(uniques []string, indexes []string) (err error)

+ func (m *Mongodb) EnsureIndexesCtx(ctx context.Context, uniques []string, indexes []string) (err error)

+ func (m *Mongodb) Find(filter interface{}, options ...opts.FindOptions) IMongodbQuery

+ func (m *Mongodb) FindCtx(ctx context.Context, filter interface{}, options ...opts.FindOptions) IMongodbQuery

+ func (m *Mongodb) GetClient() *mongodb.Client

+ func (m *Mongodb) GetCollectionName() string

+ func (m *Mongodb) InsertMany(docs interface{}, opts ...opts.InsertManyOptions) (result *qmgo.InsertManyResult, err error)

+ func (m *Mongodb) InsertManyCtx(ctx context.Context, docs interface{}, opts ...opts.InsertManyOptions) (result *qmgo.InsertManyResult, err error)

+ func (m *Mongodb) InsertOne(doc interface{}, opts ...opts.InsertOneOptions) (result *qmgo.InsertOneResult, err error)

+ func (m *Mongodb) InsertOneCtx(ctx context.Context, doc interface{}, opts ...opts.InsertOneOptions) (result *qmgo.InsertOneResult, err error)

+ func (m *Mongodb) Prepare(db, coll string, componentId ...string)

+ func (m *Mongodb) Remove(filter interface{}, opts ...opts.RemoveOptions) (err error)

+ func (m *Mongodb) RemoveAll(filter interface{}, opts ...opts.RemoveOptions) (result *qmgo.DeleteResult, err error)

+ func (m *Mongodb) RemoveAllCtx(ctx context.Context, filter interface{}, opts ...opts.RemoveOptions) (result *qmgo.DeleteResult, err error)

+ func (m *Mongodb) RemoveCtx(ctx context.Context, filter interface{}, opts ...opts.RemoveOptions) (err error)

+ func (m *Mongodb) RemoveId(id interface{}, opts ...opts.RemoveOptions) (err error)

+ func (m *Mongodb) RemoveIdCtx(ctx context.Context, id interface{}, opts ...opts.RemoveOptions) (err error)

+ func (m *Mongodb) ReplaceOne(filter interface{}, doc interface{}, opts ...opts.ReplaceOptions) (err error)

+ func (m *Mongodb) ReplaceOneCtx(ctx context.Context, filter interface{}, doc interface{}, ...) (err error)

+ func (m *Mongodb) Session() (*qmgo.Session, error)

+ func (m *Mongodb) UpdateAll(filter interface{}, update interface{}, opts ...opts.UpdateOptions) (result *qmgo.UpdateResult, err error)

+ func (m *Mongodb) UpdateAllCtx(ctx context.Context, filter interface{}, update interface{}, ...) (result *qmgo.UpdateResult, err error)

+ func (m *Mongodb) UpdateId(id interface{}, update interface{}, opts ...opts.UpdateOptions) (err error)

+ func (m *Mongodb) UpdateIdCtx(ctx context.Context, id interface{}, update interface{}, ...) (err error)

+ func (m *Mongodb) UpdateOne(filter interface{}, update interface{}, opts ...opts.UpdateOptions) (err error)

+ func (m *Mongodb) UpdateOneCtx(ctx context.Context, filter interface{}, update interface{}, ...) (err error)

+ func (m *Mongodb) Upsert(filter interface{}, replacement interface{}, opts ...opts.UpsertOptions) (result *qmgo.UpdateResult, err error)

+ func (m *Mongodb) UpsertCtx(ctx context.Context, filter interface{}, replacement interface{}, ...) (result *qmgo.UpdateResult, err error)

+ func (m *Mongodb) UpsertId(id interface{}, replacement interface{}, opts ...opts.UpsertOptions) (result *qmgo.UpdateResult, err error)

+ func (m *Mongodb) UpsertIdCtx(ctx context.Context, id interface{}, replacement interface{}, ...) (result *qmgo.UpdateResult, err error)

Dec 9, 2020

Changes in this version

+ const DefaultOrmId

+ var OrmClass string

+ var OrmLogWriterClass string

+ type IOrm interface

+ AddError func(err error) error

+ Assign func(attrs ...interface{}) IOrm

+ Association func(column string) *gorm.Association

+ Attrs func(attrs ...interface{}) IOrm

+ AutoMigrate func(dst ...interface{}) error

+ Begin func(opts ...*sql.TxOptions) IOrm

+ Clauses func(conds ...clause.Expression) IOrm

+ Commit func() IOrm

+ Count func(count *int64) IOrm

+ Create func(value interface{}) IOrm

+ CreateInBatches func(value interface{}, batchSize int) IOrm

+ Debug func() IOrm

+ Delete func(value interface{}, conds ...interface{}) IOrm

+ Distinct func(args ...interface{}) IOrm

+ Exec func(sql string, values ...interface{}) IOrm

+ Find func(dest interface{}, conds ...interface{}) IOrm

+ FindInBatches func(dest interface{}, batchSize int, fc func(pTx *gorm.DB, batch int) error) IOrm

+ First func(dest interface{}, conds ...interface{}) IOrm

+ FirstOrCreate func(dest interface{}, conds ...interface{}) IOrm

+ FirstOrInit func(dest interface{}, conds ...interface{}) IOrm

+ Get func(key string) (interface{}, bool)

+ GetConfig func() *gorm.Config

+ GetError func() error

+ GetRowsAffected func() int64

+ GetStatement func() *gorm.Statement

+ Group func(name string) IOrm

+ Having func(query interface{}, args ...interface{}) IOrm

+ InstanceGet func(key string) (interface{}, bool)

+ InstanceSet func(key string, value interface{}) IOrm

+ Joins func(query string, args ...interface{}) IOrm

+ Last func(dest string, conds ...interface{}) IOrm

+ Limit func(limit int) IOrm

+ Model func(value interface{}) IOrm

+ Not func(query interface{}, args ...interface{}) IOrm

+ Offset func(offset int) IOrm

+ Omit func(columns ...string) IOrm

+ Or func(query interface{}, args ...interface{}) IOrm

+ Order func(value interface{}) IOrm

+ Pluck func(column string, dest interface{}) IOrm

+ Preload func(query string, args ...interface{}) IOrm

+ Raw func(sql string, values ...interface{}) IOrm

+ Rollback func() IOrm

+ RollbackTo func(name string) IOrm

+ Row func() *sql.Row

+ Rows func() (*sql.Rows, error)

+ Save func(value interface{}) IOrm

+ SavePoint func(name string) IOrm

+ Scan func(dest interface{}) IOrm

+ ScanRows func(rows *sql.Rows, dest interface{}) error

+ Scopes func(funcs ...func(*gorm.DB) *gorm.DB) IOrm

+ Select func(query interface{}, args ...interface{}) IOrm

+ Session func(config *gorm.Session) IOrm

+ Set func(key string, value interface{}) IOrm

+ SetupJoinTable func(model interface{}, field string, joinTable interface{}) error

+ SqlDB func() (*sql.DB, error)

+ Table func(name string, args ...interface{}) IOrm

+ Take func(dest interface{}, conds ...interface{}) IOrm

+ Transaction func(fc func(tx *gorm.DB) error, opts ...*sql.TxOptions) (err error)

+ Unscoped func() IOrm

+ Update func(column string, value interface{}) IOrm

+ UpdateColumn func(column string, value interface{}) IOrm

+ UpdateColumns func(values interface{}) IOrm

+ Updates func(values interface{}) IOrm

+ Use func(plugin gorm.Plugin) (err error)

+ Where func(query interface{}, args ...interface{}) IOrm

+ WithContext func(ctx context.Context) IOrm

+ type LogWriter struct

+ func (l *LogWriter) Prepare()

+ func (l *LogWriter) Printf(msg string, data ...interface{})

+ type Orm struct

+ func NewOrm(ctr iface.IContext, componentId ...string) *Orm

+ func (o *Orm) Assign(attrs ...interface{}) (tx IOrm)

+ func (o *Orm) Attrs(attrs ...interface{}) (tx IOrm)

+ func (o *Orm) Begin(opts ...*sql.TxOptions) (tx IOrm)

+ func (o *Orm) Clauses(conds ...clause.Expression) (tx IOrm)

+ func (o *Orm) Commit() (tx IOrm)

+ func (o *Orm) Count(count *int64) (tx IOrm)

+ func (o *Orm) Create(value interface{}) (tx IOrm)

+ func (o *Orm) CreateInBatches(value interface{}, batchSize int) (tx IOrm)

+ func (o *Orm) Debug() (tx IOrm)

+ func (o *Orm) Delete(value interface{}, conds ...interface{}) (tx IOrm)

+ func (o *Orm) Distinct(args ...interface{}) (tx IOrm)

+ func (o *Orm) Exec(sql string, values ...interface{}) (tx IOrm)

+ func (o *Orm) Find(dest interface{}, conds ...interface{}) (tx IOrm)

+ func (o *Orm) FindInBatches(dest interface{}, batchSize int, fc func(pTx *gorm.DB, batch int) error) (tx IOrm)

+ func (o *Orm) First(dest interface{}, conds ...interface{}) (tx IOrm)

+ func (o *Orm) FirstOrCreate(dest interface{}, conds ...interface{}) (tx IOrm)

+ func (o *Orm) FirstOrInit(dest interface{}, conds ...interface{}) (tx IOrm)

+ func (o *Orm) GetConfig() *gorm.Config

+ func (o *Orm) GetError() error

+ func (o *Orm) GetRowsAffected() int64

+ func (o *Orm) GetStatement() *gorm.Statement

+ func (o *Orm) Group(name string) (tx IOrm)

+ func (o *Orm) Having(query interface{}, args ...interface{}) (tx IOrm)

+ func (o *Orm) InstanceSet(key string, value interface{}) (tx IOrm)

+ func (o *Orm) Joins(query string, args ...interface{}) (tx IOrm)

+ func (o *Orm) Last(dest string, conds ...interface{}) (tx IOrm)

+ func (o *Orm) Limit(limit int) (tx IOrm)

+ func (o *Orm) Model(value interface{}) (tx IOrm)

+ func (o *Orm) Not(query interface{}, args ...interface{}) (tx IOrm)

+ func (o *Orm) Offset(offset int) (tx IOrm)

+ func (o *Orm) Omit(columns ...string) (tx IOrm)

+ func (o *Orm) Or(query interface{}, args ...interface{}) (tx IOrm)

+ func (o *Orm) Order(value interface{}) (tx IOrm)

+ func (o *Orm) Pluck(column string, dest interface{}) (tx IOrm)

+ func (o *Orm) Preload(query string, args ...interface{}) (tx IOrm)

+ func (o *Orm) Prepare(componentId ...interface{})

+ func (o *Orm) Raw(sql string, values ...interface{}) (tx IOrm)

+ func (o *Orm) Rollback() (tx IOrm)

+ func (o *Orm) RollbackTo(name string) (tx IOrm)

+ func (o *Orm) Row() *sql.Row

+ func (o *Orm) Rows() (*sql.Rows, error)

+ func (o *Orm) Save(value interface{}) (tx IOrm)

+ func (o *Orm) SavePoint(name string) (tx IOrm)

+ func (o *Orm) Scan(dest interface{}) (tx IOrm)

+ func (o *Orm) Scopes(funcs ...func(*gorm.DB) *gorm.DB) (tx IOrm)

+ func (o *Orm) Select(query interface{}, args ...interface{}) (tx IOrm)

+ func (o *Orm) Session(config *gorm.Session) (tx IOrm)

+ func (o *Orm) Set(key string, value interface{}) (tx IOrm)

+ func (o *Orm) SqlDB() (*sql.DB, error)

+ func (o *Orm) Table(name string, args ...interface{}) (tx IOrm)

+ func (o *Orm) Take(dest interface{}, conds ...interface{}) (tx IOrm)

+ func (o *Orm) Unscoped() (tx IOrm)

+ func (o *Orm) Update(column string, value interface{}) (tx IOrm)

+ func (o *Orm) UpdateColumn(column string, value interface{}) (tx IOrm)

+ func (o *Orm) UpdateColumns(values interface{}) (tx IOrm)

+ func (o *Orm) Updates(values interface{}) (tx IOrm)

+ func (o *Orm) Where(query interface{}, args ...interface{}) (tx IOrm)

+ func (o *Orm) WithContext(ctx context.Context) (tx IOrm)

Oct 30, 2020

Changes in this version

type Http

+ func (h *Http) Prepare(componentId ...interface{})

type MaxMind

+ func (m *MaxMind) Prepare(componentId ...interface{})

type MemCache

+ func (m *MemCache) Prepare(componentId ...interface{})

type Memory

+ func (m *Memory) Prepare(componentId ...interface{})

type Mongo

+ func (m *Mongo) Prepare(args ...interface{})

type RabbitMq

+ func (r *RabbitMq) Prepare(dftConfig ...interface{})

type Redis

+ func (r *Redis) Prepare(componentId ...interface{})

Sep 3, 2020

Changes in this version

type RabbitMq

+ func (r *RabbitMq) PublishExchangeDelivery(serviceName, exchangeName, exchangeType, opCode string, data interface{}, ...) bool

Jul 9, 2020

Changes in this version

type Db

+ func (d *Db) PrepareSql(query string) IStmt

type IDb

+ PrepareSql func(query string) IStmt

type ITx

+ PrepareSql func(query string) IStmt

type Tx

+ func (t *Tx) PrepareSql(query string) IStmt

Jun 18, 2020

Changes in this version

type IRabbitMq

+ ChannelBox func() *rabbitmq.ChannelBox

type RabbitMq

+ func (r *RabbitMq) ChannelBox() *rabbitmq.ChannelBox

May 13, 2020

Changes in this version

type IRabbitMq

+ ConsumeExchange func(exchangeName, exchangeType, queueName string, opCodes []string, limit int, ...) <-chan amqp.Delivery

+ PublishExchange func(serviceName, exchangeName, exchangeType, opCode string, data interface{}, ...) bool

type RabbitMq

+ func (r *RabbitMq) ConsumeExchange(exchangeName, exchangeType, queueName string, opCodes []string, limit int, ...) <-chan amqp.Delivery

+ func (r *RabbitMq) PublishExchange(serviceName, exchangeName, exchangeType, opCode string, data interface{}, ...) bool

Dec 31, 2019

Changes in this version

+ const DefaultDbId

+ const DefaultDbTimeout

+ const DefaultHttpId

+ const DefaultMaxMindId

+ const DefaultMemCacheId

+ const DefaultMemoryId

+ const DefaultMongoId

+ const DefaultRabbitId

+ const DefaultRedisId

+ const ErrInvalidOpt

+ var DbClass string

+ var HttpClass string

+ var MaxMindClass string

+ var MemCacheClass string

+ var MemoryClass string

+ var MongoClass string

+ var RabbitMqClass string

+ var RedisClass string

+ func NewDbPool(iObj iface.IObject, componentId ...interface{}) iface.IObject

+ func NewHttpPool(iObj iface.IObject, componentId ...interface{}) iface.IObject

+ func NewMaxMindPool(iObj iface.IObject, componentId ...interface{}) iface.IObject

+ func NewMemCachePool(iObj iface.IObject, componentId ...interface{}) iface.IObject

+ func NewMemoryPool(iObj iface.IObject, componentId ...interface{}) iface.IObject

+ func NewMongoPool(iObj iface.IObject, args ...interface{}) iface.IObject

+ func NewRabbitMqPool(iObj iface.IObject, componentId ...interface{}) iface.IObject

+ func NewRedisPool(iObj iface.IObject, componentId ...interface{}) iface.IObject

+ type Db struct

+ func NewDb(componentId ...string) *Db

+ func (d *Db) Begin(opts ...*sql.TxOptions) ITx

+ func (d *Db) BeginContext(ctx context.Context, opts *sql.TxOptions) ITx

+ func (d *Db) Exec(query string, args ...interface{}) sql.Result

+ func (d *Db) ExecContext(ctx context.Context, query string, args ...interface{}) sql.Result

+ func (d *Db) GetClient() *db.Client

+ func (d *Db) GetDb(master bool) *sql.DB

+ func (d *Db) Master() bool

+ func (d *Db) Prepare(query string) IStmt

+ func (d *Db) PrepareContext(ctx context.Context, query string) IStmt

+ func (d *Db) Query(query string, args ...interface{}) *sql.Rows

+ func (d *Db) QueryContext(ctx context.Context, query string, args ...interface{}) *sql.Rows

+ func (d *Db) QueryOne(query string, args ...interface{}) IRow

+ func (d *Db) QueryOneContext(ctx context.Context, query string, args ...interface{}) IRow

+ func (d *Db) SetMaster(v bool)

+ type Http struct

+ func NewHttp(componentId ...string) *Http

+ func (h *Http) Do(req *http.Request, option ...*phttp.Option) *http.Response

+ func (h *Http) DoMulti(requests []*http.Request, option ...*phttp.Option) []*http.Response

+ func (h *Http) Get(addr string, data interface{}, option ...*phttp.Option) *http.Response

+ func (h *Http) GetClient() *phttp.Client

+ func (h *Http) Post(addr string, data interface{}, option ...*phttp.Option) *http.Response

+ func (h *Http) SetPanicRecover(v bool)

+ type IDb interface

+ Begin func(opts ...*sql.TxOptions) ITx

+ BeginContext func(ctx context.Context, opts *sql.TxOptions) ITx

+ Exec func(query string, args ...interface{}) sql.Result

+ ExecContext func(ctx context.Context, query string, args ...interface{}) sql.Result

+ GetDb func(master bool) *sql.DB

+ Prepare func(query string) IStmt

+ PrepareContext func(ctx context.Context, query string) IStmt

+ Query func(query string, args ...interface{}) *sql.Rows

+ QueryContext func(ctx context.Context, query string, args ...interface{}) *sql.Rows

+ QueryOne func(query string, args ...interface{}) IRow

+ QueryOneContext func(ctx context.Context, query string, args ...interface{}) IRow

+ SetMaster func(v bool)

+ type IHttp interface

+ Do func(req *http.Request, option ...*phttp.Option) *http.Response

+ DoMulti func(requests []*http.Request, option ...*phttp.Option) []*http.Response

+ Get func(addr string, data interface{}, option ...*phttp.Option) *http.Response

+ Post func(addr string, data interface{}, option ...*phttp.Option) *http.Response

+ SetPanicRecover func(v bool)

+ type IMaxMind interface

+ GeoByIp func(ip string, args ...interface{}) *maxmind.Geo

+ type IMemCache interface

+ Add func(key string, value interface{}, expire ...time.Duration) bool

+ Del func(key string) bool

+ Exists func(key string) bool

+ Get func(key string) *value.Value

+ Incr func(key string, delta int) int

+ MAdd func(items map[string]interface{}, expire ...time.Duration) bool

+ MDel func(keys []string) bool

+ MGet func(keys []string) map[string]*value.Value

+ MSet func(items map[string]interface{}, expire ...time.Duration) bool

+ MultiRetrieve func(cmd string, keys []string) []*memcache.Item

+ MultiStore func(cmd string, items []*memcache.Item, expire ...time.Duration) bool

+ Retrieve func(cmd, key string) *memcache.Item

+ Set func(key string, value interface{}, expire ...time.Duration) bool

+ SetPanicRecover func(v bool)

+ Store func(cmd string, item *memcache.Item, expire ...time.Duration) bool

+ type IMemory interface

+ Add func(key string, value interface{}, expire ...time.Duration) bool

+ Del func(key string) bool

+ Exists func(key string) bool

+ Get func(key string) *value.Value

+ Incr func(key string, delta int) int

+ MAdd func(items map[string]interface{}, expire ...time.Duration) bool

+ MDel func(keys []string) bool

+ MGet func(keys []string) map[string]*value.Value

+ MSet func(items map[string]interface{}, expire ...time.Duration) bool

+ Set func(key string, value interface{}, expire ...time.Duration) bool

+ SetPanicRecover func(v bool)

+ type IMongo interface

+ Count func(query interface{}, options ...bson.M) (int, error)

+ DeleteAll func(query interface{}) error

+ DeleteOne func(query interface{}) error

+ FindAll func(query interface{}, result interface{}, options ...bson.M) error

+ FindAndModify func(query interface{}, change mgo.Change, result interface{}, options ...bson.M) error

+ FindDistinct func(query interface{}, key string, result interface{}, options ...bson.M) error

+ FindOne func(query interface{}, result interface{}, options ...bson.M) error

+ InsertAll func(docs []interface{}) error

+ InsertOne func(doc interface{}) error

+ MapReduce func(query interface{}, job *mgo.MapReduce, result interface{}, options ...bson.M) error

+ PipeAll func(pipeline interface{}, result interface{}) error

+ PipeOne func(pipeline interface{}, result interface{}) error

+ UpdateAll func(query interface{}, update interface{}) error

+ UpdateOne func(query interface{}, update interface{}) error

+ UpdateOrInsert func(query interface{}, update interface{}) error

+ type IRabbitMq interface

+ Consume func(queueName string, opCodes []string, limit int, autoAck, noWait, exclusive bool) <-chan amqp.Delivery

+ DecodeBody func(d amqp.Delivery, ret interface{}) error

+ DecodeHeaders func(d amqp.Delivery) *rabbitmq.RabbitHeaders

+ ExchangeDeclare func()

+ GetConsumeChannelBox func(queueName string, opCodes []string) *rabbitmq.ChannelBox

+ Publish func(opCode string, data interface{}, dftOpUid ...string) bool

+ SetPanicRecover func(v bool)

+ type IRedis interface

+ Add func(key string, value interface{}, expire ...time.Duration) bool

+ Del func(key string) bool

+ Do func(cmd string, args ...interface{}) interface{}

+ Exists func(key string) bool

+ Get func(key string) *value.Value

+ Incr func(key string, delta int) int

+ MAdd func(items map[string]interface{}, expire ...time.Duration) bool

+ MDel func(keys []string) bool

+ MGet func(keys []string) map[string]*value.Value

+ MSet func(items map[string]interface{}, expire ...time.Duration) bool

+ Set func(key string, value interface{}, expire ...time.Duration) bool

+ SetPanicRecover func(v bool)

+ type IRow interface

+ Scan func(dest ...interface{}) error

+ type IStmt interface

+ Close func()

+ Exec func(args ...interface{}) sql.Result

+ ExecContext func(ctx context.Context, args ...interface{}) sql.Result

+ Query func(args ...interface{}) *sql.Rows

+ QueryContext func(ctx context.Context, args ...interface{}) *sql.Rows

+ QueryOne func(args ...interface{}) IRow

+ QueryOneContext func(ctx context.Context, args ...interface{}) IRow

+ type ITx interface

+ Commit func() bool

+ Exec func(query string, args ...interface{}) sql.Result

+ ExecContext func(ctx context.Context, query string, args ...interface{}) sql.Result

+ Prepare func(query string) IStmt

+ PrepareContext func(ctx context.Context, query string) IStmt

+ Query func(query string, args ...interface{}) *sql.Rows

+ QueryContext func(ctx context.Context, query string, args ...interface{}) *sql.Rows

+ QueryOne func(query string, args ...interface{}) IRow

+ QueryOneContext func(ctx context.Context, query string, args ...interface{}) IRow

+ Rollback func() bool

+ type MaxMind struct

+ func NewMaxMind(componentId ...string) *MaxMind

+ func (m *MaxMind) GeoByIp(ip string, args ...interface{}) *maxmind.Geo

+ func (m *MaxMind) GetClient() *maxmind.Client

+ type MemCache struct

+ func NewMemCache(componentId ...string) *MemCache

+ func (m *MemCache) Add(key string, value interface{}, expire ...time.Duration) bool

+ func (m *MemCache) Del(key string) bool

+ func (m *MemCache) Exists(key string) bool

+ func (m *MemCache) Get(key string) *value.Value

+ func (m *MemCache) GetClient() *memcache.Client

+ func (m *MemCache) Incr(key string, delta int) int

+ func (m *MemCache) MAdd(items map[string]interface{}, expire ...time.Duration) bool

+ func (m *MemCache) MDel(keys []string) bool

+ func (m *MemCache) MGet(keys []string) map[string]*value.Value

+ func (m *MemCache) MSet(items map[string]interface{}, expire ...time.Duration) bool

+ func (m *MemCache) MultiRetrieve(cmd string, keys []string) []*memcache.Item

+ func (m *MemCache) MultiStore(cmd string, items []*memcache.Item, expire ...time.Duration) bool

+ func (m *MemCache) Retrieve(cmd, key string) *memcache.Item

+ func (m *MemCache) Set(key string, value interface{}, expire ...time.Duration) bool

+ func (m *MemCache) SetPanicRecover(v bool)

+ func (m *MemCache) Store(cmd string, item *memcache.Item, expire ...time.Duration) bool

+ type Memory struct

+ func NewMemory(componentId ...string) *Memory

+ func (m *Memory) Add(key string, value interface{}, expire ...time.Duration) bool

+ func (m *Memory) Client() *memory.Client

+ func (m *Memory) Del(key string) bool

+ func (m *Memory) Exists(key string) bool

+ func (m *Memory) Get(key string) *value.Value

+ func (m *Memory) Incr(key string, delta int) int

+ func (m *Memory) MAdd(items map[string]interface{}, expire ...time.Duration) bool

+ func (m *Memory) MDel(keys []string) bool

+ func (m *Memory) MGet(keys []string) map[string]*value.Value

+ func (m *Memory) MSet(items map[string]interface{}, expire ...time.Duration) bool

+ func (m *Memory) Set(key string, value interface{}, expire ...time.Duration) bool

+ func (m *Memory) SetPanicRecover(v bool)

+ type Mongo struct

+ func NewMongo(db, coll string, componentId ...string) *Mongo

+ func (m *Mongo) Count(query interface{}, options ...bson.M) (int, error)

+ func (m *Mongo) DeleteAll(query interface{}) error

+ func (m *Mongo) DeleteOne(query interface{}) error

+ func (m *Mongo) FindAll(query interface{}, result interface{}, options ...bson.M) error

+ func (m *Mongo) FindAndModify(query interface{}, change mgo.Change, result interface{}, options ...bson.M) error

+ func (m *Mongo) FindDistinct(query interface{}, key string, result interface{}, options ...bson.M) error

+ func (m *Mongo) FindOne(query interface{}, result interface{}, options ...bson.M) error

+ func (m *Mongo) GetClient() *mongo.Client

+ func (m *Mongo) InsertAll(docs []interface{}) error

+ func (m *Mongo) InsertOne(doc interface{}) error

+ func (m *Mongo) MapReduce(query interface{}, job *mgo.MapReduce, result interface{}, options ...bson.M) error

+ func (m *Mongo) PipeAll(pipeline interface{}, result interface{}) error

+ func (m *Mongo) PipeOne(pipeline interface{}, result interface{}) error

+ func (m *Mongo) UpdateAll(query interface{}, update interface{}) error

+ func (m *Mongo) UpdateOne(query interface{}, update interface{}) error

+ func (m *Mongo) UpdateOrInsert(query interface{}, update interface{}) error

+ type RabbitMq struct

+ func NewRabbitMq(componentId ...string) *RabbitMq

+ func (r *RabbitMq) Consume(queueName string, opCodes []string, limit int, autoAck, noWait, exclusive bool) <-chan amqp.Delivery

+ func (r *RabbitMq) DecodeBody(d amqp.Delivery, ret interface{}) error

+ func (r *RabbitMq) DecodeHeaders(d amqp.Delivery) *rabbitmq.RabbitHeaders

+ func (r *RabbitMq) ExchangeDeclare()

+ func (r *RabbitMq) GetClient() *rabbitmq.Client

+ func (r *RabbitMq) GetConsumeChannelBox(queueName string, opCodes []string) *rabbitmq.ChannelBox

+ func (r *RabbitMq) Publish(opCode string, data interface{}, dftOpUid ...string) bool

+ func (r *RabbitMq) SetPanicRecover(v bool)

+ type Redis struct

+ func NewRedis(componentId ...string) *Redis

+ func (r *Redis) Add(key string, value interface{}, expire ...time.Duration) bool

+ func (r *Redis) Del(key string) bool

+ func (r *Redis) Do(cmd string, args ...interface{}) interface{}

+ func (r *Redis) Exists(key string) bool

+ func (r *Redis) Get(key string) *value.Value

+ func (r *Redis) GetClient() *redis.Client

+ func (r *Redis) Incr(key string, delta int) int

+ func (r *Redis) MAdd(items map[string]interface{}, expire ...time.Duration) bool

+ func (r *Redis) MDel(keys []string) bool

+ func (r *Redis) MGet(keys []string) map[string]*value.Value

+ func (r *Redis) MSet(items map[string]interface{}, expire ...time.Duration) bool

+ func (r *Redis) Set(key string, value interface{}, expire ...time.Duration) bool

+ func (r *Redis) SetPanicRecover(v bool)

+ type Row struct

+ func (r *Row) Scan(dest ...interface{}) error

+ type Stmt struct

+ func (s *Stmt) Close()

+ func (s *Stmt) Exec(args ...interface{}) sql.Result

+ func (s *Stmt) ExecContext(ctx context.Context, args ...interface{}) sql.Result

+ func (s *Stmt) Query(args ...interface{}) *sql.Rows

+ func (s *Stmt) QueryContext(ctx context.Context, args ...interface{}) *sql.Rows

+ func (s *Stmt) QueryOne(args ...interface{}) IRow

+ func (s *Stmt) QueryOneContext(ctx context.Context, args ...interface{}) IRow

+ type Tx struct

+ func (t *Tx) Commit() bool

+ func (t *Tx) Exec(query string, args ...interface{}) sql.Result

+ func (t *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) sql.Result

+ func (t *Tx) Prepare(query string) IStmt

+ func (t *Tx) PrepareContext(ctx context.Context, query string) IStmt

+ func (t *Tx) Query(query string, args ...interface{}) *sql.Rows

+ func (t *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) *sql.Rows

+ func (t *Tx) QueryOne(query string, args ...interface{}) IRow

+ func (t *Tx) QueryOneContext(ctx context.Context, query string, args ...interface{}) IRow

+ func (t *Tx) Rollback() bool