Class CelExecutor

Inheritance
object
CelExecutor
Implements
Inherited Members
Namespace: Confluent.SchemaRegistry.Rules
Assembly: Confluent.SchemaRegistry.Rules.dll
Syntax
public class CelExecutor : IRuleExecutor, IRuleBase, IDisposable

Constructors

CelExecutor()

Declaration
public CelExecutor()

Fields

NullAvroSchema

Declaration
public static readonly Schema NullAvroSchema
Field Value
Type Description
Schema

RuleType

Declaration
public static readonly string RuleType
Field Value
Type Description
string

Methods

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

Configure the rule executor or action

Declaration
public 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 void Dispose()

Execute(RuleContext, object, IDictionary<string, object>)

Declaration
public Task<object> Execute(RuleContext ctx, object obj, IDictionary<string, object> args)
Parameters
Type Name Description
RuleContext ctx
object obj
IDictionary<string, object> args
Returns
Type Description
Task<object>

Register()

Declaration
public static void Register()

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 string Type()
Returns
Type Description
string

Implements