0
0

update metrics store to latest kvstore api

This commit is contained in:
Steve Yen 2015-04-27 11:01:53 -07:00
parent 16f538d7b7
commit e98ae8ab71
2 changed files with 10 additions and 3 deletions

View File

@ -14,4 +14,3 @@ package bleve
import ( import (
_ "github.com/blevesearch/bleve/index/store/metrics" _ "github.com/blevesearch/bleve/index/store/metrics"
) )

View File

@ -131,10 +131,18 @@ type Batch struct {
o store.KVBatch o store.KVBatch
} }
func (s *Store) Open() error {
return s.o.Open()
}
func (s *Store) Close() error { func (s *Store) Close() error {
return s.o.Close() return s.o.Close()
} }
func (s *Store) SetMergeOperator(mo store.MergeOperator) {
s.o.SetMergeOperator(mo)
}
func (s *Store) Reader() (store.KVReader, error) { func (s *Store) Reader() (store.KVReader, error) {
o, err := s.o.Reader() o, err := s.o.Reader()
if err != nil { if err != nil {
@ -289,9 +297,9 @@ func (w *Batch) Delete(key []byte) {
w.o.Delete(key) w.o.Delete(key)
} }
func (w *Batch) Merge(key []byte, oper store.AssociativeMerge) { func (w *Batch) Merge(key, val []byte) {
w.s.TimerBatchMerge.Time(func() { w.s.TimerBatchMerge.Time(func() {
w.o.Merge(key, oper) w.o.Merge(key, val)
}) })
} }