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
Type Name Description
IEnumerable<KeyValuePair<string, string>> config
ISchemaRegistryClient client

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
Type Name Description
RuleContext ctx
Returns
Type Description
IFieldTransform

Transform(RuleContext, object)

Transform the message based on the rule context

Declaration
public Task<object> Transform(RuleContext ctx, object message)
Parameters
Type Name Description
RuleContext ctx
object message
Returns
Type Description
Task<object>

Type()

The type of rule executor or action

Declaration
public abstract string Type()
Returns
Type Description
string

Implements

IRuleExecutor
IRuleBase
IDisposable
In this article