Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mongodb

package

Go to main page

Versions in this module

v0

v0.0.6

Jul 9, 2024

v0.0.5

Dec 30, 2022

v0.0.4

Dec 6, 2022

v0.0.3

Nov 21, 2022

v0.0.2

Nov 19, 2022

v0.0.1

Nov 19, 2022

Changes in this version

+ const AddFields

+ const Asc

+ const Contains

+ const Count

+ const Custom

+ const Desc

+ const EndsWith

+ const Equal

+ const FilterOperation

+ const GreaterOrEqualThan

+ const GreaterThan

+ const Limit

+ const Lookup

+ const LowerOrEqualThan

+ const LowerThan

+ const Match

+ const MatchField

+ const NotEqual

+ const Page

+ const Project

+ const ProjectField

+ const RegEx

+ const SetOnInsertOperation

+ const SetOperation

+ const Skip

+ const Sort

+ const SortAfter

+ const SortAfterField

+ const SortField

+ const StartsWith

+ const UnsetOperation

+ const Unwind

+ var ErrInvalidDestination = errors.New("destination must be a pointer type")

+ var ErrInvalidInput = errors.New("odata syntax error")

+ var ErrNoElements = errors.New("no elements to process")

+ func ApplyFilter(node *parser.ParseNode) (bson.M, error)

+ func CreateUpdateModel(value interface{})

+ type BuilderOptions int

+ const UpsertBuildOption

+ type DeleteOneBuilder struct

+ Filters []builderElement

+ LiteralFilter string

+ func NewDeleteOneBuilder() *DeleteOneBuilder

+ func (c *DeleteOneBuilder) Build() (*MongoDeleteOneModel, error)

+ func (c *DeleteOneBuilder) Filter(query string) *DeleteOneBuilder

+ func (c *DeleteOneBuilder) FilterBy(key string, operation filterOperation, value interface{}) *DeleteOneBuilder

+ type FilterParser struct

+ func NewFilterParser(filter string) *FilterParser

+ func (filterParser *FilterParser) Parse() (interface{}, error)

+ type MongoClient interface

+ Connect func() error

+ Database func(string) MongoDatabaseClient

+ StartSession func() (mongoSession, error)

+ type MongoCollectionClient interface

+ Find func(context.Context, interface{}) (mongoCursor, error)

+ FindOne func(context.Context, interface{}) mongoSingleResult

+ InsertOne func(context.Context, interface{}) (interface{}, error)

+ type MongoDBService struct

+ ConnectionString string

+ GlobalDatabaseName string

+ TenantDatabaseName string

+ func Get() *MongoDBService

+ func Init() *MongoDBService

+ func New() *MongoDBService

+ func NewWithOptions(options MongoDBServiceOptions) *MongoDBService

+ func (service *MongoDBService) GetTenant() string

+ func (service *MongoDBService) GlobalDatabase() *MongoFactory

+ func (service *MongoDBService) TenantDatabase() *MongoFactory

+ func (service *MongoDBService) WithDatabase(databaseName string) *MongoDBService

+ type MongoDBServiceOptions struct

+ ConnectionString string

+ GlobalDatabaseName string

+ type MongoDatabaseClient interface

+ Collection func(name string)

+ type MongoDatabaseContext struct

+ ConnectionString string

+ CurrentCollection string

+ CurrentDatabaseName string

+ type MongoDefaultRepository struct

+ Collection *mongoCollection

+ Database *mongoDatabase

+ func (r *MongoDefaultRepository) DeleteMany(filter interface{}) (*mongoDeleteResult, error)

+ func (r *MongoDefaultRepository) DeleteOne(model *MongoDeleteOneModel) (*mongoDeleteResult, error)

+ func (r *MongoDefaultRepository) FindBy(filter string) (*mongoCursor, error)

+ func (r *MongoDefaultRepository) FindFieldBy(fieldName string, operation filterOperation, value interface{}) (*mongoCursor, error)

+ func (r *MongoDefaultRepository) FindOne(filter interface{}) *mongoSingleResult

+ func (r *MongoDefaultRepository) InsertMany(elements ...interface{}) (*mongoInsertManyResult, error)

+ func (r *MongoDefaultRepository) InsertOne(element interface{}) (*mongoInsertOneResult, error)

+ func (r *MongoDefaultRepository) UpdateMany(models ...*MongoUpdateOneModel) (*mongoBulkWriteResult, error)

+ func (r *MongoDefaultRepository) UpdateOne(model *MongoUpdateOneModel) (*mongoUpdateResult, error)

+ func (r *MongoDefaultRepository) UpsertMany(models ...*MongoUpdateOneModel) (*mongoBulkWriteResult, error)

+ func (r *MongoDefaultRepository) UpsertOne(model *MongoUpdateOneModel) (*mongoUpdateResult, error)

+ func (repository *MongoDefaultRepository) Find(filter interface{}) (*mongoCursor, error)

+ func (repository *MongoDefaultRepository) OData() *ODataParser

+ func (repository *MongoDefaultRepository) Pipeline() *PipelineBuilder

+ type MongoDeleteOneModel struct

+ Filter interface{}

+ Hint interface{}

+ func (model MongoDeleteOneModel) String() string

