Index: filter/count/mc.go |
diff --git a/filter/count/mc.go b/filter/count/mc.go |
index d65a096c657063f88db745d6012ec26e0053acf5..1000140890092084001d18c9cf2eea496baeaf95 100644 |
--- a/filter/count/mc.go |
+++ b/filter/count/mc.go |
@@ -13,18 +13,12 @@ import ( |
// MCCounter is the counter object for the Memcache service. |
type MCCounter struct { |
NewItem Entry |
- Add Entry |
- Set Entry |
- Get Entry |
- Delete Entry |
- CompareAndSwap Entry |
AddMulti Entry |
SetMulti Entry |
GetMulti Entry |
DeleteMulti Entry |
CompareAndSwapMulti Entry |
Increment Entry |
- IncrementExisting Entry |
Flush Entry |
Stats Entry |
} |
@@ -32,53 +26,43 @@ type MCCounter struct { |
type mcCounter struct { |
c *MCCounter |
- mc mc.Interface |
+ mc mc.RawInterface |
} |
-var _ mc.Interface = (*mcCounter)(nil) |
+var _ mc.RawInterface = (*mcCounter)(nil) |
func (m *mcCounter) NewItem(key string) mc.Item { |
m.c.NewItem.up() |
return m.mc.NewItem(key) |
} |
-func (m *mcCounter) Get(key string) (mc.Item, error) { |
- ret, err := m.mc.Get(key) |
- return ret, m.c.Get.up(err) |
+func (m *mcCounter) GetMulti(keys []string, cb mc.RawItemCB) error { |
+ return m.c.GetMulti.up(m.mc.GetMulti(keys, cb)) |
} |
-func (m *mcCounter) GetMulti(keys []string) (map[string]mc.Item, error) { |
- ret, err := m.mc.GetMulti(keys) |
- return ret, m.c.GetMulti.up(err) |
+func (m *mcCounter) AddMulti(items []mc.Item, cb mc.RawCB) error { |
+ return m.c.AddMulti.up(m.mc.AddMulti(items, cb)) |
} |
-func (m *mcCounter) Add(item mc.Item) error { return m.c.Add.up(m.mc.Add(item)) } |
-func (m *mcCounter) Set(item mc.Item) error { return m.c.Set.up(m.mc.Set(item)) } |
-func (m *mcCounter) Delete(key string) error { return m.c.Delete.up(m.mc.Delete(key)) } |
-func (m *mcCounter) CompareAndSwap(item mc.Item) error { |
- return m.c.CompareAndSwap.up(m.mc.CompareAndSwap(item)) |
+func (m *mcCounter) SetMulti(items []mc.Item, cb mc.RawCB) error { |
+ return m.c.SetMulti.up(m.mc.SetMulti(items, cb)) |
} |
-func (m *mcCounter) AddMulti(items []mc.Item) error { return m.c.AddMulti.up(m.mc.AddMulti(items)) } |
-func (m *mcCounter) SetMulti(items []mc.Item) error { return m.c.SetMulti.up(m.mc.SetMulti(items)) } |
-func (m *mcCounter) DeleteMulti(keys []string) error { |
- return m.c.DeleteMulti.up(m.mc.DeleteMulti(keys)) |
+ |
+func (m *mcCounter) DeleteMulti(keys []string, cb mc.RawCB) error { |
+ return m.c.DeleteMulti.up(m.mc.DeleteMulti(keys, cb)) |
} |
-func (m *mcCounter) Flush() error { return m.c.Flush.up(m.mc.Flush()) } |
-func (m *mcCounter) CompareAndSwapMulti(items []mc.Item) error { |
- return m.c.CompareAndSwapMulti.up(m.mc.CompareAndSwapMulti(items)) |
+func (m *mcCounter) CompareAndSwapMulti(items []mc.Item, cb mc.RawCB) error { |
+ return m.c.CompareAndSwapMulti.up(m.mc.CompareAndSwapMulti(items, cb)) |
} |
-func (m *mcCounter) Increment(key string, delta int64, initialValue uint64) (newValue uint64, err error) { |
+func (m *mcCounter) Flush() error { return m.c.Flush.up(m.mc.Flush()) } |
+ |
+func (m *mcCounter) Increment(key string, delta int64, initialValue *uint64) (newValue uint64, err error) { |
ret, err := m.mc.Increment(key, delta, initialValue) |
return ret, m.c.Increment.up(err) |
} |
-func (m *mcCounter) IncrementExisting(key string, delta int64) (newValue uint64, err error) { |
- ret, err := m.mc.IncrementExisting(key, delta) |
- return ret, m.c.IncrementExisting.up(err) |
-} |
- |
func (m *mcCounter) Stats() (*mc.Statistics, error) { |
ret, err := m.mc.Stats() |
return ret, m.c.Stats.up(err) |
@@ -87,7 +71,7 @@ func (m *mcCounter) Stats() (*mc.Statistics, error) { |
// FilterMC installs a counter Memcache filter in the context. |
func FilterMC(c context.Context) (context.Context, *MCCounter) { |
state := &MCCounter{} |
- return mc.AddFilters(c, func(ic context.Context, mc mc.Interface) mc.Interface { |
+ return mc.AddRawFilters(c, func(ic context.Context, mc mc.RawInterface) mc.RawInterface { |
return &mcCounter{state, mc} |
}), state |
} |