ExStorageService.Cluster.ReadCoordinator (ex_storage_service v0.6.3)

Selects a checksum-valid local or remote source for one committed blob.

Metadata and membership reads are strong. Remote candidates are tried in a deterministic, bounded order before response bytes are emitted. A failure after streaming begins is propagated to the adapter so it can cancel the response; the same response is never restarted from another replica.

Summary

Types

range()

Functions

open(context, hash, size, range, opts)

Types

range()

@type range() :: nil | :all | {non_neg_integer(), non_neg_integer()}

Functions

open(context, hash, size, range, opts)

@spec open(
  ExStorageService.Context.t(),
  binary(),
  non_neg_integer(),
  range(),
  keyword()
) ::
  {:ok, ExStorageService.BlobStore.Source.t()} | {:error, term()}