vector::sinks::aws_kinesis::record

Trait SendRecord

Source
pub trait SendRecord {
    type T;
    type E;

    // Required method
    fn send(
        &self,
        records: Vec<Self::T>,
        stream_name: String,
    ) -> impl Future<Output = Result<KinesisResponse, SdkError<Self::E, HttpResponse>>> + Send;
}
Expand description

Capable of sending records.

Required Associated Types§

Source

type T

Source

type E

Required Methods§

Source

fn send( &self, records: Vec<Self::T>, stream_name: String, ) -> impl Future<Output = Result<KinesisResponse, SdkError<Self::E, HttpResponse>>> + Send

Sends the records.

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§