confluent-kafka-dotnet
Show / Hide Table of Contents

Class FieldRuleExecutor

Inheritance
object
FieldRuleExecutor
FieldEncryptionExecutor
CelFieldExecutor
Implements
IRuleExecutor
IRuleBase
IDisposable
Inherited Members
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: Confluent.SchemaRegistry
Assembly: Confluent.SchemaRegistry.dll
Syntax
public abstract class FieldRuleExecutor : IRuleExecutor, IRuleBase, IDisposable

Methods

Configure(IEnumerable<KeyValuePair<string, string>>, ISchemaRegistryClient)

Configure the rule executor or action

Declaration
public abstract void Configure(IEnumerable<KeyValuePair<string, string>> config, ISchemaRegistryClient client = null)
Parameters
TypeNameDescription
IEnumerable<KeyValuePair<string, string>>config
ISchemaRegistryClientclient

Dispose()

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

Declaration
public abstract void Dispose()

NewTransform(RuleContext)

Declaration
public abstract IFieldTransform NewTransform(RuleContext ctx)
Parameters
TypeNameDescription
RuleContextctx
Returns
TypeDescription
IFieldTransform

Transform(RuleContext, object)

Transform the message based on the rule context

Declaration
public Task<object> Transform(RuleContext ctx, object message)
Parameters
TypeNameDescription
RuleContextctx
objectmessage
Returns
TypeDescription
Task<object>

Type()

The type of rule executor or action

Declaration
public abstract string Type()
Returns
TypeDescription
string

Implements

IRuleExecutor
IRuleBase
IDisposable
In this article