Struct EncoderCodec 

pub struct EncoderCodec<E> { /* private fields */ }

A Codec adapter that wraps any EventEncoder.

EncoderCodec calls EventEncoder::encode_key for the key and EventEncoder::encode for the value. It is the canonical bridge between the lower-level EventEncoder trait and the higher-level Codec trait.

Example

use rustcdc::codec::{Codec, EncoderCodec, JsonEncoder};
use rustcdc::{Event, Operation, EVENT_ENVELOPE_VERSION};
use serde_json::json;

let codec = EncoderCodec::new(JsonEncoder);
let event = Event {
    after: Some(json!({"id": 1})),
    op: Operation::Insert,
    primary_key: Some(vec!["id".into()]),
    ..Event::default()
};
let out = codec.encode(&event).unwrap();
assert_eq!(out.content_type, "application/json");
assert!(out.key.is_some());

Implementations

impl<E: EventEncoder> EncoderCodec<E>

pub fn new(encoder: E) -> Self

Wrap an EventEncoder as a Codec.

pub fn encoder(&self) -> &E

Borrow the inner encoder.

pub fn into_encoder(self) -> E

Unwrap the inner encoder.

Trait Implementations

impl<E: Clone> Clone for EncoderCodec<E>

fn clone(&self) -> EncoderCodec<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E: EventEncoder> Codec for EncoderCodec<E>

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.

impl<E: Debug> Debug for EncoderCodec<E>

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

Formats the value using the given formatter.

impl<E: Default> Default for EncoderCodec<E>

fn default() -> EncoderCodec<E>

Returns the “default value” for a type.