Class RestService
Assembly: Confluent.SchemaRegistry.dll
Syntax
public class RestService : IDisposable
Constructors
Initializes a new instance of the RestService class.
Declaration
public RestService(string schemaRegistryUrl, int timeoutMs, IAuthenticationHeaderValueProvider authenticationHeaderValueProvider, List<X509Certificate2> certificates, bool enableSslCertificateVerification, X509Certificate2 sslCaCertificate = null, IWebProxy proxy = null, int maxRetries = 3, int retriesWaitMs = 1000, int retriesMaxWaitMs = 20000, int maxConnectionsPerServer = 20)
Parameters
Fields
DefaultMaxConnectionsPerServer
Declaration
public const int DefaultMaxConnectionsPerServer = 20
Field Value
DefaultMaxRetries
Declaration
public const int DefaultMaxRetries = 3
Field Value
DefaultRetriesMaxWaitMs
Declaration
public const int DefaultRetriesMaxWaitMs = 20000
Field Value
DefaultRetriesWaitMs
Declaration
public const int DefaultRetriesWaitMs = 1000
Field Value
Methods
Declaration
protected static IAuthenticationHeaderValueProvider AuthenticationHeaderValueProvider(IEnumerable<KeyValuePair<string, string>> config, IAuthenticationHeaderValueProvider authenticationHeaderValueProvider, int maxRetries, int retriesWaitMs, int retriesMaxWaitMs)
Parameters
Returns
Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
Declaration
Dispose(bool)
Declaration
protected virtual void Dispose(bool disposing)
Parameters
| Type | Name | Description |
|---|
| bool | disposing | |
GetCompatibilityAsync(string)
Declaration
public Task<Compatibility> GetCompatibilityAsync(string subject)
Parameters
| Type | Name | Description |
|---|
| string | subject | |
Returns
GetLatestSchemaAsync(string)
Declaration
public Task<RegisteredSchema> GetLatestSchemaAsync(string subject)
Parameters
| Type | Name | Description |
|---|
| string | subject | |
Returns
Declaration
public Task<RegisteredSchema> GetLatestWithMetadataAsync(string subject, IDictionary<string, string> metadata, bool ignoreDeletedSchemas)
Parameters
Returns
GetSchemaAsync(int, string)
Declaration
public Task<Schema> GetSchemaAsync(int id, string format)
Parameters
Returns
GetSchemaAsync(string, int, bool)
Declaration
public Task<RegisteredSchema> GetSchemaAsync(string subject, int version, bool ignoreDeletedSchemas = true)
Parameters
| Type | Name | Description |
|---|
| string | subject | |
| int | version | |
| bool | ignoreDeletedSchemas | |
Returns
GetSchemaByGuidAsync(string, string)
Declaration
public Task<Schema> GetSchemaByGuidAsync(string guid, string format)
Parameters
Returns
GetSchemaBySubjectAndIdAsync(string, int, string)
Declaration
public Task<Schema> GetSchemaBySubjectAndIdAsync(string subject, int id, string format)
Parameters
Returns
GetSubjectVersionsAsync(string)
Declaration
public Task<List<int>> GetSubjectVersionsAsync(string subject)
Parameters
| Type | Name | Description |
|---|
| string | subject | |
Returns
GetSubjectsAsync()
Declaration
public Task<List<string>> GetSubjectsAsync()
Returns
LookupSchemaAsync(string, Schema, bool, bool)
Declaration
public Task<RegisteredSchema> LookupSchemaAsync(string subject, Schema schema, bool ignoreDeletedSchemas, bool normalize)
Parameters
Returns
RegisterSchemaAsync(string, Schema, bool)
Declaration
public Task<int> RegisterSchemaAsync(string subject, Schema schema, bool normalize)
Parameters
Returns
RegisterSchemaWithResponseAsync(string, Schema, bool)
Declaration
public Task<RegisteredSchema> RegisterSchemaWithResponseAsync(string subject, Schema schema, bool normalize)
Parameters
Returns
RequestAsync<T>(string, HttpMethod, params object[])
Declaration
protected Task<T> RequestAsync<T>(string endPoint, HttpMethod method, params object[] jsonBody)
Parameters
Returns
Type Parameters
RequestListOfAsync<T>(string, HttpMethod, params object[])
Declaration
protected Task<List<T>> RequestListOfAsync<T>(string endPoint, HttpMethod method, params object[] jsonBody)
Parameters
Returns
Type Parameters
TestCompatibilityAsync(string, int, Schema)
Declaration
public Task<bool> TestCompatibilityAsync(string subject, int versionId, Schema schema)
Parameters
Returns
TestLatestCompatibilityAsync(string, Schema)
Declaration
public Task<bool> TestLatestCompatibilityAsync(string subject, Schema schema)
Parameters
Returns
UpdateCompatibilityAsync(string, Compatibility)
Declaration
public Task<Compatibility> UpdateCompatibilityAsync(string subject, Compatibility compatibility)
Parameters
Returns
Implements