Struct BoxedCodec 

pub struct BoxedCodec(/* private fields */);

A type-erased Codec that wraps any concrete codec behind a single type.

BoxedCodec removes the need for generic parameters when storing or passing codecs across pipeline stages that support multiple encodings (JSON, CloudEvents, Avro, …) without a shared enum.

Construction

use rustcdc::codec::{BoxedCodec, Codec, JsonCodec};

// Via the .boxed() convenience method (preferred):
let codec: BoxedCodec = JsonCodec::default().boxed();

// Or explicitly:
let codec = BoxedCodec::new(JsonCodec::default());

Implementations

impl BoxedCodec

pub fn new<C: Codec + 'static>(codec: C) -> Self

Wrap any Codec implementation in a type-erased BoxedCodec.

Prefer Codec::boxed for ergonomic construction.

Trait Implementations

impl Codec for BoxedCodec

fn encode(&self, event: &Event) -> Result<CodecOutput>

Encode the event into a key + value pair.

fn content_type(&self) -> &'static str

The MIME content type for every successful value byte sequence.

fn boxed(self) -> BoxedCodec

where Self: Sized + 'static,

Wrap self in a BoxedCodec, erasing the concrete type.