From ff8b908ee7b26c13d8f0a2013a37cd8f685aba5b Mon Sep 17 00:00:00 2001 From: Bel LaPointe Date: Sun, 7 Feb 2021 13:01:45 -0600 Subject: [PATCH] impl map stream --- db.go | 3 +++ type.go | 3 +++ 2 files changed, 6 insertions(+) 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: