akka.persistence.gdpr.javadsl

Class GdprEncryption

java.lang.Object

akka.persistence.gdpr.javadsl.GdprEncryption

All Implemented Interfaces:

akka.actor.Extension

Direct Known Subclasses:

AbstractGdprEncryption, DelegatingGdprEncryption

public abstract class GdprEncryption
extends java.lang.Object
implements akka.actor.Extension

Extension point for plugging in encryption for GDPR. If you only want to provide key management then instead extend AbstractGdprEncryption.

Constructor Summary

Constructors

Constructor and Description
GdprEncryption()

Method Summary

Modifier and Type	Method and Description
static T	apply(akka.actor.ActorSystem system)
static GdprEncryption	createExtension(akka.actor.ExtendedActorSystem system)
abstract java.util.concurrent.CompletionStage<java.util.Optional<byte[]>>	decrypt(byte[] payload, java.lang.String dataSubjectId) Decrypt the given payload with the key identified by dataSubjectId.
abstract java.util.concurrent.CompletionStage<byte[]>	encrypt(byte[] payload, java.lang.String dataSubjectId) Encrypt the given payload with the key identified by dataSubjectId.
static boolean	equals(java.lang.Object other)
static GdprEncryption	get(akka.actor.ActorSystem system)
static int	hashCode()
static GdprEncryption$	lookup()
abstract java.util.concurrent.CompletionStage<akka.Done>	shred(java.lang.String dataSubjectId) Remove the key identified by dataSubjectId.

Methods inherited from class java.lang.Object

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

Constructor Detail

GdprEncryption

public GdprEncryption()

Method Detail

createExtension

public static GdprEncryption createExtension(akka.actor.ExtendedActorSystem system)

get

public static GdprEncryption get(akka.actor.ActorSystem system)

lookup

public static GdprEncryption$ lookup()

apply

public static T apply(akka.actor.ActorSystem system)

hashCode

public static final int hashCode()

equals

public static final boolean equals(java.lang.Object other)

encrypt

public abstract java.util.concurrent.CompletionStage<byte[]> encrypt(byte[] payload,
                                                                     java.lang.String dataSubjectId)

Encrypt the given payload with the key identified by dataSubjectId.

Parameters:

payload - (undocumented)

dataSubjectId - (undocumented)

Returns:

(undocumented)

decrypt

public abstract java.util.concurrent.CompletionStage<java.util.Optional<byte[]>> decrypt(byte[] payload,
                                                                                         java.lang.String dataSubjectId)

Decrypt the given payload with the key identified by dataSubjectId.

Parameters:

payload - (undocumented)

dataSubjectId - (undocumented)

Returns:

Optional.empty if the key has been deleted

shred

public abstract java.util.concurrent.CompletionStage<akka.Done> shred(java.lang.String dataSubjectId)

Remove the key identified by dataSubjectId.

Parameters:

dataSubjectId - (undocumented)

Returns:

(undocumented)