blob: f33aa913ff5999deb35f644ca3188fc57ce6c56c (
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
43
44
45
46
47
48
|
# Copyright (c) 2012 The Chromium Authors. All rights reserved.
# Use of this source code is governed by a BSD-style license that can be
# found in the LICENSE file.
from future import Future
class _SingleGetFuture(object):
def __init__(self, multi_get, key):
self._future = multi_get
self._key = key
def Get(self):
return self._future.Get().get(self._key)
class ObjectStore(object):
'''A class for caching picklable objects.
'''
def Get(self, key):
'''Gets a |Future| with the value of |key| in the object store, or None
if |key| is not in the object store.
'''
return Future(delegate=_SingleGetFuture(self.GetMulti([key]), key))
def GetMulti(self, keys):
'''Gets a |Future| with values mapped to |keys| from the object store, with
any keys not in the object store omitted.
'''
raise NotImplementedError(self.__class__)
def Set(self, key, value):
'''Sets key -> value in the object store.
'''
self.SetMulti({ key: value })
def SetMulti(self, items):
'''Atomically sets the mapping of keys to values in the object store.
'''
raise NotImplementedError(self.__class__)
def Del(self, key):
'''Deletes a key from the object store.
'''
self.DelMulti([key])
def DelMulti(self, keys):
'''Deletes |keys| from the object store.
'''
raise NotImplementedError(self.__class__)
|
