mongodb

Documentation

Index

• type Mongo
  • func NewMongo(name string, opts ...*options.ClientOptions) *Mongo
  • func (m *Mongo) Client() *mongo.Client
  • func (m *Mongo) Col(col bson.M) *mongo.Collection
  • func (m *Mongo) Connect(ctx context.Context)
  • func (m *Mongo) ConnectDefault(ctx context.Context)
  • func (m *Mongo) Disconnect(ctx context.Context)
  • func (m *Mongo) InitCollection(col bson.M)
  • func (m *Mongo) M() *Mongo
  • func (m *Mongo) Ping(ctx context.Context, rp *readpref.ReadPref)
• type MongoChanPool
  • func NewMongoChanPool(name string, maxPoolSize int, opts ...*options.ClientOptions) *MongoChanPool
  • func (m *MongoChanPool) Disconnect(ctx context.Context)
  • func (m *MongoChanPool) M() *Mongo
• type MongoRingPool
  • func NewMongoRingPool(name string, maxPoolSize int, opts ...*options.ClientOptions) *MongoRingPool
  • func (m *MongoRingPool) Disconnect(ctx context.Context)
  • func (m *MongoRingPool) M() *Mongo
• type Mongoer
  • func NewMongoPool(poolType, name string, maxPoolSize int, opts ...*options.ClientOptions) (mr Mongoer)

Types

type Mongo

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

func NewMongo

func NewMongo(name string, opts ...*options.ClientOptions) *Mongo

func (*Mongo) Client

func (m *Mongo) Client() *mongo.Client

func (*Mongo) Col

func (m *Mongo) Col(col bson.M) *mongo.Collection

func (*Mongo) Connect

func (m *Mongo) Connect(ctx context.Context)

func (*Mongo) ConnectDefault

func (m *Mongo) ConnectDefault(ctx context.Context)

func (*Mongo) Disconnect

func (m *Mongo) Disconnect(ctx context.Context)

func (*Mongo) InitCollection

func (m *Mongo) InitCollection(col bson.M)

func (*Mongo) M

func (m *Mongo) M() *Mongo

func (*Mongo) Ping

func (m *Mongo) Ping(ctx context.Context, rp *readpref.ReadPref)

type MongoChanPool

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

func NewMongoChanPool

func NewMongoChanPool(name string, maxPoolSize int, opts ...*options.ClientOptions) *MongoChanPool

func (*MongoChanPool) Disconnect

func (m *MongoChanPool) Disconnect(ctx context.Context)

func (*MongoChanPool) M

func (m *MongoChanPool) M() *Mongo

type MongoRingPool

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

func NewMongoRingPool

func NewMongoRingPool(name string, maxPoolSize int, opts ...*options.ClientOptions) *MongoRingPool

func (*MongoRingPool) Disconnect

func (m *MongoRingPool) Disconnect(ctx context.Context)

func (*MongoRingPool) M

func (m *MongoRingPool) M() *Mongo

type Mongoer

type Mongoer interface {
	M() *Mongo
	Disconnect(ctx context.Context)
}

func NewMongoPool

func NewMongoPool(poolType, name string, maxPoolSize int, opts ...*options.ClientOptions) (mr Mongoer)