mongo

package

Go to main page

Versions in this module

v1

v1.0.7

Jan 18, 2024

Changes in this version

type Chain

+ func (ch *Chain) Debug(w io.WriteCloser) *Chain

+ type Statement struct

+ Switch bool

v1.0.6

Dec 23, 2023

Changes in this version

type Option

+ func WithLoggerOptions(logOpt *options.LoggerOptions) Option

v1.0.5

Dec 21, 2023

v1.0.4

Dec 14, 2023

Changes in this version

type Option

+ func WithCommandMonitor(commandMonitor *event.CommandMonitor) Option

+ func WithMinPoolSize(minPoolSize uint64) Option

+ func WithMonitor(monitor interface{}) Option

+ func WithPoolMonitor(poolMonitor *event.PoolMonitor) Option

+ func WithServerMonitor(serverMonitor *event.ServerMonitor) Option

v1.0.3

Dec 6, 2023

Changes in this version

type Conn

+ func (c *Conn) CreateIndex(ctx context.Context, coll Collection, indexs ...SortRule) (string, error)

v1.0.2

Aug 28, 2023

Changes in this version

type Conn

+ func (c *Conn) DbStats(ctx context.Context, des interface{}) error

+ func (c *Conn) IsMaster(ctx context.Context, des interface{}) error

+ func (c *Conn) Ping(ctx context.Context) error

+ func (c *Conn) RunCommand(ctx context.Context, cmd bson.D, des interface{}) error

+ func (c *Conn) ServerStatus(ctx context.Context, des interface{}) error

v1.0.1

Aug 25, 2023

Changes in this version

+ type AggregateOpe string

+ const AggregateOpeAvg

+ const AggregateOpeFirst

+ const AggregateOpeGroup

+ const AggregateOpeLast

+ const AggregateOpeMatch

+ const AggregateOpeProject

+ const AggregateOpeSkip

+ const AggregateOpeSort

+ const AggregateOpeSum

+ const AggregateOpeUnset

+ const AggregateopeLimit

+ func (a AggregateOpe) String() string

type Chain

+ func (ch *Chain) Aggregate(des interface{}, stages ...bson.D) error

+ func (ch *Chain) GetAvgStage(calledFiled, filed string) bson.D

+ func (ch *Chain) GetFirstStage(calledFiled, filed string) bson.D

+ func (ch *Chain) GetGroupStage(groupFiled string, subStages ...bson.D) bson.D

+ func (ch *Chain) GetLastStage(calledFiled, filed string) bson.D

+ func (ch *Chain) GetLimitStage(num int64) bson.D

+ func (ch *Chain) GetMatchStage(filed, val string) bson.D

+ func (ch *Chain) GetProjectStage(fileds ...string) bson.D

+ func (ch *Chain) GetSkipStage(num int64) bson.D

+ func (ch *Chain) GetSortStage(rules ...SortRule) bson.D

+ func (ch *Chain) GetSumStage(calledFiled, filed string) bson.D

+ func (ch *Chain) GetUnsetStage(fileds ...string) bson.D

v1.0.0

Apr 19, 2023

Changes in this version

+ const SortTypeASC

+ const SortTypeDESC

+ type Chain struct

+ func (ch *Chain) Comparison(field string, symbol Comparison, val interface{}) *Chain

+ func (ch *Chain) Count() (int64, error)

+ func (ch *Chain) Delete(ctx context.Context) error

+ func (ch *Chain) DeleteOne(ctx context.Context) error

+ func (ch *Chain) Eq(field string, val interface{}) *Chain

+ func (ch *Chain) Exists(field string, exist bool) *Chain

+ func (ch *Chain) Filter(filter map[string]interface{}) *Chain

+ func (ch *Chain) Find(des interface{}) error

+ func (ch *Chain) FindOne(des interface{}) error

+ func (ch *Chain) Gt(field string, val int64) *Chain

+ func (ch *Chain) Gte(field string, val int64) *Chain

+ func (ch *Chain) In(field string, arrays []interface{}) *Chain

+ func (ch *Chain) InInt64(field string, arrays []int64) *Chain

+ func (ch *Chain) InString(field string, arrays []string) *Chain

+ func (ch *Chain) Inc(field string, incNums int64) error

+ func (ch *Chain) IncOne(field string, incNums int64) error

+ func (ch *Chain) InsertMany(docs []interface{}) error

+ func (ch *Chain) InsertOne(doc interface{}) error

+ func (ch *Chain) Limit(limit int64) *Chain

+ func (ch *Chain) Lt(field string, val int64) *Chain

+ func (ch *Chain) Lte(field string, val int64) *Chain

+ func (ch *Chain) NotEq(field string, val interface{}) *Chain

+ func (ch *Chain) NotIn(field string, arrays []interface{}) *Chain

+ func (ch *Chain) NotInInt64(field string, arrays []int64) *Chain

+ func (ch *Chain) NotInString(field string, arrays []string) *Chain

+ func (ch *Chain) Or(filter map[string]interface{}) *Chain

+ func (ch *Chain) Ors(filters ...map[string]interface{}) *Chain

+ func (ch *Chain) Paginate(f *PageFilter, des interface{}) (err error)

+ func (ch *Chain) Projection(fileds ...string) *Chain

+ func (ch *Chain) Regex(filed, content string) *Chain

+ func (ch *Chain) Skip(skip int64) *Chain

+ func (ch *Chain) Sort(rules ...SortRule) *Chain

+ func (ch *Chain) Type(field string, typ MongodbType) *Chain

+ func (ch *Chain) Update(updateMap map[string]interface{}) error

+ func (ch *Chain) UpdateOne(updateMap map[string]interface{}) error

+ func (ch *Chain) UpsertOne(content, defaultContent map[string]interface{}) error

+ func (ch *Chain) Where(key string, val interface{}) *Chain

+ func (ch *Chain) WithCtx(ctx context.Context) *Chain

+ type Collection interface

+ Collection func() string

+ type Comparison string

+ const ComparisonEq

+ const ComparisonGt

+ const ComparisonGte

+ const ComparisonIn

+ const ComparisonLt

+ const ComparisonLte

+ const ComparisonNotEq

+ const ComparisonNotIn

+ func (c Comparison) String() string

+ type Conn struct

+ func NewConn(opts ...Option) (*Conn, func())

+ func (c *Conn) Collection(i Collection) *Chain

+ func (c *Conn) GetDB() *mongo.Database

+ type Element string

+ const ElementExists

+ const ElementType

+ func (e Element) String() string

+ type MongodbType int

+ const Array

+ const BinaryData

+ const Boolean

+ const Date

+ const Double

+ const Int32

+ const Int64

+ const JavaScript

+ const Null

+ const Object

+ const ObjectId

+ const RegularExpression

+ const String

+ const Symbol

+ const Timestamp

+ const Undefined

+ type Option func(*config)

+ func WithAddr(addrs ...string) Option

+ func WithDatabase(dbName string) Option

+ func WithMaxPoolSize(maxPoolSize uint64) Option

+ func WithPassword(passwd string) Option

+ func WithUsername(username string) Option

+ type PageFilter struct

+ PageNum int64

+ PageSize int64

+ TotalCount int64

+ TotalPage int64

+ type SortRule struct

+ Field string

+ Typ SortType

+ type SortType int8

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL