1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
package storage
import (	"fmt"	"net/url"	"sync"	"time"
	"github.com/ije/gox/utils")
type Cache interface {	Has(key string) (bool, error)	Get(key string) ([]byte, error)	Set(key string, value []byte, ttl time.Duration) error	Delete(key string) error	Flush() error}
type CacheDriver interface {	Open(addr string, args url.Values) (cache Cache, err error)}
var cacheDrivers sync.Map
// New returns a new cache by urlfunc OpenCache(url string) (cache Cache, err error) {	if url == "" {		err = fmt.Errorf("invalid url")		return	}
	name, addr := utils.SplitByFirstByte(url, ':')	driver, ok := cacheDrivers.Load(name)	if !ok {		err = fmt.Errorf("unknown driver '%s'", name)		return	}
	path, options, err := parseConfigUrl(addr)	if err != nil {		return	}
	cache, err = driver.(CacheDriver).Open(path, options)	return}
func RegisterCache(name string, driver CacheDriver) error {	_, ok := cacheDrivers.Load(name)	if ok {		return fmt.Errorf("cache driver '%s' has been registered", name)	}
	cacheDrivers.Store(name, driver)	return nil}