io.confluent.kafka.schemaregistry.encryption

Class FieldEncryptionExecutor.FieldEncryptionExecutorTransform

java.lang.Object

io.confluent.kafka.schemaregistry.encryption.FieldEncryptionExecutor.FieldEncryptionExecutorTransform

All Implemented Interfaces:

FieldTransform, AutoCloseable

Enclosing class:

FieldEncryptionExecutor

public class FieldEncryptionExecutor.FieldEncryptionExecutorTransform
extends Object
implements FieldTransform

Constructor Summary

Constructors

Constructor and Description
FieldEncryptionExecutorTransform()

Method Summary

Modifier and Type	Method and Description
void	close()
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.FieldContext fieldCtx, Object fieldValue)

Methods inherited from class java.lang.Object

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

Constructor Detail

FieldEncryptionExecutorTransform

public FieldEncryptionExecutorTransform()

Method Detail

init

public void init(RuleContext ctx)
          throws RuleException

Specified by:

init in interface FieldTransform

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.FieldContext fieldCtx,
                        Object fieldValue)
                 throws RuleException

Specified by:

transform in interface FieldTransform

Throws:

RuleException

close

public void close()

Specified by:

close in interface FieldTransform

Specified by:

close in interface AutoCloseable