Documentation
¶
Index ¶
- type MongoStorage
- func (s *MongoStorage) Aggregate(collection string, query interface{}, result interface{}) error
- func (s *MongoStorage) Close() error
- func (s *MongoStorage) Count(collection string, query interface{}) (int, error)
- func (s *MongoStorage) Create(collection string, object interface{}) error
- func (s *MongoStorage) CreateMany(collection string, query []interface{}) error
- func (s *MongoStorage) Delete(collection string, query interface{}) error
- func (s *MongoStorage) DeleteMany(collection string, query interface{}) error
- func (s *MongoStorage) EnsureIndex(collection string, index mgo.Index) error
- func (s *MongoStorage) Find(collection string, query interface{}, result interface{}, ...) error
- func (s *MongoStorage) FindOne(collection string, query interface{}, result interface{}) error
- func (s *MongoStorage) NewPaginationParams() *storer.PaginationParams
- func (s *MongoStorage) Update(collection string, query interface{}, change interface{}) error
- func (s *MongoStorage) UpdateMany(collection string, query interface{}, change interface{}) error
- func (s *MongoStorage) UpdateWithOptions(collection string, query interface{}, change interface{}, options interface{}) error
- type MongoStorageOfficial
- func (s *MongoStorageOfficial) Aggregate(collectionName string, query interface{}, result interface{}) error
- func (s *MongoStorageOfficial) Close() error
- func (s *MongoStorageOfficial) Count(collectionName string, query interface{}) (int, error)
- func (s *MongoStorageOfficial) Create(collectionName string, object interface{}) error
- func (s *MongoStorageOfficial) CreateMany(collectionName string, objects []interface{}) error
- func (s *MongoStorageOfficial) Delete(collectionName string, query interface{}) error
- func (s *MongoStorageOfficial) DeleteMany(collectionName string, query interface{}) error
- func (s *MongoStorageOfficial) Find(collectionName string, query interface{}, result interface{}, ...) error
- func (s *MongoStorageOfficial) FindOne(collectionName string, query interface{}, result interface{}) error
- func (s *MongoStorageOfficial) NewPaginationParams() *storer.PaginationParams
- func (s *MongoStorageOfficial) Update(collectionName string, query interface{}, change interface{}) error
- func (s *MongoStorageOfficial) UpdateMany(collectionName string, query interface{}, change interface{}) error
- func (s *MongoStorageOfficial) UpdateWithOptions(collection string, query interface{}, change interface{}, options interface{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MongoStorage ¶
type MongoStorage struct {
DefaultPaginationParams *storer.PaginationParams
// contains filtered or unexported fields
}
MongoStorage holds session and dial info of MongoDB connection
func NewMongoStorage ¶
func NewMongoStorage(uri string) (*MongoStorage, error)
NewMongoStorage returns a new MongoStorage with an active session
func (*MongoStorage) Aggregate ¶
func (s *MongoStorage) Aggregate(collection string, query interface{}, result interface{}) error
Aggregate aggregate object(s) directly from dbms
func (*MongoStorage) Count ¶
func (s *MongoStorage) Count(collection string, query interface{}) (int, error)
Count retrieves object count directly from dbms
func (*MongoStorage) Create ¶
func (s *MongoStorage) Create(collection string, object interface{}) error
Create inserts given object to store
func (*MongoStorage) CreateMany ¶
func (s *MongoStorage) CreateMany(collection string, query []interface{}) error
func (*MongoStorage) Delete ¶
func (s *MongoStorage) Delete(collection string, query interface{}) error
Delete remove object with given id from store
func (*MongoStorage) DeleteMany ¶
func (s *MongoStorage) DeleteMany(collection string, query interface{}) error
func (*MongoStorage) EnsureIndex ¶
func (s *MongoStorage) EnsureIndex(collection string, index mgo.Index) error
EnsureIndex is set index to mongodb
func (*MongoStorage) Find ¶
func (s *MongoStorage) Find(collection string, query interface{}, result interface{}, pagination *storer.PaginationParams) error
Find returns all matching documents with query and pagination params
func (*MongoStorage) FindOne ¶
func (s *MongoStorage) FindOne(collection string, query interface{}, result interface{}) error
FindOne returns matching document
func (*MongoStorage) NewPaginationParams ¶
func (s *MongoStorage) NewPaginationParams() *storer.PaginationParams
NewPaginationParams returns default pagination params
func (*MongoStorage) Update ¶
func (s *MongoStorage) Update(collection string, query interface{}, change interface{}) error
Update updates record with given object
func (*MongoStorage) UpdateMany ¶
func (s *MongoStorage) UpdateMany(collection string, query interface{}, change interface{}) error
func (*MongoStorage) UpdateWithOptions ¶
func (s *MongoStorage) UpdateWithOptions(collection string, query interface{}, change interface{}, options interface{}) error
UpdateWithOptions updates record with given object
type MongoStorageOfficial ¶
type MongoStorageOfficial struct {
DefaultPaginationParams *storer.PaginationParams
// contains filtered or unexported fields
}
MongoStorage holds session and dial info of MongoDB connection
func NewMongoStorageOfficial ¶
func NewMongoStorageOfficial(uri string, newRelicApp *newrelic.Application) (*MongoStorageOfficial, error)
NewMongoStorage returns a new MongoStorage with an active session
func (*MongoStorageOfficial) Aggregate ¶
func (s *MongoStorageOfficial) Aggregate(collectionName string, query interface{}, result interface{}) error
Aggregate aggregate object(s) directly from dbms
func (*MongoStorageOfficial) Count ¶
func (s *MongoStorageOfficial) Count(collectionName string, query interface{}) (int, error)
Count retrieves object count directly from dbms
func (*MongoStorageOfficial) Create ¶
func (s *MongoStorageOfficial) Create(collectionName string, object interface{}) error
Create inserts given object to store
func (*MongoStorageOfficial) CreateMany ¶
func (s *MongoStorageOfficial) CreateMany(collectionName string, objects []interface{}) error
Create inserts given list of object to store
func (*MongoStorageOfficial) Delete ¶
func (s *MongoStorageOfficial) Delete(collectionName string, query interface{}) error
Delete remove object with given id from store
func (*MongoStorageOfficial) DeleteMany ¶
func (s *MongoStorageOfficial) DeleteMany(collectionName string, query interface{}) error
Delete remove object with given list of ids from store
func (*MongoStorageOfficial) Find ¶
func (s *MongoStorageOfficial) Find(collectionName string, query interface{}, result interface{}, pagination *storer.PaginationParams) error
Find returns all matching documents with query and pagination params
func (*MongoStorageOfficial) FindOne ¶
func (s *MongoStorageOfficial) FindOne(collectionName string, query interface{}, result interface{}) error
FindOne returns matching document
func (*MongoStorageOfficial) NewPaginationParams ¶
func (s *MongoStorageOfficial) NewPaginationParams() *storer.PaginationParams
NewPaginationParams returns default pagination params
func (*MongoStorageOfficial) Update ¶
func (s *MongoStorageOfficial) Update(collectionName string, query interface{}, change interface{}) error
Update updates record with given object
func (*MongoStorageOfficial) UpdateMany ¶
func (s *MongoStorageOfficial) UpdateMany(collectionName string, query interface{}, change interface{}) error
Update updates record with given lis of object object
func (*MongoStorageOfficial) UpdateWithOptions ¶
func (s *MongoStorageOfficial) UpdateWithOptions(collection string, query interface{}, change interface{}, options interface{}) error
UpdateWithOptions updates record with given object - not implemented because of official mongo driver has not method like this
Source Files
Click to show internal directories.
Click to hide internal directories.