Struct vector::sinks::aws_kinesis::sink::BatchKinesisRequest

pub struct BatchKinesisRequest<R>
where
    R: Record + Clone,
{
    pub events: Vec<KinesisRequest<R>>,
    /* private fields */
}

Fields

events: Vec<KinesisRequest<R>>

Trait Implementations

impl<R> Clone for BatchKinesisRequest<R>

where R: Record + Clone,

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<R> Finalizable for BatchKinesisRequest<R>

where R: Record + Clone,

fn take_finalizers(&mut self) -> EventFinalizers

Consumes the finalizers of this object.

impl<R> MetaDescriptive for BatchKinesisRequest<R>

where R: Record + Clone,

fn get_metadata(&self) -> &RequestMetadata

Returns the RequestMetadata associated with this object.

fn metadata_mut(&mut self) -> &mut RequestMetadata

impl<R, C, T, E> Service<BatchKinesisRequest<R>> for KinesisService<C, T, E>

where R: Record<T = T> + Clone, C: SendRecord + Clone + Sync + Send + 'static, Vec<<C as SendRecord>::T>: FromIterator<T>, <C as SendRecord>::T: Send,

type Response = KinesisResponse

Responses given by the service.

type Error = SdkError<<C as SendRecord>::E, Response>

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<KinesisService<C, T, E> as Service<BatchKinesisRequest<R>>>::Response, <KinesisService<C, T, E> as Service<BatchKinesisRequest<R>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, requests: BatchKinesisRequest<R>) -> Self::Future

Process the request and return the response asynchronously.