aws_sdk_observabilityadmin/operation/update_telemetry_pipeline/builders.rs
1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2pub use crate::operation::update_telemetry_pipeline::_update_telemetry_pipeline_output::UpdateTelemetryPipelineOutputBuilder;
3
4pub use crate::operation::update_telemetry_pipeline::_update_telemetry_pipeline_input::UpdateTelemetryPipelineInputBuilder;
5
6impl crate::operation::update_telemetry_pipeline::builders::UpdateTelemetryPipelineInputBuilder {
7 /// Sends a request with this input using the given client.
8 pub async fn send_with(
9 self,
10 client: &crate::Client,
11 ) -> ::std::result::Result<
12 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineOutput,
13 ::aws_smithy_runtime_api::client::result::SdkError<
14 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineError,
15 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
16 >,
17 > {
18 let mut fluent_builder = client.update_telemetry_pipeline();
19 fluent_builder.inner = self;
20 fluent_builder.send().await
21 }
22}
23/// Fluent builder constructing a request to `UpdateTelemetryPipeline`.
24///
25/// <p>Updates the configuration of an existing telemetry pipeline.</p><note>
26/// <p>The following attributes cannot be updated after pipeline creation:</p>
27/// <ul>
28/// <li>
29/// <p><b>Pipeline name</b> - The pipeline name is immutable</p></li>
30/// <li>
31/// <p><b>Pipeline ARN</b> - The ARN is automatically generated and cannot be changed</p></li>
32/// <li>
33/// <p><b>Source type</b> - Once a pipeline is created with a specific source type (such as S3, CloudWatch Logs, GitHub, or third-party sources), it cannot be changed to a different source type</p></li>
34/// </ul>
35/// <p>Processors can be added, removed, or modified. However, some processors are not supported for third-party pipelines and cannot be added through updates.</p>
36/// </note>
37/// <p><b>Source-Specific Update Rules</b></p>
38/// <dl>
39/// <dt>
40/// CloudWatch Logs Sources (Vended and Custom)
41/// </dt>
42/// <dd>
43/// <p><b>Updatable:</b> <code>sts_role_arn</code></p>
44/// <p><b>Fixed:</b> <code>data_source_name</code>, <code>data_source_type</code>, sink (must remain <code>@original</code>)</p>
45/// </dd>
46/// <dt>
47/// S3 Sources (Crowdstrike, Zscaler, SentinelOne, Custom)
48/// </dt>
49/// <dd>
50/// <p><b>Updatable:</b> All SQS configuration parameters, <code>sts_role_arn</code>, codec settings, compression type, bucket ownership settings, sink log group</p>
51/// <p><b>Fixed:</b> <code>notification_type</code>, <code>aws.region</code></p>
52/// </dd>
53/// <dt>
54/// GitHub Audit Logs
55/// </dt>
56/// <dd>
57/// <p><b>Updatable:</b> All Amazon Web Services Secrets Manager attributes, <code>scope</code> (can switch between ORGANIZATION/ENTERPRISE), <code>organization</code> or <code>enterprise</code> name, <code>range</code>, authentication credentials (PAT or GitHub App)</p>
58/// </dd>
59/// <dt>
60/// Microsoft Sources (Entra ID, Office365, Windows)
61/// </dt>
62/// <dd>
63/// <p><b>Updatable:</b> All Amazon Web Services Secrets Manager attributes, <code>tenant_id</code>, <code>workspace_id</code> (Windows only), OAuth2 credentials (<code>client_id</code>, <code>client_secret</code>)</p>
64/// </dd>
65/// <dt>
66/// Okta Sources (SSO, Auth0)
67/// </dt>
68/// <dd>
69/// <p><b>Updatable:</b> All Amazon Web Services Secrets Manager attributes, <code>domain</code>, <code>range</code> (SSO only), OAuth2 credentials (<code>client_id</code>, <code>client_secret</code>)</p>
70/// </dd>
71/// <dt>
72/// Palo Alto Networks
73/// </dt>
74/// <dd>
75/// <p><b>Updatable:</b> All Amazon Web Services Secrets Manager attributes, <code>hostname</code>, basic authentication credentials (<code>username</code>, <code>password</code>)</p>
76/// </dd>
77/// <dt>
78/// ServiceNow CMDB
79/// </dt>
80/// <dd>
81/// <p><b>Updatable:</b> All Amazon Web Services Secrets Manager attributes, <code>instance_url</code>, <code>range</code>, OAuth2 credentials (<code>client_id</code>, <code>client_secret</code>)</p>
82/// </dd>
83/// <dt>
84/// Wiz CNAPP
85/// </dt>
86/// <dd>
87/// <p><b>Updatable:</b> All Amazon Web Services Secrets Manager attributes, <code>region</code>, <code>range</code>, OAuth2 credentials (<code>client_id</code>, <code>client_secret</code>)</p>
88/// </dd>
89/// </dl>
90#[derive(::std::clone::Clone, ::std::fmt::Debug)]
91pub struct UpdateTelemetryPipelineFluentBuilder {
92 handle: ::std::sync::Arc<crate::client::Handle>,
93 inner: crate::operation::update_telemetry_pipeline::builders::UpdateTelemetryPipelineInputBuilder,
94 config_override: ::std::option::Option<crate::config::Builder>,
95}
96impl
97 crate::client::customize::internal::CustomizableSend<
98 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineOutput,
99 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineError,
100 > for UpdateTelemetryPipelineFluentBuilder
101{
102 fn send(
103 self,
104 config_override: crate::config::Builder,
105 ) -> crate::client::customize::internal::BoxFuture<
106 crate::client::customize::internal::SendResult<
107 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineOutput,
108 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineError,
109 >,
110 > {
111 ::std::boxed::Box::pin(async move { self.config_override(config_override).send().await })
112 }
113}
114impl UpdateTelemetryPipelineFluentBuilder {
115 /// Creates a new `UpdateTelemetryPipelineFluentBuilder`.
116 pub(crate) fn new(handle: ::std::sync::Arc<crate::client::Handle>) -> Self {
117 Self {
118 handle,
119 inner: ::std::default::Default::default(),
120 config_override: ::std::option::Option::None,
121 }
122 }
123 /// Access the UpdateTelemetryPipeline as a reference.
124 pub fn as_input(&self) -> &crate::operation::update_telemetry_pipeline::builders::UpdateTelemetryPipelineInputBuilder {
125 &self.inner
126 }
127 /// Sends the request and returns the response.
128 ///
129 /// If an error occurs, an `SdkError` will be returned with additional details that
130 /// can be matched against.
131 ///
132 /// By default, any retryable failures will be retried twice. Retry behavior
133 /// is configurable with the [RetryConfig](aws_smithy_types::retry::RetryConfig), which can be
134 /// set when configuring the client.
135 pub async fn send(
136 self,
137 ) -> ::std::result::Result<
138 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineOutput,
139 ::aws_smithy_runtime_api::client::result::SdkError<
140 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineError,
141 ::aws_smithy_runtime_api::client::orchestrator::HttpResponse,
142 >,
143 > {
144 let input = self
145 .inner
146 .build()
147 .map_err(::aws_smithy_runtime_api::client::result::SdkError::construction_failure)?;
148 let runtime_plugins = crate::operation::update_telemetry_pipeline::UpdateTelemetryPipeline::operation_runtime_plugins(
149 self.handle.runtime_plugins.clone(),
150 &self.handle.conf,
151 self.config_override,
152 );
153 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipeline::orchestrate(&runtime_plugins, input).await
154 }
155
156 /// Consumes this builder, creating a customizable operation that can be modified before being sent.
157 pub fn customize(
158 self,
159 ) -> crate::client::customize::CustomizableOperation<
160 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineOutput,
161 crate::operation::update_telemetry_pipeline::UpdateTelemetryPipelineError,
162 Self,
163 > {
164 crate::client::customize::CustomizableOperation::new(self)
165 }
166 pub(crate) fn config_override(mut self, config_override: impl ::std::convert::Into<crate::config::Builder>) -> Self {
167 self.set_config_override(::std::option::Option::Some(config_override.into()));
168 self
169 }
170
171 pub(crate) fn set_config_override(&mut self, config_override: ::std::option::Option<crate::config::Builder>) -> &mut Self {
172 self.config_override = config_override;
173 self
174 }
175 /// <p>The ARN of the telemetry pipeline to update.</p>
176 pub fn pipeline_identifier(mut self, input: impl ::std::convert::Into<::std::string::String>) -> Self {
177 self.inner = self.inner.pipeline_identifier(input.into());
178 self
179 }
180 /// <p>The ARN of the telemetry pipeline to update.</p>
181 pub fn set_pipeline_identifier(mut self, input: ::std::option::Option<::std::string::String>) -> Self {
182 self.inner = self.inner.set_pipeline_identifier(input);
183 self
184 }
185 /// <p>The ARN of the telemetry pipeline to update.</p>
186 pub fn get_pipeline_identifier(&self) -> &::std::option::Option<::std::string::String> {
187 self.inner.get_pipeline_identifier()
188 }
189 /// <p>The new configuration for the telemetry pipeline, including updated sources, processors, and destinations.</p>
190 pub fn configuration(mut self, input: crate::types::TelemetryPipelineConfiguration) -> Self {
191 self.inner = self.inner.configuration(input);
192 self
193 }
194 /// <p>The new configuration for the telemetry pipeline, including updated sources, processors, and destinations.</p>
195 pub fn set_configuration(mut self, input: ::std::option::Option<crate::types::TelemetryPipelineConfiguration>) -> Self {
196 self.inner = self.inner.set_configuration(input);
197 self
198 }
199 /// <p>The new configuration for the telemetry pipeline, including updated sources, processors, and destinations.</p>
200 pub fn get_configuration(&self) -> &::std::option::Option<crate::types::TelemetryPipelineConfiguration> {
201 self.inner.get_configuration()
202 }
203}