mongodbmodule

Documentation

Index

• type MongoModule
  • func (mm *MongoModule) Init(uri string, maxOperatorTimeOut time.Duration) error
  • func (mm *MongoModule) Start() error
  • func (mm *MongoModule) TakeSession() Session
• type Session
  • func (s *Session) Collection(db string, collection string) *mongo.Collection
  • func (s *Session) CountDocument(db string, collection string, filter interface{}) (int64, error)
  • func (s *Session) EnsureIndex(db string, collection string, indexKeys [][]string, bBackground bool, ...) error
  • func (s *Session) EnsureUniqueIndex(db string, collection string, indexKeys [][]string, bBackground bool, ...) error
  • func (s *Session) GetDefaultContext() (context.Context, context.CancelFunc)
  • func (s *Session) NextSeq(db string, collection string, id interface{}) (int, error)

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)