vector/sinks/aws_kinesis/streams/
mod.rs

1mod config;
2mod integration_tests;
3mod record;
4
5use aws_sdk_kinesis::{
6    operation::put_records::PutRecordsError, types::PutRecordsRequestEntry, Client,
7};
8
9pub use super::{
10    config::{build_sink, KinesisSinkBaseConfig},
11    record::{Record, SendRecord},
12    request_builder,
13    service::{KinesisResponse, KinesisService},
14    sink,
15};
16
17pub use self::config::KinesisStreamsSinkConfig;
18
19pub type KinesisError = PutRecordsError;
20pub type KinesisRecord = PutRecordsRequestEntry;
21pub type KinesisClient = Client;