Documentation
¶
Index ¶
- type MongoConnection
- func (mc *MongoConnection) Connect(ctx context.Context)
- func (mc *MongoConnection) DB(name string) *mongo.Database
- func (mc *MongoConnection) DbColl(db, coll string) *mongo.Collection
- func (mc *MongoConnection) Disconnect(ctx context.Context)
- func (mc *MongoConnection) IsAlive() bool
- func (mc *MongoConnection) ResumeTokenColl() *mongo.Collection
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MongoConnection ¶
type MongoConnection struct {
// contains filtered or unexported fields
}
func NewMongoConnection ¶
func NewMongoConnection(cfg *configs.MongoConfig) *MongoConnection
func (*MongoConnection) Connect ¶
func (mc *MongoConnection) Connect(ctx context.Context)
func (*MongoConnection) DbColl ¶
func (mc *MongoConnection) DbColl(db, coll string) *mongo.Collection
func (*MongoConnection) Disconnect ¶
func (mc *MongoConnection) Disconnect(ctx context.Context)
func (*MongoConnection) IsAlive ¶
func (mc *MongoConnection) IsAlive() bool
func (*MongoConnection) ResumeTokenColl ¶
func (mc *MongoConnection) ResumeTokenColl() *mongo.Collection
TODO
Source Files
Click to show internal directories.
Click to hide internal directories.