17 #include <aws/core/utils/Outcome.h> 18 #include <aws/kinesis/KinesisClient.h> 19 #include <aws/kinesis/model/GetRecordsRequest.h> 20 #include <aws/kinesis/model/GetRecordsResult.h> 33 : KinesisClient(config), Client::ThrottlingManager()
43 Model::GetRecordsOutcome
GetRecords(
const Model::GetRecordsRequest & request)
const override 45 auto get_records_base =
46 [
this](
const Model::GetRecordsRequest & request) -> Model::GetRecordsOutcome {
47 return this->KinesisClient::GetRecords(request);
49 return MakeCall<Model::GetRecordsOutcome, Model::GetRecordsRequest, KinesisErrors>(
50 get_records_base, request, __func__, KinesisErrors::PROVISIONED_THROUGHPUT_EXCEEDED,
true);
Model::GetRecordsOutcome GetRecords(const Model::GetRecordsRequest &request) const override
KinesisClientFacade(Aws::Client::ClientConfiguration config)
void SetMaxApiTps(const std::string &api, double tps)