Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetObjectID ¶
Types ¶
type MgoAggregate ¶
type MgoDBModel ¶
type MgoDBModel interface { DisableCheckBeforeSave(b bool) SetDB(db *mongo.Database) BatchUpdate(doclist []dao.DocInter, getField func(d dao.DocInter) bson.D, u dao.LogUser) (failed []dao.DocInter, err error) BatchSave(doclist []dao.DocInter, u dao.LogUser) (inserted []interface{}, failed []dao.DocInter, err error) Save(d dao.DocInter, u dao.LogUser) (interface{}, error) RemoveAll(d dao.DocInter, q primitive.M, u dao.LogUser) (int64, error) RemoveByID(d dao.DocInter, u dao.LogUser) (int64, error) UpdateOne(d dao.DocInter, fields bson.D, u dao.LogUser) (int64, error) UpdateAll(d dao.DocInter, q bson.M, fields bson.D, u dao.LogUser) (int64, error) UnsetFields(d dao.DocInter, q bson.M, fields []string, u dao.LogUser) (int64, error) Upsert(d dao.DocInter, u dao.LogUser) (interface{}, error) FindByID(d dao.DocInter) error FindOne(d dao.DocInter, q bson.M, option ...*options.FindOneOptions) error Find(d dao.DocInter, q bson.M, option ...*options.FindOptions) (interface{}, error) FindAndExec( d dao.DocInter, q bson.M, exec func(i interface{}) error, opts ...*options.FindOptions, ) error PipeFindOne(aggr MgoAggregate, filter bson.M) error PipeFind(aggr MgoAggregate, filter bson.M, opts ...*options.AggregateOptions) (interface{}, error) PipeFindAndExec( aggr MgoAggregate, q bson.M, exec func(i interface{}) error, opts ...*options.AggregateOptions, ) error PagePipeFind(aggr MgoAggregate, filter bson.M, sort bson.M, limit, page int64) (interface{}, error) PageFind(d dao.DocInter, q bson.M, limit, page int64, opts ...*options.FindOptions) (interface{}, error) CountDocuments(d dao.Collection, q bson.M) (int64, error) GetPaginationSource(d dao.DocInter, q bson.M, opts ...*options.FindOptions) util.PaginationSource GetPipePaginationSource(aggr MgoAggregate, q bson.M, sort bson.M) util.PaginationSource CreateCollection(dlist ...dao.DocInter) error //Reference to customer code, use for aggregate pagination CountAggrDocuments(aggr MgoAggregate, q bson.M) (int64, error) GetPipeMatchPaginationSource(aggr MgoAggregate, q bson.M, sort bson.M) util.PaginationSource NewFindMgoDS(d dao.DocInter, q bson.M, opts ...*options.FindOptions) MgoDS NewPipeFindMgoDS(d MgoAggregate, q bson.M, opts ...*options.AggregateOptions) MgoDS }
func NewMgoModel ¶
func NewMgoModelByReq ¶
func NewMgoModelByReq(req *http.Request, source string) MgoDBModel
Click to show internal directories.
Click to hide internal directories.