aboutsummaryrefslogtreecommitdiff
path: root/object
diff options
context:
space:
mode:
Diffstat (limited to 'object')
-rw-r--r--object/store/quarantine.go41
-rw-r--r--object/store/writer.go26
2 files changed, 67 insertions, 0 deletions
diff --git a/object/store/quarantine.go b/object/store/quarantine.go
new file mode 100644
index 00000000..b827d843
--- /dev/null
+++ b/object/store/quarantine.go
@@ -0,0 +1,41 @@
+package objectstore
+
+// Quarantine is one quarantined write. It is intended to be embedded.
+type Quarantine interface {
+ // Reader returns the objects written into this quarantine.
+ Reader() Reader
+
+ // Promote publishes quarantined writes into their final destination.
+ Promote() error
+
+ // Discard abandons quarantined writes.
+ Discard() error
+}
+
+// ObjectQuarantine represents one quarantined object-wise write.
+type ObjectQuarantine interface {
+ Quarantine
+ ObjectWriter
+}
+
+// PackQuarantine represents one quarantined pack-wise write.
+type PackQuarantine interface {
+ Quarantine
+ PackWriter
+}
+
+// ObjectQuarantineOptions controls the options for one object quarantine creation.
+type ObjectQuarantineOptions struct{}
+
+// PackQuarantineOptions controls the options for one pack quarantine creation.
+type PackQuarantineOptions struct{}
+
+// ObjectQuarantiner creates quarantines for object-wise writes.
+type ObjectQuarantiner interface {
+ BeginObjectQuarantine(opts ObjectQuarantineOptions) (ObjectQuarantine, error)
+}
+
+// PackQuarantiner creates quarantines for pack-wise writes.
+type PackQuarantiner interface {
+ BeginPackQuarantine(opts PackQuarantineOptions) (PackQuarantine, error)
+}
diff --git a/object/store/writer.go b/object/store/writer.go
new file mode 100644
index 00000000..e65134ba
--- /dev/null
+++ b/object/store/writer.go
@@ -0,0 +1,26 @@
+package objectstore
+
+import (
+ "io"
+
+ objectid "codeberg.org/lindenii/furgit/object/id"
+ objecttype "codeberg.org/lindenii/furgit/object/type"
+)
+
+// ObjectWriter writes individual Git objects.
+type ObjectWriter interface {
+ // WriteContent writes one typed object content stream.
+ WriteContent(ty objecttype.Type, size int64, src io.Reader) (objectid.ObjectID, error)
+
+ // WriteFull writes one full serialized object stream as "type size\0content".
+ WriteFull(src io.Reader) (objectid.ObjectID, error)
+}
+
+// PackWriteOptions controls one pack write operation.
+type PackWriteOptions struct{}
+
+// PackWriter writes Git pack streams.
+type PackWriter interface {
+ // WritePack ingests one pack stream.
+ WritePack(src io.Reader, opts PackWriteOptions) error
+}