From 0f24ee5d6d36cc71f7fcab04e337dfedb1fa83ae Mon Sep 17 00:00:00 2001 From: disksing Date: Mon, 2 Nov 2015 19:16:25 +0800 Subject: [PATCH] hbase-store: support snapshot --- store/hbase/kv.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/store/hbase/kv.go b/store/hbase/kv.go index e51489a4b4..51187b836b 100644 --- a/store/hbase/kv.go +++ b/store/hbase/kv.go @@ -73,8 +73,8 @@ func (s *hbaseStore) Begin() (kv.Transaction, error) { } func (s *hbaseStore) GetSnapshot(ver kv.Version) (kv.MvccSnapshot, error) { - //TODO: support snapshot - return nil, errors.New("not implemented") + t := themis.NewTxn(s.cli) + return newHbaseSnapshot(t, s.storeName), nil } func (s *hbaseStore) Close() error { @@ -91,6 +91,8 @@ func (s *hbaseStore) UUID() string { func (s *hbaseStore) CurrentVersion() (kv.Version, error) { t := themis.NewTxn(s.cli) + defer t.Release() + return kv.Version{Ver: t.GetStartTS()}, nil }