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

Class CelExecutor.Bindings

java.lang.Object

io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings

Enclosing class:

CelExecutor

protected static final class CelExecutor.Bindings
extends Object

Pre-converted CEL invocation context. Holds the CelUtils.ScriptType, a format-specific schema hint, the declTypes declarations, and the already-CEL-shaped celArgs. Reused across multiple evaluate calls within a single transform/execute so guard and body share the same conversions.

Method Summary

Modifier and Type	Method	Description
Object	boundMessage()	The value bound for the message variable, used by the identity short-circuit in CelExecutor.transform(io.confluent.kafka.schemaregistry.rules.RuleContext, java.lang.Object).
Map<String,Object>	celArgs()	Read-only view of the converted CEL args.
Object	obj()
CelUtils.ScriptType	type()

Methods inherited from class java.lang.Object

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

Method Details

type

public CelUtils.ScriptType type()

celArgs

public Map<String,Object> celArgs()

Read-only view of the converted CEL args. Wrapped to prevent subclasses from mutating between bind and evaluate (which would break the cache key invariants and the identity short-circuit). The wrapper preserves reference semantics on values, so boundMessage() still compares equal to the result of an identity-rule evaluation.

obj

public Object obj()

boundMessage

public Object boundMessage()

The value bound for the message variable, used by the identity short-circuit in CelExecutor.transform(io.confluent.kafka.schemaregistry.rules.RuleContext, java.lang.Object).