object/store/chain/chain.go


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

package chain

import (
	"errors"

	"lindenii.org/go/furgit/object/store"
)

// Chain queries multiple object databases in order.
//
// Labels: Close-Caller.
type Chain struct {
	backends []store.ObjectReader
}

var _ store.ObjectReader = (*Chain)(nil)

// New creates an ordered object database chain.
//
// The provided backends must be non-nil and distinct.
//
// Labels: Deps-Borrowed, Life-Parent.
func New(backends ...store.ObjectReader) *Chain {
	return &Chain{
		backends: append([]store.ObjectReader(nil), backends...),
	}
}

// Refresh forwards refresh calls to all backends.
func (chain *Chain) Refresh() error {
	var errs []error

	for _, backend := range chain.backends {
		err := backend.Refresh()
		if err != nil {
			errs = append(errs, err)
		}
	}

	return errors.Join(errs...)
}