Index

A B C D E F H I J M N O P R S T V
All Classes and Interfaces|All Packages|Constant Field Values

A

AVRO - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType

AvroCelTypeProvider - Class in io.confluent.kafka.schemaregistry.rules.cel.avro

A CelTypeProvider that surfaces Avro Schema record types as CEL StructTypes.

AvroResultWriter - Class in io.confluent.kafka.schemaregistry.rules.cel.avro

Converts a CEL evaluation result (typically a Map literal or scalar) back into the Avro representation matching a target Schema.

B

bind(RuleContext, Object, Map<String, Object>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

Inspect the bound message to decide ScriptType, then convert every arg to its CEL-friendly shape.

boundMessage() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings

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).

buildCompiledRule(CelUtils.ScriptType, String, Object, List<CelVarDecl>, CelUtils.RegexEngine) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Like CelUtils.buildProgram(io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType, java.lang.String, java.lang.Object, java.util.List<dev.cel.common.CelVarDecl>) but exposes the compiled AST's result-type CelKind alongside the runnable program.

buildProgram(CelUtils.ScriptType, String, Object, List<CelVarDecl>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Build a CEL CelRuntime.Program for (type, expr, schemaHint, varDecls).

buildProgram(CelUtils.ScriptType, String, Object, List<CelVarDecl>, CelUtils.RegexEngine) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

BuiltinLibrary - Class in io.confluent.kafka.schemaregistry.rules.cel.builtin

Schema Registry's built-in CEL function library.

BuiltinLibrary() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary

C

CEL_IGNORE_GUARD_SEPARATOR - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

CEL_REGEX_ENGINE - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

Selects the regex engine used by the CEL matches / matches_string overloads.

celArgs() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings

Read-only view of the converted CEL args.

CelExecutor - Class in io.confluent.kafka.schemaregistry.rules.cel

CelExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

CelExecutor.Bindings - Class in io.confluent.kafka.schemaregistry.rules.cel

Pre-converted CEL invocation context.

CelFieldExecutor - Class in io.confluent.kafka.schemaregistry.rules.cel

CelFieldExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor

CelTypeLabels - Class in io.confluent.kafka.schemaregistry.rules.cel.builtin

Canonical CEL type-name labels for the extended types (Decimal, Timestamp, Variant) plus their Java cel-java OpaqueType decls.

CelUtils - Class in io.confluent.kafka.schemaregistry.rules.cel

Shared CEL helpers used by both the transform-path executor (CelExecutor) and the validation-path executor (CelValidator).

CelUtils.CompiledRule - Class in io.confluent.kafka.schemaregistry.rules.cel

Compiled rule output: the runnable CelRuntime.Program plus the compile-time result-type CelKind.

CelUtils.RegexEngine - Enum Class in io.confluent.kafka.schemaregistry.rules.cel

Regex engine used by the CEL matches / matches_string overloads.

CelUtils.ScriptType - Enum Class in io.confluent.kafka.schemaregistry.rules.cel

CelValidator - Class in io.confluent.kafka.schemaregistry.rules.cel

Validation-rule executor backed by CEL.

CelValidator() - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelValidator

CelValidator(int) - Constructor for class io.confluent.kafka.schemaregistry.rules.cel.CelValidator

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor

configure(Map<String, ?>) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

convert(Object, Schema) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroResultWriter

Convert celValue into the Avro shape required by schema.

D

DECIMAL - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels

Java cel-java type declaration for CelTypeLabels.DECIMAL_NAME.

DECIMAL_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels

CEL type label for confluent.type.Decimal.

DEFAULT - Static variable in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine

The default engine when none is configured.

E

evaluate(RuleContext, String, CelExecutor.Bindings) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

Look up (or compile) the program for rule and run it against the pre-converted args in b.

evaluateWithGuard(RuleContext, CelExecutor.Bindings) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

Apply the optional guard (everything before the first ; in the rule expression) and then evaluate the body.

execute(RuleContext, Object, Map<String, Object>) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

Entry point used by CelFieldExecutor and any subclass that wants the full guard-then-body flow.

execute(ValidationRule, Object, Object) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelValidator

F

findCelType(Object) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Infer the CelType for a runtime value.

findCelTypeForAvroSchema(Schema) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Map an Avro Schema to a CelType.

findCelTypeForClass(Class<?>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Map a Java Class to a CelType.

findType(String) - Method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider

forSchema(Schema) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider

Build a provider that registers all record schemas reachable from root.

fromString(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine

H

hasAnyType() - Method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider

Returns true iff there's at least one record we can describe.

I

io.confluent.kafka.schemaregistry.rules.cel - package io.confluent.kafka.schemaregistry.rules.cel

io.confluent.kafka.schemaregistry.rules.cel.avro - package io.confluent.kafka.schemaregistry.rules.cel.avro

io.confluent.kafka.schemaregistry.rules.cel.builtin - package io.confluent.kafka.schemaregistry.rules.cel.builtin

io.confluent.kafka.schemaregistry.rules.jsonata - package io.confluent.kafka.schemaregistry.rules.jsonata

J

JSON - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType

JSONATA_MAX_DEPTH - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

JSONATA_TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

JsonataExecutor - Class in io.confluent.kafka.schemaregistry.rules.jsonata

JsonataExecutor() - Constructor for class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

M

MAX_DEPTH - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

Deprecated.

N

newTransform(RuleContext) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor

O

obj() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings

P

PCRE - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine

program - Variable in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.CompiledRule

PROTOBUF - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType

R

RE2 - Enum constant in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine

resultKind - Variable in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.CompiledRule

S

setCheckerOptions(CelCheckerBuilder) - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary

setRuntimeOptions(CelRuntimeBuilder) - Method in class io.confluent.kafka.schemaregistry.rules.cel.builtin.BuiltinLibrary

T

TIMEOUT_MS - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

Deprecated.

TIMESTAMP_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels

CEL type label for google.protobuf.Timestamp (= CEL built-in timestamp).

toCelValue(Object) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Convert a native value to a CEL-compatible shape: IndexedRecord (covers both GenericRecord and SpecificRecord) → JDK Map (Google cel-java's runtime selects fields on Maps natively) Utf8 / GenericEnumSymbol → String Narrow numeric types (Integer, Short, Byte, Float) widened to CEL's natural widths (long / double) byte[] / ByteString → CelByteString (CEL bytes literals only compare equal to other CelByteStrings) Lists/maps recursively converted Other values (proto Messages, BigDecimal, primitives at correct width, etc.) pass through unchanged.

toCelValueForJson(Object, ObjectMapper) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

JSON-flavored variant of CelUtils.toCelValue(Object): additionally converts Jackson JsonNode and arbitrary POJOs to maps via the supplied ObjectMapper.

toDeclTypes(Map<String, Object>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Build a name→CelType map by inferring each value's type.

toVarDecls(Map<String, CelType>) - Static method in class io.confluent.kafka.schemaregistry.rules.cel.CelUtils

Convenience wrapper to construct CelVarDecl list from a name→type map, preserving insertion order.

transform(RuleContext, Object) - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

transform(RuleContext, Object) - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

type() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor.Bindings

type() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

type() - Method in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor

type() - Method in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelExecutor

TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.CelFieldExecutor

TYPE - Static variable in class io.confluent.kafka.schemaregistry.rules.jsonata.JsonataExecutor

types() - Method in class io.confluent.kafka.schemaregistry.rules.cel.avro.AvroCelTypeProvider

V

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.RegexEngine

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.confluent.kafka.schemaregistry.rules.cel.CelUtils.ScriptType

Returns an array containing the constants of this enum class, in the order they are declared.

VARIANT - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels

Java cel-java type declaration for CelTypeLabels.VARIANT_NAME.

VARIANT_NAME - Static variable in class io.confluent.kafka.schemaregistry.rules.cel.builtin.CelTypeLabels

CEL type label for confluent.type.Variant.

A B C D E F H I J M N O P R S T V
All Classes and Interfaces|All Packages|Constant Field Values