utilMongodb

Documentation

Index

• func MongodbHasIndexes(indexView mongo.IndexView) (found bool)
• type MongodbClient
  • func NewMongodbClient(conf *MongodbClientConf) (client *MongodbClient, err error)
  • func (mc *MongodbClient) CollectionAggregate(collectionName string, group bson.D, filter interface{}, sort interface{}, ...) error
  • func (mc *MongodbClient) CollectionCreateIndexes(collectionName string, indexModels []mongo.IndexModel) (err error)
  • func (mc *MongodbClient) CollectionDelete(collectionName string, filter interface{}) (count int64, err error)
  • func (mc *MongodbClient) CollectionFind(collectionName string, filter interface{}, sort interface{}, ...) (err error)
  • func (mc *MongodbClient) CollectionInsertMany(collectionName string, data []interface{}) (ids []string, err error)
  • func (mc *MongodbClient) CollectionInsertOne(collectionName string, data interface{}) (id string, err error)
  • func (mc *MongodbClient) CollectionSelect(collectionName string, filter interface{}, sort interface{}, limit int64, ...) (err error)
  • func (mc *MongodbClient) CollectionUpdate(collectionName string, filter interface{}, update interface{}) (count int64, err error)
  • func (mc *MongodbClient) New() (client *MongodbClient, err error)
• type MongodbClientConf

Functions

func MongodbHasIndexes

func MongodbHasIndexes(indexView mongo.IndexView) (found bool)

Types

type MongodbClient

type MongodbClient struct {
	*mongo.Database
	// contains filtered or unexported fields
}

func NewMongodbClient

func NewMongodbClient(conf *MongodbClientConf) (client *MongodbClient, err error)

func (*MongodbClient) CollectionAggregate

func (mc *MongodbClient) CollectionAggregate(collectionName string, group bson.D, filter interface{}, sort interface{}, results interface{}) error

func (*MongodbClient) CollectionCreateIndexes

func (mc *MongodbClient) CollectionCreateIndexes(collectionName string, indexModels []mongo.IndexModel) (err error)

func (*MongodbClient) CollectionDelete

func (mc *MongodbClient) CollectionDelete(collectionName string, filter interface{}) (count int64, err error)

func (*MongodbClient) CollectionFind

func (mc *MongodbClient) CollectionFind(collectionName string, filter interface{}, sort interface{}, result interface{}) (err error)

func (*MongodbClient) CollectionInsertMany

func (mc *MongodbClient) CollectionInsertMany(collectionName string, data []interface{}) (ids []string, err error)

func (*MongodbClient) CollectionInsertOne

func (mc *MongodbClient) CollectionInsertOne(collectionName string, data interface{}) (id string, err error)

func (*MongodbClient) CollectionSelect

func (mc *MongodbClient) CollectionSelect(collectionName string, filter interface{}, sort interface{}, limit int64, offset int64, results interface{}, total *int64) (err error)

func (*MongodbClient) CollectionUpdate

func (mc *MongodbClient) CollectionUpdate(collectionName string, filter interface{}, update interface{}) (count int64, err error)

func (*MongodbClient) New

func (mc *MongodbClient) New() (client *MongodbClient, err error)

type MongodbClientConf

type MongodbClientConf struct {
	Host          string
	DbName        string
	User          string
	Password      string
	LoggerOptions *options.LoggerOptions
}