konserve-azure-blob.core — org.replikativ/konserve-azure-blob 0.1.3

Azure Blob Storage backend for konserve.

build-service-client clj

(build-service-client {:keys [service-client connection-string endpoint
                              account-name credential service-version]})

Build a BlobServiceClient from a backend spec.

Supported inputs, in precedence order:

• :service-client
• :connection-string
• :endpoint plus :credential
• :account-name plus DefaultAzureCredential

clear-client-cache! clj

(clear-client-cache!)

Forget cached service clients. Azure SDK clients do not require closing.

client-cache-size clj

(client-cache-size)

Number of shared clients currently retained by the bounded cache.

connect-store clj

(connect-store spec & {:keys [opts] :or {opts {:sync? true}}})

Connect a DefaultStore to Azure Blob Storage. The multimethod API should be preferred by applications; this lower-level entry point retains the sibling backends' direct API.

default-buffer-size clj

default-container clj

default-max-edn-value-size clj

default-max-metadata-size clj

default-service-version clj

delete-store clj

(delete-store spec & {:keys [opts] :or {opts {:sync? true}}})

io-executor-stats clj

(io-executor-stats)

Current bounded I/O executor utilization, for monitoring and tests.

io-queue-capacity clj

io-thread-count clj

max-cached-clients clj

read-object clj

(read-object container-client name)

Read a complete blob and return {:data byte-array :etag string}, or ::not-found. This low-level helper intentionally materializes its result; normal store reads use bounded ranges or streams instead.

release clj

(release store-instance env)

service-client clj

(service-client spec)

Return an injected client or a shared client for this endpoint and credential set.

shutdown-io-executor! clj

(shutdown-io-executor!)

Stop the shared daemon I/O executor, primarily for application shutdown.

spec->store-path clj

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

write-object! clj

(write-object! container-client name bytes expected-etag)

Create or overwrite a blob. When expected-etag is non-nil, use If-Match and return false on a CAS conflict; otherwise return true.