1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
pub use crate::operation::update_flow_output::_update_flow_output_output::UpdateFlowOutputOutputBuilder;
pub use crate::operation::update_flow_output::_update_flow_output_input::UpdateFlowOutputInputBuilder;
/// Fluent builder constructing a request to `UpdateFlowOutput`.
///
/// Updates an existing flow output.
#[derive(std::clone::Clone, std::fmt::Debug)]
pub struct UpdateFlowOutputFluentBuilder {
handle: std::sync::Arc<crate::client::Handle>,
inner: crate::operation::update_flow_output::builders::UpdateFlowOutputInputBuilder,
}
impl UpdateFlowOutputFluentBuilder {
/// Creates a new `UpdateFlowOutput`.
pub(crate) fn new(handle: std::sync::Arc<crate::client::Handle>) -> Self {
Self {
handle,
inner: Default::default(),
}
}
/// Consume this builder, creating a customizable operation that can be modified before being
/// sent. The operation's inner [http::Request] can be modified as well.
pub async fn customize(
self,
) -> std::result::Result<
crate::client::customize::CustomizableOperation<
crate::operation::update_flow_output::UpdateFlowOutput,
aws_http::retry::AwsResponseRetryClassifier,
>,
aws_smithy_http::result::SdkError<
crate::operation::update_flow_output::UpdateFlowOutputError,
>,
> {
let handle = self.handle.clone();
let operation = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
Ok(crate::client::customize::CustomizableOperation { handle, operation })
}
/// Sends the request and returns the response.
///
/// If an error occurs, an `SdkError` will be returned with additional details that
/// can be matched against.
///
/// By default, any retryable failures will be retried twice. Retry behavior
/// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
/// set when configuring the client.
pub async fn send(
self,
) -> std::result::Result<
crate::operation::update_flow_output::UpdateFlowOutputOutput,
aws_smithy_http::result::SdkError<
crate::operation::update_flow_output::UpdateFlowOutputError,
>,
> {
let op = self
.inner
.build()
.map_err(aws_smithy_http::result::SdkError::construction_failure)?
.make_operation(&self.handle.conf)
.await
.map_err(aws_smithy_http::result::SdkError::construction_failure)?;
self.handle.client.call(op).await
}
/// Appends an item to `CidrAllowList`.
///
/// To override the contents of this collection use [`set_cidr_allow_list`](Self::set_cidr_allow_list).
///
/// The range of IP addresses that should be allowed to initiate output requests to this flow. These IP addresses should be in the form of a Classless Inter-Domain Routing (CIDR) block; for example, 10.0.0.0/16.
pub fn cidr_allow_list(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.cidr_allow_list(input.into());
self
}
/// The range of IP addresses that should be allowed to initiate output requests to this flow. These IP addresses should be in the form of a Classless Inter-Domain Routing (CIDR) block; for example, 10.0.0.0/16.
pub fn set_cidr_allow_list(
mut self,
input: std::option::Option<std::vec::Vec<std::string::String>>,
) -> Self {
self.inner = self.inner.set_cidr_allow_list(input);
self
}
/// A description of the output. This description appears only on the AWS Elemental MediaConnect console and will not be seen by the end user.
pub fn description(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.description(input.into());
self
}
/// A description of the output. This description appears only on the AWS Elemental MediaConnect console and will not be seen by the end user.
pub fn set_description(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_description(input);
self
}
/// The IP address where you want to send the output.
pub fn destination(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.destination(input.into());
self
}
/// The IP address where you want to send the output.
pub fn set_destination(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_destination(input);
self
}
/// The type of key used for the encryption. If no keyType is provided, the service will use the default setting (static-key). Allowable encryption types: static-key.
pub fn encryption(mut self, input: crate::types::UpdateEncryption) -> Self {
self.inner = self.inner.encryption(input);
self
}
/// The type of key used for the encryption. If no keyType is provided, the service will use the default setting (static-key). Allowable encryption types: static-key.
pub fn set_encryption(
mut self,
input: std::option::Option<crate::types::UpdateEncryption>,
) -> Self {
self.inner = self.inner.set_encryption(input);
self
}
/// The flow that is associated with the output that you want to update.
pub fn flow_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.flow_arn(input.into());
self
}
/// The flow that is associated with the output that you want to update.
pub fn set_flow_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_flow_arn(input);
self
}
/// The maximum latency in milliseconds. This parameter applies only to RIST-based, Zixi-based, and Fujitsu-based streams.
pub fn max_latency(mut self, input: i32) -> Self {
self.inner = self.inner.max_latency(input);
self
}
/// The maximum latency in milliseconds. This parameter applies only to RIST-based, Zixi-based, and Fujitsu-based streams.
pub fn set_max_latency(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_max_latency(input);
self
}
/// Appends an item to `MediaStreamOutputConfigurations`.
///
/// To override the contents of this collection use [`set_media_stream_output_configurations`](Self::set_media_stream_output_configurations).
///
/// The media streams that are associated with the output, and the parameters for those associations.
pub fn media_stream_output_configurations(
mut self,
input: crate::types::MediaStreamOutputConfigurationRequest,
) -> Self {
self.inner = self.inner.media_stream_output_configurations(input);
self
}
/// The media streams that are associated with the output, and the parameters for those associations.
pub fn set_media_stream_output_configurations(
mut self,
input: std::option::Option<
std::vec::Vec<crate::types::MediaStreamOutputConfigurationRequest>,
>,
) -> Self {
self.inner = self.inner.set_media_stream_output_configurations(input);
self
}
/// The minimum latency in milliseconds for SRT-based streams. In streams that use the SRT protocol, this value that you set on your MediaConnect source or output represents the minimal potential latency of that connection. The latency of the stream is set to the highest number between the sender’s minimum latency and the receiver’s minimum latency.
pub fn min_latency(mut self, input: i32) -> Self {
self.inner = self.inner.min_latency(input);
self
}
/// The minimum latency in milliseconds for SRT-based streams. In streams that use the SRT protocol, this value that you set on your MediaConnect source or output represents the minimal potential latency of that connection. The latency of the stream is set to the highest number between the sender’s minimum latency and the receiver’s minimum latency.
pub fn set_min_latency(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_min_latency(input);
self
}
/// The ARN of the output that you want to update.
pub fn output_arn(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.output_arn(input.into());
self
}
/// The ARN of the output that you want to update.
pub fn set_output_arn(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_output_arn(input);
self
}
/// The port to use when content is distributed to this output.
pub fn port(mut self, input: i32) -> Self {
self.inner = self.inner.port(input);
self
}
/// The port to use when content is distributed to this output.
pub fn set_port(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_port(input);
self
}
/// The protocol to use for the output.
pub fn protocol(mut self, input: crate::types::Protocol) -> Self {
self.inner = self.inner.protocol(input);
self
}
/// The protocol to use for the output.
pub fn set_protocol(mut self, input: std::option::Option<crate::types::Protocol>) -> Self {
self.inner = self.inner.set_protocol(input);
self
}
/// The remote ID for the Zixi-pull stream.
pub fn remote_id(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.remote_id(input.into());
self
}
/// The remote ID for the Zixi-pull stream.
pub fn set_remote_id(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_remote_id(input);
self
}
/// The port that the flow uses to send outbound requests to initiate connection with the sender.
pub fn sender_control_port(mut self, input: i32) -> Self {
self.inner = self.inner.sender_control_port(input);
self
}
/// The port that the flow uses to send outbound requests to initiate connection with the sender.
pub fn set_sender_control_port(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_sender_control_port(input);
self
}
/// The IP address that the flow communicates with to initiate connection with the sender.
pub fn sender_ip_address(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.sender_ip_address(input.into());
self
}
/// The IP address that the flow communicates with to initiate connection with the sender.
pub fn set_sender_ip_address(
mut self,
input: std::option::Option<std::string::String>,
) -> Self {
self.inner = self.inner.set_sender_ip_address(input);
self
}
/// The smoothing latency in milliseconds for RIST, RTP, and RTP-FEC streams.
pub fn smoothing_latency(mut self, input: i32) -> Self {
self.inner = self.inner.smoothing_latency(input);
self
}
/// The smoothing latency in milliseconds for RIST, RTP, and RTP-FEC streams.
pub fn set_smoothing_latency(mut self, input: std::option::Option<i32>) -> Self {
self.inner = self.inner.set_smoothing_latency(input);
self
}
/// The stream ID that you want to use for this transport. This parameter applies only to Zixi and SRT caller-based streams.
pub fn stream_id(mut self, input: impl Into<std::string::String>) -> Self {
self.inner = self.inner.stream_id(input.into());
self
}
/// The stream ID that you want to use for this transport. This parameter applies only to Zixi and SRT caller-based streams.
pub fn set_stream_id(mut self, input: std::option::Option<std::string::String>) -> Self {
self.inner = self.inner.set_stream_id(input);
self
}
/// The name of the VPC interface attachment to use for this output.
pub fn vpc_interface_attachment(mut self, input: crate::types::VpcInterfaceAttachment) -> Self {
self.inner = self.inner.vpc_interface_attachment(input);
self
}
/// The name of the VPC interface attachment to use for this output.
pub fn set_vpc_interface_attachment(
mut self,
input: std::option::Option<crate::types::VpcInterfaceAttachment>,
) -> Self {
self.inner = self.inner.set_vpc_interface_attachment(input);
self
}
}