storage: transactional, new storage with transactional capabilities

Signed-off-by: Máximo Cuadros <mcuadros@gmail.com>

1 files changed, 12 insertions, 0 deletions

diff --git a/storage/transactional/object.go b/storage/transactional/object.go
index 2a46d3c..21490b7 100644
--- a/storage/transactional/object.go
+++ b/storage/transactional/object.go
@@ -61,3 +61,15 @@ func (o *ObjectStorage) IterEncodedObjects(t plumbing.ObjectType) (storer.Encode
 		temporalIter,
 	}), nil
 }
+
+func (o *ObjectStorage) Commit() error {
+	iter, err := o.temporal.IterEncodedObjects(plumbing.AnyObject)
+	if err != nil {
+		return err
+	}
+
+	return iter.ForEach(func(obj plumbing.EncodedObject) error {
+		_, err := o.EncodedObjectStorer.SetEncodedObject(obj)
+		return err
+	})
+}