/*******************************************************************************
* Copyright 2012-2019 Amazon.com, Inc. or its affiliates. All Rights Reserved.
* Licensed under the Apache License, Version 2.0 (the "License"). You may not use
* this file except in compliance with the License. A copy of the License is located at
*
* http://aws.amazon.com/apache2.0
*
* or in the "license" file accompanying this file.
* This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
* CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
* *****************************************************************************
*
* AWS Tools for Windows (TM) PowerShell (TM)
*
*/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Management.Automation;
using System.Text;
using Amazon.PowerShell.Common;
using Amazon.Runtime;
using Amazon.Pipes;
using Amazon.Pipes.Model;
namespace Amazon.PowerShell.Cmdlets.PIPES
{
///
/// Update an existing pipe. When you call UpdatePipe
, only the fields that
/// are included in the request are changed, the rest are unchanged. The exception to
/// this is if you modify any Amazon Web Services-service specific fields in the SourceParameters
,
/// EnrichmentParameters
, or TargetParameters
objects. The fields
/// in these objects are updated atomically as one and override existing values. This
/// is by design and means that if you don't specify an optional field in one of these
/// Parameters objects, that field will be set to its system-default value after the update.
///
///
///
/// For more information about pipes, see
/// Amazon EventBridge Pipes in the Amazon EventBridge User Guide.
///
///
[Cmdlet("Update", "PIPESPipe", SupportsShouldProcess = true, ConfirmImpact = ConfirmImpact.Medium)]
[OutputType("Amazon.Pipes.Model.UpdatePipeResponse")]
[AWSCmdlet("Calls the Amazon EventBridge Pipes UpdatePipe API operation.", Operation = new[] {"UpdatePipe"}, SelectReturnType = typeof(Amazon.Pipes.Model.UpdatePipeResponse))]
[AWSCmdletOutput("Amazon.Pipes.Model.UpdatePipeResponse",
"This cmdlet returns an Amazon.Pipes.Model.UpdatePipeResponse object containing multiple properties. The object can also be referenced from properties attached to the cmdlet entry in the $AWSHistory stack."
)]
public partial class UpdatePIPESPipeCmdlet : AmazonPipesClientCmdlet, IExecutor
{
protected override bool IsSensitiveRequest { get; set; } = true;
#region Parameter SourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn
///
///
/// The ARN of the Amazon SQS queue specified as the target for the dead-letter queue.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_DynamoDBStream_DeadLetterConfig_Arn")]
public System.String SourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn { get; set; }
#endregion
#region Parameter SourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn
///
///
/// The ARN of the Amazon SQS queue specified as the target for the dead-letter queue.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_KinesisStream_DeadLetterConfig_Arn")]
public System.String SourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn { get; set; }
#endregion
#region Parameter AwsvpcConfiguration_AssignPublicIp
///
///
/// Specifies whether the task's elastic network interface receives a public IP address.
/// You can specify ENABLED
only when LaunchType
in EcsParameters
/// is set to FARGATE
.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_AssignPublicIp")]
[AWSConstantClassSource("Amazon.Pipes.AssignPublicIp")]
public Amazon.Pipes.AssignPublicIp AwsvpcConfiguration_AssignPublicIp { get; set; }
#endregion
#region Parameter RetryStrategy_Attempt
///
///
/// The number of times to move a job to the RUNNABLE
status. If the value
/// of attempts
is greater than one, the job is retried on failure the same
/// number of attempts as the value.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_RetryStrategy_Attempts")]
public System.Int32? RetryStrategy_Attempt { get; set; }
#endregion
#region Parameter SourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_ActiveMQBrokerParameters_Credentials_BasicAuth")]
public System.String SourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth { get; set; }
#endregion
#region Parameter SourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_RabbitMQBrokerParameters_Credentials_BasicAuth")]
public System.String SourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth { get; set; }
#endregion
#region Parameter SourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_SelfManagedKafkaParameters_Credentials_BasicAuth")]
public System.String SourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth { get; set; }
#endregion
#region Parameter ActiveMQBrokerParameters_BatchSize
///
///
/// The maximum number of records to include in each batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_ActiveMQBrokerParameters_BatchSize")]
public System.Int32? ActiveMQBrokerParameters_BatchSize { get; set; }
#endregion
#region Parameter DynamoDBStreamParameters_BatchSize
///
///
/// The maximum number of records to include in each batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_DynamoDBStreamParameters_BatchSize")]
public System.Int32? DynamoDBStreamParameters_BatchSize { get; set; }
#endregion
#region Parameter KinesisStreamParameters_BatchSize
///
///
/// The maximum number of records to include in each batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_KinesisStreamParameters_BatchSize")]
public System.Int32? KinesisStreamParameters_BatchSize { get; set; }
#endregion
#region Parameter ManagedStreamingKafkaParameters_BatchSize
///
///
/// The maximum number of records to include in each batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_ManagedStreamingKafkaParameters_BatchSize")]
public System.Int32? ManagedStreamingKafkaParameters_BatchSize { get; set; }
#endregion
#region Parameter RabbitMQBrokerParameters_BatchSize
///
///
/// The maximum number of records to include in each batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_RabbitMQBrokerParameters_BatchSize")]
public System.Int32? RabbitMQBrokerParameters_BatchSize { get; set; }
#endregion
#region Parameter SelfManagedKafkaParameters_BatchSize
///
///
/// The maximum number of records to include in each batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SelfManagedKafkaParameters_BatchSize")]
public System.Int32? SelfManagedKafkaParameters_BatchSize { get; set; }
#endregion
#region Parameter SqsQueueParameters_BatchSize
///
///
/// The maximum number of records to include in each batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SqsQueueParameters_BatchSize")]
public System.Int32? SqsQueueParameters_BatchSize { get; set; }
#endregion
#region Parameter EcsTaskParameters_CapacityProviderStrategy
///
///
/// The capacity provider strategy to use for the task.If a capacityProviderStrategy
is specified, the launchType
/// parameter must be omitted. If no capacityProviderStrategy
or launchType
/// is specified, the defaultCapacityProviderStrategy
for the cluster is
/// used.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_CapacityProviderStrategy")]
public Amazon.Pipes.Model.CapacityProviderStrategyItem[] EcsTaskParameters_CapacityProviderStrategy { get; set; }
#endregion
#region Parameter SourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_ManagedStreamingKafka_Credentials_ClientCertificateTlsAuth")]
public System.String SourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth { get; set; }
#endregion
#region Parameter SourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_SelfStreamingKafka_Credentials_ClientCertificateTlsAuth")]
public System.String SourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth { get; set; }
#endregion
#region Parameter ContainerOverrides_Command
///
///
/// The command to send to the container that overrides the default command from the Docker
/// image or the task definition.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_ContainerOverrides_Command")]
public System.String[] ContainerOverrides_Command { get; set; }
#endregion
#region Parameter Overrides_ContainerOverride
///
///
/// One or more container overrides that are sent to a task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Overrides_ContainerOverrides")]
public Amazon.Pipes.Model.EcsContainerOverride[] Overrides_ContainerOverride { get; set; }
#endregion
#region Parameter Overrides_Cpu
///
///
/// The cpu override for the task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Overrides_Cpu")]
public System.String Overrides_Cpu { get; set; }
#endregion
#region Parameter RedshiftDataParameters_Database
///
///
/// The name of the database. Required when authenticating using temporary credentials.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_RedshiftDataParameters_Database")]
public System.String RedshiftDataParameters_Database { get; set; }
#endregion
#region Parameter RedshiftDataParameters_DbUser
///
///
/// The database user name. Required when authenticating using temporary credentials.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_RedshiftDataParameters_DbUser")]
public System.String RedshiftDataParameters_DbUser { get; set; }
#endregion
#region Parameter BatchJobParameters_DependsOn
///
///
/// A list of dependencies for the job. A job can depend upon a maximum of 20 jobs. You
/// can specify a SEQUENTIAL
type dependency without specifying a job ID
/// for array jobs so that each child array job completes sequentially, starting at index
/// 0. You can also specify an N_TO_N
type dependency with a job ID for array
/// jobs. In that case, each index child of this job must wait for the corresponding index
/// child of each dependency to complete before it can begin.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_DependsOn")]
public Amazon.Pipes.Model.BatchJobDependency[] BatchJobParameters_DependsOn { get; set; }
#endregion
#region Parameter Description
///
///
/// A description of the pipe.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String Description { get; set; }
#endregion
#region Parameter DesiredState
///
///
/// The state the pipe should be in.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[AWSConstantClassSource("Amazon.Pipes.RequestedPipeState")]
public Amazon.Pipes.RequestedPipeState DesiredState { get; set; }
#endregion
#region Parameter EventBridgeEventBusParameters_DetailType
///
///
/// A free-form string, with a maximum of 128 characters, used to decide what fields to
/// expect in the event detail.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EventBridgeEventBusParameters_DetailType")]
public System.String EventBridgeEventBusParameters_DetailType { get; set; }
#endregion
#region Parameter EcsTaskParameters_EnableECSManagedTag
///
///
/// Specifies whether to enable Amazon ECS managed tags for the task. For more information,
/// see Tagging
/// Your Amazon ECS Resources in the Amazon Elastic Container Service Developer Guide.
///
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_EnableECSManagedTags")]
public System.Boolean? EcsTaskParameters_EnableECSManagedTag { get; set; }
#endregion
#region Parameter EcsTaskParameters_EnableExecuteCommand
///
///
/// Whether or not to enable the execute command functionality for the containers in this
/// task. If true, this enables execute command functionality on all containers in the
/// task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_EnableExecuteCommand")]
public System.Boolean? EcsTaskParameters_EnableExecuteCommand { get; set; }
#endregion
#region Parameter EventBridgeEventBusParameters_EndpointId
///
///
/// The URL subdomain of the endpoint. For example, if the URL for Endpoint is https://abcde.veo.endpoints.event.amazonaws.com,
/// then the EndpointId is abcde.veo
.When using Java, you must include auth-crt
on the class path.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EventBridgeEventBusParameters_EndpointId")]
public System.String EventBridgeEventBusParameters_EndpointId { get; set; }
#endregion
#region Parameter Enrichment
///
///
/// The ARN of the enrichment resource.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String Enrichment { get; set; }
#endregion
#region Parameter ContainerOverrides_Environment
///
///
/// The environment variables to send to the container. You can add new environment variables,
/// which are added to the container at launch, or you can override the existing environment
/// variables from the Docker image or the task definition.Environment variables cannot start with "Batch
". This naming convention
/// is reserved for variables that Batch sets.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_ContainerOverrides_Environment")]
public Amazon.Pipes.Model.BatchEnvironmentVariable[] ContainerOverrides_Environment { get; set; }
#endregion
#region Parameter Overrides_ExecutionRoleArn
///
///
/// The Amazon Resource Name (ARN) of the task execution IAM role override for the task.
/// For more information, see Amazon
/// ECS task execution IAM role in the Amazon Elastic Container Service Developer
/// Guide.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Overrides_ExecutionRoleArn")]
public System.String Overrides_ExecutionRoleArn { get; set; }
#endregion
#region Parameter FilterCriteria_Filter
///
///
/// The event patterns.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_FilterCriteria_Filters")]
public Amazon.Pipes.Model.Filter[] FilterCriteria_Filter { get; set; }
#endregion
#region Parameter EcsTaskParameters_Group
///
///
/// Specifies an Amazon ECS task group for the task. The maximum length is 255 characters.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Group")]
public System.String EcsTaskParameters_Group { get; set; }
#endregion
#region Parameter EnrichmentParameters_HttpParameters_HeaderParameters
///
///
/// The headers that need to be sent as part of request invoking the API Gateway REST
/// API or EventBridge ApiDestination.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Enrichment_HttpParameters_HeaderParameters")]
public System.Collections.Hashtable EnrichmentParameters_HttpParameters_HeaderParameters { get; set; }
#endregion
#region Parameter TargetParameters_HttpParameters_HeaderParameters
///
///
/// The headers that need to be sent as part of request invoking the API Gateway REST
/// API or EventBridge ApiDestination.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Target_HttpParameters_HeaderParameters")]
public System.Collections.Hashtable TargetParameters_HttpParameters_HeaderParameters { get; set; }
#endregion
#region Parameter Overrides_InferenceAcceleratorOverride
///
///
/// The Elastic Inference accelerator override for the task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Overrides_InferenceAcceleratorOverrides")]
public Amazon.Pipes.Model.EcsInferenceAcceleratorOverride[] Overrides_InferenceAcceleratorOverride { get; set; }
#endregion
#region Parameter EnrichmentParameters_InputTemplate
///
///
/// Valid JSON text passed to the enrichment. In this case, nothing from the event itself
/// is passed to the enrichment. For more information, see The
/// JavaScript Object Notation (JSON) Data Interchange Format.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String EnrichmentParameters_InputTemplate { get; set; }
#endregion
#region Parameter TargetParameters_InputTemplate
///
///
/// Valid JSON text passed to the target. In this case, nothing from the event itself
/// is passed to the target. For more information, see The
/// JavaScript Object Notation (JSON) Data Interchange Format.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String TargetParameters_InputTemplate { get; set; }
#endregion
#region Parameter ContainerOverrides_InstanceType
///
///
/// The instance type to use for a multi-node parallel job.This parameter isn't applicable to single-node container jobs or jobs that run on
/// Fargate resources, and shouldn't be provided.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_ContainerOverrides_InstanceType")]
public System.String ContainerOverrides_InstanceType { get; set; }
#endregion
#region Parameter LambdaFunctionParameters_InvocationType
///
///
/// Choose from the following options.RequestResponse
(default) - Invoke the function synchronously. Keep
/// the connection open until the function returns a response or times out. The API response
/// includes the function response and additional data.Event
- Invoke the function asynchronously. Send events that fail multiple
/// times to the function's dead-letter queue (if it's configured). The API response only
/// includes a status code.DryRun
- Validate parameter values and verify that the user or role
/// has permission to invoke the function.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_LambdaFunctionParameters_InvocationType")]
[AWSConstantClassSource("Amazon.Pipes.PipeTargetInvocationType")]
public Amazon.Pipes.PipeTargetInvocationType LambdaFunctionParameters_InvocationType { get; set; }
#endregion
#region Parameter StepFunctionStateMachineParameters_InvocationType
///
///
/// Specify whether to wait for the state machine to finish or not.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_StepFunctionStateMachineParameters_InvocationType")]
[AWSConstantClassSource("Amazon.Pipes.PipeTargetInvocationType")]
public Amazon.Pipes.PipeTargetInvocationType StepFunctionStateMachineParameters_InvocationType { get; set; }
#endregion
#region Parameter BatchJobParameters_JobDefinition
///
///
/// The job definition used by this job. This value can be one of name
, name:revision
,
/// or the Amazon Resource Name (ARN) for the job definition. If name is specified without
/// a revision then the latest active revision is used.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_JobDefinition")]
public System.String BatchJobParameters_JobDefinition { get; set; }
#endregion
#region Parameter BatchJobParameters_JobName
///
///
/// The name of the job. It can be up to 128 letters long. The first character must be
/// alphanumeric, can contain uppercase and lowercase letters, numbers, hyphens (-), and
/// underscores (_).
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_JobName")]
public System.String BatchJobParameters_JobName { get; set; }
#endregion
#region Parameter EcsTaskParameters_LaunchType
///
///
/// Specifies the launch type on which your task is running. The launch type that you
/// specify here must match one of the launch type (compatibilities) of the target task.
/// The FARGATE
value is supported only in the Regions where Fargate with
/// Amazon ECS is supported. For more information, see Fargate
/// on Amazon ECS in the Amazon Elastic Container Service Developer Guide.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_LaunchType")]
[AWSConstantClassSource("Amazon.Pipes.LaunchType")]
public Amazon.Pipes.LaunchType EcsTaskParameters_LaunchType { get; set; }
#endregion
#region Parameter CloudWatchLogsParameters_LogStreamName
///
///
/// The name of the log stream.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_CloudWatchLogsParameters_LogStreamName")]
public System.String CloudWatchLogsParameters_LogStreamName { get; set; }
#endregion
#region Parameter ActiveMQBrokerParameters_MaximumBatchingWindowInSecond
///
///
/// The maximum length of a time to wait for events.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_ActiveMQBrokerParameters_MaximumBatchingWindowInSeconds")]
public System.Int32? ActiveMQBrokerParameters_MaximumBatchingWindowInSecond { get; set; }
#endregion
#region Parameter DynamoDBStreamParameters_MaximumBatchingWindowInSecond
///
///
/// The maximum length of a time to wait for events.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_DynamoDBStreamParameters_MaximumBatchingWindowInSeconds")]
public System.Int32? DynamoDBStreamParameters_MaximumBatchingWindowInSecond { get; set; }
#endregion
#region Parameter KinesisStreamParameters_MaximumBatchingWindowInSecond
///
///
/// The maximum length of a time to wait for events.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_KinesisStreamParameters_MaximumBatchingWindowInSeconds")]
public System.Int32? KinesisStreamParameters_MaximumBatchingWindowInSecond { get; set; }
#endregion
#region Parameter ManagedStreamingKafkaParameters_MaximumBatchingWindowInSecond
///
///
/// The maximum length of a time to wait for events.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_ManagedStreamingKafkaParameters_MaximumBatchingWindowInSeconds")]
public System.Int32? ManagedStreamingKafkaParameters_MaximumBatchingWindowInSecond { get; set; }
#endregion
#region Parameter RabbitMQBrokerParameters_MaximumBatchingWindowInSecond
///
///
/// The maximum length of a time to wait for events.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_RabbitMQBrokerParameters_MaximumBatchingWindowInSeconds")]
public System.Int32? RabbitMQBrokerParameters_MaximumBatchingWindowInSecond { get; set; }
#endregion
#region Parameter SelfManagedKafkaParameters_MaximumBatchingWindowInSecond
///
///
/// The maximum length of a time to wait for events.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SelfManagedKafkaParameters_MaximumBatchingWindowInSeconds")]
public System.Int32? SelfManagedKafkaParameters_MaximumBatchingWindowInSecond { get; set; }
#endregion
#region Parameter SqsQueueParameters_MaximumBatchingWindowInSecond
///
///
/// The maximum length of a time to wait for events.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SqsQueueParameters_MaximumBatchingWindowInSeconds")]
public System.Int32? SqsQueueParameters_MaximumBatchingWindowInSecond { get; set; }
#endregion
#region Parameter DynamoDBStreamParameters_MaximumRecordAgeInSecond
///
///
/// (Streams only) Discard records older than the specified age. The default value is
/// -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge
/// never discards old records.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_DynamoDBStreamParameters_MaximumRecordAgeInSeconds")]
public System.Int32? DynamoDBStreamParameters_MaximumRecordAgeInSecond { get; set; }
#endregion
#region Parameter KinesisStreamParameters_MaximumRecordAgeInSecond
///
///
/// (Streams only) Discard records older than the specified age. The default value is
/// -1, which sets the maximum age to infinite. When the value is set to infinite, EventBridge
/// never discards old records.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_KinesisStreamParameters_MaximumRecordAgeInSeconds")]
public System.Int32? KinesisStreamParameters_MaximumRecordAgeInSecond { get; set; }
#endregion
#region Parameter DynamoDBStreamParameters_MaximumRetryAttempt
///
///
/// (Streams only) Discard records after the specified number of retries. The default
/// value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts
/// is infinite, EventBridge retries failed records until the record expires in the event
/// source.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_DynamoDBStreamParameters_MaximumRetryAttempts")]
public System.Int32? DynamoDBStreamParameters_MaximumRetryAttempt { get; set; }
#endregion
#region Parameter KinesisStreamParameters_MaximumRetryAttempt
///
///
/// (Streams only) Discard records after the specified number of retries. The default
/// value is -1, which sets the maximum number of retries to infinite. When MaximumRetryAttempts
/// is infinite, EventBridge retries failed records until the record expires in the event
/// source.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_KinesisStreamParameters_MaximumRetryAttempts")]
public System.Int32? KinesisStreamParameters_MaximumRetryAttempt { get; set; }
#endregion
#region Parameter Overrides_Memory
///
///
/// The memory override for the task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Overrides_Memory")]
public System.String Overrides_Memory { get; set; }
#endregion
#region Parameter SqsQueueParameters_MessageDeduplicationId
///
///
/// This parameter applies only to FIFO (first-in-first-out) queues.The token used for deduplication of sent messages.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_SqsQueueParameters_MessageDeduplicationId")]
public System.String SqsQueueParameters_MessageDeduplicationId { get; set; }
#endregion
#region Parameter SqsQueueParameters_MessageGroupId
///
///
/// The FIFO message group ID to use as the target.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_SqsQueueParameters_MessageGroupId")]
public System.String SqsQueueParameters_MessageGroupId { get; set; }
#endregion
#region Parameter Name
///
///
/// The name of the pipe.
///
///
#if !MODULAR
[System.Management.Automation.Parameter(Position = 0, ValueFromPipelineByPropertyName = true, ValueFromPipeline = true)]
#else
[System.Management.Automation.Parameter(Position = 0, ValueFromPipelineByPropertyName = true, ValueFromPipeline = true, Mandatory = true)]
[System.Management.Automation.AllowEmptyString]
[System.Management.Automation.AllowNull]
#endif
[Amazon.PowerShell.Common.AWSRequiredParameter]
public System.String Name { get; set; }
#endregion
#region Parameter DynamoDBStreamParameters_OnPartialBatchItemFailure
///
///
/// (Streams only) Define how to handle item process failures. AUTOMATIC_BISECT
/// halves each batch and retry each half until all the records are processed or there
/// is one failed message left in the batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_DynamoDBStreamParameters_OnPartialBatchItemFailure")]
[AWSConstantClassSource("Amazon.Pipes.OnPartialBatchItemFailureStreams")]
public Amazon.Pipes.OnPartialBatchItemFailureStreams DynamoDBStreamParameters_OnPartialBatchItemFailure { get; set; }
#endregion
#region Parameter KinesisStreamParameters_OnPartialBatchItemFailure
///
///
/// (Streams only) Define how to handle item process failures. AUTOMATIC_BISECT
/// halves each batch and retry each half until all the records are processed or there
/// is one failed message left in the batch.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_KinesisStreamParameters_OnPartialBatchItemFailure")]
[AWSConstantClassSource("Amazon.Pipes.OnPartialBatchItemFailureStreams")]
public Amazon.Pipes.OnPartialBatchItemFailureStreams KinesisStreamParameters_OnPartialBatchItemFailure { get; set; }
#endregion
#region Parameter DynamoDBStreamParameters_ParallelizationFactor
///
///
/// (Streams only) The number of batches to process concurrently from each shard. The
/// default value is 1.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_DynamoDBStreamParameters_ParallelizationFactor")]
public System.Int32? DynamoDBStreamParameters_ParallelizationFactor { get; set; }
#endregion
#region Parameter KinesisStreamParameters_ParallelizationFactor
///
///
/// (Streams only) The number of batches to process concurrently from each shard. The
/// default value is 1.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_KinesisStreamParameters_ParallelizationFactor")]
public System.Int32? KinesisStreamParameters_ParallelizationFactor { get; set; }
#endregion
#region Parameter BatchJobParameters_Parameter
///
///
/// Additional parameters passed to the job that replace parameter substitution placeholders
/// that are set in the job definition. Parameters are specified as a key and value pair
/// mapping. Parameters included here override any corresponding parameter defaults from
/// the job definition.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_Parameters")]
public System.Collections.Hashtable BatchJobParameters_Parameter { get; set; }
#endregion
#region Parameter KinesisStreamParameters_PartitionKey
///
///
/// Determines which shard in the stream the data record is assigned to. Partition keys
/// are Unicode strings with a maximum length limit of 256 characters for each key. Amazon
/// Kinesis Data Streams uses the partition key as input to a hash function that maps
/// the partition key and associated data to a specific shard. Specifically, an MD5 hash
/// function is used to map partition keys to 128-bit integer values and to map associated
/// data records to shards. As a result of this hashing mechanism, all data records with
/// the same partition key map to the same shard within the stream.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_KinesisStreamParameters_PartitionKey")]
public System.String KinesisStreamParameters_PartitionKey { get; set; }
#endregion
#region Parameter EnrichmentParameters_HttpParameters_PathParameterValues
///
///
/// The path parameter values to be used to populate API Gateway REST API or EventBridge
/// ApiDestination path wildcards ("*").
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Enrichment_HttpParameters_PathParameterValues")]
public System.String[] EnrichmentParameters_HttpParameters_PathParameterValues { get; set; }
#endregion
#region Parameter TargetParameters_HttpParameters_PathParameterValues
///
///
/// The path parameter values to be used to populate API Gateway REST API or EventBridge
/// ApiDestination path wildcards ("*").
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Target_HttpParameters_PathParameterValues")]
public System.String[] TargetParameters_HttpParameters_PathParameterValues { get; set; }
#endregion
#region Parameter SageMakerPipelineParameters_PipelineParameterList
///
///
/// List of Parameter names and values for SageMaker Model Building Pipeline execution.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_SageMakerPipelineParameters_PipelineParameterList")]
public Amazon.Pipes.Model.SageMakerPipelineParameter[] SageMakerPipelineParameters_PipelineParameterList { get; set; }
#endregion
#region Parameter EcsTaskParameters_PlacementConstraint
///
///
/// An array of placement constraint objects to use for the task. You can specify up to
/// 10 constraints per task (including constraints in the task definition and those specified
/// at runtime).
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_PlacementConstraints")]
public Amazon.Pipes.Model.PlacementConstraint[] EcsTaskParameters_PlacementConstraint { get; set; }
#endregion
#region Parameter EcsTaskParameters_PlacementStrategy
///
///
/// The placement strategy objects to use for the task. You can specify a maximum of five
/// strategy rules per task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_PlacementStrategy")]
public Amazon.Pipes.Model.PlacementStrategy[] EcsTaskParameters_PlacementStrategy { get; set; }
#endregion
#region Parameter EcsTaskParameters_PlatformVersion
///
///
/// Specifies the platform version for the task. Specify only the numeric portion of the
/// platform version, such as 1.1.0
.This structure is used only if LaunchType
is FARGATE
. For
/// more information about valid platform versions, see Fargate
/// Platform Versions in the Amazon Elastic Container Service Developer Guide.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_PlatformVersion")]
public System.String EcsTaskParameters_PlatformVersion { get; set; }
#endregion
#region Parameter EcsTaskParameters_PropagateTag
///
///
/// Specifies whether to propagate the tags from the task definition to the task. If no
/// value is specified, the tags are not propagated. Tags can only be propagated to the
/// task during task creation. To add tags to a task after task creation, use the TagResource
/// API action.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_PropagateTags")]
[AWSConstantClassSource("Amazon.Pipes.PropagateTags")]
public Amazon.Pipes.PropagateTags EcsTaskParameters_PropagateTag { get; set; }
#endregion
#region Parameter EnrichmentParameters_HttpParameters_QueryStringParameters
///
///
/// The query string keys/values that need to be sent as part of request invoking the
/// API Gateway REST API or EventBridge ApiDestination.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Enrichment_HttpParameters_QueryStringParameters")]
public System.Collections.Hashtable EnrichmentParameters_HttpParameters_QueryStringParameters { get; set; }
#endregion
#region Parameter TargetParameters_HttpParameters_QueryStringParameters
///
///
/// The query string keys/values that need to be sent as part of request invoking the
/// API Gateway REST API or EventBridge ApiDestination.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Target_HttpParameters_QueryStringParameters")]
public System.Collections.Hashtable TargetParameters_HttpParameters_QueryStringParameters { get; set; }
#endregion
#region Parameter EcsTaskParameters_ReferenceId
///
///
/// The reference ID to use for the task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_ReferenceId")]
public System.String EcsTaskParameters_ReferenceId { get; set; }
#endregion
#region Parameter ContainerOverrides_ResourceRequirement
///
///
/// The type and amount of resources to assign to a container. This overrides the settings
/// in the job definition. The supported resources include GPU
, MEMORY
,
/// and VCPU
.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_ContainerOverrides_ResourceRequirements")]
public Amazon.Pipes.Model.BatchResourceRequirement[] ContainerOverrides_ResourceRequirement { get; set; }
#endregion
#region Parameter EventBridgeEventBusParameters_Resource
///
///
/// Amazon Web Services resources, identified by Amazon Resource Name (ARN), which the
/// event primarily concerns. Any number, including zero, may be present.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EventBridgeEventBusParameters_Resources")]
public System.String[] EventBridgeEventBusParameters_Resource { get; set; }
#endregion
#region Parameter RoleArn
///
///
/// The ARN of the role that allows the pipe to send data to the target.
///
///
#if !MODULAR
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
#else
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true, Mandatory = true)]
[System.Management.Automation.AllowEmptyString]
[System.Management.Automation.AllowNull]
#endif
[Amazon.PowerShell.Common.AWSRequiredParameter]
public System.String RoleArn { get; set; }
#endregion
#region Parameter Credentials_SaslScram256Auth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SelfManagedKafkaParameters_Credentials_SaslScram256Auth")]
public System.String Credentials_SaslScram256Auth { get; set; }
#endregion
#region Parameter SourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("Source_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth")]
public System.String SourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth { get; set; }
#endregion
#region Parameter Credentials_SaslScram512Auth
///
///
/// The ARN of the Secrets Manager secret.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SelfManagedKafkaParameters_Credentials_SaslScram512Auth")]
public System.String Credentials_SaslScram512Auth { get; set; }
#endregion
#region Parameter RedshiftDataParameters_SecretManagerArn
///
///
/// The name or ARN of the secret that enables access to the database. Required when authenticating
/// using SageMaker.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_RedshiftDataParameters_SecretManagerArn")]
public System.String RedshiftDataParameters_SecretManagerArn { get; set; }
#endregion
#region Parameter Vpc_SecurityGroup
///
///
/// Specifies the security groups associated with the stream. These security groups must
/// all be in the same VPC. You can specify as many as five security groups. If you do
/// not specify a security group, the default security group for the VPC is used.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SelfManagedKafkaParameters_Vpc_SecurityGroup")]
public System.String[] Vpc_SecurityGroup { get; set; }
#endregion
#region Parameter AwsvpcConfiguration_SecurityGroup
///
///
/// Specifies the security groups associated with the task. These security groups must
/// all be in the same VPC. You can specify as many as five security groups. If you do
/// not specify a security group, the default security group for the VPC is used.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_SecurityGroups")]
public System.String[] AwsvpcConfiguration_SecurityGroup { get; set; }
#endregion
#region Parameter SelfManagedKafkaParameters_ServerRootCaCertificate
///
///
/// The ARN of the Secrets Manager secret used for certification.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SelfManagedKafkaParameters_ServerRootCaCertificate")]
public System.String SelfManagedKafkaParameters_ServerRootCaCertificate { get; set; }
#endregion
#region Parameter ArrayProperties_Size
///
///
/// The size of the array, if this is an array batch job.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_BatchJobParameters_ArrayProperties_Size")]
public System.Int32? ArrayProperties_Size { get; set; }
#endregion
#region Parameter EphemeralStorage_SizeInGiB
///
///
/// The total amount, in GiB, of ephemeral storage to set for the task. The minimum supported
/// value is 21
GiB and the maximum supported value is 200
GiB.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Overrides_EphemeralStorage_SizeInGiB")]
public System.Int32? EphemeralStorage_SizeInGiB { get; set; }
#endregion
#region Parameter EventBridgeEventBusParameters_Source
///
///
/// The source of the event.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EventBridgeEventBusParameters_Source")]
public System.String EventBridgeEventBusParameters_Source { get; set; }
#endregion
#region Parameter RedshiftDataParameters_Sql
///
///
/// The SQL statement text to run.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_RedshiftDataParameters_Sqls")]
public System.String[] RedshiftDataParameters_Sql { get; set; }
#endregion
#region Parameter RedshiftDataParameters_StatementName
///
///
/// The name of the SQL statement. You can name the SQL statement when you create it to
/// identify the query.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_RedshiftDataParameters_StatementName")]
public System.String RedshiftDataParameters_StatementName { get; set; }
#endregion
#region Parameter Vpc_Subnet
///
///
/// Specifies the subnets associated with the stream. These subnets must all be in the
/// same VPC. You can specify as many as 16 subnets.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("SourceParameters_SelfManagedKafkaParameters_Vpc_Subnets")]
public System.String[] Vpc_Subnet { get; set; }
#endregion
#region Parameter AwsvpcConfiguration_Subnet
///
///
/// Specifies the subnets associated with the task. These subnets must all be in the same
/// VPC. You can specify as many as 16 subnets.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_Subnets")]
public System.String[] AwsvpcConfiguration_Subnet { get; set; }
#endregion
#region Parameter EcsTaskParameters_Tag
///
///
/// The metadata that you apply to the task to help you categorize and organize them.
/// Each tag consists of a key and an optional value, both of which you define. To learn
/// more, see RunTask
/// in the Amazon ECS API Reference.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Tags")]
public Amazon.Pipes.Model.Tag[] EcsTaskParameters_Tag { get; set; }
#endregion
#region Parameter Target
///
///
/// The ARN of the target resource.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public System.String Target { get; set; }
#endregion
#region Parameter EcsTaskParameters_TaskCount
///
///
/// The number of tasks to create based on TaskDefinition
. The default is
/// 1.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_TaskCount")]
public System.Int32? EcsTaskParameters_TaskCount { get; set; }
#endregion
#region Parameter EcsTaskParameters_TaskDefinitionArn
///
///
/// The ARN of the task definition to use if the event target is an Amazon ECS task.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_TaskDefinitionArn")]
public System.String EcsTaskParameters_TaskDefinitionArn { get; set; }
#endregion
#region Parameter Overrides_TaskRoleArn
///
///
/// The Amazon Resource Name (ARN) of the IAM role that containers in this task can assume.
/// All containers in this task are granted the permissions that are specified in this
/// role. For more information, see IAM
/// Role for Tasks in the Amazon Elastic Container Service Developer Guide.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EcsTaskParameters_Overrides_TaskRoleArn")]
public System.String Overrides_TaskRoleArn { get; set; }
#endregion
#region Parameter EventBridgeEventBusParameters_Time
///
///
/// The time stamp of the event, per RFC3339.
/// If no time stamp is provided, the time stamp of the PutEvents
/// call is used.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_EventBridgeEventBusParameters_Time")]
public System.String EventBridgeEventBusParameters_Time { get; set; }
#endregion
#region Parameter CloudWatchLogsParameters_Timestamp
///
///
/// The time the event occurred, expressed as the number of milliseconds after Jan 1,
/// 1970 00:00:00 UTC.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_CloudWatchLogsParameters_Timestamp")]
public System.String CloudWatchLogsParameters_Timestamp { get; set; }
#endregion
#region Parameter RedshiftDataParameters_WithEvent
///
///
/// Indicates whether to send an event back to EventBridge after the SQL statement runs.
///
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
[Alias("TargetParameters_RedshiftDataParameters_WithEvent")]
public System.Boolean? RedshiftDataParameters_WithEvent { get; set; }
#endregion
#region Parameter Select
///
/// Use the -Select parameter to control the cmdlet output. The default value is '*'.
/// Specifying -Select '*' will result in the cmdlet returning the whole service response (Amazon.Pipes.Model.UpdatePipeResponse).
/// Specifying the name of a property of type Amazon.Pipes.Model.UpdatePipeResponse will result in that property being returned.
/// Specifying -Select '^ParameterName' will result in the cmdlet returning the selected cmdlet parameter value.
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public string Select { get; set; } = "*";
#endregion
#region Parameter PassThru
///
/// Changes the cmdlet behavior to return the value passed to the Name parameter.
/// The -PassThru parameter is deprecated, use -Select '^Name' instead. This parameter will be removed in a future version.
///
[System.Obsolete("The -PassThru parameter is deprecated, use -Select '^Name' instead. This parameter will be removed in a future version.")]
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public SwitchParameter PassThru { get; set; }
#endregion
#region Parameter Force
///
/// This parameter overrides confirmation prompts to force
/// the cmdlet to continue its operation. This parameter should always
/// be used with caution.
///
[System.Management.Automation.Parameter(ValueFromPipelineByPropertyName = true)]
public SwitchParameter Force { get; set; }
#endregion
protected override void ProcessRecord()
{
this._AWSSignerType = "v4";
base.ProcessRecord();
var resourceIdentifiersText = FormatParameterValuesForConfirmationMsg(nameof(this.Name), MyInvocation.BoundParameters);
if (!ConfirmShouldProceed(this.Force.IsPresent, resourceIdentifiersText, "Update-PIPESPipe (UpdatePipe)"))
{
return;
}
var context = new CmdletContext();
// allow for manipulation of parameters prior to loading into context
PreExecutionContextLoad(context);
#pragma warning disable CS0618, CS0612 //A class member was marked with the Obsolete attribute
if (ParameterWasBound(nameof(this.Select)))
{
context.Select = CreateSelectDelegate(Select) ??
throw new System.ArgumentException("Invalid value for -Select parameter.", nameof(this.Select));
if (this.PassThru.IsPresent)
{
throw new System.ArgumentException("-PassThru cannot be used when -Select is specified.", nameof(this.Select));
}
}
else if (this.PassThru.IsPresent)
{
context.Select = (response, cmdlet) => this.Name;
}
#pragma warning restore CS0618, CS0612 //A class member was marked with the Obsolete attribute
context.Description = this.Description;
context.DesiredState = this.DesiredState;
context.Enrichment = this.Enrichment;
if (this.EnrichmentParameters_HttpParameters_HeaderParameters != null)
{
context.EnrichmentParameters_HttpParameters_HeaderParameters = new Dictionary(StringComparer.Ordinal);
foreach (var hashKey in this.EnrichmentParameters_HttpParameters_HeaderParameters.Keys)
{
context.EnrichmentParameters_HttpParameters_HeaderParameters.Add((String)hashKey, (String)(this.EnrichmentParameters_HttpParameters_HeaderParameters[hashKey]));
}
}
if (this.EnrichmentParameters_HttpParameters_PathParameterValues != null)
{
context.EnrichmentParameters_HttpParameters_PathParameterValues = new List(this.EnrichmentParameters_HttpParameters_PathParameterValues);
}
if (this.EnrichmentParameters_HttpParameters_QueryStringParameters != null)
{
context.EnrichmentParameters_HttpParameters_QueryStringParameters = new Dictionary(StringComparer.Ordinal);
foreach (var hashKey in this.EnrichmentParameters_HttpParameters_QueryStringParameters.Keys)
{
context.EnrichmentParameters_HttpParameters_QueryStringParameters.Add((String)hashKey, (String)(this.EnrichmentParameters_HttpParameters_QueryStringParameters[hashKey]));
}
}
context.EnrichmentParameters_InputTemplate = this.EnrichmentParameters_InputTemplate;
context.Name = this.Name;
#if MODULAR
if (this.Name == null && ParameterWasBound(nameof(this.Name)))
{
WriteWarning("You are passing $null as a value for parameter Name which is marked as required. In case you believe this parameter was incorrectly marked as required, report this by opening an issue at https://github.com/aws/aws-tools-for-powershell/issues.");
}
#endif
context.RoleArn = this.RoleArn;
#if MODULAR
if (this.RoleArn == null && ParameterWasBound(nameof(this.RoleArn)))
{
WriteWarning("You are passing $null as a value for parameter RoleArn which is marked as required. In case you believe this parameter was incorrectly marked as required, report this by opening an issue at https://github.com/aws/aws-tools-for-powershell/issues.");
}
#endif
context.ActiveMQBrokerParameters_BatchSize = this.ActiveMQBrokerParameters_BatchSize;
context.SourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth = this.SourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth;
context.ActiveMQBrokerParameters_MaximumBatchingWindowInSecond = this.ActiveMQBrokerParameters_MaximumBatchingWindowInSecond;
context.DynamoDBStreamParameters_BatchSize = this.DynamoDBStreamParameters_BatchSize;
context.SourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn = this.SourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn;
context.DynamoDBStreamParameters_MaximumBatchingWindowInSecond = this.DynamoDBStreamParameters_MaximumBatchingWindowInSecond;
context.DynamoDBStreamParameters_MaximumRecordAgeInSecond = this.DynamoDBStreamParameters_MaximumRecordAgeInSecond;
context.DynamoDBStreamParameters_MaximumRetryAttempt = this.DynamoDBStreamParameters_MaximumRetryAttempt;
context.DynamoDBStreamParameters_OnPartialBatchItemFailure = this.DynamoDBStreamParameters_OnPartialBatchItemFailure;
context.DynamoDBStreamParameters_ParallelizationFactor = this.DynamoDBStreamParameters_ParallelizationFactor;
if (this.FilterCriteria_Filter != null)
{
context.FilterCriteria_Filter = new List(this.FilterCriteria_Filter);
}
context.KinesisStreamParameters_BatchSize = this.KinesisStreamParameters_BatchSize;
context.SourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn = this.SourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn;
context.KinesisStreamParameters_MaximumBatchingWindowInSecond = this.KinesisStreamParameters_MaximumBatchingWindowInSecond;
context.KinesisStreamParameters_MaximumRecordAgeInSecond = this.KinesisStreamParameters_MaximumRecordAgeInSecond;
context.KinesisStreamParameters_MaximumRetryAttempt = this.KinesisStreamParameters_MaximumRetryAttempt;
context.KinesisStreamParameters_OnPartialBatchItemFailure = this.KinesisStreamParameters_OnPartialBatchItemFailure;
context.KinesisStreamParameters_ParallelizationFactor = this.KinesisStreamParameters_ParallelizationFactor;
context.ManagedStreamingKafkaParameters_BatchSize = this.ManagedStreamingKafkaParameters_BatchSize;
context.SourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth = this.SourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth;
context.SourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth = this.SourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth;
context.ManagedStreamingKafkaParameters_MaximumBatchingWindowInSecond = this.ManagedStreamingKafkaParameters_MaximumBatchingWindowInSecond;
context.RabbitMQBrokerParameters_BatchSize = this.RabbitMQBrokerParameters_BatchSize;
context.SourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth = this.SourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth;
context.RabbitMQBrokerParameters_MaximumBatchingWindowInSecond = this.RabbitMQBrokerParameters_MaximumBatchingWindowInSecond;
context.SelfManagedKafkaParameters_BatchSize = this.SelfManagedKafkaParameters_BatchSize;
context.SourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth = this.SourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth;
context.SourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth = this.SourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth;
context.Credentials_SaslScram256Auth = this.Credentials_SaslScram256Auth;
context.Credentials_SaslScram512Auth = this.Credentials_SaslScram512Auth;
context.SelfManagedKafkaParameters_MaximumBatchingWindowInSecond = this.SelfManagedKafkaParameters_MaximumBatchingWindowInSecond;
context.SelfManagedKafkaParameters_ServerRootCaCertificate = this.SelfManagedKafkaParameters_ServerRootCaCertificate;
if (this.Vpc_SecurityGroup != null)
{
context.Vpc_SecurityGroup = new List(this.Vpc_SecurityGroup);
}
if (this.Vpc_Subnet != null)
{
context.Vpc_Subnet = new List(this.Vpc_Subnet);
}
context.SqsQueueParameters_BatchSize = this.SqsQueueParameters_BatchSize;
context.SqsQueueParameters_MaximumBatchingWindowInSecond = this.SqsQueueParameters_MaximumBatchingWindowInSecond;
context.Target = this.Target;
context.ArrayProperties_Size = this.ArrayProperties_Size;
if (this.ContainerOverrides_Command != null)
{
context.ContainerOverrides_Command = new List(this.ContainerOverrides_Command);
}
if (this.ContainerOverrides_Environment != null)
{
context.ContainerOverrides_Environment = new List(this.ContainerOverrides_Environment);
}
context.ContainerOverrides_InstanceType = this.ContainerOverrides_InstanceType;
if (this.ContainerOverrides_ResourceRequirement != null)
{
context.ContainerOverrides_ResourceRequirement = new List(this.ContainerOverrides_ResourceRequirement);
}
if (this.BatchJobParameters_DependsOn != null)
{
context.BatchJobParameters_DependsOn = new List(this.BatchJobParameters_DependsOn);
}
context.BatchJobParameters_JobDefinition = this.BatchJobParameters_JobDefinition;
context.BatchJobParameters_JobName = this.BatchJobParameters_JobName;
if (this.BatchJobParameters_Parameter != null)
{
context.BatchJobParameters_Parameter = new Dictionary(StringComparer.Ordinal);
foreach (var hashKey in this.BatchJobParameters_Parameter.Keys)
{
context.BatchJobParameters_Parameter.Add((String)hashKey, (String)(this.BatchJobParameters_Parameter[hashKey]));
}
}
context.RetryStrategy_Attempt = this.RetryStrategy_Attempt;
context.CloudWatchLogsParameters_LogStreamName = this.CloudWatchLogsParameters_LogStreamName;
context.CloudWatchLogsParameters_Timestamp = this.CloudWatchLogsParameters_Timestamp;
if (this.EcsTaskParameters_CapacityProviderStrategy != null)
{
context.EcsTaskParameters_CapacityProviderStrategy = new List(this.EcsTaskParameters_CapacityProviderStrategy);
}
context.EcsTaskParameters_EnableECSManagedTag = this.EcsTaskParameters_EnableECSManagedTag;
context.EcsTaskParameters_EnableExecuteCommand = this.EcsTaskParameters_EnableExecuteCommand;
context.EcsTaskParameters_Group = this.EcsTaskParameters_Group;
context.EcsTaskParameters_LaunchType = this.EcsTaskParameters_LaunchType;
context.AwsvpcConfiguration_AssignPublicIp = this.AwsvpcConfiguration_AssignPublicIp;
if (this.AwsvpcConfiguration_SecurityGroup != null)
{
context.AwsvpcConfiguration_SecurityGroup = new List(this.AwsvpcConfiguration_SecurityGroup);
}
if (this.AwsvpcConfiguration_Subnet != null)
{
context.AwsvpcConfiguration_Subnet = new List(this.AwsvpcConfiguration_Subnet);
}
if (this.Overrides_ContainerOverride != null)
{
context.Overrides_ContainerOverride = new List(this.Overrides_ContainerOverride);
}
context.Overrides_Cpu = this.Overrides_Cpu;
context.EphemeralStorage_SizeInGiB = this.EphemeralStorage_SizeInGiB;
context.Overrides_ExecutionRoleArn = this.Overrides_ExecutionRoleArn;
if (this.Overrides_InferenceAcceleratorOverride != null)
{
context.Overrides_InferenceAcceleratorOverride = new List(this.Overrides_InferenceAcceleratorOverride);
}
context.Overrides_Memory = this.Overrides_Memory;
context.Overrides_TaskRoleArn = this.Overrides_TaskRoleArn;
if (this.EcsTaskParameters_PlacementConstraint != null)
{
context.EcsTaskParameters_PlacementConstraint = new List(this.EcsTaskParameters_PlacementConstraint);
}
if (this.EcsTaskParameters_PlacementStrategy != null)
{
context.EcsTaskParameters_PlacementStrategy = new List(this.EcsTaskParameters_PlacementStrategy);
}
context.EcsTaskParameters_PlatformVersion = this.EcsTaskParameters_PlatformVersion;
context.EcsTaskParameters_PropagateTag = this.EcsTaskParameters_PropagateTag;
context.EcsTaskParameters_ReferenceId = this.EcsTaskParameters_ReferenceId;
if (this.EcsTaskParameters_Tag != null)
{
context.EcsTaskParameters_Tag = new List(this.EcsTaskParameters_Tag);
}
context.EcsTaskParameters_TaskCount = this.EcsTaskParameters_TaskCount;
context.EcsTaskParameters_TaskDefinitionArn = this.EcsTaskParameters_TaskDefinitionArn;
context.EventBridgeEventBusParameters_DetailType = this.EventBridgeEventBusParameters_DetailType;
context.EventBridgeEventBusParameters_EndpointId = this.EventBridgeEventBusParameters_EndpointId;
if (this.EventBridgeEventBusParameters_Resource != null)
{
context.EventBridgeEventBusParameters_Resource = new List(this.EventBridgeEventBusParameters_Resource);
}
context.EventBridgeEventBusParameters_Source = this.EventBridgeEventBusParameters_Source;
context.EventBridgeEventBusParameters_Time = this.EventBridgeEventBusParameters_Time;
if (this.TargetParameters_HttpParameters_HeaderParameters != null)
{
context.TargetParameters_HttpParameters_HeaderParameters = new Dictionary(StringComparer.Ordinal);
foreach (var hashKey in this.TargetParameters_HttpParameters_HeaderParameters.Keys)
{
context.TargetParameters_HttpParameters_HeaderParameters.Add((String)hashKey, (String)(this.TargetParameters_HttpParameters_HeaderParameters[hashKey]));
}
}
if (this.TargetParameters_HttpParameters_PathParameterValues != null)
{
context.TargetParameters_HttpParameters_PathParameterValues = new List(this.TargetParameters_HttpParameters_PathParameterValues);
}
if (this.TargetParameters_HttpParameters_QueryStringParameters != null)
{
context.TargetParameters_HttpParameters_QueryStringParameters = new Dictionary(StringComparer.Ordinal);
foreach (var hashKey in this.TargetParameters_HttpParameters_QueryStringParameters.Keys)
{
context.TargetParameters_HttpParameters_QueryStringParameters.Add((String)hashKey, (String)(this.TargetParameters_HttpParameters_QueryStringParameters[hashKey]));
}
}
context.TargetParameters_InputTemplate = this.TargetParameters_InputTemplate;
context.KinesisStreamParameters_PartitionKey = this.KinesisStreamParameters_PartitionKey;
context.LambdaFunctionParameters_InvocationType = this.LambdaFunctionParameters_InvocationType;
context.RedshiftDataParameters_Database = this.RedshiftDataParameters_Database;
context.RedshiftDataParameters_DbUser = this.RedshiftDataParameters_DbUser;
context.RedshiftDataParameters_SecretManagerArn = this.RedshiftDataParameters_SecretManagerArn;
if (this.RedshiftDataParameters_Sql != null)
{
context.RedshiftDataParameters_Sql = new List(this.RedshiftDataParameters_Sql);
}
context.RedshiftDataParameters_StatementName = this.RedshiftDataParameters_StatementName;
context.RedshiftDataParameters_WithEvent = this.RedshiftDataParameters_WithEvent;
if (this.SageMakerPipelineParameters_PipelineParameterList != null)
{
context.SageMakerPipelineParameters_PipelineParameterList = new List(this.SageMakerPipelineParameters_PipelineParameterList);
}
context.SqsQueueParameters_MessageDeduplicationId = this.SqsQueueParameters_MessageDeduplicationId;
context.SqsQueueParameters_MessageGroupId = this.SqsQueueParameters_MessageGroupId;
context.StepFunctionStateMachineParameters_InvocationType = this.StepFunctionStateMachineParameters_InvocationType;
// allow further manipulation of loaded context prior to processing
PostExecutionContextLoad(context);
var output = Execute(context) as CmdletOutput;
ProcessOutput(output);
}
#region IExecutor Members
public object Execute(ExecutorContext context)
{
var cmdletContext = context as CmdletContext;
// create request
var request = new Amazon.Pipes.Model.UpdatePipeRequest();
if (cmdletContext.Description != null)
{
request.Description = cmdletContext.Description;
}
if (cmdletContext.DesiredState != null)
{
request.DesiredState = cmdletContext.DesiredState;
}
if (cmdletContext.Enrichment != null)
{
request.Enrichment = cmdletContext.Enrichment;
}
// populate EnrichmentParameters
var requestEnrichmentParametersIsNull = true;
request.EnrichmentParameters = new Amazon.Pipes.Model.PipeEnrichmentParameters();
System.String requestEnrichmentParameters_enrichmentParameters_InputTemplate = null;
if (cmdletContext.EnrichmentParameters_InputTemplate != null)
{
requestEnrichmentParameters_enrichmentParameters_InputTemplate = cmdletContext.EnrichmentParameters_InputTemplate;
}
if (requestEnrichmentParameters_enrichmentParameters_InputTemplate != null)
{
request.EnrichmentParameters.InputTemplate = requestEnrichmentParameters_enrichmentParameters_InputTemplate;
requestEnrichmentParametersIsNull = false;
}
Amazon.Pipes.Model.PipeEnrichmentHttpParameters requestEnrichmentParameters_enrichmentParameters_HttpParameters = null;
// populate HttpParameters
var requestEnrichmentParameters_enrichmentParameters_HttpParametersIsNull = true;
requestEnrichmentParameters_enrichmentParameters_HttpParameters = new Amazon.Pipes.Model.PipeEnrichmentHttpParameters();
Dictionary requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_HeaderParameters = null;
if (cmdletContext.EnrichmentParameters_HttpParameters_HeaderParameters != null)
{
requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_HeaderParameters = cmdletContext.EnrichmentParameters_HttpParameters_HeaderParameters;
}
if (requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_HeaderParameters != null)
{
requestEnrichmentParameters_enrichmentParameters_HttpParameters.HeaderParameters = requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_HeaderParameters;
requestEnrichmentParameters_enrichmentParameters_HttpParametersIsNull = false;
}
List requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_PathParameterValues = null;
if (cmdletContext.EnrichmentParameters_HttpParameters_PathParameterValues != null)
{
requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_PathParameterValues = cmdletContext.EnrichmentParameters_HttpParameters_PathParameterValues;
}
if (requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_PathParameterValues != null)
{
requestEnrichmentParameters_enrichmentParameters_HttpParameters.PathParameterValues = requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_PathParameterValues;
requestEnrichmentParameters_enrichmentParameters_HttpParametersIsNull = false;
}
Dictionary requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_QueryStringParameters = null;
if (cmdletContext.EnrichmentParameters_HttpParameters_QueryStringParameters != null)
{
requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_QueryStringParameters = cmdletContext.EnrichmentParameters_HttpParameters_QueryStringParameters;
}
if (requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_QueryStringParameters != null)
{
requestEnrichmentParameters_enrichmentParameters_HttpParameters.QueryStringParameters = requestEnrichmentParameters_enrichmentParameters_HttpParameters_enrichmentParameters_HttpParameters_QueryStringParameters;
requestEnrichmentParameters_enrichmentParameters_HttpParametersIsNull = false;
}
// determine if requestEnrichmentParameters_enrichmentParameters_HttpParameters should be set to null
if (requestEnrichmentParameters_enrichmentParameters_HttpParametersIsNull)
{
requestEnrichmentParameters_enrichmentParameters_HttpParameters = null;
}
if (requestEnrichmentParameters_enrichmentParameters_HttpParameters != null)
{
request.EnrichmentParameters.HttpParameters = requestEnrichmentParameters_enrichmentParameters_HttpParameters;
requestEnrichmentParametersIsNull = false;
}
// determine if request.EnrichmentParameters should be set to null
if (requestEnrichmentParametersIsNull)
{
request.EnrichmentParameters = null;
}
if (cmdletContext.Name != null)
{
request.Name = cmdletContext.Name;
}
if (cmdletContext.RoleArn != null)
{
request.RoleArn = cmdletContext.RoleArn;
}
// populate SourceParameters
var requestSourceParametersIsNull = true;
request.SourceParameters = new Amazon.Pipes.Model.UpdatePipeSourceParameters();
Amazon.Pipes.Model.FilterCriteria requestSourceParameters_sourceParameters_FilterCriteria = null;
// populate FilterCriteria
var requestSourceParameters_sourceParameters_FilterCriteriaIsNull = true;
requestSourceParameters_sourceParameters_FilterCriteria = new Amazon.Pipes.Model.FilterCriteria();
List requestSourceParameters_sourceParameters_FilterCriteria_filterCriteria_Filter = null;
if (cmdletContext.FilterCriteria_Filter != null)
{
requestSourceParameters_sourceParameters_FilterCriteria_filterCriteria_Filter = cmdletContext.FilterCriteria_Filter;
}
if (requestSourceParameters_sourceParameters_FilterCriteria_filterCriteria_Filter != null)
{
requestSourceParameters_sourceParameters_FilterCriteria.Filters = requestSourceParameters_sourceParameters_FilterCriteria_filterCriteria_Filter;
requestSourceParameters_sourceParameters_FilterCriteriaIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_FilterCriteria should be set to null
if (requestSourceParameters_sourceParameters_FilterCriteriaIsNull)
{
requestSourceParameters_sourceParameters_FilterCriteria = null;
}
if (requestSourceParameters_sourceParameters_FilterCriteria != null)
{
request.SourceParameters.FilterCriteria = requestSourceParameters_sourceParameters_FilterCriteria;
requestSourceParametersIsNull = false;
}
Amazon.Pipes.Model.UpdatePipeSourceSqsQueueParameters requestSourceParameters_sourceParameters_SqsQueueParameters = null;
// populate SqsQueueParameters
var requestSourceParameters_sourceParameters_SqsQueueParametersIsNull = true;
requestSourceParameters_sourceParameters_SqsQueueParameters = new Amazon.Pipes.Model.UpdatePipeSourceSqsQueueParameters();
System.Int32? requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_BatchSize = null;
if (cmdletContext.SqsQueueParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_BatchSize = cmdletContext.SqsQueueParameters_BatchSize.Value;
}
if (requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_SqsQueueParameters.BatchSize = requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_BatchSize.Value;
requestSourceParameters_sourceParameters_SqsQueueParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_MaximumBatchingWindowInSecond = null;
if (cmdletContext.SqsQueueParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_MaximumBatchingWindowInSecond = cmdletContext.SqsQueueParameters_MaximumBatchingWindowInSecond.Value;
}
if (requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_SqsQueueParameters.MaximumBatchingWindowInSeconds = requestSourceParameters_sourceParameters_SqsQueueParameters_sqsQueueParameters_MaximumBatchingWindowInSecond.Value;
requestSourceParameters_sourceParameters_SqsQueueParametersIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_SqsQueueParameters should be set to null
if (requestSourceParameters_sourceParameters_SqsQueueParametersIsNull)
{
requestSourceParameters_sourceParameters_SqsQueueParameters = null;
}
if (requestSourceParameters_sourceParameters_SqsQueueParameters != null)
{
request.SourceParameters.SqsQueueParameters = requestSourceParameters_sourceParameters_SqsQueueParameters;
requestSourceParametersIsNull = false;
}
Amazon.Pipes.Model.UpdatePipeSourceActiveMQBrokerParameters requestSourceParameters_sourceParameters_ActiveMQBrokerParameters = null;
// populate ActiveMQBrokerParameters
var requestSourceParameters_sourceParameters_ActiveMQBrokerParametersIsNull = true;
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters = new Amazon.Pipes.Model.UpdatePipeSourceActiveMQBrokerParameters();
System.Int32? requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_BatchSize = null;
if (cmdletContext.ActiveMQBrokerParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_BatchSize = cmdletContext.ActiveMQBrokerParameters_BatchSize.Value;
}
if (requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters.BatchSize = requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_BatchSize.Value;
requestSourceParameters_sourceParameters_ActiveMQBrokerParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_MaximumBatchingWindowInSecond = null;
if (cmdletContext.ActiveMQBrokerParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_MaximumBatchingWindowInSecond = cmdletContext.ActiveMQBrokerParameters_MaximumBatchingWindowInSecond.Value;
}
if (requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters.MaximumBatchingWindowInSeconds = requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_activeMQBrokerParameters_MaximumBatchingWindowInSecond.Value;
requestSourceParameters_sourceParameters_ActiveMQBrokerParametersIsNull = false;
}
Amazon.Pipes.Model.MQBrokerAccessCredentials requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials = null;
// populate Credentials
var requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_CredentialsIsNull = true;
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials = new Amazon.Pipes.Model.MQBrokerAccessCredentials();
System.String requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials_sourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth = null;
if (cmdletContext.SourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth != null)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials_sourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth = cmdletContext.SourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth;
}
if (requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials_sourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth != null)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials.BasicAuth = requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials_sourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth;
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_CredentialsIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials should be set to null
if (requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_CredentialsIsNull)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials = null;
}
if (requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials != null)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters.Credentials = requestSourceParameters_sourceParameters_ActiveMQBrokerParameters_sourceParameters_ActiveMQBrokerParameters_Credentials;
requestSourceParameters_sourceParameters_ActiveMQBrokerParametersIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_ActiveMQBrokerParameters should be set to null
if (requestSourceParameters_sourceParameters_ActiveMQBrokerParametersIsNull)
{
requestSourceParameters_sourceParameters_ActiveMQBrokerParameters = null;
}
if (requestSourceParameters_sourceParameters_ActiveMQBrokerParameters != null)
{
request.SourceParameters.ActiveMQBrokerParameters = requestSourceParameters_sourceParameters_ActiveMQBrokerParameters;
requestSourceParametersIsNull = false;
}
Amazon.Pipes.Model.UpdatePipeSourceManagedStreamingKafkaParameters requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters = null;
// populate ManagedStreamingKafkaParameters
var requestSourceParameters_sourceParameters_ManagedStreamingKafkaParametersIsNull = true;
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters = new Amazon.Pipes.Model.UpdatePipeSourceManagedStreamingKafkaParameters();
System.Int32? requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_BatchSize = null;
if (cmdletContext.ManagedStreamingKafkaParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_BatchSize = cmdletContext.ManagedStreamingKafkaParameters_BatchSize.Value;
}
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters.BatchSize = requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_BatchSize.Value;
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_MaximumBatchingWindowInSecond = null;
if (cmdletContext.ManagedStreamingKafkaParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_MaximumBatchingWindowInSecond = cmdletContext.ManagedStreamingKafkaParameters_MaximumBatchingWindowInSecond.Value;
}
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters.MaximumBatchingWindowInSeconds = requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_managedStreamingKafkaParameters_MaximumBatchingWindowInSecond.Value;
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParametersIsNull = false;
}
Amazon.Pipes.Model.MSKAccessCredentials requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials = null;
// populate Credentials
var requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_CredentialsIsNull = true;
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials = new Amazon.Pipes.Model.MSKAccessCredentials();
System.String requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth = null;
if (cmdletContext.SourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth = cmdletContext.SourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth;
}
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials.ClientCertificateTlsAuth = requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth;
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_CredentialsIsNull = false;
}
System.String requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth = null;
if (cmdletContext.SourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth = cmdletContext.SourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth;
}
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials.SaslScram512Auth = requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials_sourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth;
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_CredentialsIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials should be set to null
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_CredentialsIsNull)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials = null;
}
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials != null)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters.Credentials = requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters_sourceParameters_ManagedStreamingKafkaParameters_Credentials;
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParametersIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters should be set to null
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParametersIsNull)
{
requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters = null;
}
if (requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters != null)
{
request.SourceParameters.ManagedStreamingKafkaParameters = requestSourceParameters_sourceParameters_ManagedStreamingKafkaParameters;
requestSourceParametersIsNull = false;
}
Amazon.Pipes.Model.UpdatePipeSourceRabbitMQBrokerParameters requestSourceParameters_sourceParameters_RabbitMQBrokerParameters = null;
// populate RabbitMQBrokerParameters
var requestSourceParameters_sourceParameters_RabbitMQBrokerParametersIsNull = true;
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters = new Amazon.Pipes.Model.UpdatePipeSourceRabbitMQBrokerParameters();
System.Int32? requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_BatchSize = null;
if (cmdletContext.RabbitMQBrokerParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_BatchSize = cmdletContext.RabbitMQBrokerParameters_BatchSize.Value;
}
if (requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters.BatchSize = requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_BatchSize.Value;
requestSourceParameters_sourceParameters_RabbitMQBrokerParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_MaximumBatchingWindowInSecond = null;
if (cmdletContext.RabbitMQBrokerParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_MaximumBatchingWindowInSecond = cmdletContext.RabbitMQBrokerParameters_MaximumBatchingWindowInSecond.Value;
}
if (requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters.MaximumBatchingWindowInSeconds = requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_rabbitMQBrokerParameters_MaximumBatchingWindowInSecond.Value;
requestSourceParameters_sourceParameters_RabbitMQBrokerParametersIsNull = false;
}
Amazon.Pipes.Model.MQBrokerAccessCredentials requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials = null;
// populate Credentials
var requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_CredentialsIsNull = true;
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials = new Amazon.Pipes.Model.MQBrokerAccessCredentials();
System.String requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials_sourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth = null;
if (cmdletContext.SourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth != null)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials_sourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth = cmdletContext.SourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth;
}
if (requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials_sourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth != null)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials.BasicAuth = requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials_sourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth;
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_CredentialsIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials should be set to null
if (requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_CredentialsIsNull)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials = null;
}
if (requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials != null)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters.Credentials = requestSourceParameters_sourceParameters_RabbitMQBrokerParameters_sourceParameters_RabbitMQBrokerParameters_Credentials;
requestSourceParameters_sourceParameters_RabbitMQBrokerParametersIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_RabbitMQBrokerParameters should be set to null
if (requestSourceParameters_sourceParameters_RabbitMQBrokerParametersIsNull)
{
requestSourceParameters_sourceParameters_RabbitMQBrokerParameters = null;
}
if (requestSourceParameters_sourceParameters_RabbitMQBrokerParameters != null)
{
request.SourceParameters.RabbitMQBrokerParameters = requestSourceParameters_sourceParameters_RabbitMQBrokerParameters;
requestSourceParametersIsNull = false;
}
Amazon.Pipes.Model.UpdatePipeSourceSelfManagedKafkaParameters requestSourceParameters_sourceParameters_SelfManagedKafkaParameters = null;
// populate SelfManagedKafkaParameters
var requestSourceParameters_sourceParameters_SelfManagedKafkaParametersIsNull = true;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters = new Amazon.Pipes.Model.UpdatePipeSourceSelfManagedKafkaParameters();
System.Int32? requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_BatchSize = null;
if (cmdletContext.SelfManagedKafkaParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_BatchSize = cmdletContext.SelfManagedKafkaParameters_BatchSize.Value;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters.BatchSize = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_BatchSize.Value;
requestSourceParameters_sourceParameters_SelfManagedKafkaParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_MaximumBatchingWindowInSecond = null;
if (cmdletContext.SelfManagedKafkaParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_MaximumBatchingWindowInSecond = cmdletContext.SelfManagedKafkaParameters_MaximumBatchingWindowInSecond.Value;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters.MaximumBatchingWindowInSeconds = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_MaximumBatchingWindowInSecond.Value;
requestSourceParameters_sourceParameters_SelfManagedKafkaParametersIsNull = false;
}
System.String requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_ServerRootCaCertificate = null;
if (cmdletContext.SelfManagedKafkaParameters_ServerRootCaCertificate != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_ServerRootCaCertificate = cmdletContext.SelfManagedKafkaParameters_ServerRootCaCertificate;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_ServerRootCaCertificate != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters.ServerRootCaCertificate = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_selfManagedKafkaParameters_ServerRootCaCertificate;
requestSourceParameters_sourceParameters_SelfManagedKafkaParametersIsNull = false;
}
Amazon.Pipes.Model.SelfManagedKafkaAccessConfigurationVpc requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc = null;
// populate Vpc
var requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_VpcIsNull = true;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc = new Amazon.Pipes.Model.SelfManagedKafkaAccessConfigurationVpc();
List requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_SecurityGroup = null;
if (cmdletContext.Vpc_SecurityGroup != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_SecurityGroup = cmdletContext.Vpc_SecurityGroup;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_SecurityGroup != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc.SecurityGroup = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_SecurityGroup;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_VpcIsNull = false;
}
List requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_Subnet = null;
if (cmdletContext.Vpc_Subnet != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_Subnet = cmdletContext.Vpc_Subnet;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_Subnet != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc.Subnets = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc_vpc_Subnet;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_VpcIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc should be set to null
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_VpcIsNull)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc = null;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters.Vpc = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Vpc;
requestSourceParameters_sourceParameters_SelfManagedKafkaParametersIsNull = false;
}
Amazon.Pipes.Model.SelfManagedKafkaAccessConfigurationCredentials requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials = null;
// populate Credentials
var requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_CredentialsIsNull = true;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials = new Amazon.Pipes.Model.SelfManagedKafkaAccessConfigurationCredentials();
System.String requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth = null;
if (cmdletContext.SourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth = cmdletContext.SourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials.BasicAuth = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_CredentialsIsNull = false;
}
System.String requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth = null;
if (cmdletContext.SourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth = cmdletContext.SourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials.ClientCertificateTlsAuth = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_sourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_CredentialsIsNull = false;
}
System.String requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram256Auth = null;
if (cmdletContext.Credentials_SaslScram256Auth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram256Auth = cmdletContext.Credentials_SaslScram256Auth;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram256Auth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials.SaslScram256Auth = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram256Auth;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_CredentialsIsNull = false;
}
System.String requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram512Auth = null;
if (cmdletContext.Credentials_SaslScram512Auth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram512Auth = cmdletContext.Credentials_SaslScram512Auth;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram512Auth != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials.SaslScram512Auth = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials_credentials_SaslScram512Auth;
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_CredentialsIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials should be set to null
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_CredentialsIsNull)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials = null;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials != null)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters.Credentials = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters_sourceParameters_SelfManagedKafkaParameters_Credentials;
requestSourceParameters_sourceParameters_SelfManagedKafkaParametersIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_SelfManagedKafkaParameters should be set to null
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParametersIsNull)
{
requestSourceParameters_sourceParameters_SelfManagedKafkaParameters = null;
}
if (requestSourceParameters_sourceParameters_SelfManagedKafkaParameters != null)
{
request.SourceParameters.SelfManagedKafkaParameters = requestSourceParameters_sourceParameters_SelfManagedKafkaParameters;
requestSourceParametersIsNull = false;
}
Amazon.Pipes.Model.UpdatePipeSourceDynamoDBStreamParameters requestSourceParameters_sourceParameters_DynamoDBStreamParameters = null;
// populate DynamoDBStreamParameters
var requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = true;
requestSourceParameters_sourceParameters_DynamoDBStreamParameters = new Amazon.Pipes.Model.UpdatePipeSourceDynamoDBStreamParameters();
System.Int32? requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_BatchSize = null;
if (cmdletContext.DynamoDBStreamParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_BatchSize = cmdletContext.DynamoDBStreamParameters_BatchSize.Value;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters.BatchSize = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_BatchSize.Value;
requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumBatchingWindowInSecond = null;
if (cmdletContext.DynamoDBStreamParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumBatchingWindowInSecond = cmdletContext.DynamoDBStreamParameters_MaximumBatchingWindowInSecond.Value;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters.MaximumBatchingWindowInSeconds = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumBatchingWindowInSecond.Value;
requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRecordAgeInSecond = null;
if (cmdletContext.DynamoDBStreamParameters_MaximumRecordAgeInSecond != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRecordAgeInSecond = cmdletContext.DynamoDBStreamParameters_MaximumRecordAgeInSecond.Value;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRecordAgeInSecond != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters.MaximumRecordAgeInSeconds = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRecordAgeInSecond.Value;
requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRetryAttempt = null;
if (cmdletContext.DynamoDBStreamParameters_MaximumRetryAttempt != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRetryAttempt = cmdletContext.DynamoDBStreamParameters_MaximumRetryAttempt.Value;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRetryAttempt != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters.MaximumRetryAttempts = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_MaximumRetryAttempt.Value;
requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = false;
}
Amazon.Pipes.OnPartialBatchItemFailureStreams requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_OnPartialBatchItemFailure = null;
if (cmdletContext.DynamoDBStreamParameters_OnPartialBatchItemFailure != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_OnPartialBatchItemFailure = cmdletContext.DynamoDBStreamParameters_OnPartialBatchItemFailure;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_OnPartialBatchItemFailure != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters.OnPartialBatchItemFailure = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_OnPartialBatchItemFailure;
requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_ParallelizationFactor = null;
if (cmdletContext.DynamoDBStreamParameters_ParallelizationFactor != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_ParallelizationFactor = cmdletContext.DynamoDBStreamParameters_ParallelizationFactor.Value;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_ParallelizationFactor != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters.ParallelizationFactor = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_dynamoDBStreamParameters_ParallelizationFactor.Value;
requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = false;
}
Amazon.Pipes.Model.DeadLetterConfig requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig = null;
// populate DeadLetterConfig
var requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfigIsNull = true;
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig = new Amazon.Pipes.Model.DeadLetterConfig();
System.String requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn = null;
if (cmdletContext.SourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn = cmdletContext.SourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig.Arn = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn;
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfigIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig should be set to null
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfigIsNull)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig = null;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig != null)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters.DeadLetterConfig = requestSourceParameters_sourceParameters_DynamoDBStreamParameters_sourceParameters_DynamoDBStreamParameters_DeadLetterConfig;
requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_DynamoDBStreamParameters should be set to null
if (requestSourceParameters_sourceParameters_DynamoDBStreamParametersIsNull)
{
requestSourceParameters_sourceParameters_DynamoDBStreamParameters = null;
}
if (requestSourceParameters_sourceParameters_DynamoDBStreamParameters != null)
{
request.SourceParameters.DynamoDBStreamParameters = requestSourceParameters_sourceParameters_DynamoDBStreamParameters;
requestSourceParametersIsNull = false;
}
Amazon.Pipes.Model.UpdatePipeSourceKinesisStreamParameters requestSourceParameters_sourceParameters_KinesisStreamParameters = null;
// populate KinesisStreamParameters
var requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = true;
requestSourceParameters_sourceParameters_KinesisStreamParameters = new Amazon.Pipes.Model.UpdatePipeSourceKinesisStreamParameters();
System.Int32? requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_BatchSize = null;
if (cmdletContext.KinesisStreamParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_BatchSize = cmdletContext.KinesisStreamParameters_BatchSize.Value;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_BatchSize != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters.BatchSize = requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_BatchSize.Value;
requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumBatchingWindowInSecond = null;
if (cmdletContext.KinesisStreamParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumBatchingWindowInSecond = cmdletContext.KinesisStreamParameters_MaximumBatchingWindowInSecond.Value;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumBatchingWindowInSecond != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters.MaximumBatchingWindowInSeconds = requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumBatchingWindowInSecond.Value;
requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRecordAgeInSecond = null;
if (cmdletContext.KinesisStreamParameters_MaximumRecordAgeInSecond != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRecordAgeInSecond = cmdletContext.KinesisStreamParameters_MaximumRecordAgeInSecond.Value;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRecordAgeInSecond != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters.MaximumRecordAgeInSeconds = requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRecordAgeInSecond.Value;
requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRetryAttempt = null;
if (cmdletContext.KinesisStreamParameters_MaximumRetryAttempt != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRetryAttempt = cmdletContext.KinesisStreamParameters_MaximumRetryAttempt.Value;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRetryAttempt != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters.MaximumRetryAttempts = requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_MaximumRetryAttempt.Value;
requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = false;
}
Amazon.Pipes.OnPartialBatchItemFailureStreams requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_OnPartialBatchItemFailure = null;
if (cmdletContext.KinesisStreamParameters_OnPartialBatchItemFailure != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_OnPartialBatchItemFailure = cmdletContext.KinesisStreamParameters_OnPartialBatchItemFailure;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_OnPartialBatchItemFailure != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters.OnPartialBatchItemFailure = requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_OnPartialBatchItemFailure;
requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = false;
}
System.Int32? requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_ParallelizationFactor = null;
if (cmdletContext.KinesisStreamParameters_ParallelizationFactor != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_ParallelizationFactor = cmdletContext.KinesisStreamParameters_ParallelizationFactor.Value;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_ParallelizationFactor != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters.ParallelizationFactor = requestSourceParameters_sourceParameters_KinesisStreamParameters_kinesisStreamParameters_ParallelizationFactor.Value;
requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = false;
}
Amazon.Pipes.Model.DeadLetterConfig requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig = null;
// populate DeadLetterConfig
var requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfigIsNull = true;
requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig = new Amazon.Pipes.Model.DeadLetterConfig();
System.String requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig_sourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn = null;
if (cmdletContext.SourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig_sourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn = cmdletContext.SourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig_sourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig.Arn = requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig_sourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn;
requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfigIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig should be set to null
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfigIsNull)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig = null;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig != null)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters.DeadLetterConfig = requestSourceParameters_sourceParameters_KinesisStreamParameters_sourceParameters_KinesisStreamParameters_DeadLetterConfig;
requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull = false;
}
// determine if requestSourceParameters_sourceParameters_KinesisStreamParameters should be set to null
if (requestSourceParameters_sourceParameters_KinesisStreamParametersIsNull)
{
requestSourceParameters_sourceParameters_KinesisStreamParameters = null;
}
if (requestSourceParameters_sourceParameters_KinesisStreamParameters != null)
{
request.SourceParameters.KinesisStreamParameters = requestSourceParameters_sourceParameters_KinesisStreamParameters;
requestSourceParametersIsNull = false;
}
// determine if request.SourceParameters should be set to null
if (requestSourceParametersIsNull)
{
request.SourceParameters = null;
}
if (cmdletContext.Target != null)
{
request.Target = cmdletContext.Target;
}
// populate TargetParameters
var requestTargetParametersIsNull = true;
request.TargetParameters = new Amazon.Pipes.Model.PipeTargetParameters();
System.String requestTargetParameters_targetParameters_InputTemplate = null;
if (cmdletContext.TargetParameters_InputTemplate != null)
{
requestTargetParameters_targetParameters_InputTemplate = cmdletContext.TargetParameters_InputTemplate;
}
if (requestTargetParameters_targetParameters_InputTemplate != null)
{
request.TargetParameters.InputTemplate = requestTargetParameters_targetParameters_InputTemplate;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetKinesisStreamParameters requestTargetParameters_targetParameters_KinesisStreamParameters = null;
// populate KinesisStreamParameters
var requestTargetParameters_targetParameters_KinesisStreamParametersIsNull = true;
requestTargetParameters_targetParameters_KinesisStreamParameters = new Amazon.Pipes.Model.PipeTargetKinesisStreamParameters();
System.String requestTargetParameters_targetParameters_KinesisStreamParameters_kinesisStreamParameters_PartitionKey = null;
if (cmdletContext.KinesisStreamParameters_PartitionKey != null)
{
requestTargetParameters_targetParameters_KinesisStreamParameters_kinesisStreamParameters_PartitionKey = cmdletContext.KinesisStreamParameters_PartitionKey;
}
if (requestTargetParameters_targetParameters_KinesisStreamParameters_kinesisStreamParameters_PartitionKey != null)
{
requestTargetParameters_targetParameters_KinesisStreamParameters.PartitionKey = requestTargetParameters_targetParameters_KinesisStreamParameters_kinesisStreamParameters_PartitionKey;
requestTargetParameters_targetParameters_KinesisStreamParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_KinesisStreamParameters should be set to null
if (requestTargetParameters_targetParameters_KinesisStreamParametersIsNull)
{
requestTargetParameters_targetParameters_KinesisStreamParameters = null;
}
if (requestTargetParameters_targetParameters_KinesisStreamParameters != null)
{
request.TargetParameters.KinesisStreamParameters = requestTargetParameters_targetParameters_KinesisStreamParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetLambdaFunctionParameters requestTargetParameters_targetParameters_LambdaFunctionParameters = null;
// populate LambdaFunctionParameters
var requestTargetParameters_targetParameters_LambdaFunctionParametersIsNull = true;
requestTargetParameters_targetParameters_LambdaFunctionParameters = new Amazon.Pipes.Model.PipeTargetLambdaFunctionParameters();
Amazon.Pipes.PipeTargetInvocationType requestTargetParameters_targetParameters_LambdaFunctionParameters_lambdaFunctionParameters_InvocationType = null;
if (cmdletContext.LambdaFunctionParameters_InvocationType != null)
{
requestTargetParameters_targetParameters_LambdaFunctionParameters_lambdaFunctionParameters_InvocationType = cmdletContext.LambdaFunctionParameters_InvocationType;
}
if (requestTargetParameters_targetParameters_LambdaFunctionParameters_lambdaFunctionParameters_InvocationType != null)
{
requestTargetParameters_targetParameters_LambdaFunctionParameters.InvocationType = requestTargetParameters_targetParameters_LambdaFunctionParameters_lambdaFunctionParameters_InvocationType;
requestTargetParameters_targetParameters_LambdaFunctionParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_LambdaFunctionParameters should be set to null
if (requestTargetParameters_targetParameters_LambdaFunctionParametersIsNull)
{
requestTargetParameters_targetParameters_LambdaFunctionParameters = null;
}
if (requestTargetParameters_targetParameters_LambdaFunctionParameters != null)
{
request.TargetParameters.LambdaFunctionParameters = requestTargetParameters_targetParameters_LambdaFunctionParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetSageMakerPipelineParameters requestTargetParameters_targetParameters_SageMakerPipelineParameters = null;
// populate SageMakerPipelineParameters
var requestTargetParameters_targetParameters_SageMakerPipelineParametersIsNull = true;
requestTargetParameters_targetParameters_SageMakerPipelineParameters = new Amazon.Pipes.Model.PipeTargetSageMakerPipelineParameters();
List requestTargetParameters_targetParameters_SageMakerPipelineParameters_sageMakerPipelineParameters_PipelineParameterList = null;
if (cmdletContext.SageMakerPipelineParameters_PipelineParameterList != null)
{
requestTargetParameters_targetParameters_SageMakerPipelineParameters_sageMakerPipelineParameters_PipelineParameterList = cmdletContext.SageMakerPipelineParameters_PipelineParameterList;
}
if (requestTargetParameters_targetParameters_SageMakerPipelineParameters_sageMakerPipelineParameters_PipelineParameterList != null)
{
requestTargetParameters_targetParameters_SageMakerPipelineParameters.PipelineParameterList = requestTargetParameters_targetParameters_SageMakerPipelineParameters_sageMakerPipelineParameters_PipelineParameterList;
requestTargetParameters_targetParameters_SageMakerPipelineParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_SageMakerPipelineParameters should be set to null
if (requestTargetParameters_targetParameters_SageMakerPipelineParametersIsNull)
{
requestTargetParameters_targetParameters_SageMakerPipelineParameters = null;
}
if (requestTargetParameters_targetParameters_SageMakerPipelineParameters != null)
{
request.TargetParameters.SageMakerPipelineParameters = requestTargetParameters_targetParameters_SageMakerPipelineParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetStateMachineParameters requestTargetParameters_targetParameters_StepFunctionStateMachineParameters = null;
// populate StepFunctionStateMachineParameters
var requestTargetParameters_targetParameters_StepFunctionStateMachineParametersIsNull = true;
requestTargetParameters_targetParameters_StepFunctionStateMachineParameters = new Amazon.Pipes.Model.PipeTargetStateMachineParameters();
Amazon.Pipes.PipeTargetInvocationType requestTargetParameters_targetParameters_StepFunctionStateMachineParameters_stepFunctionStateMachineParameters_InvocationType = null;
if (cmdletContext.StepFunctionStateMachineParameters_InvocationType != null)
{
requestTargetParameters_targetParameters_StepFunctionStateMachineParameters_stepFunctionStateMachineParameters_InvocationType = cmdletContext.StepFunctionStateMachineParameters_InvocationType;
}
if (requestTargetParameters_targetParameters_StepFunctionStateMachineParameters_stepFunctionStateMachineParameters_InvocationType != null)
{
requestTargetParameters_targetParameters_StepFunctionStateMachineParameters.InvocationType = requestTargetParameters_targetParameters_StepFunctionStateMachineParameters_stepFunctionStateMachineParameters_InvocationType;
requestTargetParameters_targetParameters_StepFunctionStateMachineParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_StepFunctionStateMachineParameters should be set to null
if (requestTargetParameters_targetParameters_StepFunctionStateMachineParametersIsNull)
{
requestTargetParameters_targetParameters_StepFunctionStateMachineParameters = null;
}
if (requestTargetParameters_targetParameters_StepFunctionStateMachineParameters != null)
{
request.TargetParameters.StepFunctionStateMachineParameters = requestTargetParameters_targetParameters_StepFunctionStateMachineParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetCloudWatchLogsParameters requestTargetParameters_targetParameters_CloudWatchLogsParameters = null;
// populate CloudWatchLogsParameters
var requestTargetParameters_targetParameters_CloudWatchLogsParametersIsNull = true;
requestTargetParameters_targetParameters_CloudWatchLogsParameters = new Amazon.Pipes.Model.PipeTargetCloudWatchLogsParameters();
System.String requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_LogStreamName = null;
if (cmdletContext.CloudWatchLogsParameters_LogStreamName != null)
{
requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_LogStreamName = cmdletContext.CloudWatchLogsParameters_LogStreamName;
}
if (requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_LogStreamName != null)
{
requestTargetParameters_targetParameters_CloudWatchLogsParameters.LogStreamName = requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_LogStreamName;
requestTargetParameters_targetParameters_CloudWatchLogsParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_Timestamp = null;
if (cmdletContext.CloudWatchLogsParameters_Timestamp != null)
{
requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_Timestamp = cmdletContext.CloudWatchLogsParameters_Timestamp;
}
if (requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_Timestamp != null)
{
requestTargetParameters_targetParameters_CloudWatchLogsParameters.Timestamp = requestTargetParameters_targetParameters_CloudWatchLogsParameters_cloudWatchLogsParameters_Timestamp;
requestTargetParameters_targetParameters_CloudWatchLogsParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_CloudWatchLogsParameters should be set to null
if (requestTargetParameters_targetParameters_CloudWatchLogsParametersIsNull)
{
requestTargetParameters_targetParameters_CloudWatchLogsParameters = null;
}
if (requestTargetParameters_targetParameters_CloudWatchLogsParameters != null)
{
request.TargetParameters.CloudWatchLogsParameters = requestTargetParameters_targetParameters_CloudWatchLogsParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetSqsQueueParameters requestTargetParameters_targetParameters_SqsQueueParameters = null;
// populate SqsQueueParameters
var requestTargetParameters_targetParameters_SqsQueueParametersIsNull = true;
requestTargetParameters_targetParameters_SqsQueueParameters = new Amazon.Pipes.Model.PipeTargetSqsQueueParameters();
System.String requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageDeduplicationId = null;
if (cmdletContext.SqsQueueParameters_MessageDeduplicationId != null)
{
requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageDeduplicationId = cmdletContext.SqsQueueParameters_MessageDeduplicationId;
}
if (requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageDeduplicationId != null)
{
requestTargetParameters_targetParameters_SqsQueueParameters.MessageDeduplicationId = requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageDeduplicationId;
requestTargetParameters_targetParameters_SqsQueueParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageGroupId = null;
if (cmdletContext.SqsQueueParameters_MessageGroupId != null)
{
requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageGroupId = cmdletContext.SqsQueueParameters_MessageGroupId;
}
if (requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageGroupId != null)
{
requestTargetParameters_targetParameters_SqsQueueParameters.MessageGroupId = requestTargetParameters_targetParameters_SqsQueueParameters_sqsQueueParameters_MessageGroupId;
requestTargetParameters_targetParameters_SqsQueueParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_SqsQueueParameters should be set to null
if (requestTargetParameters_targetParameters_SqsQueueParametersIsNull)
{
requestTargetParameters_targetParameters_SqsQueueParameters = null;
}
if (requestTargetParameters_targetParameters_SqsQueueParameters != null)
{
request.TargetParameters.SqsQueueParameters = requestTargetParameters_targetParameters_SqsQueueParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetHttpParameters requestTargetParameters_targetParameters_HttpParameters = null;
// populate HttpParameters
var requestTargetParameters_targetParameters_HttpParametersIsNull = true;
requestTargetParameters_targetParameters_HttpParameters = new Amazon.Pipes.Model.PipeTargetHttpParameters();
Dictionary requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_HeaderParameters = null;
if (cmdletContext.TargetParameters_HttpParameters_HeaderParameters != null)
{
requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_HeaderParameters = cmdletContext.TargetParameters_HttpParameters_HeaderParameters;
}
if (requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_HeaderParameters != null)
{
requestTargetParameters_targetParameters_HttpParameters.HeaderParameters = requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_HeaderParameters;
requestTargetParameters_targetParameters_HttpParametersIsNull = false;
}
List requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_PathParameterValues = null;
if (cmdletContext.TargetParameters_HttpParameters_PathParameterValues != null)
{
requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_PathParameterValues = cmdletContext.TargetParameters_HttpParameters_PathParameterValues;
}
if (requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_PathParameterValues != null)
{
requestTargetParameters_targetParameters_HttpParameters.PathParameterValues = requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_PathParameterValues;
requestTargetParameters_targetParameters_HttpParametersIsNull = false;
}
Dictionary requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_QueryStringParameters = null;
if (cmdletContext.TargetParameters_HttpParameters_QueryStringParameters != null)
{
requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_QueryStringParameters = cmdletContext.TargetParameters_HttpParameters_QueryStringParameters;
}
if (requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_QueryStringParameters != null)
{
requestTargetParameters_targetParameters_HttpParameters.QueryStringParameters = requestTargetParameters_targetParameters_HttpParameters_targetParameters_HttpParameters_QueryStringParameters;
requestTargetParameters_targetParameters_HttpParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_HttpParameters should be set to null
if (requestTargetParameters_targetParameters_HttpParametersIsNull)
{
requestTargetParameters_targetParameters_HttpParameters = null;
}
if (requestTargetParameters_targetParameters_HttpParameters != null)
{
request.TargetParameters.HttpParameters = requestTargetParameters_targetParameters_HttpParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetEventBridgeEventBusParameters requestTargetParameters_targetParameters_EventBridgeEventBusParameters = null;
// populate EventBridgeEventBusParameters
var requestTargetParameters_targetParameters_EventBridgeEventBusParametersIsNull = true;
requestTargetParameters_targetParameters_EventBridgeEventBusParameters = new Amazon.Pipes.Model.PipeTargetEventBridgeEventBusParameters();
System.String requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_DetailType = null;
if (cmdletContext.EventBridgeEventBusParameters_DetailType != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_DetailType = cmdletContext.EventBridgeEventBusParameters_DetailType;
}
if (requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_DetailType != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters.DetailType = requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_DetailType;
requestTargetParameters_targetParameters_EventBridgeEventBusParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_EndpointId = null;
if (cmdletContext.EventBridgeEventBusParameters_EndpointId != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_EndpointId = cmdletContext.EventBridgeEventBusParameters_EndpointId;
}
if (requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_EndpointId != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters.EndpointId = requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_EndpointId;
requestTargetParameters_targetParameters_EventBridgeEventBusParametersIsNull = false;
}
List requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Resource = null;
if (cmdletContext.EventBridgeEventBusParameters_Resource != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Resource = cmdletContext.EventBridgeEventBusParameters_Resource;
}
if (requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Resource != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters.Resources = requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Resource;
requestTargetParameters_targetParameters_EventBridgeEventBusParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Source = null;
if (cmdletContext.EventBridgeEventBusParameters_Source != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Source = cmdletContext.EventBridgeEventBusParameters_Source;
}
if (requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Source != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters.Source = requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Source;
requestTargetParameters_targetParameters_EventBridgeEventBusParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Time = null;
if (cmdletContext.EventBridgeEventBusParameters_Time != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Time = cmdletContext.EventBridgeEventBusParameters_Time;
}
if (requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Time != null)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters.Time = requestTargetParameters_targetParameters_EventBridgeEventBusParameters_eventBridgeEventBusParameters_Time;
requestTargetParameters_targetParameters_EventBridgeEventBusParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_EventBridgeEventBusParameters should be set to null
if (requestTargetParameters_targetParameters_EventBridgeEventBusParametersIsNull)
{
requestTargetParameters_targetParameters_EventBridgeEventBusParameters = null;
}
if (requestTargetParameters_targetParameters_EventBridgeEventBusParameters != null)
{
request.TargetParameters.EventBridgeEventBusParameters = requestTargetParameters_targetParameters_EventBridgeEventBusParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetRedshiftDataParameters requestTargetParameters_targetParameters_RedshiftDataParameters = null;
// populate RedshiftDataParameters
var requestTargetParameters_targetParameters_RedshiftDataParametersIsNull = true;
requestTargetParameters_targetParameters_RedshiftDataParameters = new Amazon.Pipes.Model.PipeTargetRedshiftDataParameters();
System.String requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Database = null;
if (cmdletContext.RedshiftDataParameters_Database != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Database = cmdletContext.RedshiftDataParameters_Database;
}
if (requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Database != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters.Database = requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Database;
requestTargetParameters_targetParameters_RedshiftDataParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_DbUser = null;
if (cmdletContext.RedshiftDataParameters_DbUser != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_DbUser = cmdletContext.RedshiftDataParameters_DbUser;
}
if (requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_DbUser != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters.DbUser = requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_DbUser;
requestTargetParameters_targetParameters_RedshiftDataParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_SecretManagerArn = null;
if (cmdletContext.RedshiftDataParameters_SecretManagerArn != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_SecretManagerArn = cmdletContext.RedshiftDataParameters_SecretManagerArn;
}
if (requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_SecretManagerArn != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters.SecretManagerArn = requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_SecretManagerArn;
requestTargetParameters_targetParameters_RedshiftDataParametersIsNull = false;
}
List requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Sql = null;
if (cmdletContext.RedshiftDataParameters_Sql != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Sql = cmdletContext.RedshiftDataParameters_Sql;
}
if (requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Sql != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters.Sqls = requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_Sql;
requestTargetParameters_targetParameters_RedshiftDataParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_StatementName = null;
if (cmdletContext.RedshiftDataParameters_StatementName != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_StatementName = cmdletContext.RedshiftDataParameters_StatementName;
}
if (requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_StatementName != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters.StatementName = requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_StatementName;
requestTargetParameters_targetParameters_RedshiftDataParametersIsNull = false;
}
System.Boolean? requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_WithEvent = null;
if (cmdletContext.RedshiftDataParameters_WithEvent != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_WithEvent = cmdletContext.RedshiftDataParameters_WithEvent.Value;
}
if (requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_WithEvent != null)
{
requestTargetParameters_targetParameters_RedshiftDataParameters.WithEvent = requestTargetParameters_targetParameters_RedshiftDataParameters_redshiftDataParameters_WithEvent.Value;
requestTargetParameters_targetParameters_RedshiftDataParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_RedshiftDataParameters should be set to null
if (requestTargetParameters_targetParameters_RedshiftDataParametersIsNull)
{
requestTargetParameters_targetParameters_RedshiftDataParameters = null;
}
if (requestTargetParameters_targetParameters_RedshiftDataParameters != null)
{
request.TargetParameters.RedshiftDataParameters = requestTargetParameters_targetParameters_RedshiftDataParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetBatchJobParameters requestTargetParameters_targetParameters_BatchJobParameters = null;
// populate BatchJobParameters
var requestTargetParameters_targetParameters_BatchJobParametersIsNull = true;
requestTargetParameters_targetParameters_BatchJobParameters = new Amazon.Pipes.Model.PipeTargetBatchJobParameters();
List requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_DependsOn = null;
if (cmdletContext.BatchJobParameters_DependsOn != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_DependsOn = cmdletContext.BatchJobParameters_DependsOn;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_DependsOn != null)
{
requestTargetParameters_targetParameters_BatchJobParameters.DependsOn = requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_DependsOn;
requestTargetParameters_targetParameters_BatchJobParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobDefinition = null;
if (cmdletContext.BatchJobParameters_JobDefinition != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobDefinition = cmdletContext.BatchJobParameters_JobDefinition;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobDefinition != null)
{
requestTargetParameters_targetParameters_BatchJobParameters.JobDefinition = requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobDefinition;
requestTargetParameters_targetParameters_BatchJobParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobName = null;
if (cmdletContext.BatchJobParameters_JobName != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobName = cmdletContext.BatchJobParameters_JobName;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobName != null)
{
requestTargetParameters_targetParameters_BatchJobParameters.JobName = requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_JobName;
requestTargetParameters_targetParameters_BatchJobParametersIsNull = false;
}
Dictionary requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_Parameter = null;
if (cmdletContext.BatchJobParameters_Parameter != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_Parameter = cmdletContext.BatchJobParameters_Parameter;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_Parameter != null)
{
requestTargetParameters_targetParameters_BatchJobParameters.Parameters = requestTargetParameters_targetParameters_BatchJobParameters_batchJobParameters_Parameter;
requestTargetParameters_targetParameters_BatchJobParametersIsNull = false;
}
Amazon.Pipes.Model.BatchArrayProperties requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties = null;
// populate ArrayProperties
var requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayPropertiesIsNull = true;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties = new Amazon.Pipes.Model.BatchArrayProperties();
System.Int32? requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties_arrayProperties_Size = null;
if (cmdletContext.ArrayProperties_Size != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties_arrayProperties_Size = cmdletContext.ArrayProperties_Size.Value;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties_arrayProperties_Size != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties.Size = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties_arrayProperties_Size.Value;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayPropertiesIsNull = false;
}
// determine if requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties should be set to null
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayPropertiesIsNull)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties = null;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties != null)
{
requestTargetParameters_targetParameters_BatchJobParameters.ArrayProperties = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ArrayProperties;
requestTargetParameters_targetParameters_BatchJobParametersIsNull = false;
}
Amazon.Pipes.Model.BatchRetryStrategy requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy = null;
// populate RetryStrategy
var requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategyIsNull = true;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy = new Amazon.Pipes.Model.BatchRetryStrategy();
System.Int32? requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy_retryStrategy_Attempt = null;
if (cmdletContext.RetryStrategy_Attempt != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy_retryStrategy_Attempt = cmdletContext.RetryStrategy_Attempt.Value;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy_retryStrategy_Attempt != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy.Attempts = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy_retryStrategy_Attempt.Value;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategyIsNull = false;
}
// determine if requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy should be set to null
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategyIsNull)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy = null;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy != null)
{
requestTargetParameters_targetParameters_BatchJobParameters.RetryStrategy = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_RetryStrategy;
requestTargetParameters_targetParameters_BatchJobParametersIsNull = false;
}
Amazon.Pipes.Model.BatchContainerOverrides requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides = null;
// populate ContainerOverrides
var requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverridesIsNull = true;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides = new Amazon.Pipes.Model.BatchContainerOverrides();
List requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Command = null;
if (cmdletContext.ContainerOverrides_Command != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Command = cmdletContext.ContainerOverrides_Command;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Command != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides.Command = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Command;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverridesIsNull = false;
}
List requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Environment = null;
if (cmdletContext.ContainerOverrides_Environment != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Environment = cmdletContext.ContainerOverrides_Environment;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Environment != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides.Environment = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_Environment;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverridesIsNull = false;
}
System.String requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_InstanceType = null;
if (cmdletContext.ContainerOverrides_InstanceType != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_InstanceType = cmdletContext.ContainerOverrides_InstanceType;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_InstanceType != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides.InstanceType = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_InstanceType;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverridesIsNull = false;
}
List requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_ResourceRequirement = null;
if (cmdletContext.ContainerOverrides_ResourceRequirement != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_ResourceRequirement = cmdletContext.ContainerOverrides_ResourceRequirement;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_ResourceRequirement != null)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides.ResourceRequirements = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides_containerOverrides_ResourceRequirement;
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverridesIsNull = false;
}
// determine if requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides should be set to null
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverridesIsNull)
{
requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides = null;
}
if (requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides != null)
{
requestTargetParameters_targetParameters_BatchJobParameters.ContainerOverrides = requestTargetParameters_targetParameters_BatchJobParameters_targetParameters_BatchJobParameters_ContainerOverrides;
requestTargetParameters_targetParameters_BatchJobParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_BatchJobParameters should be set to null
if (requestTargetParameters_targetParameters_BatchJobParametersIsNull)
{
requestTargetParameters_targetParameters_BatchJobParameters = null;
}
if (requestTargetParameters_targetParameters_BatchJobParameters != null)
{
request.TargetParameters.BatchJobParameters = requestTargetParameters_targetParameters_BatchJobParameters;
requestTargetParametersIsNull = false;
}
Amazon.Pipes.Model.PipeTargetEcsTaskParameters requestTargetParameters_targetParameters_EcsTaskParameters = null;
// populate EcsTaskParameters
var requestTargetParameters_targetParameters_EcsTaskParametersIsNull = true;
requestTargetParameters_targetParameters_EcsTaskParameters = new Amazon.Pipes.Model.PipeTargetEcsTaskParameters();
List requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_CapacityProviderStrategy = null;
if (cmdletContext.EcsTaskParameters_CapacityProviderStrategy != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_CapacityProviderStrategy = cmdletContext.EcsTaskParameters_CapacityProviderStrategy;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_CapacityProviderStrategy != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.CapacityProviderStrategy = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_CapacityProviderStrategy;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
System.Boolean? requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableECSManagedTag = null;
if (cmdletContext.EcsTaskParameters_EnableECSManagedTag != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableECSManagedTag = cmdletContext.EcsTaskParameters_EnableECSManagedTag.Value;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableECSManagedTag != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.EnableECSManagedTags = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableECSManagedTag.Value;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
System.Boolean? requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableExecuteCommand = null;
if (cmdletContext.EcsTaskParameters_EnableExecuteCommand != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableExecuteCommand = cmdletContext.EcsTaskParameters_EnableExecuteCommand.Value;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableExecuteCommand != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.EnableExecuteCommand = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_EnableExecuteCommand.Value;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Group = null;
if (cmdletContext.EcsTaskParameters_Group != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Group = cmdletContext.EcsTaskParameters_Group;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Group != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.Group = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Group;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
Amazon.Pipes.LaunchType requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_LaunchType = null;
if (cmdletContext.EcsTaskParameters_LaunchType != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_LaunchType = cmdletContext.EcsTaskParameters_LaunchType;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_LaunchType != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.LaunchType = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_LaunchType;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
List requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementConstraint = null;
if (cmdletContext.EcsTaskParameters_PlacementConstraint != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementConstraint = cmdletContext.EcsTaskParameters_PlacementConstraint;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementConstraint != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.PlacementConstraints = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementConstraint;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
List requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementStrategy = null;
if (cmdletContext.EcsTaskParameters_PlacementStrategy != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementStrategy = cmdletContext.EcsTaskParameters_PlacementStrategy;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementStrategy != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.PlacementStrategy = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlacementStrategy;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlatformVersion = null;
if (cmdletContext.EcsTaskParameters_PlatformVersion != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlatformVersion = cmdletContext.EcsTaskParameters_PlatformVersion;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlatformVersion != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.PlatformVersion = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PlatformVersion;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
Amazon.Pipes.PropagateTags requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PropagateTag = null;
if (cmdletContext.EcsTaskParameters_PropagateTag != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PropagateTag = cmdletContext.EcsTaskParameters_PropagateTag;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PropagateTag != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.PropagateTags = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_PropagateTag;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_ReferenceId = null;
if (cmdletContext.EcsTaskParameters_ReferenceId != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_ReferenceId = cmdletContext.EcsTaskParameters_ReferenceId;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_ReferenceId != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.ReferenceId = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_ReferenceId;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
List requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Tag = null;
if (cmdletContext.EcsTaskParameters_Tag != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Tag = cmdletContext.EcsTaskParameters_Tag;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Tag != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.Tags = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_Tag;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
System.Int32? requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskCount = null;
if (cmdletContext.EcsTaskParameters_TaskCount != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskCount = cmdletContext.EcsTaskParameters_TaskCount.Value;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskCount != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.TaskCount = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskCount.Value;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskDefinitionArn = null;
if (cmdletContext.EcsTaskParameters_TaskDefinitionArn != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskDefinitionArn = cmdletContext.EcsTaskParameters_TaskDefinitionArn;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskDefinitionArn != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.TaskDefinitionArn = requestTargetParameters_targetParameters_EcsTaskParameters_ecsTaskParameters_TaskDefinitionArn;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
Amazon.Pipes.Model.NetworkConfiguration requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration = null;
// populate NetworkConfiguration
var requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfigurationIsNull = true;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration = new Amazon.Pipes.Model.NetworkConfiguration();
Amazon.Pipes.Model.AwsVpcConfiguration requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration = null;
// populate AwsvpcConfiguration
var requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfigurationIsNull = true;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration = new Amazon.Pipes.Model.AwsVpcConfiguration();
Amazon.Pipes.AssignPublicIp requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_AssignPublicIp = null;
if (cmdletContext.AwsvpcConfiguration_AssignPublicIp != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_AssignPublicIp = cmdletContext.AwsvpcConfiguration_AssignPublicIp;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_AssignPublicIp != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration.AssignPublicIp = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_AssignPublicIp;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfigurationIsNull = false;
}
List requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_SecurityGroup = null;
if (cmdletContext.AwsvpcConfiguration_SecurityGroup != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_SecurityGroup = cmdletContext.AwsvpcConfiguration_SecurityGroup;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_SecurityGroup != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration.SecurityGroups = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_SecurityGroup;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfigurationIsNull = false;
}
List requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_Subnet = null;
if (cmdletContext.AwsvpcConfiguration_Subnet != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_Subnet = cmdletContext.AwsvpcConfiguration_Subnet;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_Subnet != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration.Subnets = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration_awsvpcConfiguration_Subnet;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfigurationIsNull = false;
}
// determine if requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration should be set to null
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfigurationIsNull)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration = null;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration.AwsvpcConfiguration = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration_targetParameters_EcsTaskParameters_NetworkConfiguration_AwsvpcConfiguration;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfigurationIsNull = false;
}
// determine if requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration should be set to null
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfigurationIsNull)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration = null;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.NetworkConfiguration = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_NetworkConfiguration;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
Amazon.Pipes.Model.EcsTaskOverride requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides = null;
// populate Overrides
var requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = true;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides = new Amazon.Pipes.Model.EcsTaskOverride();
List requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ContainerOverride = null;
if (cmdletContext.Overrides_ContainerOverride != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ContainerOverride = cmdletContext.Overrides_ContainerOverride;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ContainerOverride != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides.ContainerOverrides = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ContainerOverride;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Cpu = null;
if (cmdletContext.Overrides_Cpu != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Cpu = cmdletContext.Overrides_Cpu;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Cpu != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides.Cpu = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Cpu;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ExecutionRoleArn = null;
if (cmdletContext.Overrides_ExecutionRoleArn != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ExecutionRoleArn = cmdletContext.Overrides_ExecutionRoleArn;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ExecutionRoleArn != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides.ExecutionRoleArn = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_ExecutionRoleArn;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = false;
}
List requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_InferenceAcceleratorOverride = null;
if (cmdletContext.Overrides_InferenceAcceleratorOverride != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_InferenceAcceleratorOverride = cmdletContext.Overrides_InferenceAcceleratorOverride;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_InferenceAcceleratorOverride != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides.InferenceAcceleratorOverrides = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_InferenceAcceleratorOverride;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Memory = null;
if (cmdletContext.Overrides_Memory != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Memory = cmdletContext.Overrides_Memory;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Memory != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides.Memory = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_Memory;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = false;
}
System.String requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_TaskRoleArn = null;
if (cmdletContext.Overrides_TaskRoleArn != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_TaskRoleArn = cmdletContext.Overrides_TaskRoleArn;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_TaskRoleArn != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides.TaskRoleArn = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_overrides_TaskRoleArn;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = false;
}
Amazon.Pipes.Model.EcsEphemeralStorage requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage = null;
// populate EphemeralStorage
var requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorageIsNull = true;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage = new Amazon.Pipes.Model.EcsEphemeralStorage();
System.Int32? requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage_ephemeralStorage_SizeInGiB = null;
if (cmdletContext.EphemeralStorage_SizeInGiB != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage_ephemeralStorage_SizeInGiB = cmdletContext.EphemeralStorage_SizeInGiB.Value;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage_ephemeralStorage_SizeInGiB != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage.SizeInGiB = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage_ephemeralStorage_SizeInGiB.Value;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorageIsNull = false;
}
// determine if requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage should be set to null
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorageIsNull)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage = null;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides.EphemeralStorage = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides_targetParameters_EcsTaskParameters_Overrides_EphemeralStorage;
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull = false;
}
// determine if requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides should be set to null
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_OverridesIsNull)
{
requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides = null;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides != null)
{
requestTargetParameters_targetParameters_EcsTaskParameters.Overrides = requestTargetParameters_targetParameters_EcsTaskParameters_targetParameters_EcsTaskParameters_Overrides;
requestTargetParameters_targetParameters_EcsTaskParametersIsNull = false;
}
// determine if requestTargetParameters_targetParameters_EcsTaskParameters should be set to null
if (requestTargetParameters_targetParameters_EcsTaskParametersIsNull)
{
requestTargetParameters_targetParameters_EcsTaskParameters = null;
}
if (requestTargetParameters_targetParameters_EcsTaskParameters != null)
{
request.TargetParameters.EcsTaskParameters = requestTargetParameters_targetParameters_EcsTaskParameters;
requestTargetParametersIsNull = false;
}
// determine if request.TargetParameters should be set to null
if (requestTargetParametersIsNull)
{
request.TargetParameters = null;
}
CmdletOutput output;
// issue call
var client = Client ?? CreateClient(_CurrentCredentials, _RegionEndpoint);
try
{
var response = CallAWSServiceOperation(client, request);
object pipelineOutput = null;
pipelineOutput = cmdletContext.Select(response, this);
output = new CmdletOutput
{
PipelineOutput = pipelineOutput,
ServiceResponse = response
};
}
catch (Exception e)
{
output = new CmdletOutput { ErrorResponse = e };
}
return output;
}
public ExecutorContext CreateContext()
{
return new CmdletContext();
}
#endregion
#region AWS Service Operation Call
private Amazon.Pipes.Model.UpdatePipeResponse CallAWSServiceOperation(IAmazonPipes client, Amazon.Pipes.Model.UpdatePipeRequest request)
{
Utils.Common.WriteVerboseEndpointMessage(this, client.Config, "Amazon EventBridge Pipes", "UpdatePipe");
try
{
#if DESKTOP
return client.UpdatePipe(request);
#elif CORECLR
return client.UpdatePipeAsync(request).GetAwaiter().GetResult();
#else
#error "Unknown build edition"
#endif
}
catch (AmazonServiceException exc)
{
var webException = exc.InnerException as System.Net.WebException;
if (webException != null)
{
throw new Exception(Utils.Common.FormatNameResolutionFailureMessage(client.Config, webException.Message), webException);
}
throw;
}
}
#endregion
internal partial class CmdletContext : ExecutorContext
{
public System.String Description { get; set; }
public Amazon.Pipes.RequestedPipeState DesiredState { get; set; }
public System.String Enrichment { get; set; }
public Dictionary EnrichmentParameters_HttpParameters_HeaderParameters { get; set; }
public List EnrichmentParameters_HttpParameters_PathParameterValues { get; set; }
public Dictionary EnrichmentParameters_HttpParameters_QueryStringParameters { get; set; }
public System.String EnrichmentParameters_InputTemplate { get; set; }
public System.String Name { get; set; }
public System.String RoleArn { get; set; }
public System.Int32? ActiveMQBrokerParameters_BatchSize { get; set; }
public System.String SourceParameters_ActiveMQBrokerParameters_Credentials_BasicAuth { get; set; }
public System.Int32? ActiveMQBrokerParameters_MaximumBatchingWindowInSecond { get; set; }
public System.Int32? DynamoDBStreamParameters_BatchSize { get; set; }
public System.String SourceParameters_DynamoDBStreamParameters_DeadLetterConfig_Arn { get; set; }
public System.Int32? DynamoDBStreamParameters_MaximumBatchingWindowInSecond { get; set; }
public System.Int32? DynamoDBStreamParameters_MaximumRecordAgeInSecond { get; set; }
public System.Int32? DynamoDBStreamParameters_MaximumRetryAttempt { get; set; }
public Amazon.Pipes.OnPartialBatchItemFailureStreams DynamoDBStreamParameters_OnPartialBatchItemFailure { get; set; }
public System.Int32? DynamoDBStreamParameters_ParallelizationFactor { get; set; }
public List FilterCriteria_Filter { get; set; }
public System.Int32? KinesisStreamParameters_BatchSize { get; set; }
public System.String SourceParameters_KinesisStreamParameters_DeadLetterConfig_Arn { get; set; }
public System.Int32? KinesisStreamParameters_MaximumBatchingWindowInSecond { get; set; }
public System.Int32? KinesisStreamParameters_MaximumRecordAgeInSecond { get; set; }
public System.Int32? KinesisStreamParameters_MaximumRetryAttempt { get; set; }
public Amazon.Pipes.OnPartialBatchItemFailureStreams KinesisStreamParameters_OnPartialBatchItemFailure { get; set; }
public System.Int32? KinesisStreamParameters_ParallelizationFactor { get; set; }
public System.Int32? ManagedStreamingKafkaParameters_BatchSize { get; set; }
public System.String SourceParameters_ManagedStreamingKafkaParameters_Credentials_ClientCertificateTlsAuth { get; set; }
public System.String SourceParameters_ManagedStreamingKafkaParameters_Credentials_SaslScram512Auth { get; set; }
public System.Int32? ManagedStreamingKafkaParameters_MaximumBatchingWindowInSecond { get; set; }
public System.Int32? RabbitMQBrokerParameters_BatchSize { get; set; }
public System.String SourceParameters_RabbitMQBrokerParameters_Credentials_BasicAuth { get; set; }
public System.Int32? RabbitMQBrokerParameters_MaximumBatchingWindowInSecond { get; set; }
public System.Int32? SelfManagedKafkaParameters_BatchSize { get; set; }
public System.String SourceParameters_SelfManagedKafkaParameters_Credentials_BasicAuth { get; set; }
public System.String SourceParameters_SelfManagedKafkaParameters_Credentials_ClientCertificateTlsAuth { get; set; }
public System.String Credentials_SaslScram256Auth { get; set; }
public System.String Credentials_SaslScram512Auth { get; set; }
public System.Int32? SelfManagedKafkaParameters_MaximumBatchingWindowInSecond { get; set; }
public System.String SelfManagedKafkaParameters_ServerRootCaCertificate { get; set; }
public List Vpc_SecurityGroup { get; set; }
public List Vpc_Subnet { get; set; }
public System.Int32? SqsQueueParameters_BatchSize { get; set; }
public System.Int32? SqsQueueParameters_MaximumBatchingWindowInSecond { get; set; }
public System.String Target { get; set; }
public System.Int32? ArrayProperties_Size { get; set; }
public List ContainerOverrides_Command { get; set; }
public List ContainerOverrides_Environment { get; set; }
public System.String ContainerOverrides_InstanceType { get; set; }
public List ContainerOverrides_ResourceRequirement { get; set; }
public List BatchJobParameters_DependsOn { get; set; }
public System.String BatchJobParameters_JobDefinition { get; set; }
public System.String BatchJobParameters_JobName { get; set; }
public Dictionary BatchJobParameters_Parameter { get; set; }
public System.Int32? RetryStrategy_Attempt { get; set; }
public System.String CloudWatchLogsParameters_LogStreamName { get; set; }
public System.String CloudWatchLogsParameters_Timestamp { get; set; }
public List EcsTaskParameters_CapacityProviderStrategy { get; set; }
public System.Boolean? EcsTaskParameters_EnableECSManagedTag { get; set; }
public System.Boolean? EcsTaskParameters_EnableExecuteCommand { get; set; }
public System.String EcsTaskParameters_Group { get; set; }
public Amazon.Pipes.LaunchType EcsTaskParameters_LaunchType { get; set; }
public Amazon.Pipes.AssignPublicIp AwsvpcConfiguration_AssignPublicIp { get; set; }
public List AwsvpcConfiguration_SecurityGroup { get; set; }
public List AwsvpcConfiguration_Subnet { get; set; }
public List Overrides_ContainerOverride { get; set; }
public System.String Overrides_Cpu { get; set; }
public System.Int32? EphemeralStorage_SizeInGiB { get; set; }
public System.String Overrides_ExecutionRoleArn { get; set; }
public List Overrides_InferenceAcceleratorOverride { get; set; }
public System.String Overrides_Memory { get; set; }
public System.String Overrides_TaskRoleArn { get; set; }
public List EcsTaskParameters_PlacementConstraint { get; set; }
public List EcsTaskParameters_PlacementStrategy { get; set; }
public System.String EcsTaskParameters_PlatformVersion { get; set; }
public Amazon.Pipes.PropagateTags EcsTaskParameters_PropagateTag { get; set; }
public System.String EcsTaskParameters_ReferenceId { get; set; }
public List EcsTaskParameters_Tag { get; set; }
public System.Int32? EcsTaskParameters_TaskCount { get; set; }
public System.String EcsTaskParameters_TaskDefinitionArn { get; set; }
public System.String EventBridgeEventBusParameters_DetailType { get; set; }
public System.String EventBridgeEventBusParameters_EndpointId { get; set; }
public List EventBridgeEventBusParameters_Resource { get; set; }
public System.String EventBridgeEventBusParameters_Source { get; set; }
public System.String EventBridgeEventBusParameters_Time { get; set; }
public Dictionary TargetParameters_HttpParameters_HeaderParameters { get; set; }
public List TargetParameters_HttpParameters_PathParameterValues { get; set; }
public Dictionary TargetParameters_HttpParameters_QueryStringParameters { get; set; }
public System.String TargetParameters_InputTemplate { get; set; }
public System.String KinesisStreamParameters_PartitionKey { get; set; }
public Amazon.Pipes.PipeTargetInvocationType LambdaFunctionParameters_InvocationType { get; set; }
public System.String RedshiftDataParameters_Database { get; set; }
public System.String RedshiftDataParameters_DbUser { get; set; }
public System.String RedshiftDataParameters_SecretManagerArn { get; set; }
public List RedshiftDataParameters_Sql { get; set; }
public System.String RedshiftDataParameters_StatementName { get; set; }
public System.Boolean? RedshiftDataParameters_WithEvent { get; set; }
public List SageMakerPipelineParameters_PipelineParameterList { get; set; }
public System.String SqsQueueParameters_MessageDeduplicationId { get; set; }
public System.String SqsQueueParameters_MessageGroupId { get; set; }
public Amazon.Pipes.PipeTargetInvocationType StepFunctionStateMachineParameters_InvocationType { get; set; }
public System.Func Select { get; set; } =
(response, cmdlet) => response;
}
}
}