Class RestService

Inheritance
object
RestService
DekRestService
Implements
Inherited Members
Namespace: Confluent.SchemaRegistry
Assembly: Confluent.SchemaRegistry.dll
Syntax
public class RestService : IDisposable

Constructors

RestService(string, int, IAuthenticationHeaderValueProvider, List<X509Certificate2>, bool, X509Certificate2, IWebProxy)

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)
Parameters
Type Name Description
string schemaRegistryUrl
int timeoutMs
IAuthenticationHeaderValueProvider authenticationHeaderValueProvider
List<X509Certificate2> certificates
bool enableSslCertificateVerification
X509Certificate2 sslCaCertificate
IWebProxy proxy

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

Declaration
public void Dispose()

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
Type Description
Task<Compatibility>

GetLatestSchemaAsync(string)

Declaration
public Task<RegisteredSchema> GetLatestSchemaAsync(string subject)
Parameters
Type Name Description
string subject
Returns
Type Description
Task<RegisteredSchema>

GetLatestWithMetadataAsync(string, IDictionary<string, string>, bool)

Declaration
public Task<RegisteredSchema> GetLatestWithMetadataAsync(string subject, IDictionary<string, string> metadata, bool ignoreDeletedSchemas)
Parameters
Type Name Description
string subject
IDictionary<string, string> metadata
bool ignoreDeletedSchemas
Returns
Type Description
Task<RegisteredSchema>

GetSchemaAsync(int, string)

Declaration
public Task<Schema> GetSchemaAsync(int id, string format)
Parameters
Type Name Description
int id
string format
Returns
Type Description
Task<Schema>

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
Type Description
Task<RegisteredSchema>

GetSchemaBySubjectAndIdAsync(string, int, string)

Declaration
public Task<Schema> GetSchemaBySubjectAndIdAsync(string subject, int id, string format)
Parameters
Type Name Description
string subject
int id
string format
Returns
Type Description
Task<Schema>

GetSubjectVersionsAsync(string)

Declaration
public Task<List<int>> GetSubjectVersionsAsync(string subject)
Parameters
Type Name Description
string subject
Returns
Type Description
Task<List<int>>

GetSubjectsAsync()

Declaration
public Task<List<string>> GetSubjectsAsync()
Returns
Type Description
Task<List<string>>

LookupSchemaAsync(string, Schema, bool, bool)

Declaration
public Task<RegisteredSchema> LookupSchemaAsync(string subject, Schema schema, bool ignoreDeletedSchemas, bool normalize)
Parameters
Type Name Description
string subject
Schema schema
bool ignoreDeletedSchemas
bool normalize
Returns
Type Description
Task<RegisteredSchema>

RegisterSchemaAsync(string, Schema, bool)

Declaration
public Task<int> RegisterSchemaAsync(string subject, Schema schema, bool normalize)
Parameters
Type Name Description
string subject
Schema schema
bool normalize
Returns
Type Description
Task<int>

RequestAsync<T>(string, HttpMethod, params object[])

Declaration
protected Task<T> RequestAsync<T>(string endPoint, HttpMethod method, params object[] jsonBody)
Parameters
Type Name Description
string endPoint
HttpMethod method
object[] jsonBody
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
Remarks

Used for end points that return a json object { ... }

RequestListOfAsync<T>(string, HttpMethod, params object[])

Declaration
protected Task<List<T>> RequestListOfAsync<T>(string endPoint, HttpMethod method, params object[] jsonBody)
Parameters
Type Name Description
string endPoint
HttpMethod method
object[] jsonBody
Returns
Type Description
Task<List<T>>
Type Parameters
Name Description
T
Remarks

Used for end points that return a json array [ ... ]

TestCompatibilityAsync(string, int, Schema)

Declaration
public Task<bool> TestCompatibilityAsync(string subject, int versionId, Schema schema)
Parameters
Type Name Description
string subject
int versionId
Schema schema
Returns
Type Description
Task<bool>

TestLatestCompatibilityAsync(string, Schema)

Declaration
public Task<bool> TestLatestCompatibilityAsync(string subject, Schema schema)
Parameters
Type Name Description
string subject
Schema schema
Returns
Type Description
Task<bool>

UpdateCompatibilityAsync(string, Compatibility)

Declaration
public Task<Compatibility> UpdateCompatibilityAsync(string subject, Compatibility compatibility)
Parameters
Type Name Description
string subject
Compatibility compatibility
Returns
Type Description
Task<Compatibility>

Implements