Skip to content

Commit 7feb129

Browse files
committed
change revision logic
1 parent ffebe02 commit 7feb129

File tree

2 files changed

+53
-17
lines changed

2 files changed

+53
-17
lines changed

main.go

+52-14
Original file line numberDiff line numberDiff line change
@@ -2,10 +2,51 @@ package main
22

33
import (
44
"fmt"
5-
6-
"github.com/bradfitz/gomemcache/memcache"
75
memcacheWithTag "github.com/dakimura/memctag/memcache"
6+
"github.com/bradfitz/gomemcache/memcache"
87
)
8+
// memcacheWithTag "github.com/dakimura/memctag/memcache"
9+
10+
//func main() {
11+
// mc := memcacheWithTag.NewClient("127.0.0.1:11211")
12+
//
13+
// item := memcache.Item{Key: "1:message", Value: []byte("cache1")}
14+
// item2 := memcache.Item{Key: "2:message", Value: []byte("cache2")}
15+
// item3 := memcache.Item{Key: "3:message", Value: []byte("cache3")}
16+
// item4 := memcache.Item{Key: "4:message", Value: []byte("cache4")}
17+
// item5 := memcache.Item{Key: "5:message", Value: []byte("cache5")}
18+
// item6 := memcache.Item{Key: "6:message", Value: []byte("cache6")}
19+
// item7 := memcache.Item{Key: "7:message", Value: []byte("cache7")}
20+
// item8 := memcache.Item{Key: "8:message", Value: []byte("cache8")}
21+
// item9 := memcache.Item{Key: "9:message", Value: []byte("cache9")}
22+
// item10 := memcache.Item{Key: "10:message", Value: []byte("cache10")}
23+
//
24+
// tags := []string{"1-tag"}
25+
//
26+
// mc.SetWithTags(&item, tags)
27+
// mc.SetWithTags(&item2, tags)
28+
// mc.SetWithTags(&item3, tags)
29+
// mc.SetWithTags(&item4, tags)
30+
// mc.SetWithTags(&item5, tags)
31+
// mc.SetWithTags(&item6, tags)
32+
// mc.SetWithTags(&item7, tags)
33+
// mc.SetWithTags(&item8, tags)
34+
// mc.SetWithTags(&item9, tags)
35+
// mc.SetWithTags(&item10, tags)
36+
//
37+
// printCache(mc.GetWithTags("1:message", tags))
38+
// printCache(mc.GetWithTags("2:message", tags))
39+
// printCache(mc.GetWithTags("3:message", tags))
40+
// printCache(mc.GetWithTags("4:message", tags))
41+
// printCache(mc.GetWithTags("5:message", tags))
42+
// printCache(mc.GetWithTags("6:message", tags))
43+
// printCache(mc.GetWithTags("7:message", tags))
44+
// printCache(mc.GetWithTags("8:message", tags))
45+
// printCache(mc.GetWithTags("9:message", tags))
46+
// printCache(mc.GetWithTags("10:message", tags))
47+
//}
48+
49+
950

1051
func main() {
1152
mc := memcacheWithTag.NewClient("127.0.0.1:11211")
@@ -17,27 +58,24 @@ func main() {
1758
item2 := memcache.Item{Key: "2:message", Value: []byte("cache2")}
1859
item3 := memcache.Item{Key: "3:message", Value: []byte("cache3")}
1960

20-
mc.SetWithTags(&item, tags)
21-
mc.SetWithTags(&item2, tags)
22-
mc.SetWithTags(&item3, tag)
61+
mc.SetWithTags(&item, []string{"1-tag", "2-tag"})
62+
mc.SetWithTags(&item2, []string{"1-tag", "2-tag"})
63+
mc.SetWithTags(&item3, []string{"1-tag"})
2364

24-
printCache(mc.GetWithTags("1:message", tags)) //"1-tag", "2-tag"
25-
printCache(mc.GetWithTags("2:message", tags)) //"1-tag", "2-tag"
26-
printCache(mc.GetWithTags("3:message", tag)) //"1-tag"
27-
28-
fmt.Println("-------")
65+
//fmt.Println("-------")
2966
mc.Delete("2-tag")
3067

3168
printCache(mc.GetWithTags("1:message", tags)) //"1-tag", "2-tag"
3269
printCache(mc.GetWithTags("2:message", tags)) //"1-tag", "2-tag"
3370
printCache(mc.GetWithTags("3:message", tag)) //"1-tag"
3471

35-
fmt.Println("-------")
72+
//fmt.Println("-------")
73+
//
74+
//mc.Delete("3:message")
75+
//printCache(mc.GetWithTags("3:message", tag))
76+
}
3677

37-
mc.Delete("3:message")
38-
printCache(mc.GetWithTags("3:message", tag))
3978

40-
}
4179

4280
func printCache(item *memcache.Item, err error) {
4381
if err != nil {

memcache/set.go

+1-3
Original file line numberDiff line numberDiff line change
@@ -46,9 +46,7 @@ func (c *Client) generateKeyStr(k string, tags []string) (string, error) {
4646
}
4747

4848
func createRevision() []byte {
49-
revision := make([]byte, 1)
50-
revision[0] = byte(rand.Intn(26) + 65)
51-
return revision
49+
return []byte(string(rand.Intn(100000)))
5250
}
5351

5452
func (c *Client) setRevision(key string, revision []byte) error {

0 commit comments

Comments
 (0)