mongo

Documentation

Index

• Variables
• type ISession
  • func NewExtendMongoDatabase(logger *zap.Logger, opt config.Mongo) (ISession, func(), error)

Variables

var NewSession = func(ctx context.Context, opt config.Mongo) (ISession, error) {
	serverAPIOptions := options.ServerAPI(options.ServerAPIVersion1)
	clientOptions := options.Client().
		ApplyURI(fmt.Sprintf("%s://%s:%s@%s/%s?retryWrites=true&w=majority", opt.MongoProtocol, opt.MongoUsername, opt.MongoPassword, opt.MongoHost, opt.MongoDatabase)).
		SetServerAPIOptions(serverAPIOptions)
	return newClient(ctx, clientOptions)
}

NewSession method

Types

type ISession

type ISession interface {
	Connect(ctx context.Context) error
	Disconnect(ctx context.Context) error
	Ping(ctx context.Context, rp *readpref.ReadPref) error
	StartSession(opts ...*options.SessionOptions) (mongo.Session, error)
	Database(name string, opts ...*options.DatabaseOptions) *mongo.Database
	ListDatabases(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) (mongo.ListDatabasesResult, error)
	ListDatabaseNames(ctx context.Context, filter interface{}, opts ...*options.ListDatabasesOptions) ([]string, error)
	UseSession(ctx context.Context, fn func(mongo.SessionContext) error) error
	UseSessionWithOptions(ctx context.Context, opts *options.SessionOptions, fn func(mongo.SessionContext) error) error
	Watch(ctx context.Context, pipeline interface{},
		opts ...*options.ChangeStreamOptions) (*mongo.ChangeStream, error)
	NumberSessionsInProgress() int
	Timeout() *time.Duration
}

ISession interface

func NewExtendMongoDatabase

func NewExtendMongoDatabase(logger *zap.Logger, opt config.Mongo) (ISession, func(), error)