Package io.confluent.kafka.schemaregistry.rules.cel

Class CelValidator

java.lang.Object

io.confluent.kafka.schemaregistry.rules.cel.CelValidator

All Implemented Interfaces:

ValidationRuleExecutor

public final class CelValidator
extends Object
implements ValidationRuleExecutor

Validation-rule executor backed by CEL. Each instance owns its own program cache; the cache key is (expr, scriptType, thisType, schemaHint) — narrow enough that the same compiled CelRuntime.Program is reused across records that share the same field shape.

Instantiated per serializer (lazily, the first time a validation rule fires) so that deserializer-only flows pay nothing.

Constructor Summary

Constructors

Constructor	Description
CelValidator()
CelValidator(int cacheSize)

Method Summary

Modifier and Type	Method	Description
Object	execute(ValidationRule rule, Object schema, Object value)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CelValidator

public CelValidator()

CelValidator

public CelValidator(int cacheSize)

Method Details

execute

public Object execute(ValidationRule rule,
 Object schema,
 Object value)
               throws RuleException

Specified by:

execute in interface ValidationRuleExecutor

Throws:

RuleException