/* * 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 emr-containers-2020-10-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.EMRContainers.Model; using Amazon.EMRContainers.Model.Internal.MarshallTransformations; using Amazon.EMRContainers.Internal; using Amazon.Runtime; using Amazon.Runtime.Internal; using Amazon.Runtime.Internal.Auth; using Amazon.Runtime.Internal.Transform; namespace Amazon.EMRContainers { /// /// Implementation for accessing EMRContainers /// /// Amazon EMR on EKS provides a deployment option for Amazon EMR that allows you to run /// open-source big data frameworks on Amazon Elastic Kubernetes Service (Amazon EKS). /// With this deployment option, you can focus on running analytics workloads while Amazon /// EMR on EKS builds, configures, and manages containers for open-source applications. /// For more information about Amazon EMR on EKS concepts and tasks, see What /// is shared id="EMR-EKS"/>. /// /// /// /// Amazon EMR containers is the API name for Amazon EMR on EKS. The emr-containers /// prefix is used in the following scenarios: /// /// /// public partial class AmazonEMRContainersClient : AmazonServiceClient, IAmazonEMRContainers { private static IServiceMetadata serviceMetadata = new AmazonEMRContainersMetadata(); #region Constructors /// /// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient() : base(FallbackCredentialsFactory.GetCredentials(), new AmazonEMRContainersConfig()) { } /// /// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient(RegionEndpoint region) : base(FallbackCredentialsFactory.GetCredentials(), new AmazonEMRContainersConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient Configuration Object public AmazonEMRContainersClient(AmazonEMRContainersConfig config) : base(FallbackCredentialsFactory.GetCredentials(config), config){} /// /// Constructs AmazonEMRContainersClient with AWS Credentials /// /// AWS Credentials public AmazonEMRContainersClient(AWSCredentials credentials) : this(credentials, new AmazonEMRContainersConfig()) { } /// /// Constructs AmazonEMRContainersClient with AWS Credentials /// /// AWS Credentials /// The region to connect. public AmazonEMRContainersClient(AWSCredentials credentials, RegionEndpoint region) : this(credentials, new AmazonEMRContainersConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonEMRContainersClient with AWS Credentials and an /// AmazonEMRContainersClient Configuration object. /// /// AWS Credentials /// The AmazonEMRContainersClient Configuration Object public AmazonEMRContainersClient(AWSCredentials credentials, AmazonEMRContainersConfig clientConfig) : base(credentials, clientConfig) { } /// /// Constructs AmazonEMRContainersClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonEMRContainersConfig()) { } /// /// Constructs AmazonEMRContainersClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// The region to connect. public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, new AmazonEMRContainersConfig() {RegionEndpoint=region}) { } /// /// Constructs AmazonEMRContainersClient with AWS Access Key ID, AWS Secret Key and an /// AmazonEMRContainersClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// The AmazonEMRContainersClient Configuration Object public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonEMRContainersConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, clientConfig) { } /// /// Constructs AmazonEMRContainersClient with AWS Access Key ID and AWS Secret Key /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonEMRContainersConfig()) { } /// /// Constructs AmazonEMRContainersClient 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 AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region) : this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonEMRContainersConfig{RegionEndpoint = region}) { } /// /// Constructs AmazonEMRContainersClient with AWS Access Key ID, AWS Secret Key and an /// AmazonEMRContainersClient Configuration object. /// /// AWS Access Key ID /// AWS Secret Access Key /// AWS Session Token /// The AmazonEMRContainersClient Configuration Object public AmazonEMRContainersClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonEMRContainersConfig clientConfig) : base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig) { } #endregion #if AWS_ASYNC_ENUMERABLES_API private IEMRContainersPaginatorFactory _paginators; /// /// Paginators for the service /// public IEMRContainersPaginatorFactory Paginators { get { if (this._paginators == null) { this._paginators = new EMRContainersPaginatorFactory(this); } return this._paginators; } } #endif #region Overrides /// /// Creates the signer for the service. /// protected override AbstractAWSSigner CreateSigner() { return new AWS4Signer(); } /// /// Customizes the runtime pipeline. /// /// Runtime pipeline for the current client. protected override void CustomizeRuntimePipeline(RuntimePipeline pipeline) { pipeline.RemoveHandler(); pipeline.AddHandlerAfter(new AmazonEMRContainersEndpointResolver()); } /// /// 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 CancelJobRun internal virtual CancelJobRunResponse CancelJobRun(CancelJobRunRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CancelJobRunRequestMarshaller.Instance; options.ResponseUnmarshaller = CancelJobRunResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Cancels a job run. A job run is a unit of work, such as a Spark jar, PySpark script, /// or SparkSQL query, that you submit to Amazon EMR on EKS. /// /// Container for the necessary parameters to execute the CancelJobRun service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CancelJobRun service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for CancelJobRun Operation public virtual Task CancelJobRunAsync(CancelJobRunRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CancelJobRunRequestMarshaller.Instance; options.ResponseUnmarshaller = CancelJobRunResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region CreateJobTemplate internal virtual CreateJobTemplateResponse CreateJobTemplate(CreateJobTemplateRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateJobTemplateRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateJobTemplateResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Creates a job template. Job template stores values of StartJobRun API request in a /// template and can be used to start a job run. Job template allows two use cases: avoid /// repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun /// API request. /// /// Container for the necessary parameters to execute the CreateJobTemplate service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CreateJobTemplate service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for CreateJobTemplate Operation public virtual Task CreateJobTemplateAsync(CreateJobTemplateRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CreateJobTemplateRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateJobTemplateResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region CreateManagedEndpoint internal virtual CreateManagedEndpointResponse CreateManagedEndpoint(CreateManagedEndpointRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateManagedEndpointRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateManagedEndpointResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Creates a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR /// Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual /// cluster. /// /// Container for the necessary parameters to execute the CreateManagedEndpoint service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CreateManagedEndpoint service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for CreateManagedEndpoint Operation public virtual Task CreateManagedEndpointAsync(CreateManagedEndpointRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CreateManagedEndpointRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateManagedEndpointResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region CreateVirtualCluster internal virtual CreateVirtualClusterResponse CreateVirtualCluster(CreateVirtualClusterRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = CreateVirtualClusterRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateVirtualClusterResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Creates a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. /// You can create, describe, list and delete virtual clusters. They do not consume any /// additional resource in your system. A single virtual cluster maps to a single Kubernetes /// namespace. Given this relationship, you can model virtual clusters the same way you /// model Kubernetes namespaces to meet your requirements. /// /// Container for the necessary parameters to execute the CreateVirtualCluster service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the CreateVirtualCluster service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for CreateVirtualCluster Operation public virtual Task CreateVirtualClusterAsync(CreateVirtualClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = CreateVirtualClusterRequestMarshaller.Instance; options.ResponseUnmarshaller = CreateVirtualClusterResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DeleteJobTemplate internal virtual DeleteJobTemplateResponse DeleteJobTemplate(DeleteJobTemplateRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteJobTemplateRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteJobTemplateResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Deletes a job template. Job template stores values of StartJobRun API request in a /// template and can be used to start a job run. Job template allows two use cases: avoid /// repeating recurring StartJobRun API request values, enforcing certain values in StartJobRun /// API request. /// /// Container for the necessary parameters to execute the DeleteJobTemplate service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DeleteJobTemplate service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for DeleteJobTemplate Operation public virtual Task DeleteJobTemplateAsync(DeleteJobTemplateRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteJobTemplateRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteJobTemplateResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DeleteManagedEndpoint internal virtual DeleteManagedEndpointResponse DeleteManagedEndpoint(DeleteManagedEndpointRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteManagedEndpointRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteManagedEndpointResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Deletes a managed endpoint. A managed endpoint is a gateway that connects Amazon EMR /// Studio to Amazon EMR on EKS so that Amazon EMR Studio can communicate with your virtual /// cluster. /// /// Container for the necessary parameters to execute the DeleteManagedEndpoint service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DeleteManagedEndpoint service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for DeleteManagedEndpoint Operation public virtual Task DeleteManagedEndpointAsync(DeleteManagedEndpointRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteManagedEndpointRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteManagedEndpointResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DeleteVirtualCluster internal virtual DeleteVirtualClusterResponse DeleteVirtualCluster(DeleteVirtualClusterRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteVirtualClusterRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteVirtualClusterResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Deletes a virtual cluster. Virtual cluster is a managed entity on Amazon EMR on EKS. /// You can create, describe, list and delete virtual clusters. They do not consume any /// additional resource in your system. A single virtual cluster maps to a single Kubernetes /// namespace. Given this relationship, you can model virtual clusters the same way you /// model Kubernetes namespaces to meet your requirements. /// /// Container for the necessary parameters to execute the DeleteVirtualCluster service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DeleteVirtualCluster service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for DeleteVirtualCluster Operation public virtual Task DeleteVirtualClusterAsync(DeleteVirtualClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DeleteVirtualClusterRequestMarshaller.Instance; options.ResponseUnmarshaller = DeleteVirtualClusterResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeJobRun internal virtual DescribeJobRunResponse DescribeJobRun(DescribeJobRunRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeJobRunRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeJobRunResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Displays detailed information about a job run. A job run is a unit of work, such as /// a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS. /// /// Container for the necessary parameters to execute the DescribeJobRun service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeJobRun service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for DescribeJobRun Operation public virtual Task DescribeJobRunAsync(DescribeJobRunRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeJobRunRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeJobRunResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeJobTemplate internal virtual DescribeJobTemplateResponse DescribeJobTemplate(DescribeJobTemplateRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeJobTemplateRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeJobTemplateResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Displays detailed information about a specified job template. Job template stores /// values of StartJobRun API request in a template and can be used to start a job run. /// Job template allows two use cases: avoid repeating recurring StartJobRun API request /// values, enforcing certain values in StartJobRun API request. /// /// Container for the necessary parameters to execute the DescribeJobTemplate service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeJobTemplate service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for DescribeJobTemplate Operation public virtual Task DescribeJobTemplateAsync(DescribeJobTemplateRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeJobTemplateRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeJobTemplateResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeManagedEndpoint internal virtual DescribeManagedEndpointResponse DescribeManagedEndpoint(DescribeManagedEndpointRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeManagedEndpointRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeManagedEndpointResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Displays detailed information about a managed endpoint. A managed endpoint is a gateway /// that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can /// communicate with your virtual cluster. /// /// Container for the necessary parameters to execute the DescribeManagedEndpoint service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeManagedEndpoint service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for DescribeManagedEndpoint Operation public virtual Task DescribeManagedEndpointAsync(DescribeManagedEndpointRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeManagedEndpointRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeManagedEndpointResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region DescribeVirtualCluster internal virtual DescribeVirtualClusterResponse DescribeVirtualCluster(DescribeVirtualClusterRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeVirtualClusterRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeVirtualClusterResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Displays detailed information about a specified virtual cluster. Virtual cluster is /// a managed entity on Amazon EMR on EKS. You can create, describe, list and delete virtual /// clusters. They do not consume any additional resource in your system. A single virtual /// cluster maps to a single Kubernetes namespace. Given this relationship, you can model /// virtual clusters the same way you model Kubernetes namespaces to meet your requirements. /// /// Container for the necessary parameters to execute the DescribeVirtualCluster service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the DescribeVirtualCluster service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for DescribeVirtualCluster Operation public virtual Task DescribeVirtualClusterAsync(DescribeVirtualClusterRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = DescribeVirtualClusterRequestMarshaller.Instance; options.ResponseUnmarshaller = DescribeVirtualClusterResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region GetManagedEndpointSessionCredentials internal virtual GetManagedEndpointSessionCredentialsResponse GetManagedEndpointSessionCredentials(GetManagedEndpointSessionCredentialsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = GetManagedEndpointSessionCredentialsRequestMarshaller.Instance; options.ResponseUnmarshaller = GetManagedEndpointSessionCredentialsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Generate a session token to connect to a managed endpoint. /// /// Container for the necessary parameters to execute the GetManagedEndpointSessionCredentials service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the GetManagedEndpointSessionCredentials service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The request throttled. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for GetManagedEndpointSessionCredentials Operation public virtual Task GetManagedEndpointSessionCredentialsAsync(GetManagedEndpointSessionCredentialsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = GetManagedEndpointSessionCredentialsRequestMarshaller.Instance; options.ResponseUnmarshaller = GetManagedEndpointSessionCredentialsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListJobRuns internal virtual ListJobRunsResponse ListJobRuns(ListJobRunsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListJobRunsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListJobRunsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Lists job runs based on a set of parameters. A job run is a unit of work, such as /// a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS. /// /// Container for the necessary parameters to execute the ListJobRuns service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListJobRuns service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for ListJobRuns Operation public virtual Task ListJobRunsAsync(ListJobRunsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListJobRunsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListJobRunsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListJobTemplates internal virtual ListJobTemplatesResponse ListJobTemplates(ListJobTemplatesRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListJobTemplatesRequestMarshaller.Instance; options.ResponseUnmarshaller = ListJobTemplatesResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Lists job templates based on a set of parameters. Job template stores values of StartJobRun /// API request in a template and can be used to start a job run. Job template allows /// two use cases: avoid repeating recurring StartJobRun API request values, enforcing /// certain values in StartJobRun API request. /// /// Container for the necessary parameters to execute the ListJobTemplates service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListJobTemplates service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for ListJobTemplates Operation public virtual Task ListJobTemplatesAsync(ListJobTemplatesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListJobTemplatesRequestMarshaller.Instance; options.ResponseUnmarshaller = ListJobTemplatesResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListManagedEndpoints internal virtual ListManagedEndpointsResponse ListManagedEndpoints(ListManagedEndpointsRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListManagedEndpointsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListManagedEndpointsResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Lists managed endpoints based on a set of parameters. A managed endpoint is a gateway /// that connects Amazon EMR Studio to Amazon EMR on EKS so that Amazon EMR Studio can /// communicate with your virtual cluster. /// /// Container for the necessary parameters to execute the ListManagedEndpoints service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListManagedEndpoints service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for ListManagedEndpoints Operation public virtual Task ListManagedEndpointsAsync(ListManagedEndpointsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListManagedEndpointsRequestMarshaller.Instance; options.ResponseUnmarshaller = ListManagedEndpointsResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region ListTagsForResource internal virtual ListTagsForResourceResponse ListTagsForResource(ListTagsForResourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListTagsForResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = ListTagsForResourceResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Lists the tags assigned to the resources. /// /// 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 EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// 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 ListVirtualClusters internal virtual ListVirtualClustersResponse ListVirtualClusters(ListVirtualClustersRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = ListVirtualClustersRequestMarshaller.Instance; options.ResponseUnmarshaller = ListVirtualClustersResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Lists information about the specified virtual cluster. Virtual cluster is a managed /// entity on Amazon EMR on EKS. You can create, describe, list and delete virtual clusters. /// They do not consume any additional resource in your system. A single virtual cluster /// maps to a single Kubernetes namespace. Given this relationship, you can model virtual /// clusters the same way you model Kubernetes namespaces to meet your requirements. /// /// Container for the necessary parameters to execute the ListVirtualClusters service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the ListVirtualClusters service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for ListVirtualClusters Operation public virtual Task ListVirtualClustersAsync(ListVirtualClustersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = ListVirtualClustersRequestMarshaller.Instance; options.ResponseUnmarshaller = ListVirtualClustersResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region StartJobRun internal virtual StartJobRunResponse StartJobRun(StartJobRunRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = StartJobRunRequestMarshaller.Instance; options.ResponseUnmarshaller = StartJobRunResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Starts a job run. A job run is a unit of work, such as a Spark jar, PySpark script, /// or SparkSQL query, that you submit to Amazon EMR on EKS. /// /// Container for the necessary parameters to execute the StartJobRun service method. /// /// A cancellation token that can be used by other objects or threads to receive notice of cancellation. /// /// /// The response from the StartJobRun service method, as returned by EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// REST API Reference for StartJobRun Operation public virtual Task StartJobRunAsync(StartJobRunRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken)) { var options = new InvokeOptions(); options.RequestMarshaller = StartJobRunRequestMarshaller.Instance; options.ResponseUnmarshaller = StartJobRunResponseUnmarshaller.Instance; return InvokeAsync(request, options, cancellationToken); } #endregion #region TagResource internal virtual TagResourceResponse TagResource(TagResourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = TagResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = TagResourceResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Assigns tags to resources. A tag is a label that you assign to an Amazon Web Services /// resource. Each tag consists of a key and an optional value, both of which you define. /// Tags enable you to categorize your Amazon Web Services resources by attributes such /// as purpose, owner, or environment. When you have many resources of the same type, /// you can quickly identify a specific resource based on the tags you've assigned to /// it. For example, you can define a set of tags for your Amazon EMR on EKS clusters /// to help you track each cluster's owner and stack level. We recommend that you devise /// a consistent set of tag keys for each resource type. You can then search and filter /// the resources based on the tags that you add. /// /// 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 EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// 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 internal virtual UntagResourceResponse UntagResource(UntagResourceRequest request) { var options = new InvokeOptions(); options.RequestMarshaller = UntagResourceRequestMarshaller.Instance; options.ResponseUnmarshaller = UntagResourceResponseUnmarshaller.Instance; return Invoke(request, options); } /// /// Removes tags from resources. /// /// 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 EMRContainers. /// /// This is an internal server exception. /// /// /// The specified resource was not found. /// /// /// There are invalid parameters in the client request. /// /// 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 } }