objectstore: Refresh v0.1.80

* Add manual Refresh for various objectstore's
* RefreshPolicy option
* Refreshable MRU and atomic snapshotting

1 files changed, 30 insertions, 0 deletions

diff --git a/objectstore/mix/refresh.go b/objectstore/mix/refresh.go
new file mode 100644
index 00000000..a9418a62
--- /dev/null
+++ b/objectstore/mix/refresh.go
@@ -0,0 +1,30 @@
+package mix
+
+import (
+	"errors"
+
+	"codeberg.org/lindenii/furgit/objectstore"
+)
+
+// Refresh forwards refresh calls to refresh-capable backends.
+func (mix *Mix) Refresh() error {
+	mix.mu.RLock()
+
+	backends := make([]objectstore.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...)
+}