SegmentBlobStore

一级存储接口:字节对象的 put / get / head / list / delete。 S3 / OSS / COS / MinIO / GCS / Azure / GridFS / 文件系统皆此级;分段、编码、清单提交、 热盘 LRU 与重试由引擎内置分层核完成,适配器只需守 StoreError 四类错误约定。

继承于

• ChaosBlobStore

属性

capabilities

readonly capabilities: BlobStoreCapabilities;

方法

delete()

delete(keys, signal?): Promise<void>;

不存在不算错

参数

keys

readonly string[]

signal?

any

返回

Promise<void>

---

get()

get(
   key,
   range?,
   signal?
): Promise<ReadableStream<Uint8Array<ArrayBufferLike>>>;

返回的流由引擎消费与关闭;适配器不得整段读入内存

参数

key

string

range?

ByteRange

signal?

any

返回

Promise<ReadableStream<Uint8Array<ArrayBufferLike>>>

---

head()

head(key, signal?): Promise<BlobMeta | null>;

不存在 → null(不抛)

参数

key

string

signal?

any

返回

Promise<BlobMeta | null>

---

list()

list(
   prefix,
   cursor?,
   signal?
): AsyncIterable<BlobListEntry>;

允许最终一致;引擎只用于 gc 与盘点

参数

prefix

string

cursor?

string

signal?

any

返回

AsyncIterable<BlobListEntry>

---

put()

put(
   key,
   body,
   meta,
   opts?
): Promise<PutResult>;

至少一次、按 meta.sha256 幂等(同键同哈希重复 put 必须成功且无副作用)

参数

key

string

body

ReadableStream<Uint8Array<ArrayBufferLike>>

meta

BlobMeta

opts?

PutOptions

返回

Promise<PutResult>

이 페이지가 도움이 되었나요?

예아니요