Add support for MongoDB Atlas

This commit is contained in:
Kalissaac
2020-11-23 17:29:38 -08:00
parent 3f5230b6e5
commit d304cb36a9
2 changed files with 12 additions and 1 deletions

View File

@@ -2,6 +2,11 @@ package mongodb
// Config defines the config for storage.
type Config struct {
// Whether the DB is hosted on MongoDB Atlas
//
// Optional. Default is false
Atlas bool
// Host name where the DB is hosted
//
// Optional. Default is "127.0.0.1"
@@ -40,6 +45,7 @@ type Config struct {
// ConfigDefault is the default config
var ConfigDefault = Config{
Atlas: false,
Host: "127.0.0.1",
Port: 27017,
Database: "fiber",

View File

@@ -33,7 +33,12 @@ func New(config ...Config) *Storage {
cfg := configDefault(config...)
// Create data source name
var dsn = "mongodb://"
var dsn = "mongodb"
if cfg.Atlas == true {
dsn += "+srv://"
} else {
dsn += "://"
}
if cfg.Username != "" {
dsn += url.QueryEscape(cfg.Username)
}