db

Documentation

Index

• type DatabaseRecord
• type DatabaseRecorder
  • func (r *DatabaseRecorder) Record(record DatabaseRecord)
• type RecordingDatabase
  • func (d *RecordingDatabase) DeleteOne(coll database.Collection, filter bson.M) error
  • func (d *RecordingDatabase) DeleteOneById(coll database.Collection, id string) error
  • func (d *RecordingDatabase) EnsureIndex(coll database.Collection, model mongo.IndexModel) error
  • func (d *RecordingDatabase) FindMany(coll database.Collection, filter bson.M, ...) error
  • func (d *RecordingDatabase) FindManyWithOptions(coll database.Collection, filter bson.M, ...) error
  • func (d *RecordingDatabase) FindOne(coll database.Collection, filter interface{}, res interface{}) error
  • func (d *RecordingDatabase) FindOneById(coll database.Collection, id string, res interface{}) error
  • func (d *RecordingDatabase) FindOneSorted(coll database.Collection, filter bson.M, sort bson.M, res interface{}) error
  • func (d *RecordingDatabase) InsertOne(coll database.Collection, existsFilter interface{}, data interface{}) error
  • func (d *RecordingDatabase) ListPaginated(coll database.Collection, perPage int, page int, p *sdk.Pagination, ...) error
  • func (d *RecordingDatabase) UpdateMany(coll database.Collection, filters map[string]interface{}, ...) error
  • func (d *RecordingDatabase) UpdateOne(coll database.Collection, filter bson.M, createIfMissing bool, ...) error
  • func (d *RecordingDatabase) UpdateOneById(coll database.Collection, id string, createIfMissing bool, update interface{}, ...) error
  • func (d *RecordingDatabase) UpdateProvided(coll database.Collection, provider string, updates map[string]interface{}) error

Types

type DatabaseRecord

type DatabaseRecord struct {
	Collection      database.Collection
	Filter          interface{}
	Id              string
	Sort            interface{}
	Limit           int
	PerPage         int
	Page            int
	Provider        string
	Updates         map[string]interface{}
	Filters         map[string]interface{}
	CreateIfMissing bool
	Update          interface{}
	Data            interface{}
}

type DatabaseRecorder

type DatabaseRecorder struct {
	Records []DatabaseRecord
}

func (*DatabaseRecorder) Record

func (r *DatabaseRecorder) Record(record DatabaseRecord)

type RecordingDatabase

type RecordingDatabase struct {
	Recorder         *DatabaseRecorder
	Return           func(target interface{})
	ReturnEach       func(each func(decodable database.Decodable) error)
	ReturnPagination func(pagination *sdk.Pagination)
	Err              error
}

func (*RecordingDatabase) DeleteOne

func (d *RecordingDatabase) DeleteOne(coll database.Collection, filter bson.M) error

func (*RecordingDatabase) DeleteOneById

func (d *RecordingDatabase) DeleteOneById(coll database.Collection, id string) error

func (*RecordingDatabase) EnsureIndex

func (d *RecordingDatabase) EnsureIndex(coll database.Collection, model mongo.IndexModel) error

func (*RecordingDatabase) FindMany

func (d *RecordingDatabase) FindMany(coll database.Collection, filter bson.M, each func(dec database.Decodable) error) error

func (*RecordingDatabase) FindManyWithOptions

func (d *RecordingDatabase) FindManyWithOptions(coll database.Collection, filter bson.M, each func(dec database.Decodable) error, sort bson.M, limit int) error

func (*RecordingDatabase) FindOne

func (d *RecordingDatabase) FindOne(coll database.Collection, filter interface{}, res interface{}) error

func (*RecordingDatabase) FindOneById

func (d *RecordingDatabase) FindOneById(coll database.Collection, id string, res interface{}) error

func (*RecordingDatabase) FindOneSorted

func (d *RecordingDatabase) FindOneSorted(coll database.Collection, filter bson.M, sort bson.M, res interface{}) error

func (*RecordingDatabase) InsertOne

func (d *RecordingDatabase) InsertOne(coll database.Collection, existsFilter interface{}, data interface{}) error

func (*RecordingDatabase) ListPaginated

func (d *RecordingDatabase) ListPaginated(coll database.Collection, perPage int, page int, p *sdk.Pagination, each func(dec database.Decodable) error) error

func (*RecordingDatabase) UpdateMany

func (d *RecordingDatabase) UpdateMany(coll database.Collection, filters map[string]interface{}, updates map[string]interface{}) error

func (*RecordingDatabase) UpdateOne

func (d *RecordingDatabase) UpdateOne(coll database.Collection, filter bson.M, createIfMissing bool, update interface{}, res interface{}) error

func (*RecordingDatabase) UpdateOneById

func (d *RecordingDatabase) UpdateOneById(coll database.Collection, id string, createIfMissing bool, update interface{}, res interface{}) error

func (*RecordingDatabase) UpdateProvided

func (d *RecordingDatabase) UpdateProvided(coll database.Collection, provider string, updates map[string]interface{}) error