expose forestdb rollback methods
This commit is contained in:
parent
5467e0a385
commit
ae3600aeea
|
@ -133,7 +133,7 @@ func (s *Store) newSnapshot() (*forestdb.KVStore, error) {
|
||||||
return s.dbkv.SnapshotOpen(seqNum)
|
return s.dbkv.SnapshotOpen(seqNum)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Store) getRollbackID() ([]byte, error) {
|
func (s *Store) GetRollbackID() ([]byte, error) {
|
||||||
seqNum, err := s.getSeqNum()
|
seqNum, err := s.getSeqNum()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
|
@ -146,7 +146,7 @@ func (s *Store) getRollbackID() ([]byte, error) {
|
||||||
return buf.Bytes(), nil
|
return buf.Bytes(), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Store) rollbackTo(rollbackId []byte) error {
|
func (s *Store) RollbackTo(rollbackId []byte) error {
|
||||||
s.writer.Lock()
|
s.writer.Lock()
|
||||||
defer s.writer.Unlock()
|
defer s.writer.Unlock()
|
||||||
buf := bytes.NewReader(rollbackId)
|
buf := bytes.NewReader(rollbackId)
|
||||||
|
|
|
@ -72,7 +72,7 @@ func TestRollbackSameHandle(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// get the rollback id
|
// get the rollback id
|
||||||
rollbackId, err := s.getRollbackID()
|
rollbackId, err := s.GetRollbackID()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
|
@ -103,7 +103,7 @@ func TestRollbackSameHandle(t *testing.T) {
|
||||||
reader.Close()
|
reader.Close()
|
||||||
|
|
||||||
// now rollback
|
// now rollback
|
||||||
err = s.rollbackTo(rollbackId)
|
err = s.RollbackTo(rollbackId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
@ -152,7 +152,7 @@ func TestRollbackNewHandle(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// get the rollback id
|
// get the rollback id
|
||||||
rollbackId, err := s.getRollbackID()
|
rollbackId, err := s.GetRollbackID()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
|
@ -183,7 +183,7 @@ func TestRollbackNewHandle(t *testing.T) {
|
||||||
reader.Close()
|
reader.Close()
|
||||||
|
|
||||||
// now rollback
|
// now rollback
|
||||||
err = s.rollbackTo(rollbackId)
|
err = s.RollbackTo(rollbackId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
@ -246,7 +246,7 @@ func TestRollbackOtherHandle(t *testing.T) {
|
||||||
}
|
}
|
||||||
|
|
||||||
// get the rollback id
|
// get the rollback id
|
||||||
rollbackId, err := s.getRollbackID()
|
rollbackId, err := s.GetRollbackID()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
|
@ -277,7 +277,7 @@ func TestRollbackOtherHandle(t *testing.T) {
|
||||||
reader.Close()
|
reader.Close()
|
||||||
|
|
||||||
// now rollback
|
// now rollback
|
||||||
err = s.rollbackTo(rollbackId)
|
err = s.RollbackTo(rollbackId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatal(err)
|
t.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue
Block a user