-
Notifications
You must be signed in to change notification settings - Fork 0
/
bucket_type_test.go
66 lines (53 loc) · 1.13 KB
/
bucket_type_test.go
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
59
60
61
62
63
64
65
66
// +build riak
package rkive
import (
"bytes"
check "gopkg.in/check.v1"
"time"
)
func (s *riakSuite) TestGetBucketTypeProperties(c *check.C) {
c.Skip("not implemented")
}
func (s *riakSuite) TestCache(c *check.C) {
startt := time.Now()
cache := s.cl.Bucket("test-cache")
err := cache.MakeCache()
if err != nil {
c.Fatal(err)
}
props, err := cache.GetProperties()
if err != nil {
c.Error(err)
}
if !bytes.Equal(props.GetBackend(), []byte("cache")) {
c.Errorf("Expected backend %q; got %q", "cache", props.GetBackend())
}
// cache buckets are the only place
// in which Overwrite is safe...
ob := &TestObject{
Data: []byte("Save this."),
}
err = cache.New(ob, nil)
if err != nil {
c.Error(err)
}
ob2 := &TestObject{
Data: []byte("overwrite!"),
}
err = cache.Overwrite(ob2, ob.Info().Key())
if err != nil {
c.Error(err)
}
var upd bool
upd, err = cache.Update(ob)
if err != nil {
c.Error(err)
}
if !upd {
c.Error("Expected update.")
}
if !bytes.Equal(ob.Data, []byte("overwrite!")) {
c.Errorf("Expected body %q; got %q", []byte("overwrite!"), ob.Data)
}
s.runtime += time.Since(startt)
}