vector::sinks::aws_kinesis::record

Trait Record

Source
pub trait Record {
    type T;

    // Required methods
    fn new(payload_bytes: &Bytes, partition_key: &str) -> Self;
    fn encoded_length(&self) -> usize;
    fn get(self) -> Self::T;
}
Expand description

An AWS Kinesis record type primarily to store the underlying aws crates’ actual record T, and to abstract the encoded length calculation.

Required Associated Types§

Source

type T

Required Methods§

Source

fn new(payload_bytes: &Bytes, partition_key: &str) -> Self

Create a new instance of this record.

Source

fn encoded_length(&self) -> usize

Returns the encoded length of the record.

Source

fn get(self) -> Self::T

Moves the contained record to the caller.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§