mongodb

Documentation

Index

• func NewDataRepositoryMongo(client MongoDatabase) d.Repository
• type DataRepositoryMongo
  • func (m *DataRepositoryMongo) BulkUpdateOne(collectionName string, bulkData []d.BulkUpdateOne) <-chan d.RepositoryResult
  • func (m *DataRepositoryMongo) CreateIndex(collectionName string, indexes map[string]interface{}) <-chan error
  • func (m *DataRepositoryMongo) Delete(collectionName string, filter interface{}, justOne bool) <-chan d.RepositoryResult
  • func (m *DataRepositoryMongo) Find(collectionName string, filter interface{}, limit int64, skip int64, ...) <-chan d.QueryResult
  • func (m *DataRepositoryMongo) FindOne(collectionName string, filter interface{}) <-chan d.QuerySingleResult
  • func (m *DataRepositoryMongo) Save(collectionName string, data interface{}) <-chan d.RepositoryResult
  • func (m *DataRepositoryMongo) SaveMany(collectionName string, data []interface{}) <-chan d.RepositoryResult
  • func (m *DataRepositoryMongo) Update(collectionName string, filter interface{}, data interface{}, ...) <-chan d.RepositoryResult
  • func (m *DataRepositoryMongo) UpdateMany(collectionName string, filter interface{}, data interface{}, ...) <-chan d.RepositoryResult
• type DataResult
  • func (sr *DataResult) Close()
  • func (sr *DataResult) Decode(v interface{}) error
  • func (sr *DataResult) Error() error
  • func (sr *DataResult) Next() bool
• type DataSingleResult
  • func (sr *DataSingleResult) Decode(v interface{}) error
  • func (sr *DataSingleResult) Error() error
  • func (sr *DataSingleResult) NoResult() bool
• type MongoClient
  • func (c *MongoClient) Close() error
  • func (c *MongoClient) GetCollection(collectionName string) (*mongo.Collection, error)
  • func (c *MongoClient) GetContext() (context.Context, error)
  • func (c *MongoClient) GetDb() (*mongo.Database, error)
  • func (c *MongoClient) Ping() error
• type MongoDatabase
  • func NewMongoClient(ctx context.Context, mongoDBHost string, database string) (MongoDatabase, error)

Functions

func NewDataRepositoryMongo

func NewDataRepositoryMongo(client MongoDatabase) d.Repository

NewDataRepositoryMongo create new data repository for mongodb.

Types

type DataRepositoryMongo

type DataRepositoryMongo struct {
	Client MongoDatabase
}

func (*DataRepositoryMongo) BulkUpdateOne

func (m *DataRepositoryMongo) BulkUpdateOne(collectionName string, bulkData []d.BulkUpdateOne) <-chan d.RepositoryResult

UpdateMany bulk update one object.

func (*DataRepositoryMongo) CreateIndex

func (m *DataRepositoryMongo) CreateIndex(collectionName string, indexes map[string]interface{}) <-chan error

CreateIndex creates multiple indexes in the collection specified by the indexes.

func (*DataRepositoryMongo) Delete

func (m *DataRepositoryMongo) Delete(collectionName string, filter interface{}, justOne bool) <-chan d.RepositoryResult

Delete get object list

func (*DataRepositoryMongo) Find

func (m *DataRepositoryMongo) Find(collectionName string, filter interface{}, limit int64, skip int64, sort map[string]int) <-chan d.QueryResult

Find get list of object.

func (*DataRepositoryMongo) FindOne

func (m *DataRepositoryMongo) FindOne(collectionName string, filter interface{}) <-chan d.QuerySingleResult

FindOne get object list

func (*DataRepositoryMongo) Save

func (m *DataRepositoryMongo) Save(collectionName string, data interface{}) <-chan d.RepositoryResult

Save storing the data object.

func (*DataRepositoryMongo) SaveMany

func (m *DataRepositoryMongo) SaveMany(collectionName string, data []interface{}) <-chan d.RepositoryResult

Save storing a list of objects.

func (*DataRepositoryMongo) Update

func (m *DataRepositoryMongo) Update(collectionName string, filter interface{}, data interface{}, opts ...*d.UpdateOptions) <-chan d.RepositoryResult

Update update object.

func (*DataRepositoryMongo) UpdateMany

func (m *DataRepositoryMongo) UpdateMany(collectionName string, filter interface{}, data interface{}, opts ...*d.UpdateOptions) <-chan d.RepositoryResult

Update update many objects.

type DataResult

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

func (*DataResult) Close

func (sr *DataResult) Close()

Close close cursor

func (*DataResult) Decode

func (sr *DataResult) Decode(v interface{}) error

Decode multi data result decoding

func (*DataResult) Error

func (sr *DataResult) Error() error

Error data result error

func (*DataResult) Next

func (sr *DataResult) Next() bool

Next data result iterator

type DataSingleResult

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

func (*DataSingleResult) Decode

func (sr *DataSingleResult) Decode(v interface{}) error

Decode single data result decoding

func (*DataSingleResult) Error

func (sr *DataSingleResult) Error() error

Error single data result error

func (*DataSingleResult) NoResult

func (sr *DataSingleResult) NoResult() bool

Decode single data result decoding

type MongoClient

type MongoClient struct {
	Context context.Context
}

Struct used for maintaining HTTP Request Context

func (*MongoClient) Close

func (c *MongoClient) Close() error

Close Client

func (*MongoClient) GetCollection

func (c *MongoClient) GetCollection(collectionName string) (*mongo.Collection, error)

GetCollection gets database collection

func (*MongoClient) GetContext

func (c *MongoClient) GetContext() (context.Context, error)

GetContext get mongodb context

func (*MongoClient) GetDb

func (c *MongoClient) GetDb() (*mongo.Database, error)

Create database session

func (*MongoClient) Ping

func (c *MongoClient) Ping() error

Ping database

type MongoDatabase

type MongoDatabase interface {
	GetCollection(collectionName string) (*mongo.Collection, error)
	GetDb() (*mongo.Database, error)
	Close() error
	GetContext() (context.Context, error)
	Ping() error
}

func NewMongoClient

func NewMongoClient(ctx context.Context, mongoDBHost string, database string) (MongoDatabase, error)

Create a new mogodb client object