OLD | NEW |
---|---|
(Empty) | |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 package memory | |
6 | |
7 import ( | |
8 "github.com/luci/gkvlite" | |
9 ) | |
10 | |
11 // memStore is a gkvlite.Store which will panic for anything which might | |
12 // otherwise return an error. | |
13 // | |
14 // This is reasonable for in-memory Store objects, since the only errors that | |
15 // should occur happen with file IO on the underlying file (which of course | |
16 // doesn't exist). | |
17 type memStore gkvlite.Store | |
18 | |
19 func newMemStore() *memStore { | |
20 ret, err := gkvlite.NewStore(nil) | |
21 if err != nil { | |
22 panic(err) | |
23 } | |
24 return (*memStore)(ret) | |
25 } | |
26 | |
27 func (bs *memStore) Snapshot() *memStore { | |
M-A Ruel
2015/05/29 16:16:18
From what I understand, these functions are export
| |
28 return (*memStore)((*gkvlite.Store)(bs).Snapshot()) | |
29 } | |
30 | |
31 func (bs *memStore) MakePrivateCollection(cmp gkvlite.KeyCompare) *memCollection { | |
32 return (*memCollection)((*gkvlite.Store)(bs).MakePrivateCollection(cmp)) | |
33 } | |
34 | |
35 func (bs *memStore) GetCollection(name string) *memCollection { | |
36 return (*memCollection)((*gkvlite.Store)(bs).GetCollection(name)) | |
37 } | |
38 | |
39 func (bs *memStore) SetCollection(name string, cmp gkvlite.KeyCompare) *memColle ction { | |
40 return (*memCollection)((*gkvlite.Store)(bs).SetCollection(name, cmp)) | |
41 } | |
42 | |
43 // memCollection is a gkvlite.Collection which will panic for anything which | |
44 // might otherwise return an error. | |
45 // | |
46 // This is reasonable for in-memory Store objects, since the only errors that | |
47 // should occur happen with file IO on the underlying file (which of course | |
48 // doesn't exist. | |
49 type memCollection gkvlite.Collection | |
50 | |
51 func (bc *memCollection) Get(k []byte) []byte { | |
52 ret, err := (*gkvlite.Collection)(bc).Get(k) | |
53 if err != nil { | |
54 panic(err) | |
55 } | |
56 return ret | |
57 } | |
58 | |
59 func (bc *memCollection) Set(k, v []byte) { | |
60 err := (*gkvlite.Collection)(bc).Set(k, v) | |
M-A Ruel
2015/05/29 02:01:23
combine lines
iannucci
2015/05/29 02:42:28
done
| |
61 if err != nil { | |
62 panic(err) | |
63 } | |
64 } | |
65 | |
66 func (bc *memCollection) Delete(k []byte) bool { | |
67 ret, err := (*gkvlite.Collection)(bc).Delete(k) | |
68 if err != nil { | |
69 panic(err) | |
70 } | |
71 return ret | |
72 } | |
73 | |
74 func (bc *memCollection) VisitItemsAscend(target []byte, withValue bool, visitor gkvlite.ItemVisitor) { | |
75 err := (*gkvlite.Collection)(bc).VisitItemsAscend(target, withValue, vis itor) | |
M-A Ruel
2015/05/29 02:01:23
here too, and 82
iannucci
2015/05/29 02:42:28
done
| |
76 if err != nil { | |
77 panic(err) | |
78 } | |
79 } | |
80 | |
81 func (bc *memCollection) VisitItemsDescend(target []byte, withValue bool, visito r gkvlite.ItemVisitor) { | |
82 err := (*gkvlite.Collection)(bc).VisitItemsDescend(target, withValue, vi sitor) | |
83 if err != nil { | |
84 panic(err) | |
85 } | |
86 } | |
87 | |
88 func (bc *memCollection) GetTotals() (numItems, numBytes uint64) { | |
89 numItems, numBytes, err := (*gkvlite.Collection)(bc).GetTotals() | |
M-A Ruel
2015/05/29 02:01:23
This code doesn't do what you think it does.
Look
iannucci
2015/05/29 02:42:28
What do you think I think it does?
M-A Ruel
2015/05/29 16:16:18
I thought it aliased the variables but it looks li
| |
90 if err != nil { | |
91 panic(err) | |
92 } | |
93 return | |
94 } | |
OLD | NEW |