Package io.confluent.kafka.schemaregistry.encryption

Class EncryptionExecutor.EncryptionExecutorTransform

java.lang.Object

io.confluent.kafka.schemaregistry.encryption.EncryptionExecutor.EncryptionExecutorTransform

Enclosing class:

EncryptionExecutor

public class EncryptionExecutor.EncryptionExecutorTransform
extends Object

Constructor Summary

Constructors

Constructor	Description
EncryptionExecutorTransform()

Method Summary

Modifier and Type	Method	Description
void	checkDeferredFailure()	Rethrows a kek lookup failure that init(RuleContext) deferred so the field walk could record per-field metadata.
protected String	getKekName(RuleContext ctx)
Dek	getOrCreateDek(RuleContext ctx, Integer version)
protected Kek	getOrCreateKek(RuleContext ctx)
void	init(RuleContext ctx)
boolean	isDekRotated()
Object	transform(RuleContext ctx, RuleContext.Type type, Object value)

Methods inherited from class java.lang.Object

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

Constructor Details

EncryptionExecutorTransform

public EncryptionExecutorTransform()

Method Details

init

public void init(RuleContext ctx)
          throws RuleException

Throws:

RuleException

checkDeferredFailure

public void checkDeferredFailure()
                          throws RuleException

Rethrows a kek lookup failure that init(RuleContext) deferred so the field walk could record per-field metadata. Must be called once the walk is done, before its result is used.

Throws:

RuleException

isDekRotated

public boolean isDekRotated()

getKekName

protected String getKekName(RuleContext ctx)
                     throws RuleException

Throws:

RuleException

getOrCreateKek

protected Kek getOrCreateKek(RuleContext ctx)
                      throws RuleException

Throws:

RuleException

getOrCreateDek

public Dek getOrCreateDek(RuleContext ctx,
 Integer version)
                   throws RuleException,
GeneralSecurityException

Throws:

RuleException

GeneralSecurityException

transform

public Object transform(RuleContext ctx,
 RuleContext.Type type,
 Object value)
                 throws RuleException

Throws:

RuleException