Skip to content

Commit d47e2bf

Browse files
committed
Skip backup to reduce latency.
1 parent 848ebe2 commit d47e2bf

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

deps.edn

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{:paths ["src"]
22
:deps {com.taoensso/timbre {:mvn/version "5.1.2"}
3-
io.replikativ/konserve {:mvn/version "0.7.285"}
3+
io.replikativ/konserve {:mvn/version "0.7.319"}
44
io.replikativ/superv.async {:mvn/version "0.3.43"}
55
org.clojure/clojure {:mvn/version "1.10.3"}
66

src/konserve_s3/core.clj

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,8 @@
44
[konserve.impl.storage-layout :refer [PBackingStore PBackingBlob PBackingLock -delete-store header-size]]
55
[konserve.utils :refer [async+sync *default-sync-translation*]]
66
[superv.async :refer [go-try-]]
7-
[taoensso.timbre :refer [info trace]])
7+
[taoensso.timbre :refer [info trace]]
8+
[clojure.core.async :refer [chan]])
89
(:import [java.io ByteArrayInputStream ByteArrayOutputStream]
910
[java.util Arrays]
1011
;; AWS API
@@ -270,7 +271,8 @@
270271
backing (S3Bucket. (s3-client s3-spec) (:bucket s3-spec) (:store-id s3-spec))
271272
config (merge {:opts complete-opts
272273
:config {:sync-blob? true
273-
:in-place? false
274+
:in-place? true
275+
:no-backup? true
274276
:lock-blob? true}
275277
:default-serializer :FressianSerializer
276278
:buffer-size (* 1024 1024)}

0 commit comments

Comments
 (0)