*: object/store -> object/storer v0.1.107

1 files changed, 30 insertions, 0 deletions

diff --git a/object/storer/mix/refresh.go b/object/storer/mix/refresh.go
new file mode 100644
index 00000000..916d9e8f
--- /dev/null
+++ b/object/storer/mix/refresh.go
@@ -0,0 +1,30 @@
+package mix
+
+import (
+	"errors"
+
+	"codeberg.org/lindenii/furgit/object/storer"
+)
+
+// Refresh forwards refresh calls to refresh-capable backends.
+func (mix *Mix) Refresh() error {
+	mix.mu.RLock()
+
+	backends := make([]objectstorer.Store, 0, len(mix.backendNodeByStore))
+	for node := mix.backendHead; node != nil; node = node.next {
+		backends = append(backends, node.backend)
+	}
+
+	mix.mu.RUnlock()
+
+	var errs []error
+
+	for _, backend := range backends {
+		err := backend.Refresh()
+		if err != nil {
+			errs = append(errs, err)
+		}
+	}
+
+	return errors.Join(errs...)
+}