1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
package transactional
import (
"gopkg.in/src-d/go-git.v4/plumbing"
"gopkg.in/src-d/go-git.v4/plumbing/storer"
)
type ObjectStorage struct {
storer.EncodedObjectStorer
temporal storer.EncodedObjectStorer
}
func NewObjectStorage(s, temporal storer.EncodedObjectStorer) *ObjectStorage {
return &ObjectStorage{EncodedObjectStorer: s, temporal: temporal}
}
func (o *ObjectStorage) SetEncodedObject(obj plumbing.EncodedObject) (plumbing.Hash, error) {
return o.temporal.SetEncodedObject(obj)
}
func (o *ObjectStorage) HasEncodedObject(h plumbing.Hash) error {
err := o.EncodedObjectStorer.HasEncodedObject(h)
if err == plumbing.ErrObjectNotFound {
return o.temporal.HasEncodedObject(h)
}
return err
}
func (o *ObjectStorage) EncodedObjectSize(h plumbing.Hash) (int64, error) {
sz, err := o.EncodedObjectStorer.EncodedObjectSize(h)
if err == plumbing.ErrObjectNotFound {
return o.temporal.EncodedObjectSize(h)
}
return sz, err
}
func (o *ObjectStorage) EncodedObject(t plumbing.ObjectType, h plumbing.Hash) (plumbing.EncodedObject, error) {
obj, err := o.EncodedObjectStorer.EncodedObject(t, h)
if err == plumbing.ErrObjectNotFound {
return o.temporal.EncodedObject(t, h)
}
return obj, err
}
func (o *ObjectStorage) IterEncodedObjects(t plumbing.ObjectType) (storer.EncodedObjectIter, error) {
baseIter, err := o.EncodedObjectStorer.IterEncodedObjects(t)
if err != nil {
return nil, err
}
temporalIter, err := o.temporal.IterEncodedObjects(t)
if err != nil {
return nil, err
}
return storer.NewMultiEncodedObjectIter([]storer.EncodedObjectIter{
baseIter,
temporalIter,
}), nil
}
|
