diff --git a/db.go b/db.go
index 3ceeec1..dc09b8f 100755
--- a/db.go
+++ b/db.go
@@ -33,6 +33,9 @@ func New(key Type, params ...string) (db DB, err error) {
 		db, err = NewDynomite(params[0], params[1], params[2])
 	case REDIS:
 		db, err = NewRedis(params[0], params[1], params[2])
+	case MAPSTREAM:
+		db = NewMapStream()
+		err = nil
 	case MAP:
 		db = NewMap()
 		err = nil
diff --git a/type.go b/type.go
index edbd6d7..b848f8e 100755
--- a/type.go
+++ b/type.go
@@ -20,6 +20,7 @@ const (
 	MONGO           = Type(iota)
 	MINIO           = Type(iota)
 	RCLONE          = Type(iota)
+	MAPSTREAM       = Type(iota)
 )
 
 func (t Type) String() string {
@@ -28,6 +29,8 @@ func (t Type) String() string {
 		return "dynomite"
 	case REDIS:
 		return "redis"
+	case MAPSTREAM:
+		return "mapstream"
 	case MAP:
 		return "map"
 	case RCLONE: