Trait vector::sinks::aws_kinesis::record::Record

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;
}

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

type T

Required Methods

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

Create a new instance of this record.

fn encoded_length(&self) -> usize

Returns the encoded length of the record.

fn get(self) -> Self::T

Moves the contained record to the caller.

Object Safety

This trait is not object safe.

Implementors