AWS SDK for C++  1.9.103
AWS SDK for C++
SubscribeToShardRequest.h
Go to the documentation of this file.
1 
6 #pragma once
13 #include <utility>
14 
15 namespace Aws
16 {
17 namespace Kinesis
18 {
19 namespace Model
20 {
21 
25  {
26  public:
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 "SubscribeToShard"; }
34 
35  Aws::String SerializePayload() const override;
36 
38 
43 
47  inline const SubscribeToShardHandler& GetEventStreamHandler() const { return m_handler; }
48 
52  inline void SetEventStreamHandler(const SubscribeToShardHandler& value) { m_handler = value; m_decoder.ResetEventStreamHandler(&m_handler); }
53 
57  inline SubscribeToShardRequest& WithEventStreamHandler(const SubscribeToShardHandler& value) { SetEventStreamHandler(value); return *this; }
58 
59 
64  inline const Aws::String& GetConsumerARN() const{ return m_consumerARN; }
65 
70  inline bool ConsumerARNHasBeenSet() const { return m_consumerARNHasBeenSet; }
71 
76  inline void SetConsumerARN(const Aws::String& value) { m_consumerARNHasBeenSet = true; m_consumerARN = value; }
77 
82  inline void SetConsumerARN(Aws::String&& value) { m_consumerARNHasBeenSet = true; m_consumerARN = std::move(value); }
83 
88  inline void SetConsumerARN(const char* value) { m_consumerARNHasBeenSet = true; m_consumerARN.assign(value); }
89 
94  inline SubscribeToShardRequest& WithConsumerARN(const Aws::String& value) { SetConsumerARN(value); return *this;}
95 
100  inline SubscribeToShardRequest& WithConsumerARN(Aws::String&& value) { SetConsumerARN(std::move(value)); return *this;}
101 
106  inline SubscribeToShardRequest& WithConsumerARN(const char* value) { SetConsumerARN(value); return *this;}
107 
108 
113  inline const Aws::String& GetShardId() const{ return m_shardId; }
114 
119  inline bool ShardIdHasBeenSet() const { return m_shardIdHasBeenSet; }
120 
125  inline void SetShardId(const Aws::String& value) { m_shardIdHasBeenSet = true; m_shardId = value; }
126 
131  inline void SetShardId(Aws::String&& value) { m_shardIdHasBeenSet = true; m_shardId = std::move(value); }
132 
137  inline void SetShardId(const char* value) { m_shardIdHasBeenSet = true; m_shardId.assign(value); }
138 
143  inline SubscribeToShardRequest& WithShardId(const Aws::String& value) { SetShardId(value); return *this;}
144 
149  inline SubscribeToShardRequest& WithShardId(Aws::String&& value) { SetShardId(std::move(value)); return *this;}
150 
155  inline SubscribeToShardRequest& WithShardId(const char* value) { SetShardId(value); return *this;}
156 
157 
161  inline const StartingPosition& GetStartingPosition() const{ return m_startingPosition; }
162 
166  inline bool StartingPositionHasBeenSet() const { return m_startingPositionHasBeenSet; }
167 
171  inline void SetStartingPosition(const StartingPosition& value) { m_startingPositionHasBeenSet = true; m_startingPosition = value; }
172 
176  inline void SetStartingPosition(StartingPosition&& value) { m_startingPositionHasBeenSet = true; m_startingPosition = std::move(value); }
177 
181  inline SubscribeToShardRequest& WithStartingPosition(const StartingPosition& value) { SetStartingPosition(value); return *this;}
182 
186  inline SubscribeToShardRequest& WithStartingPosition(StartingPosition&& value) { SetStartingPosition(std::move(value)); return *this;}
187 
188  private:
189 
190  Aws::String m_consumerARN;
191  bool m_consumerARNHasBeenSet;
192 
193  Aws::String m_shardId;
194  bool m_shardIdHasBeenSet;
195 
196  StartingPosition m_startingPosition;
197  bool m_startingPositionHasBeenSet;
199  SubscribeToShardHandler m_handler;
200 
201  };
202 
203 } // namespace Model
204 } // namespace Kinesis
205 } // namespace Aws
Aws::Kinesis::Model::SubscribeToShardRequest::SetConsumerARN
void SetConsumerARN(const char *value)
Definition: SubscribeToShardRequest.h:88
Aws::Kinesis::Model::SubscribeToShardRequest::WithShardId
SubscribeToShardRequest & WithShardId(Aws::String &&value)
Definition: SubscribeToShardRequest.h:149
Aws::Kinesis::Model::SubscribeToShardRequest::ShardIdHasBeenSet
bool ShardIdHasBeenSet() const
Definition: SubscribeToShardRequest.h:119
Aws::Http::HeaderValueCollection
Aws::Map< Aws::String, Aws::String > HeaderValueCollection
Definition: HttpTypes.h:53
Aws::Kinesis::Model::SubscribeToShardRequest::WithConsumerARN
SubscribeToShardRequest & WithConsumerARN(const char *value)
Definition: SubscribeToShardRequest.h:106
Aws::Kinesis::Model::SubscribeToShardRequest::WithConsumerARN
SubscribeToShardRequest & WithConsumerARN(const Aws::String &value)
Definition: SubscribeToShardRequest.h:94
Aws::Kinesis::Model::SubscribeToShardRequest::WithShardId
SubscribeToShardRequest & WithShardId(const Aws::String &value)
Definition: SubscribeToShardRequest.h:143
Aws::Kinesis::Model::SubscribeToShardRequest::SetShardId
void SetShardId(const Aws::String &value)
Definition: SubscribeToShardRequest.h:125
SubscribeToShardHandler.h
Aws::Kinesis::Model::SubscribeToShardRequest::StartingPositionHasBeenSet
bool StartingPositionHasBeenSet() const
Definition: SubscribeToShardRequest.h:166
Aws::Kinesis::Model::SubscribeToShardRequest::SetConsumerARN
void SetConsumerARN(Aws::String &&value)
Definition: SubscribeToShardRequest.h:82
Aws::Kinesis::Model::SubscribeToShardHandler
Definition: SubscribeToShardHandler.h:28
AWS_KINESIS_API
#define AWS_KINESIS_API
Definition: Kinesis_EXPORTS.h:28
StartingPosition.h
Aws::Kinesis::Model::SubscribeToShardRequest::ConsumerARNHasBeenSet
bool ConsumerARNHasBeenSet() const
Definition: SubscribeToShardRequest.h:70
Aws::Kinesis::Model::SubscribeToShardRequest::GetShardId
const Aws::String & GetShardId() const
Definition: SubscribeToShardRequest.h:113
EventStreamDecoder.h
Aws::Kinesis::Model::SubscribeToShardRequest::GetEventStreamHandler
const SubscribeToShardHandler & GetEventStreamHandler() const
Definition: SubscribeToShardRequest.h:47
KinesisRequest.h
Aws::Kinesis::Model::SubscribeToShardRequest::SetShardId
void SetShardId(Aws::String &&value)
Definition: SubscribeToShardRequest.h:131
Aws::Kinesis::Model::SubscribeToShardRequest::GetServiceRequestName
virtual const char * GetServiceRequestName() const override
Definition: SubscribeToShardRequest.h:33
Aws::Kinesis::Model::SubscribeToShardRequest::GetEventStreamDecoder
Aws::Utils::Event::EventStreamDecoder & GetEventStreamDecoder()
Definition: SubscribeToShardRequest.h:42
Aws::Kinesis::Model::SubscribeToShardRequest::GetStartingPosition
const StartingPosition & GetStartingPosition() const
Definition: SubscribeToShardRequest.h:161
AWSString.h
Aws::Kinesis::Model::SubscribeToShardRequest
Definition: SubscribeToShardRequest.h:25
Aws::Kinesis::KinesisRequest
Definition: KinesisRequest.h:17
Aws::Kinesis::Model::SubscribeToShardRequest::SetStartingPosition
void SetStartingPosition(const StartingPosition &value)
Definition: SubscribeToShardRequest.h:171
Aws::Kinesis::Model::SubscribeToShardRequest::SetEventStreamHandler
void SetEventStreamHandler(const SubscribeToShardHandler &value)
Definition: SubscribeToShardRequest.h:52
Aws::Kinesis::Model::SubscribeToShardRequest::GetRequestSpecificHeaders
Aws::Http::HeaderValueCollection GetRequestSpecificHeaders() const override
Kinesis_EXPORTS.h
Aws::Utils::Event::EventStreamDecoder
Definition: EventStreamDecoder.h:20
Aws::Kinesis::Model::SubscribeToShardRequest::WithShardId
SubscribeToShardRequest & WithShardId(const char *value)
Definition: SubscribeToShardRequest.h:155
Aws
Definition: AccessManagementClient.h:15
Aws::Kinesis::Model::SubscribeToShardRequest::SubscribeToShardRequest
SubscribeToShardRequest()
Aws::Kinesis::Model::SubscribeToShardRequest::WithStartingPosition
SubscribeToShardRequest & WithStartingPosition(StartingPosition &&value)
Definition: SubscribeToShardRequest.h:186
Aws::String
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Definition: AWSString.h:97
Aws::Kinesis::Model::SubscribeToShardRequest::WithEventStreamHandler
SubscribeToShardRequest & WithEventStreamHandler(const SubscribeToShardHandler &value)
Definition: SubscribeToShardRequest.h:57
Aws::Kinesis::Model::SubscribeToShardRequest::SetShardId
void SetShardId(const char *value)
Definition: SubscribeToShardRequest.h:137
Aws::Kinesis::Model::SubscribeToShardRequest::SetConsumerARN
void SetConsumerARN(const Aws::String &value)
Definition: SubscribeToShardRequest.h:76
Aws::Kinesis::Model::StartingPosition
Definition: StartingPosition.h:34
Aws::Kinesis::Model::SubscribeToShardRequest::GetConsumerARN
const Aws::String & GetConsumerARN() const
Definition: SubscribeToShardRequest.h:64
Aws::Kinesis::Model::SubscribeToShardRequest::SerializePayload
Aws::String SerializePayload() const override
Aws::Kinesis::Model::SubscribeToShardRequest::SetStartingPosition
void SetStartingPosition(StartingPosition &&value)
Definition: SubscribeToShardRequest.h:176
Aws::Kinesis::Model::SubscribeToShardRequest::WithStartingPosition
SubscribeToShardRequest & WithStartingPosition(const StartingPosition &value)
Definition: SubscribeToShardRequest.h:181
Aws::Kinesis::Model::SubscribeToShardRequest::WithConsumerARN
SubscribeToShardRequest & WithConsumerARN(Aws::String &&value)
Definition: SubscribeToShardRequest.h:100