vector/sinks/aws_kinesis/streams/
mod.rs

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