refstore/files: Accept timeout instead of reading from config

And split things up again.

1 files changed, 17 insertions, 0 deletions

diff --git a/refstore/files/transaction_queue.go b/refstore/files/transaction_queue.go
new file mode 100644
index 00000000..59b49419
--- /dev/null
+++ b/refstore/files/transaction_queue.go
@@ -0,0 +1,17 @@
+package files
+
+func (tx *Transaction) queue(op txOp) error {
+	err := tx.ensureOpen()
+	if err != nil {
+		return err
+	}
+
+	err = tx.validateOp(op)
+	if err != nil {
+		return err
+	}
+
+	tx.ops = append(tx.ops, op)
+
+	return nil
+}