Class AsyncSerde<TParsedSchema>

Inheritance
object
AsyncSerde<TParsedSchema>
AsyncDeserializer<T, TParsedSchema>
AsyncSerializer<T, TParsedSchema>
Inherited Members
Namespace: Confluent.SchemaRegistry
Assembly: Confluent.SchemaRegistry.dll
Syntax
public abstract class AsyncSerde<TParsedSchema>
Type Parameters
Name Description
TParsedSchema

Constructors

AsyncSerde(ISchemaRegistryClient, SerdeConfig, IList<IRuleExecutor>)

Declaration
protected AsyncSerde(ISchemaRegistryClient schemaRegistryClient, SerdeConfig config, IList<IRuleExecutor> ruleExecutors = null)
Parameters
Type Name Description
ISchemaRegistryClient schemaRegistryClient
SerdeConfig config
IList<IRuleExecutor> ruleExecutors

Fields

latestCompatibilityStrict

Declaration
protected bool latestCompatibilityStrict
Field Value
Type Description
bool

ruleExecutors

Declaration
protected IList<IRuleExecutor> ruleExecutors
Field Value
Type Description
IList<IRuleExecutor>

schemaRegistryClient

Declaration
protected ISchemaRegistryClient schemaRegistryClient
Field Value
Type Description
ISchemaRegistryClient

serdeMutex

Declaration
protected SemaphoreSlim serdeMutex
Field Value
Type Description
SemaphoreSlim

subjectNameStrategy

Declaration
protected SubjectNameStrategyDelegate subjectNameStrategy
Field Value
Type Description
SubjectNameStrategyDelegate

useLatestVersion

Declaration
protected bool useLatestVersion
Field Value
Type Description
bool

useLatestWithMetadata

Declaration
protected IDictionary<string, string> useLatestWithMetadata
Field Value
Type Description
IDictionary<string, string>

Methods

ExecuteMigrations(IList<Migration>, bool, string, string, Headers, object)

Declaration
protected Task<object> ExecuteMigrations(IList<Migration> migrations, bool isKey, string subject, string topic, Headers headers, object message)
Parameters
Type Name Description
IList<Migration> migrations
bool isKey
string subject
string topic
Headers headers
object message
Returns
Type Description
Task<object>

ExecuteRules(bool, string, string, Headers, RuleMode, Schema, Schema, object, FieldTransformer)

Execute rules

Declaration
protected Task<object> ExecuteRules(bool isKey, string subject, string topic, Headers headers, RuleMode ruleMode, Schema source, Schema target, object message, FieldTransformer fieldTransformer)
Parameters
Type Name Description
bool isKey
string subject
string topic
Headers headers
RuleMode ruleMode
Schema source
Schema target
object message
FieldTransformer fieldTransformer
Returns
Type Description
Task<object>
Exceptions
Type Condition
RuleConditionException
ArgumentException

GetMigrations(string, Schema, Schema)

Declaration
protected Task<IList<Migration>> GetMigrations(string subject, Schema writerSchema, Schema readerSchema)
Parameters
Type Name Description
string subject
Schema writerSchema
Schema readerSchema
Returns
Type Description
Task<IList<Migration>>

GetParsedSchema(Schema)

Declaration
protected Task<TParsedSchema> GetParsedSchema(Schema schema)
Parameters
Type Name Description
Schema schema
Returns
Type Description
Task<TParsedSchema>

GetReaderSchema(string, Schema)

Declaration
protected Task<RegisteredSchema> GetReaderSchema(string subject, Schema schema = null)
Parameters
Type Name Description
string subject
Schema schema
Returns
Type Description
Task<RegisteredSchema>

GetSchema(string, int, string)

Declaration
protected Task<(Schema, TParsedSchema)> GetSchema(string subject, int writerId, string format = null)
Parameters
Type Name Description
string subject
int writerId
string format
Returns
Type Description
Task<(Schema, TParsedSchema)>

ParseSchema(Schema)

Declaration
protected abstract Task<TParsedSchema> ParseSchema(Schema schema)
Parameters
Type Name Description
Schema schema
Returns
Type Description
Task<TParsedSchema>

ResolveReferences(Schema)

Declaration
protected Task<IDictionary<string, string>> ResolveReferences(Schema schema)
Parameters
Type Name Description
Schema schema
Returns
Type Description
Task<IDictionary<string, string>>