aboutsummaryrefslogtreecommitdiffstats
path: root/storage/transactional/index.go
diff options
context:
space:
mode:
Diffstat (limited to 'storage/transactional/index.go')
-rw-r--r--storage/transactional/index.go50
1 files changed, 50 insertions, 0 deletions
diff --git a/storage/transactional/index.go b/storage/transactional/index.go
new file mode 100644
index 0000000..26042d6
--- /dev/null
+++ b/storage/transactional/index.go
@@ -0,0 +1,50 @@
+package transactional
+
+import (
+ "gopkg.in/src-d/go-git.v4/plumbing/format/index"
+ "gopkg.in/src-d/go-git.v4/plumbing/storer"
+)
+
+type IndexStorage struct {
+ storer.IndexStorer
+ temporal storer.IndexStorer
+
+ set bool
+}
+
+func NewIndexStorage(s, temporal storer.IndexStorer) *IndexStorage {
+ return &IndexStorage{
+ IndexStorer: s,
+ temporal: temporal,
+ }
+}
+
+func (s *IndexStorage) SetIndex(idx *index.Index) (err error) {
+ if err := s.temporal.SetIndex(idx); err != nil {
+ return err
+ }
+
+ s.set = true
+ return nil
+}
+
+func (s *IndexStorage) Index() (*index.Index, error) {
+ if !s.set {
+ return s.IndexStorer.Index()
+ }
+
+ return s.temporal.Index()
+}
+
+func (c *IndexStorage) Commit() error {
+ if !c.set {
+ return nil
+ }
+
+ idx, err := c.temporal.Index()
+ if err != nil {
+ return err
+ }
+
+ return c.IndexStorer.SetIndex(idx)
+}