Trait vector::sinks::aws_kinesis::record::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.

Object Safety§

This trait is not object safe.

Implementors§