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)
Parameters
Methods
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
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
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