ExStorageService.BlobStore.ReadRepair (ex_storage_service v0.6.4)

Bounded tee-to-local repair for full remote blob streams.

Each upstream chunk is written before it is forwarded, so memory remains bounded by one transport chunk. Final checksum verification, CAS publication, and metadata repair run under the instance replica task supervisor after the client stream completes.

Summary

Functions

wrap(source, hash, size, opts)

Functions

wrap(source, hash, size, opts)

@spec wrap(
  ExStorageService.BlobStore.Source.t(),
  binary(),
  non_neg_integer(),
  keyword()
) ::
  ExStorageService.BlobStore.Source.t()