/*
* Copyright 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.
*/
/*
* Do not modify this file. This file is generated from the osis-2022-01-01.normal.json service model.
*/
using System;
using System.Runtime.ExceptionServices;
using System.Threading;
using System.Threading.Tasks;
using System.Collections.Generic;
using System.Net;
using Amazon.OSIS.Model;
using Amazon.OSIS.Model.Internal.MarshallTransformations;
using Amazon.OSIS.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.OSIS
{
///
/// Implementation for accessing OSIS
///
/// Use the Amazon OpenSearch Ingestion API to create and manage ingestion pipelines.
/// OpenSearch Ingestion is a fully managed data collector that delivers real-time log
/// and trace data to OpenSearch Service domains. For more information, see Getting
/// data into your cluster using OpenSearch Ingestion.
///
public partial class AmazonOSISClient : AmazonServiceClient, IAmazonOSIS
{
private static IServiceMetadata serviceMetadata = new AmazonOSISMetadata();
private IOSISPaginatorFactory _paginators;
///
/// Paginators for the service
///
public IOSISPaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new OSISPaginatorFactory(this);
}
return this._paginators;
}
}
#region Constructors
///
/// Constructs AmazonOSISClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
public AmazonOSISClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonOSISConfig()) { }
///
/// Constructs AmazonOSISClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
/// The region to connect.
public AmazonOSISClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonOSISConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonOSISClient with the credentials loaded from the application's
/// default configuration, and if unsuccessful from the Instance Profile service on an EC2 instance.
///
/// Example App.config with credentials set.
///
/// <?xml version="1.0" encoding="utf-8" ?>
/// <configuration>
/// <appSettings>
/// <add key="AWSProfileName" value="AWS Default"/>
/// </appSettings>
/// </configuration>
///
///
///
/// The AmazonOSISClient Configuration Object
public AmazonOSISClient(AmazonOSISConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonOSISClient with AWS Credentials
///
/// AWS Credentials
public AmazonOSISClient(AWSCredentials credentials)
: this(credentials, new AmazonOSISConfig())
{
}
///
/// Constructs AmazonOSISClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonOSISClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonOSISConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonOSISClient with AWS Credentials and an
/// AmazonOSISClient Configuration object.
///
/// AWS Credentials
/// The AmazonOSISClient Configuration Object
public AmazonOSISClient(AWSCredentials credentials, AmazonOSISConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonOSISClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonOSISClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonOSISConfig())
{
}
///
/// Constructs AmazonOSISClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonOSISClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonOSISConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonOSISClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonOSISClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonOSISClient Configuration Object
public AmazonOSISClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonOSISConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonOSISClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonOSISClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonOSISConfig())
{
}
///
/// Constructs AmazonOSISClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The region to connect.
public AmazonOSISClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonOSISConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonOSISClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonOSISClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonOSISClient Configuration Object
public AmazonOSISClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonOSISConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig)
{
}
#endregion
#region Overrides
///
/// Creates the signer for the service.
///
protected override AbstractAWSSigner CreateSigner()
{
return new AWS4Signer();
}
///
/// Customize the pipeline
///
///
protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline)
{
pipeline.RemoveHandler();
pipeline.AddHandlerAfter(new AmazonOSISEndpointResolver());
}
///
/// Capture metadata for the service.
///
protected override IServiceMetadata ServiceMetadata
{
get
{
return serviceMetadata;
}
}
#endregion
#region Dispose
///
/// Disposes the service client.
///
protected override void Dispose(bool disposing)
{
base.Dispose(disposing);
}
#endregion
#region CreatePipeline
///
/// Creates an OpenSearch Ingestion pipeline. For more information, see Creating
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the CreatePipeline service method.
///
/// The response from the CreatePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to create more than the allowed number of tags.
///
///
/// You attempted to create a resource that already exists.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for CreatePipeline Operation
public virtual CreatePipelineResponse CreatePipeline(CreatePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreatePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates an OpenSearch Ingestion pipeline. For more information, see Creating
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the CreatePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreatePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to create more than the allowed number of tags.
///
///
/// You attempted to create a resource that already exists.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for CreatePipeline Operation
public virtual Task CreatePipelineAsync(CreatePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreatePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeletePipeline
///
/// Deletes an OpenSearch Ingestion pipeline. For more information, see Deleting
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the DeletePipeline service method.
///
/// The response from the DeletePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for DeletePipeline Operation
public virtual DeletePipelineResponse DeletePipeline(DeletePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeletePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeletePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes an OpenSearch Ingestion pipeline. For more information, see Deleting
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the DeletePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeletePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for DeletePipeline Operation
public virtual Task DeletePipelineAsync(DeletePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeletePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeletePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetPipeline
///
/// Retrieves information about an OpenSearch Ingestion pipeline.
///
/// Container for the necessary parameters to execute the GetPipeline service method.
///
/// The response from the GetPipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for GetPipeline Operation
public virtual GetPipelineResponse GetPipeline(GetPipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetPipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetPipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Retrieves information about an OpenSearch Ingestion pipeline.
///
/// Container for the necessary parameters to execute the GetPipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetPipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for GetPipeline Operation
public virtual Task GetPipelineAsync(GetPipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetPipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetPipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetPipelineBlueprint
///
/// Retrieves information about a specific blueprint for OpenSearch Ingestion. Blueprints
/// are templates for the configuration needed for a CreatePipeline request.
/// For more information, see Using
/// blueprints to create a pipeline.
///
/// Container for the necessary parameters to execute the GetPipelineBlueprint service method.
///
/// The response from the GetPipelineBlueprint service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for GetPipelineBlueprint Operation
public virtual GetPipelineBlueprintResponse GetPipelineBlueprint(GetPipelineBlueprintRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetPipelineBlueprintRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetPipelineBlueprintResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Retrieves information about a specific blueprint for OpenSearch Ingestion. Blueprints
/// are templates for the configuration needed for a CreatePipeline request.
/// For more information, see Using
/// blueprints to create a pipeline.
///
/// Container for the necessary parameters to execute the GetPipelineBlueprint service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetPipelineBlueprint service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for GetPipelineBlueprint Operation
public virtual Task GetPipelineBlueprintAsync(GetPipelineBlueprintRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetPipelineBlueprintRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetPipelineBlueprintResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetPipelineChangeProgress
///
/// Returns progress information for the current change happening on an OpenSearch Ingestion
/// pipeline. Currently, this operation only returns information when a pipeline is being
/// created.
///
///
///
/// For more information, see Tracking
/// the status of pipeline creation.
///
///
/// Container for the necessary parameters to execute the GetPipelineChangeProgress service method.
///
/// The response from the GetPipelineChangeProgress service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for GetPipelineChangeProgress Operation
public virtual GetPipelineChangeProgressResponse GetPipelineChangeProgress(GetPipelineChangeProgressRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetPipelineChangeProgressRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetPipelineChangeProgressResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Returns progress information for the current change happening on an OpenSearch Ingestion
/// pipeline. Currently, this operation only returns information when a pipeline is being
/// created.
///
///
///
/// For more information, see Tracking
/// the status of pipeline creation.
///
///
/// Container for the necessary parameters to execute the GetPipelineChangeProgress service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetPipelineChangeProgress service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for GetPipelineChangeProgress Operation
public virtual Task GetPipelineChangeProgressAsync(GetPipelineChangeProgressRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetPipelineChangeProgressRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetPipelineChangeProgressResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListPipelineBlueprints
///
/// Retrieves a list of all available blueprints for Data Prepper. For more information,
/// see Using
/// blueprints to create a pipeline.
///
/// Container for the necessary parameters to execute the ListPipelineBlueprints service method.
///
/// The response from the ListPipelineBlueprints service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// An invalid pagination token provided in the request.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ListPipelineBlueprints Operation
public virtual ListPipelineBlueprintsResponse ListPipelineBlueprints(ListPipelineBlueprintsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipelineBlueprintsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipelineBlueprintsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Retrieves a list of all available blueprints for Data Prepper. For more information,
/// see Using
/// blueprints to create a pipeline.
///
/// Container for the necessary parameters to execute the ListPipelineBlueprints service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListPipelineBlueprints service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// An invalid pagination token provided in the request.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ListPipelineBlueprints Operation
public virtual Task ListPipelineBlueprintsAsync(ListPipelineBlueprintsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipelineBlueprintsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipelineBlueprintsResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListPipelines
///
/// Lists all OpenSearch Ingestion pipelines in the current Amazon Web Services account
/// and Region. For more information, see Viewing
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the ListPipelines service method.
///
/// The response from the ListPipelines service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// An invalid pagination token provided in the request.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ListPipelines Operation
public virtual ListPipelinesResponse ListPipelines(ListPipelinesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipelinesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipelinesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists all OpenSearch Ingestion pipelines in the current Amazon Web Services account
/// and Region. For more information, see Viewing
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the ListPipelines service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListPipelines service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// An invalid pagination token provided in the request.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ListPipelines Operation
public virtual Task ListPipelinesAsync(ListPipelinesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListPipelinesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListPipelinesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListTagsForResource
///
/// Lists all resource tags associated with an OpenSearch Ingestion pipeline. For more
/// information, see Tagging
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// The response from the ListTagsForResource service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ListTagsForResource Operation
public virtual ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Lists all resource tags associated with an OpenSearch Ingestion pipeline. For more
/// information, see Tagging
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the ListTagsForResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListTagsForResource service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ListTagsForResource Operation
public virtual Task ListTagsForResourceAsync(ListTagsForResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StartPipeline
///
/// Starts an OpenSearch Ingestion pipeline. For more information, see Starting
/// an OpenSearch Ingestion pipeline.
///
/// Container for the necessary parameters to execute the StartPipeline service method.
///
/// The response from the StartPipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for StartPipeline Operation
public virtual StartPipelineResponse StartPipeline(StartPipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartPipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartPipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Starts an OpenSearch Ingestion pipeline. For more information, see Starting
/// an OpenSearch Ingestion pipeline.
///
/// Container for the necessary parameters to execute the StartPipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StartPipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for StartPipeline Operation
public virtual Task StartPipelineAsync(StartPipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StartPipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartPipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StopPipeline
///
/// Stops an OpenSearch Ingestion pipeline. For more information, see Stopping
/// an OpenSearch Ingestion pipeline.
///
/// Container for the necessary parameters to execute the StopPipeline service method.
///
/// The response from the StopPipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for StopPipeline Operation
public virtual StopPipelineResponse StopPipeline(StopPipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StopPipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopPipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Stops an OpenSearch Ingestion pipeline. For more information, see Stopping
/// an OpenSearch Ingestion pipeline.
///
/// Container for the necessary parameters to execute the StopPipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StopPipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for StopPipeline Operation
public virtual Task StopPipelineAsync(StopPipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StopPipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopPipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region TagResource
///
/// Tags an OpenSearch Ingestion pipeline. For more information, see Tagging
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// The response from the TagResource service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to create more than the allowed number of tags.
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for TagResource Operation
public virtual TagResourceResponse TagResource(TagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Tags an OpenSearch Ingestion pipeline. For more information, see Tagging
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the TagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the TagResource service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to create more than the allowed number of tags.
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for TagResource Operation
public virtual Task TagResourceAsync(TagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = TagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UntagResource
///
/// Removes one or more tags from an OpenSearch Ingestion pipeline. For more information,
/// see Tagging
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// The response from the UntagResource service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for UntagResource Operation
public virtual UntagResourceResponse UntagResource(UntagResourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Removes one or more tags from an OpenSearch Ingestion pipeline. For more information,
/// see Tagging
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the UntagResource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UntagResource service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for UntagResource Operation
public virtual Task UntagResourceAsync(UntagResourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UntagResourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdatePipeline
///
/// Updates an OpenSearch Ingestion pipeline. For more information, see Updating
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the UpdatePipeline service method.
///
/// The response from the UpdatePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for UpdatePipeline Operation
public virtual UpdatePipelineResponse UpdatePipeline(UpdatePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdatePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates an OpenSearch Ingestion pipeline. For more information, see Updating
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the UpdatePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdatePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The client attempted to remove a resource that is currently in use.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// You attempted to access or delete a resource that does not exist.
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for UpdatePipeline Operation
public virtual Task UpdatePipelineAsync(UpdatePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdatePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ValidatePipeline
///
/// Checks whether an OpenSearch Ingestion pipeline configuration is valid prior to creation.
/// For more information, see Creating
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the ValidatePipeline service method.
///
/// The response from the ValidatePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ValidatePipeline Operation
public virtual ValidatePipelineResponse ValidatePipeline(ValidatePipelineRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ValidatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = ValidatePipelineResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Checks whether an OpenSearch Ingestion pipeline configuration is valid prior to creation.
/// For more information, see Creating
/// Amazon OpenSearch Ingestion pipelines.
///
/// Container for the necessary parameters to execute the ValidatePipeline service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ValidatePipeline service method, as returned by OSIS.
///
/// You don't have permissions to access the resource.
///
///
/// The request failed because of an unknown error, exception, or failure (the failure
/// is internal to the service).
///
///
/// An exception for missing or invalid input fields.
///
/// REST API Reference for ValidatePipeline Operation
public virtual Task ValidatePipelineAsync(ValidatePipelineRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ValidatePipelineRequestMarshaller.Instance;
options.ResponseUnmarshaller = ValidatePipelineResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}