mongo_driver

package module

v1.10.1 Latest Latest Go to latest Published: Jun 11, 2021 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

func CreateIndex(c *mongo.Collection, opts ...*IndexOption) error

func CursorList(c *mongo.Collection, opt *ListOption) (cursor *mongo.Cursor, err error)

func List(c *mongo.Collection, opt *ListOption, results interface{}) error

func RemoveIndex(c *mongo.Collection, indexNames ...string) error

func RemoveIndexByOption(c *mongo.Collection, opts ...*IndexOption) error

type IndexOption struct {
	Name   string
	Keys   map[string]interface{}
	Unique bool
}

type ListOption struct {
	Filter     interface{}
	Sorter     interface{}
	Projection interface{}
	Limit      int64
	Skip       int64
}

type MongoDriver struct {
	// contains filtered or unexported fields
}

func NewMongoDriver(opts MongoDriverOptions) (*MongoDriver, error)

func (d *MongoDriver) DeleteFile(gridfsBucketName, fileID string) error

func (d *MongoDriver) DownloadFile(gridfsBucketName, fileID string) (fileInfo *gridfs.File, fileContent []byte, err error)

func (d *MongoDriver) GetCollection(name string) *mongo.Collection

func (d *MongoDriver) GetFileDownloadStream(gridfsBucketName, fileID string) (stream *gridfs.DownloadStream, err error)

func (d *MongoDriver) GetGridfsBucket(name string) (bucket *gridfs.Bucket, err error)

func (d *MongoDriver) UploadFile(gridfsBucketName, fileID, fileName string, fileContent []byte) error

type MongoDriverOptions struct {
	Database   string
	Host       string
	Port       int
	Username   string
	Password   string
	AuthSource string
}