/*
* 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 schemas-2019-12-02.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.Schemas.Model;
using Amazon.Schemas.Model.Internal.MarshallTransformations;
using Amazon.Schemas.Internal;
using Amazon.Runtime;
using Amazon.Runtime.Internal;
using Amazon.Runtime.Internal.Auth;
using Amazon.Runtime.Internal.Transform;
namespace Amazon.Schemas
{
///
/// Implementation for accessing Schemas
///
/// Amazon EventBridge Schema Registry
///
public partial class AmazonSchemasClient : AmazonServiceClient, IAmazonSchemas
{
private static IServiceMetadata serviceMetadata = new AmazonSchemasMetadata();
#region Constructors
///
/// Constructs AmazonSchemasClient 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 AmazonSchemasClient()
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonSchemasConfig()) { }
///
/// Constructs AmazonSchemasClient 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 AmazonSchemasClient(RegionEndpoint region)
: base(FallbackCredentialsFactory.GetCredentials(), new AmazonSchemasConfig{RegionEndpoint = region}) { }
///
/// Constructs AmazonSchemasClient 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 AmazonSchemasClient Configuration Object
public AmazonSchemasClient(AmazonSchemasConfig config)
: base(FallbackCredentialsFactory.GetCredentials(config), config){}
///
/// Constructs AmazonSchemasClient with AWS Credentials
///
/// AWS Credentials
public AmazonSchemasClient(AWSCredentials credentials)
: this(credentials, new AmazonSchemasConfig())
{
}
///
/// Constructs AmazonSchemasClient with AWS Credentials
///
/// AWS Credentials
/// The region to connect.
public AmazonSchemasClient(AWSCredentials credentials, RegionEndpoint region)
: this(credentials, new AmazonSchemasConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonSchemasClient with AWS Credentials and an
/// AmazonSchemasClient Configuration object.
///
/// AWS Credentials
/// The AmazonSchemasClient Configuration Object
public AmazonSchemasClient(AWSCredentials credentials, AmazonSchemasConfig clientConfig)
: base(credentials, clientConfig)
{
}
///
/// Constructs AmazonSchemasClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
public AmazonSchemasClient(string awsAccessKeyId, string awsSecretAccessKey)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonSchemasConfig())
{
}
///
/// Constructs AmazonSchemasClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The region to connect.
public AmazonSchemasClient(string awsAccessKeyId, string awsSecretAccessKey, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, new AmazonSchemasConfig() {RegionEndpoint=region})
{
}
///
/// Constructs AmazonSchemasClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonSchemasClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// The AmazonSchemasClient Configuration Object
public AmazonSchemasClient(string awsAccessKeyId, string awsSecretAccessKey, AmazonSchemasConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, clientConfig)
{
}
///
/// Constructs AmazonSchemasClient with AWS Access Key ID and AWS Secret Key
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
public AmazonSchemasClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonSchemasConfig())
{
}
///
/// Constructs AmazonSchemasClient 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 AmazonSchemasClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, RegionEndpoint region)
: this(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, new AmazonSchemasConfig{RegionEndpoint = region})
{
}
///
/// Constructs AmazonSchemasClient with AWS Access Key ID, AWS Secret Key and an
/// AmazonSchemasClient Configuration object.
///
/// AWS Access Key ID
/// AWS Secret Access Key
/// AWS Session Token
/// The AmazonSchemasClient Configuration Object
public AmazonSchemasClient(string awsAccessKeyId, string awsSecretAccessKey, string awsSessionToken, AmazonSchemasConfig clientConfig)
: base(awsAccessKeyId, awsSecretAccessKey, awsSessionToken, clientConfig)
{
}
#endregion
#if AWS_ASYNC_ENUMERABLES_API
private ISchemasPaginatorFactory _paginators;
///
/// Paginators for the service
///
public ISchemasPaginatorFactory Paginators
{
get
{
if (this._paginators == null)
{
this._paginators = new SchemasPaginatorFactory(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 AmazonSchemasEndpointResolver());
}
///
/// 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 CreateDiscoverer
internal virtual CreateDiscovererResponse CreateDiscoverer(CreateDiscovererRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDiscovererResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a discoverer.
///
/// Container for the necessary parameters to execute the CreateDiscoverer service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateDiscoverer service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for CreateDiscoverer Operation
public virtual Task CreateDiscovererAsync(CreateDiscovererRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateDiscovererResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateRegistry
internal virtual CreateRegistryResponse CreateRegistry(CreateRegistryRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateRegistryResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a registry.
///
/// Container for the necessary parameters to execute the CreateRegistry service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateRegistry service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for CreateRegistry Operation
public virtual Task CreateRegistryAsync(CreateRegistryRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateRegistryResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region CreateSchema
internal virtual CreateSchemaResponse CreateSchema(CreateSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Creates a schema definition.
///
///
///
/// Inactive schemas will be deleted after two years.
///
///
///
/// Container for the necessary parameters to execute the CreateSchema service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the CreateSchema service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for CreateSchema Operation
public virtual Task CreateSchemaAsync(CreateSchemaRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = CreateSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = CreateSchemaResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteDiscoverer
internal virtual DeleteDiscovererResponse DeleteDiscoverer(DeleteDiscovererRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDiscovererResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a discoverer.
///
/// Container for the necessary parameters to execute the DeleteDiscoverer service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteDiscoverer service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DeleteDiscoverer Operation
public virtual Task DeleteDiscovererAsync(DeleteDiscovererRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteDiscovererResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteRegistry
internal virtual DeleteRegistryResponse DeleteRegistry(DeleteRegistryRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteRegistryResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Deletes a Registry.
///
/// Container for the necessary parameters to execute the DeleteRegistry service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteRegistry service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DeleteRegistry Operation
public virtual Task DeleteRegistryAsync(DeleteRegistryRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteRegistryResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteResourcePolicy
internal virtual DeleteResourcePolicyResponse DeleteResourcePolicy(DeleteResourcePolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteResourcePolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteResourcePolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Delete the resource-based policy attached to the specified registry.
///
/// Container for the necessary parameters to execute the DeleteResourcePolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteResourcePolicy service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DeleteResourcePolicy Operation
public virtual Task DeleteResourcePolicyAsync(DeleteResourcePolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteResourcePolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteResourcePolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteSchema
internal virtual DeleteSchemaResponse DeleteSchema(DeleteSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Delete a schema definition.
///
/// Container for the necessary parameters to execute the DeleteSchema service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteSchema service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DeleteSchema Operation
public virtual Task DeleteSchemaAsync(DeleteSchemaRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteSchemaResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DeleteSchemaVersion
internal virtual DeleteSchemaVersionResponse DeleteSchemaVersion(DeleteSchemaVersionRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteSchemaVersionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteSchemaVersionResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Delete the schema version definition
///
/// Container for the necessary parameters to execute the DeleteSchemaVersion service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DeleteSchemaVersion service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DeleteSchemaVersion Operation
public virtual Task DeleteSchemaVersionAsync(DeleteSchemaVersionRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DeleteSchemaVersionRequestMarshaller.Instance;
options.ResponseUnmarshaller = DeleteSchemaVersionResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeCodeBinding
internal virtual DescribeCodeBindingResponse DescribeCodeBinding(DescribeCodeBindingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeCodeBindingRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeCodeBindingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Describe the code binding URI.
///
/// Container for the necessary parameters to execute the DescribeCodeBinding service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeCodeBinding service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DescribeCodeBinding Operation
public virtual Task DescribeCodeBindingAsync(DescribeCodeBindingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeCodeBindingRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeCodeBindingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeDiscoverer
internal virtual DescribeDiscovererResponse DescribeDiscoverer(DescribeDiscovererRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeDiscovererResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Describes the discoverer.
///
/// Container for the necessary parameters to execute the DescribeDiscoverer service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeDiscoverer service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DescribeDiscoverer Operation
public virtual Task DescribeDiscovererAsync(DescribeDiscovererRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeDiscovererResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeRegistry
internal virtual DescribeRegistryResponse DescribeRegistry(DescribeRegistryRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeRegistryResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Describes the registry.
///
/// Container for the necessary parameters to execute the DescribeRegistry service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeRegistry service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DescribeRegistry Operation
public virtual Task DescribeRegistryAsync(DescribeRegistryRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeRegistryResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region DescribeSchema
internal virtual DescribeSchemaResponse DescribeSchema(DescribeSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Retrieve the schema definition.
///
/// Container for the necessary parameters to execute the DescribeSchema service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the DescribeSchema service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for DescribeSchema Operation
public virtual Task DescribeSchemaAsync(DescribeSchemaRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = DescribeSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = DescribeSchemaResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ExportSchema
internal virtual ExportSchemaResponse ExportSchema(ExportSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ExportSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = ExportSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
///
///
/// Container for the necessary parameters to execute the ExportSchema service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ExportSchema service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for ExportSchema Operation
public virtual Task ExportSchemaAsync(ExportSchemaRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ExportSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = ExportSchemaResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetCodeBindingSource
internal virtual GetCodeBindingSourceResponse GetCodeBindingSource(GetCodeBindingSourceRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetCodeBindingSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetCodeBindingSourceResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Get the code binding source URI.
///
/// Container for the necessary parameters to execute the GetCodeBindingSource service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetCodeBindingSource service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for GetCodeBindingSource Operation
public virtual Task GetCodeBindingSourceAsync(GetCodeBindingSourceRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetCodeBindingSourceRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetCodeBindingSourceResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetDiscoveredSchema
internal virtual GetDiscoveredSchemaResponse GetDiscoveredSchema(GetDiscoveredSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetDiscoveredSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetDiscoveredSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Get the discovered schema that was generated based on sampled events.
///
/// Container for the necessary parameters to execute the GetDiscoveredSchema service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetDiscoveredSchema service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for GetDiscoveredSchema Operation
public virtual Task GetDiscoveredSchemaAsync(GetDiscoveredSchemaRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetDiscoveredSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetDiscoveredSchemaResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region GetResourcePolicy
internal virtual GetResourcePolicyResponse GetResourcePolicy(GetResourcePolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = GetResourcePolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetResourcePolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Retrieves the resource-based policy attached to a given registry.
///
/// Container for the necessary parameters to execute the GetResourcePolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the GetResourcePolicy service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for GetResourcePolicy Operation
public virtual Task GetResourcePolicyAsync(GetResourcePolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = GetResourcePolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = GetResourcePolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListDiscoverers
internal virtual ListDiscoverersResponse ListDiscoverers(ListDiscoverersRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDiscoverersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDiscoverersResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// List the discoverers.
///
/// Container for the necessary parameters to execute the ListDiscoverers service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListDiscoverers service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for ListDiscoverers Operation
public virtual Task ListDiscoverersAsync(ListDiscoverersRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListDiscoverersRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListDiscoverersResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListRegistries
internal virtual ListRegistriesResponse ListRegistries(ListRegistriesRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListRegistriesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListRegistriesResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// List the registries.
///
/// Container for the necessary parameters to execute the ListRegistries service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListRegistries service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for ListRegistries Operation
public virtual Task ListRegistriesAsync(ListRegistriesRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListRegistriesRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListRegistriesResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListSchemas
internal virtual ListSchemasResponse ListSchemas(ListSchemasRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSchemasRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSchemasResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// List the schemas.
///
/// Container for the necessary parameters to execute the ListSchemas service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListSchemas service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for ListSchemas Operation
public virtual Task ListSchemasAsync(ListSchemasRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSchemasRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSchemasResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region ListSchemaVersions
internal virtual ListSchemaVersionsResponse ListSchemaVersions(ListSchemaVersionsRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSchemaVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSchemaVersionsResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Provides a list of the schema versions and related information.
///
/// Container for the necessary parameters to execute the ListSchemaVersions service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the ListSchemaVersions service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for ListSchemaVersions Operation
public virtual Task ListSchemaVersionsAsync(ListSchemaVersionsRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = ListSchemaVersionsRequestMarshaller.Instance;
options.ResponseUnmarshaller = ListSchemaVersionsResponseUnmarshaller.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);
}
///
/// Get tags for resource.
///
/// 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 Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
/// 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 PutCodeBinding
internal virtual PutCodeBindingResponse PutCodeBinding(PutCodeBindingRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutCodeBindingRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutCodeBindingResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Put code binding URI
///
/// Container for the necessary parameters to execute the PutCodeBinding service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutCodeBinding service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for PutCodeBinding Operation
public virtual Task PutCodeBindingAsync(PutCodeBindingRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutCodeBindingRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutCodeBindingResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region PutResourcePolicy
internal virtual PutResourcePolicyResponse PutResourcePolicy(PutResourcePolicyRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = PutResourcePolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutResourcePolicyResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// The name of the policy.
///
/// Container for the necessary parameters to execute the PutResourcePolicy service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the PutResourcePolicy service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for PutResourcePolicy Operation
public virtual Task PutResourcePolicyAsync(PutResourcePolicyRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = PutResourcePolicyRequestMarshaller.Instance;
options.ResponseUnmarshaller = PutResourcePolicyResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region SearchSchemas
internal virtual SearchSchemasResponse SearchSchemas(SearchSchemasRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = SearchSchemasRequestMarshaller.Instance;
options.ResponseUnmarshaller = SearchSchemasResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Search the schemas
///
/// Container for the necessary parameters to execute the SearchSchemas service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the SearchSchemas service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for SearchSchemas Operation
public virtual Task SearchSchemasAsync(SearchSchemasRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = SearchSchemasRequestMarshaller.Instance;
options.ResponseUnmarshaller = SearchSchemasResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StartDiscoverer
internal virtual StartDiscovererResponse StartDiscoverer(StartDiscovererRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StartDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartDiscovererResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Starts the discoverer
///
/// Container for the necessary parameters to execute the StartDiscoverer service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StartDiscoverer service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for StartDiscoverer Operation
public virtual Task StartDiscovererAsync(StartDiscovererRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StartDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = StartDiscovererResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region StopDiscoverer
internal virtual StopDiscovererResponse StopDiscoverer(StopDiscovererRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = StopDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopDiscovererResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Stops the discoverer
///
/// Container for the necessary parameters to execute the StopDiscoverer service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the StopDiscoverer service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for StopDiscoverer Operation
public virtual Task StopDiscovererAsync(StopDiscovererRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = StopDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = StopDiscovererResponseUnmarshaller.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);
}
///
/// Add tags to a resource.
///
/// 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 Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
/// 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 a resource.
///
/// 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 Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
/// 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 UpdateDiscoverer
internal virtual UpdateDiscovererResponse UpdateDiscoverer(UpdateDiscovererRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateDiscovererResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the discoverer
///
/// Container for the necessary parameters to execute the UpdateDiscoverer service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateDiscoverer service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for UpdateDiscoverer Operation
public virtual Task UpdateDiscovererAsync(UpdateDiscovererRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateDiscovererRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateDiscovererResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateRegistry
internal virtual UpdateRegistryResponse UpdateRegistry(UpdateRegistryRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateRegistryResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates a registry.
///
/// Container for the necessary parameters to execute the UpdateRegistry service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateRegistry service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for UpdateRegistry Operation
public virtual Task UpdateRegistryAsync(UpdateRegistryRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateRegistryRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateRegistryResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
#region UpdateSchema
internal virtual UpdateSchemaResponse UpdateSchema(UpdateSchemaRequest request)
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateSchemaResponseUnmarshaller.Instance;
return Invoke(request, options);
}
///
/// Updates the schema definition
///
///
///
/// Inactive schemas will be deleted after two years.
///
///
///
/// Container for the necessary parameters to execute the UpdateSchema service method.
///
/// A cancellation token that can be used by other objects or threads to receive notice of cancellation.
///
///
/// The response from the UpdateSchema service method, as returned by Schemas.
///
///
///
///
///
///
///
///
///
///
///
///
///
///
///
/// REST API Reference for UpdateSchema Operation
public virtual Task UpdateSchemaAsync(UpdateSchemaRequest request, System.Threading.CancellationToken cancellationToken = default(CancellationToken))
{
var options = new InvokeOptions();
options.RequestMarshaller = UpdateSchemaRequestMarshaller.Instance;
options.ResponseUnmarshaller = UpdateSchemaResponseUnmarshaller.Instance;
return InvokeAsync(request, options, cancellationToken);
}
#endregion
}
}