repository

Documentation

Index

• type QueryBuilder
  • func (qb QueryBuilder) Equals(property string, value interface{}) interface{}
  • func (qb QueryBuilder) EqualsHexID(value string) interface{}
  • func (qb QueryBuilder) EqualsID(value primitive.ObjectID) interface{}
  • func (qb QueryBuilder) Limit(value int) interface{}
  • func (qb QueryBuilder) Match(value map[string]interface{}) interface{}
  • func (qb QueryBuilder) MatchSingle(property string, value interface{}) interface{}
  • func (qb QueryBuilder) Pipeline(args ...interface{}) interface{}
  • func (qb QueryBuilder) Skip(value int) interface{}
  • func (qb QueryBuilder) Sort(value map[string]int) interface{}
  • func (qb QueryBuilder) SortSingle(property string, value int) interface{}
• type QueryBuilderOptions
• type RepositoryBase
  • func NewRepositoryBase(collectionName string) RepositoryBase
  • func (base RepositoryBase) Aggregate(pipeline interface{}, obj interface{}) error
  • func (base RepositoryBase) Count(query interface{}) (int64, error)
  • func (base RepositoryBase) DeleteOne(id primitive.ObjectID) error
  • func (base RepositoryBase) Find(query interface{}, obj interface{}) error
  • func (base RepositoryBase) InsertOne(value interface{}) (primitive.ObjectID, error)
  • func (base RepositoryBase) ReplaceOne(query interface{}, obj interface{}) (err error)
  • func (base RepositoryBase) UpdateOne(query interface{}, update interface{}, obj interface{}) error

Types

type QueryBuilder

type QueryBuilder struct {
	Options QueryBuilderOptions
}

func (QueryBuilder) Equals

func (qb QueryBuilder) Equals(property string, value interface{}) interface{}

func (QueryBuilder) EqualsHexID

func (qb QueryBuilder) EqualsHexID(value string) interface{}

func (QueryBuilder) EqualsID

func (qb QueryBuilder) EqualsID(value primitive.ObjectID) interface{}

func (QueryBuilder) Limit

func (qb QueryBuilder) Limit(value int) interface{}

func (QueryBuilder) Match

func (qb QueryBuilder) Match(value map[string]interface{}) interface{}

func (QueryBuilder) MatchSingle

func (qb QueryBuilder) MatchSingle(property string, value interface{}) interface{}

func (QueryBuilder) Pipeline

func (qb QueryBuilder) Pipeline(args ...interface{}) interface{}

func (QueryBuilder) Skip

func (qb QueryBuilder) Skip(value int) interface{}

func (QueryBuilder) Sort

func (qb QueryBuilder) Sort(value map[string]int) interface{}

func (QueryBuilder) SortSingle

func (qb QueryBuilder) SortSingle(property string, value int) interface{}

type QueryBuilderOptions

type QueryBuilderOptions struct {
	KeyProperty string
}

type RepositoryBase

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

func NewRepositoryBase

func NewRepositoryBase(collectionName string) RepositoryBase

NewRepositoryBase creates a new service base

func (RepositoryBase) Aggregate

func (base RepositoryBase) Aggregate(pipeline interface{}, obj interface{}) error

Aggregate executes a aggregated command in the database

func (RepositoryBase) Count

func (base RepositoryBase) Count(query interface{}) (int64, error)

Count returns a count of all documents in repository

func (RepositoryBase) DeleteOne

func (base RepositoryBase) DeleteOne(id primitive.ObjectID) error

DeleteOne removes an elemento from database

func (RepositoryBase) Find

func (base RepositoryBase) Find(query interface{}, obj interface{}) error

query retrieves documents by query or all

func (RepositoryBase) InsertOne

func (base RepositoryBase) InsertOne(value interface{}) (primitive.ObjectID, error)

InsertOne : inserts a new object in repository

func (RepositoryBase) ReplaceOne

func (base RepositoryBase) ReplaceOne(query interface{}, obj interface{}) (err error)

ReplaceOne replace an entire document

func (RepositoryBase) UpdateOne

func (base RepositoryBase) UpdateOne(query interface{}, update interface{}, obj interface{}) error

UpdateOne : updates an document