41 lines
759 B
Go
41 lines
759 B
Go
package storage
|
|
|
|
import (
|
|
"fmt"
|
|
)
|
|
|
|
type DB interface {
|
|
Get(string) ([]byte, error)
|
|
Set(string, []byte) error
|
|
Close() error
|
|
}
|
|
|
|
var DefaultNamespace = "namespace"
|
|
|
|
func New(key Type, params ...string) (db DB, err error) {
|
|
defer func() {
|
|
if i := recover(); i != nil {
|
|
err = fmt.Errorf("panic making %s: %v", key, i)
|
|
}
|
|
}()
|
|
err = ErrNotImpl
|
|
switch key {
|
|
case MAP:
|
|
db = NewMap()
|
|
err = nil
|
|
case BOLT:
|
|
db, err = NewBolt(params[0])
|
|
case CACHE:
|
|
db, err = NewCache(params...)
|
|
case LEVELDB:
|
|
db, err = NewLevelDB(params[0])
|
|
case MEMCACHE:
|
|
db, err = NewMemcache(params[0], params[1:]...)
|
|
case MEMCACHECLUSTER:
|
|
db, err = NewMemcacheCluster(params[0], params[1:]...)
|
|
case MONGO:
|
|
db, err = NewMongo(params[0], params[1:]...)
|
|
}
|
|
return
|
|
}
|