blob: bc6a07b26a8faaa9f0d4e6d22cdb1ff79a6fde13 (
plain)
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
|
package kv
import kvv1 "github.com/spiral/roadrunner/v2/proto/kv/v1beta"
// Storage represents single abstract storage.
type Storage interface {
// Has checks if value exists.
Has(keys ...string) (map[string]bool, error)
// Get loads value content into a byte slice.
Get(key string) ([]byte, error)
// MGet loads content of multiple values
// Returns the map with existing keys and associated values
MGet(keys ...string) (map[string][]byte, error)
// Set used to upload item to KV with TTL
// 0 value in TTL means no TTL
Set(items ...*kvv1.Item) error
// MExpire sets the TTL for multiply keys
MExpire(items ...*kvv1.Item) error
// TTL return the rest time to live for provided keys
// Not supported for the memcached
TTL(keys ...string) (map[string]string, error)
// Clear clean the entire storage
Clear() error
// Delete one or multiple keys.
Delete(keys ...string) error
// Stop the storage driver
Stop()
}
// Constructor provides storage based on the config
type Constructor interface {
// KVConstruct provides Storage based on the config key
KVConstruct(key string) (Storage, error)
}
|
