odm

Documentation

Index

• func GetClient() *mongo.Client
• type AbstractRepository
  • func (r *AbstractRepository) Find(filters bson.M, sort bson.D, limit, skip int64) chan Result
  • func (r *AbstractRepository) FindOne(filters bson.M) chan Result
  • func (r *AbstractRepository) FindOneById(id string) chan Result
  • func (r *AbstractRepository) GetModel(proto interface{}) interface{}
  • func (r *AbstractRepository) IsExistsById(id string) bool
  • func (r *AbstractRepository) Save(model DbModel) chan error
• type DbModel
• type Result

Functions

func GetClient

func GetClient() *mongo.Client

Types

type AbstractRepository

type AbstractRepository struct {
	Database       string
	CollectionName string
	Model          reflect.Type
}

func (*AbstractRepository) Find

func (r *AbstractRepository) Find(filters bson.M, sort bson.D, limit, skip int64) chan Result

func (*AbstractRepository) FindOne

func (r *AbstractRepository) FindOne(filters bson.M) chan Result

Finds one object based on filters.

func (*AbstractRepository) FindOneById

func (r *AbstractRepository) FindOneById(id string) chan Result

Finds one object based on Id.

func (*AbstractRepository) GetModel

func (r *AbstractRepository) GetModel(proto interface{}) interface{}

Gets an instance of model from proto or othe object.

func (*AbstractRepository) IsExistsById

func (r *AbstractRepository) IsExistsById(id string) bool

checks if a record exists by id. Synchronous becuase it is expected to be very light-weighted without deserialization etc.

func (*AbstractRepository) Save

func (r *AbstractRepository) Save(model DbModel) chan error

type DbModel

type DbModel interface {
	Id() string
}

type Result

type Result struct {
	Value interface{}
	Err   error
}