konserve-gcs.core — io.replikativ/konserve-gcs 0.1.8

*default-bucket* clj

*deletion-batch-size* clj

*output-stream-buffer-size* clj

blob-exists? clj

(blob-exists? client bucket store-path blob-key)

blob-id clj

(blob-id bucket blob-store-path)

(blob-id bucket store-path blob-key)

cloud-storage-client clj

(cloud-storage-client {:keys [client project-id host]})

Create a GCS client. Supports :host for emulator endpoint (e.g., 'http://localhost:4443').

connect-store clj

(connect-store spec & {:keys [opts config] :as params})

copy-blob clj

(copy-blob client bucket store-path from-blob-key to-blob-key)

Copy blob from one key to another. Returns nil if source doesn't exist.

create-bucket clj

(create-bucket client location bucket)

delete-blob clj

(delete-blob client bucket store-path blob-key)

Delete blob. Returns true if deleted, false if not found.

delete-many-blobs clj

(delete-many-blobs client bucket blob-store-paths)

delete-store clj

(delete-store spec & {:keys [opts]})

get-bucket clj

(get-bucket client bucket-name)

list-objects clj

(list-objects client bucket store-path)

read-blob clj

(read-blob client blob-id)

read-blob-with-generation clj

(read-blob-with-generation client blob-id)

Read blob and return map with :data and :generation, or nil if not found. Returns nil if blob doesn't exist or was updated during read (stale generation).

release clj

(release store env)

spec->store-path clj

(spec->store-path {:keys [store-path store-id]})

store-exists? clj

(store-exists? spec & {:keys [opts]})

Check if a konserve store exists at the given spec.

write-blob clj

(write-blob client blob-id bytes)

write-blob-conditional clj

(write-blob-conditional client blob-id bytes expected-generation)

Write blob with generation match precondition. Returns true on success, false on conflict. GCS returns HTTP 412 (Precondition Failed) when generation doesn't match.