Class CelExecutor
Assembly: Confluent.SchemaRegistry.Rules.dll
Syntax
public class CelExecutor : IRuleExecutor, IRuleBase, IDisposable
Constructors
CelExecutor()
Declaration
Fields
NullAvroSchema
Declaration
public static readonly Schema NullAvroSchema
Field Value
RuleType
Declaration
public static readonly string RuleType
Field Value
Methods
Configure the rule executor or action
Declaration
public void Configure(IEnumerable<KeyValuePair<string, string>> config, ISchemaRegistryClient client = null)
Parameters
Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
Declaration
Execute(RuleContext, object, IDictionary<string, object>)
Declaration
public Task<object> Execute(RuleContext ctx, object obj, IDictionary<string, object> args)
Parameters
Returns
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
Returns
Type()
The type of rule executor or action
Declaration
Returns
Implements