Struct DefaultComponentCodec 

pub struct DefaultComponentCodec<C> { /* private fields */ }

Wraps an existing VersionedStateCodec as a ComponentStateCodec without requiring a second codec implementation.

Implementations

impl<C> DefaultComponentCodec<C>

pub const fn new( schema: C, codec_id: CodecId, codec_version: CodecVersion, restartability: RestartabilityDeclaration, ) -> DefaultComponentCodec<C>

Wraps schema with the codec identity/version and restartability declaration this component requires.

pub fn with_codec_upgrades( self, upgrades: Vec<CodecVersionUpgrade>, ) -> DefaultComponentCodec<C>

Declares the directed codec-version upgrades this codec can apply.

pub const fn with_sensitivity( self, sensitivity: StateSensitivity, ) -> DefaultComponentCodec<C>

Declares this component’s state sensitivity.

Trait Implementations

impl<T, C> ComponentStateCodec<T> for DefaultComponentCodec<C>

where C: VersionedStateCodec<T>,

fn codec_id(&self) -> &CodecId

Returns the stable codec identifier.

fn codec_version(&self) -> CodecVersion

Returns the version emitted when encoding.

fn codec_upgrades(&self) -> &[CodecVersionUpgrade]

Declares the directed codec-version upgrades this codec can apply.

fn sensitivity(&self) -> StateSensitivity

Declares this component’s state sensitivity.

fn restartability(&self) -> RestartabilityDeclaration

Declares whether this component can honestly claim restartability.

impl<T, C> VersionedStateCodec<T> for DefaultComponentCodec<C>

where C: VersionedStateCodec<T>,

fn schema_id(&self) -> &StateSchemaId

Returns the stable schema identifier.

fn current_version(&self) -> StateSchemaVersion

Returns the version emitted by encode.

fn upgrades(&self) -> &[StateSchemaUpgrade]

Declares the directed upgrades this codec can apply.

fn encode(&self, value: &T) -> Result<Vec<u8>, StateCodecError>

Encodes the current typed value as one JSON object.

fn decode(&self, payload: &[u8]) -> Result<T, StateCodecError>

Decodes one JSON-object payload already at current_version.