Struct CodecRegistry 

pub struct CodecRegistry { /* private fields */ }

codec dispatch レジストリ。Arc 越しに S4Service / 複数タスクから共有する想定。

Implementations

impl CodecRegistry

pub fn new(default: CodecKind) -> Self

default で指定した codec が PUT 時の codec として使われる (dispatcher が別 kind を選んだ場合は、その kind が登録されていれば優先)。

pub fn register(&mut self, codec: Arc<dyn Codec>) -> &mut Self

codec を登録。同じ kind を 2 度登録すると後勝ち。

pub fn with(self, codec: Arc<dyn Codec>) -> Self

register の chain 用 builder

pub fn kinds(&self) -> impl Iterator<Item = CodecKind> + '_

登録済 kind 一覧

pub fn default_kind(&self) -> CodecKind

default kind

pub async fn compress( &self, input: Bytes, kind: CodecKind, ) -> Result<(Bytes, ChunkManifest), CodecError>

指定 kind の codec で compress

pub async fn decompress( &self, input: Bytes, manifest: &ChunkManifest, ) -> Result<Bytes, CodecError>

manifest が指す codec で decompress (本命の dispatch path)

Trait Implementations

impl Debug for CodecRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.