AWS SDK for C++

AWS SDK for C++ Version 1.11.875

Loading...
Searching...
No Matches
CreateStreamRequest.h
1
6#pragma once
7#include <aws/core/utils/memory/stl/AWSMap.h>
8#include <aws/core/utils/memory/stl/AWSString.h>
9#include <aws/kinesis/KinesisRequest.h>
10#include <aws/kinesis/Kinesis_EXPORTS.h>
11#include <aws/kinesis/model/StreamModeDetails.h>
12
13#include <utility>
14
15namespace Aws {
16namespace Kinesis {
17namespace Model {
18
26 public:
27 AWS_KINESIS_API CreateStreamRequest() = default;
28
29 // Service request name is the Operation name which will send this request out,
30 // each operation should has unique request name, so that we can get operation's name from this request.
31 // Note: this is not true for response, multiple operations may have the same response name,
32 // so we can not get operation's name from response.
33 inline virtual const char* GetServiceRequestName() const override { return "CreateStream"; }
34
35 AWS_KINESIS_API Aws::String SerializePayload() const override;
36
38
42 AWS_KINESIS_API EndpointParameters GetEndpointContextParams() const override;
43
45
53 inline const Aws::String& GetStreamName() const { return m_streamName; }
54 inline bool StreamNameHasBeenSet() const { return m_streamNameHasBeenSet; }
55 template <typename StreamNameT = Aws::String>
56 void SetStreamName(StreamNameT&& value) {
57 m_streamNameHasBeenSet = true;
58 m_streamName = std::forward<StreamNameT>(value);
59 }
60 template <typename StreamNameT = Aws::String>
61 CreateStreamRequest& WithStreamName(StreamNameT&& value) {
62 SetStreamName(std::forward<StreamNameT>(value));
63 return *this;
64 }
66
68
73 inline int GetShardCount() const { return m_shardCount; }
74 inline bool ShardCountHasBeenSet() const { return m_shardCountHasBeenSet; }
75 inline void SetShardCount(int value) {
76 m_shardCountHasBeenSet = true;
77 m_shardCount = value;
78 }
80 SetShardCount(value);
81 return *this;
82 }
84
86
91 inline const StreamModeDetails& GetStreamModeDetails() const { return m_streamModeDetails; }
92 inline bool StreamModeDetailsHasBeenSet() const { return m_streamModeDetailsHasBeenSet; }
93 template <typename StreamModeDetailsT = StreamModeDetails>
94 void SetStreamModeDetails(StreamModeDetailsT&& value) {
95 m_streamModeDetailsHasBeenSet = true;
96 m_streamModeDetails = std::forward<StreamModeDetailsT>(value);
97 }
98 template <typename StreamModeDetailsT = StreamModeDetails>
99 CreateStreamRequest& WithStreamModeDetails(StreamModeDetailsT&& value) {
100 SetStreamModeDetails(std::forward<StreamModeDetailsT>(value));
101 return *this;
102 }
104
106
110 inline const Aws::Map<Aws::String, Aws::String>& GetTags() const { return m_tags; }
111 inline bool TagsHasBeenSet() const { return m_tagsHasBeenSet; }
112 template <typename TagsT = Aws::Map<Aws::String, Aws::String>>
113 void SetTags(TagsT&& value) {
114 m_tagsHasBeenSet = true;
115 m_tags = std::forward<TagsT>(value);
116 }
117 template <typename TagsT = Aws::Map<Aws::String, Aws::String>>
119 SetTags(std::forward<TagsT>(value));
120 return *this;
121 }
122 template <typename TagsKeyT = Aws::String, typename TagsValueT = Aws::String>
123 CreateStreamRequest& AddTags(TagsKeyT&& key, TagsValueT&& value) {
124 m_tagsHasBeenSet = true;
125 m_tags.emplace(std::forward<TagsKeyT>(key), std::forward<TagsValueT>(value));
126 return *this;
127 }
129
131
136 inline int GetWarmThroughputMiBps() const { return m_warmThroughputMiBps; }
137 inline bool WarmThroughputMiBpsHasBeenSet() const { return m_warmThroughputMiBpsHasBeenSet; }
138 inline void SetWarmThroughputMiBps(int value) {
139 m_warmThroughputMiBpsHasBeenSet = true;
140 m_warmThroughputMiBps = value;
141 }
144 return *this;
145 }
147
149
153 inline int GetMaxRecordSizeInKiB() const { return m_maxRecordSizeInKiB; }
154 inline bool MaxRecordSizeInKiBHasBeenSet() const { return m_maxRecordSizeInKiBHasBeenSet; }
155 inline void SetMaxRecordSizeInKiB(int value) {
156 m_maxRecordSizeInKiBHasBeenSet = true;
157 m_maxRecordSizeInKiB = value;
158 }
161 return *this;
162 }
164 private:
165 Aws::String m_streamName;
166
167 int m_shardCount{0};
168
169 StreamModeDetails m_streamModeDetails;
170
172
173 int m_warmThroughputMiBps{0};
174
175 int m_maxRecordSizeInKiB{0};
176 bool m_streamNameHasBeenSet = false;
177 bool m_shardCountHasBeenSet = false;
178 bool m_streamModeDetailsHasBeenSet = false;
179 bool m_tagsHasBeenSet = false;
180 bool m_warmThroughputMiBpsHasBeenSet = false;
181 bool m_maxRecordSizeInKiBHasBeenSet = false;
182};
183
184} // namespace Model
185} // namespace Kinesis
186} // namespace Aws
Aws::Endpoint::EndpointParameters EndpointParameters
AWS_KINESIS_API Aws::Http::HeaderValueCollection GetRequestSpecificHeaders() const override
CreateStreamRequest & WithShardCount(int value)
virtual const char * GetServiceRequestName() const override
CreateStreamRequest & WithStreamName(StreamNameT &&value)
void SetStreamModeDetails(StreamModeDetailsT &&value)
CreateStreamRequest & WithStreamModeDetails(StreamModeDetailsT &&value)
CreateStreamRequest & WithTags(TagsT &&value)
CreateStreamRequest & WithWarmThroughputMiBps(int value)
AWS_KINESIS_API Aws::String SerializePayload() const override
CreateStreamRequest & AddTags(TagsKeyT &&key, TagsValueT &&value)
CreateStreamRequest & WithMaxRecordSizeInKiB(int value)
const StreamModeDetails & GetStreamModeDetails() const
AWS_KINESIS_API CreateStreamRequest()=default
const Aws::Map< Aws::String, Aws::String > & GetTags() const
AWS_KINESIS_API EndpointParameters GetEndpointContextParams() const override
Aws::Map< Aws::String, Aws::String > HeaderValueCollection
std::map< K, V, std::less< K >, Aws::Allocator< std::pair< const K, V > > > Map
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String