mongodbmodule

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 18, 2023 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MongoModule

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

func (*MongoModule) Init

func (mm *MongoModule) Init(uri string, maxOperatorTimeOut time.Duration) error

func (*MongoModule) Start

func (mm *MongoModule) Start() error

func (*MongoModule) TakeSession

func (mm *MongoModule) TakeSession() Session

type Session

type Session struct {
	*mongo.Client
	// contains filtered or unexported fields
}

func (*Session) Collection

func (s *Session) Collection(db string, collection string) *mongo.Collection

func (*Session) CountDocument

func (s *Session) CountDocument(db string, collection string, filter interface{}) (int64, error)

func (*Session) EnsureIndex

func (s *Session) EnsureIndex(db string, collection string, indexKeys [][]string, bBackground bool, sparse bool, asc bool) error

indexKeys[索引][每个索引key字段]

func (*Session) EnsureUniqueIndex

func (s *Session) EnsureUniqueIndex(db string, collection string, indexKeys [][]string, bBackground bool, sparse bool, asc bool) error

indexKeys[索引][每个索引key字段]

func (*Session) GetDefaultContext

func (s *Session) GetDefaultContext() (context.Context, context.CancelFunc)

func (*Session) NextSeq

func (s *Session) NextSeq(db string, collection string, id interface{}) (int, error)

Jump to

Keyboard shortcuts

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