mongo_client

Jun 25, 2020

Changes in this version

+ func BsonDeserialize(ex interface{}) gotask.Middleware

+ func BsonSerialize() gotask.Middleware

+ func ErrorFilter() gotask.Middleware

+ type BulkWriteCmd struct

+ Collection string

+ Database string

+ Operations []map[string][]bson.Raw

+ Opts *options.BulkWriteOptions

+ type CreateIndexCmd struct

+ Collection string

+ CreateOpts *options.CreateIndexesOptions

+ Database string

+ IndexKeys bson.Raw

+ Opts *options.IndexOptions

+ type CreateIndexesCmd struct

+ Collection string

+ CreateOpts *options.CreateIndexesOptions

+ Database string

+ Models []mongo.IndexModel

+ Opts *options.IndexOptions

+ type DistinctCmd struct

+ Collection string

+ Database string

+ FieldName string

+ Filter bson.Raw

+ Opts *options.DistinctOptions

+ type DropIndexCmd struct

+ Collection string

+ Database string

+ Name string

+ Opts *options.DropIndexesOptions

+ type DropIndexesCmd struct

+ Collection string

+ Database string

+ Opts *options.DropIndexesOptions

+ type FindOneAndDeleteCmd struct

+ Collection string

+ Database string

+ Filter bson.Raw

+ Opts *options.FindOneAndDeleteOptions

+ type FindOneAndReplaceCmd struct

+ Collection string

+ Database string

+ Filter bson.Raw

+ Opts *options.FindOneAndReplaceOptions

+ Replace bson.Raw

+ type FindOneAndUpdateCmd struct

+ Collection string

+ Database string

+ Filter bson.Raw

+ Opts *options.FindOneAndUpdateOptions

+ Update bson.Raw

+ type ListIndexesCmd struct

+ Collection string

+ Database string

+ Opts *options.ListIndexesOptions

type MongoProxy

+ func (m *MongoProxy) BulkWrite(payload []byte, result *[]byte) error

+ func (m *MongoProxy) CreateIndex(payload []byte, result *[]byte) error

+ func (m *MongoProxy) CreateIndexes(payload []byte, result *[]byte) error

+ func (m *MongoProxy) Distinct(payload []byte, result *[]byte) error

+ func (m *MongoProxy) DropIndex(payload []byte, result *[]byte) error

+ func (m *MongoProxy) DropIndexes(payload []byte, result *[]byte) error

+ func (m *MongoProxy) FindOneAndDelete(payload []byte, result *[]byte) error

+ func (m *MongoProxy) FindOneAndReplace(payload []byte, result *[]byte) error

+ func (m *MongoProxy) FindOneAndUpdate(payload []byte, result *[]byte) error

+ func (m *MongoProxy) ListIndexes(payload []byte, result *[]byte) error

Jun 1, 2020

Changes in this version

+ type AggregateCmd struct

+ Collection string

+ Database string

+ Opts []*options.AggregateOptions

+ Pipeline []interface{}

+ type Cmd struct

+ Command interface{}

+ Database string

+ Opts []*options.RunCmdOptions

+ type Config struct

+ ConnectTimeout time.Duration

+ ReadWriteTimeout time.Duration

+ Uri string

+ func LoadConfig() Config

+ type CountDocumentsCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.CountOptions

+ type DeleteManyCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.DeleteOptions

+ type DeleteOneCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.DeleteOptions

+ type DropCmd struct

+ Collection string

+ Database string

+ type FindCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.FindOptions

+ type FindOneCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.FindOneOptions

+ type InsertManyCmd struct

+ Collection string

+ Database string

+ Opts []*options.InsertManyOptions

+ Records []interface{}

+ type InsertOneCmd struct

+ Collection string

+ Database string

+ Opts []*options.InsertOneOptions

+ Record interface{}

+ type MongoProxy struct

+ func NewMongoProxy(client *mongo.Client) *MongoProxy

+ func NewMongoProxyWithTimeout(client *mongo.Client, timeout time.Duration) *MongoProxy

+ func (m *MongoProxy) Aggregate(payload AggregateCmd, result *[]map[string]interface{}) error

+ func (m *MongoProxy) CountDocuments(payload CountDocumentsCmd, result *interface{}) error

+ func (m *MongoProxy) DeleteMany(payload DeleteManyCmd, result *interface{}) error

+ func (m *MongoProxy) DeleteOne(payload DeleteOneCmd, result *interface{}) error

+ func (m *MongoProxy) Drop(payload DropCmd, result *interface{}) error

+ func (m *MongoProxy) Find(payload FindCmd, result *[]map[string]interface{}) error

+ func (m *MongoProxy) FindOne(payload FindOneCmd, result *map[string]interface{}) error

+ func (m *MongoProxy) InsertMany(payload InsertManyCmd, result *interface{}) error

+ func (m *MongoProxy) InsertOne(payload InsertOneCmd, result *interface{}) error

+ func (m *MongoProxy) ReplaceOne(payload ReplaceOneCmd, result *interface{}) error

+ func (m *MongoProxy) RunCommand(payload Cmd, result *map[string]interface{}) error

+ func (m *MongoProxy) RunCommandCursor(payload Cmd, result *[]map[string]interface{}) error

+ func (m *MongoProxy) UpdateMany(payload UpdateManyCmd, result *interface{}) error

+ func (m *MongoProxy) UpdateOne(payload UpdateOneCmd, result *interface{}) error

+ type ReplaceOneCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.ReplaceOptions

+ Replace interface{}

+ type UpdateManyCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.UpdateOptions

+ Update interface{}

+ type UpdateOneCmd struct

+ Collection string

+ Database string

+ Filter interface{}

+ Opts []*options.UpdateOptions

+ Update interface{}