impl map stream

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

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: