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

pie

package module

Go to main page

Versions in this module

v0

v0.1.14

Jan 25, 2024

Changes in this version

+ var ErrUnsupportedType = errors.New("Unsupported type")

+ type Aggregate interface

+ All func(result interface{}, ctx ...context.Context) error

+ Collection func(doc interface{}) Aggregate

+ Match func(c Condition) Aggregate

+ One func(result interface{}, ctx ...context.Context) error

+ Pipeline func(pipeline bson.A) Aggregate

+ SetAllowDiskUse func(b bool) Aggregate

+ SetBatchSize func(i int32) Aggregate

+ SetBypassDocumentValidation func(b bool) Aggregate

+ SetCollReadPreference func(rp *readpref.ReadPref) Aggregate

+ SetCollRegistry func(r *bsoncodec.Registry) Aggregate

+ SetCollWriteConcern func(wc *writeconcern.WriteConcern) Aggregate

+ SetCollation func(c *options.Collation) Aggregate

+ SetComment func(s string) Aggregate

+ SetDatabase func(db string) Aggregate

+ SetHint func(h interface{}) Aggregate

+ SetMaxAwaitTime func(d time.Duration) Aggregate

+ SetMaxTime func(d time.Duration) Aggregate

+ SetReadConcern func(rc *readconcern.ReadConcern) Aggregate

+ func NewAggregate(engine Client) Aggregate

+ type Client interface

+ AddIndex func(keys interface{}, opt ...*options.IndexOptions) Indexes

+ Aggregate func() Aggregate

+ And func(filter Condition) Session

+ Asc func(colNames ...string) Session

+ BulkWrite func(docs interface{}, ctx ...context.Context) (*mongo.BulkWriteResult, error)

+ Collection func(name string, collOpts []*options.CollectionOptions, db ...string) *mongo.Collection

+ CollectionNameForSlice func(doc interface{}) (*schemas.Collection, error)

+ CollectionNameForStruct func(doc interface{}) (*schemas.Collection, error)

+ Connect func(ctx ...context.Context) (err error)

+ Count func(i interface{}, ctx ...context.Context) (int64, error)

+ DataBase func() *mongo.Database

+ DeleteMany func(filter interface{}, ctx ...context.Context) (*mongo.DeleteResult, error)

+ DeleteOne func(filter interface{}, ctx ...context.Context) (*mongo.DeleteResult, error)

+ Desc func(s1 ...string) Session

+ Disconnect func(ctx ...context.Context) error

+ Distinct func(doc interface{}, columns string, ctx ...context.Context) ([]interface{}, error)

+ DropAll func(doc interface{}, ctx ...context.Context) error

+ DropOne func(doc interface{}, name string, ctx ...context.Context) error

+ Eq func(key string, value interface{}) Session

+ Exists func(key string, exists bool, filter ...Condition) Session

+ Expr func(filter Condition) Session

+ Filter func(key string, value interface{}) Session

+ FilterBson func(d bson.D) Session

+ FilterBy func(object interface{}) Session

+ FindAll func(docs interface{}, ctx ...context.Context) error

+ FindAndDelete func(doc interface{}, ctx ...context.Context) error

+ FindOne func(doc interface{}, ctx ...context.Context) error

+ FindOneAndReplace func(doc interface{}, ctx ...context.Context) error

+ FindOneAndUpdate func(doc interface{}, ctx ...context.Context) (*mongo.SingleResult, error)

+ FindOneAndUpdateBson func(coll interface{}, bson interface{}, ctx ...context.Context) (*mongo.SingleResult, error)

+ FindPagination func(needCount bool, doc interface{}, ctx ...context.Context) (int64, error)

+ Gt func(key string, value interface{}) Session

+ Gte func(key string, value interface{}) Session

+ ID func(id interface{}) Session

+ In func(key string, value interface{}) Session

+ InsertMany func(v interface{}, ctx ...context.Context) (*mongo.InsertManyResult, error)

+ InsertOne func(v interface{}, ctx ...context.Context) (primitive.ObjectID, error)

+ Limit func(limit int64) Session

+ Lt func(key string, value interface{}) Session

+ Lte func(key string, value interface{}) Session

+ Ne func(key string, ne interface{}) Session

+ NewIndexes func() Indexes

+ NewSession func() Session

+ Nin func(key string, nin interface{}) Session

+ Nor func(c Condition) Session

+ Not func(key string, value interface{}) Session

+ Or func(filter Condition) Session

+ Ping func() error

+ Regex func(key string, value string) Session

+ RegexFilter func(key, pattern string) Session

+ ReplaceOne func(doc interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ Skip func(skip int64) Session

+ Soft func(s bool) Session

+ SoftDeleteMany func(filter interface{}, ctx ...context.Context) error

+ SoftDeleteOne func(filter interface{}, ctx ...context.Context) error

+ Transaction func(ctx context.Context, f schemas.TransFunc) error

+ TransactionWithOptions func(ctx context.Context, f schemas.TransFunc, opt ...*options.SessionOptions) error

+ Type func(key string, t interface{}) Session

+ Update func(bean interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ UpdateMany func(bean interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ UpdateManyBson func(coll interface{}, bson interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ UpdateOneBson func(coll interface{}, bson interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ type ClientOptions interface

+ SetArrayFilters func(filters options.ArrayFilters) Session

+ SetBypassDocumentValidation func(b bool) Session

+ SetCollation func(collation *options.Collation) Session

+ SetHint func(hint interface{}) Session

+ SetMaxTime func(d time.Duration) Session

+ SetOrdered func(ordered bool) Session

+ SetProjection func(projection interface{}) Session

+ SetReturnDocument func(rd options.ReturnDocument) Session

+ SetSort func(sort interface{}) Session

+ SetUpsert func(b bool) Session

type Condition

+ Clone func() Condition

+ Err func() error

+ FilterBson func(d interface{}) Condition

+ FilterBy func(object interface{}) Condition

+ type Indexes interface

+ AddIndex func(keys interface{}, opt ...*options.IndexOptions) Indexes

+ Collection func(doc interface{}) Indexes

+ CreateIndexes func(doc interface{}, ctx ...context.Context) ([]string, error)

+ DropAll func(doc interface{}, ctx ...context.Context) error

+ DropOne func(doc interface{}, name string, ctx ...context.Context) error

+ SetCommitQuorumInt func(quorum int32) Indexes

+ SetCommitQuorumMajority func() Indexes

+ SetCommitQuorumString func(quorum string) Indexes

+ SetCommitQuorumVotingMembers func() Indexes

+ SetDatabase func(db string) Indexes

+ SetMaxTime func(d time.Duration) Indexes

+ func NewIndexes(driver Client) Indexes

+ type Options struct

+ UpdateEmpty bool

+ func (o *Options) SetUpdateEmpty(e bool)

+ type Parser struct

+ func NewParser(collectionMapper, columnMapper names.Mapper) *Parser

+ func (parser *Parser) Parse(v reflect.Value) (*schemas.Collection, error)

+ type Session interface

+ And func(c Condition) Session

+ Asc func(colNames ...string) Session

+ BulkWrite func(docs interface{}, ctx ...context.Context) (*mongo.BulkWriteResult, error)

+ Clone func() Session

+ Count func(i interface{}, ctx ...context.Context) (int64, error)

+ DeleteMany func(doc interface{}, ctx ...context.Context) (*mongo.DeleteResult, error)

+ DeleteOne func(doc interface{}, ctx ...context.Context) (*mongo.DeleteResult, error)

+ Desc func(colNames ...string) Session

+ Distinct func(doc interface{}, columns string, ctx ...context.Context) ([]interface{}, error)

+ Eq func(key string, value interface{}) Session

+ Exists func(key string, exists bool, filter ...Condition) Session

+ Expr func(c Condition) Session

+ Filter func(key string, value interface{}) Session

+ FilterBson func(d bson.D) Session

+ FilterBy func(object interface{}) Session

+ FindAll func(rowsSlicePtr interface{}, ctx ...context.Context) error

+ FindAndDelete func(doc interface{}, ctx ...context.Context) error

+ FindOne func(doc interface{}, ctx ...context.Context) error

+ FindOneAndReplace func(doc interface{}, ctx ...context.Context) error

+ FindOneAndUpdate func(doc interface{}, ctx ...context.Context) (*mongo.SingleResult, error)

+ FindOneAndUpdateBson func(coll interface{}, bson interface{}, ctx ...context.Context) (*mongo.SingleResult, error)

+ FindPagination func(needCount bool, rowsSlicePtr interface{}, ctx ...context.Context) (int64, error)

+ Gt func(key string, gt interface{}) Session

+ Gte func(key string, gte interface{}) Session

+ ID func(id interface{}) Session

+ In func(key string, in interface{}) Session

+ InsertMany func(docs interface{}, ctx ...context.Context) (*mongo.InsertManyResult, error)

+ InsertOne func(doc interface{}, ctx ...context.Context) (primitive.ObjectID, error)

+ Limit func(i int64) Session

+ Lt func(key string, lt interface{}) Session

+ Lte func(key string, lte interface{}) Session

+ Ne func(key string, ne interface{}) Session

+ Nin func(key string, nin interface{}) Session

+ Nor func(c Condition) Session

+ Not func(key string, not interface{}) Session

+ Or func(c Condition) Session

+ Regex func(key string, value string) Session

+ RegexFilter func(key, pattern string) Session

+ ReplaceOne func(doc interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ SetArrayFilters func(filters options.ArrayFilters) Session

+ SetBypassDocumentValidation func(b bool) Session

+ SetCollReadPreference func(rp *readpref.ReadPref) Session

+ SetCollRegistry func(r *bsoncodec.Registry) Session

+ SetCollWriteConcern func(wc *writeconcern.WriteConcern) Session

+ SetCollation func(collation *options.Collation) Session

+ SetDatabase func(db string) Session

+ SetHint func(hint interface{}) Session

+ SetMaxTime func(d time.Duration) Session

+ SetOrdered func(ordered bool) Session

+ SetProjection func(projection interface{}) Session

+ SetReadConcern func(rc *readconcern.ReadConcern) Session

+ SetReturnDocument func(rd options.ReturnDocument) Session

+ SetSort func(sort interface{}) Session

+ SetUpsert func(b bool) Session

+ Skip func(i int64) Session

+ Soft func(f bool) Session

+ SoftDeleteMany func(doc interface{}, ctx ...context.Context) error

+ SoftDeleteOne func(doc interface{}, ctx ...context.Context) error

+ Sort func(colNames ...string) Session

+ Type func(key string, t interface{}) Session

+ UpdateMany func(bean interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ UpdateManyBson func(coll interface{}, bson interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ UpdateOne func(bean interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ UpdateOneBson func(coll interface{}, bson interface{}, ctx ...context.Context) (*mongo.UpdateResult, error)

+ func NewSession(engine Client) Session

v0.1.13

Jan 19, 2024

v0.1.12

Jan 19, 2024

v0.1.11

Jan 17, 2022

v0.1.10

Jan 17, 2022

v0.1.9

Jan 5, 2022

v0.1.8

Oct 18, 2021

v0.1.7

Oct 18, 2021

v0.1.6

Oct 18, 2021

v0.1.5

Sep 18, 2021

Changes in this version

+ func NewClient(db string, options ...*options.ClientOptions) (driver.Client, error)

+ func NewCondition() driver.Condition

+ type Condition interface

+ A func() bson.A

+ And func(filter Condition) *filter

+ Eq func(key string, value interface{}) *filter

+ Exists func(key string, exists bool, filter ...Condition) *filter

+ Expr func(filter Condition) *filter

+ Filters func() bson.D

+ Gt func(key string, gt interface{}) *filter

+ Gte func(key string, gte interface{}) *filter

+ ID func(id interface{}) *filter

+ In func(key string, in interface{}) *filter

+ Lt func(key string, lt interface{}) *filter

+ Lte func(key string, lte interface{}) *filter

+ Ne func(key string, ne interface{}) *filter

+ Nin func(key string, nin interface{}) *filter

+ Nor func(filter Condition) *filter

+ Not func(key string, not interface{}) *filter

+ Or func(filter Condition) *filter

+ Regex func(key string, value interface{}) *filter

+ RegexFilter func(key, pattern string) *filter

+ Type func(key string, t interface{}) *filter

+ func DefaultCondition() Condition

+ type TagMaker interface

+ MakeTag func(structureType reflect.Type, fieldIndex int) reflect.StructTag