+ type MongoFactory struct

+ Client *mongoClient

+ Context *execution_context.Context

+ Database *mongoDatabase

+ DatabaseContext *MongoDatabaseContext

+ Logger *log.Logger

+ func NewFactory(connectionString string) *MongoFactory

+ func (f *MongoFactory) GetClient() *mongoClient

+ func (f *MongoFactory) GetCollection(collectionName string) *mongoCollection

+ func (f *MongoFactory) GetDatabase(databaseName string) *mongoDatabase

+ func (f *MongoFactory) StartSession() (mongo.Session, error)

+ func (f *MongoFactory) WithDatabase(databaseName string) *MongoFactory

+ func (mongoFactory *MongoFactory) NewDatabaseRepository(database string, collection string) MongoRepository

+ func (mongoFactory *MongoFactory) NewRepository(collection string) MongoRepository

+ type MongoRepository interface

+ DeleteMany func(filter interface{}) (*mongoDeleteResult, error)

+ DeleteOne func(model *MongoDeleteOneModel) (*mongoDeleteResult, error)

+ Find func(filter interface{}) (*mongoCursor, error)

+ FindBy func(filter string) (*mongoCursor, error)

+ FindFieldBy func(fieldName string, operation filterOperation, value interface{}) (*mongoCursor, error)

+ FindOne func(filter interface{}) *mongoSingleResult

+ InsertMany func(elements ...interface{}) (*mongoInsertManyResult, error)

+ InsertOne func(element interface{}) (*mongoInsertOneResult, error)

+ OData func() *ODataParser

+ Pipeline func() *PipelineBuilder

+ UpdateMany func(models ...*MongoUpdateOneModel) (*mongoBulkWriteResult, error)

+ UpdateOne func(model *MongoUpdateOneModel) (*mongoUpdateResult, error)

+ UpsertMany func(models ...*MongoUpdateOneModel) (*mongoBulkWriteResult, error)

+ UpsertOne func(model *MongoUpdateOneModel) (*mongoUpdateResult, error)

+ type MongoUpdateOneModel struct

+ Filter interface{}

+ Hint interface{}

+ Update interface{}

+ func (model MongoUpdateOneModel) String() string

+ type ODataParser struct

+ Collection *mongoCollection

+ func EmptyODataParser(collection *mongoCollection) *ODataParser

+ func (odataParser *ODataParser) Decode(query url.Values, destination interface{}) error

+ func (odataParser *ODataParser) GetODataResponse(query url.Values) (*models.ODataResponse, error)

+ func (odataParser *ODataParser) Query(query url.Values) (*mongoCursor, error)

+ type Pipeline struct

+ type PipelineBuilder struct

+ func NewEmptyPipeline(collection *mongoCollection) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Add(pipeline bson.D) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) AddField(field string, value interface{}) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Aggregate() (*mongoCursor, error)

+ func (pipelineBuilder *PipelineBuilder) Count() *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) CountCollection() int

+ func (pipelineBuilder *PipelineBuilder) CountPipeline() int

+ func (pipelineBuilder *PipelineBuilder) Filter(filter string) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) FilterBy(field string, operation filterOperation, value interface{}) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) FilterByUserPipelines() *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Limit(limit int) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Lookup(from string, localField string, foreignField string, fieldAs string) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Match(value interface{}) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Page(page int, pageSize int) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Project(fields interface{}) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) ProjectField(field string) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) ProjectFieldAs(field string, projectedAs string) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Skip(skip int) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Sort(fields interface{}) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) SortAtEnd(fields interface{}) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) SortBy(field string, order mongoSort) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) SortByAtEnd(field string, order mongoSort) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) Unwind(path string) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) UnwindWidthIndex(path string, includeArrayIndex string, preserveNullAndEmptyArrays bool) *PipelineBuilder

+ func (pipelineBuilder *PipelineBuilder) WithOptions(options PipelineOptions) *PipelineBuilder

+ type PipelineOptions struct

+ IncludeAddFields bool

+ IncludeCount bool

+ IncludeLimit bool

+ IncludeMatch bool

+ IncludeProjection bool

+ IncludeSkip bool

+ IncludeSort bool

+ IncludeUnwind bool

+ IncludeUser bool

+ type UpdateOneModelBuilder struct

+ Elements []builderElement

+ LiteralFilter string

+ func NewUpdateOneModelBuilder() *UpdateOneModelBuilder

+ func (c *UpdateOneModelBuilder) Build(options ...BuilderOptions) (*MongoUpdateOneModel, error)

+ func (c *UpdateOneModelBuilder) Encode(element interface{}, ignoredFields ...string) *UpdateOneModelBuilder

+ func (c *UpdateOneModelBuilder) Filter(query string) *UpdateOneModelBuilder

+ func (c *UpdateOneModelBuilder) FilterBy(key string, operation filterOperation, value interface{}) *UpdateOneModelBuilder

+ func (c *UpdateOneModelBuilder) Set(field string, value interface{}) *UpdateOneModelBuilder

+ func (c *UpdateOneModelBuilder) SetOnInsert(field string, value interface{}) *UpdateOneModelBuilder

+ func (c *UpdateOneModelBuilder) Unset(field string) *UpdateOneModelBuilder