confluent-kafka-dotnet
Show / Hide Table of Contents

Class EncryptionExecutor

Inheritance
object
EncryptionExecutor
Implements
IRuleExecutor
IRuleBase
IDisposable
Inherited Members
object.Equals(object)
object.Equals(object, object)
object.GetHashCode()
object.GetType()
object.MemberwiseClone()
object.ReferenceEquals(object, object)
object.ToString()
Namespace: Confluent.SchemaRegistry.Encryption
Assembly: Confluent.SchemaRegistry.Encryption.dll
Syntax
public class EncryptionExecutor : IRuleExecutor, IRuleBase, IDisposable

Constructors

EncryptionExecutor()

Declaration
public EncryptionExecutor()

EncryptionExecutor(IDekRegistryClient, IClock)

Declaration
public EncryptionExecutor(IDekRegistryClient client, IClock clock)
Parameters
TypeNameDescription
IDekRegistryClientclient
IClockclock

Fields

EncryptAlternateKmsKeyIds

Declaration
public static readonly string EncryptAlternateKmsKeyIds
Field Value
TypeDescription
string

EncryptDekAlgorithm

Declaration
public static readonly string EncryptDekAlgorithm
Field Value
TypeDescription
string

EncryptDekExpiryDays

Declaration
public static readonly string EncryptDekExpiryDays
Field Value
TypeDescription
string

EncryptKekName

Declaration
public static readonly string EncryptKekName
Field Value
TypeDescription
string

EncryptKmsKeyid

Declaration
public static readonly string EncryptKmsKeyid
Field Value
TypeDescription
string

EncryptKmsType

Declaration
public static readonly string EncryptKmsType
Field Value
TypeDescription
string

KmsTypeSuffix

Declaration
public static readonly string KmsTypeSuffix
Field Value
TypeDescription
string

RuleType

Declaration
public static readonly string RuleType
Field Value
TypeDescription
string

Methods

Configure(IEnumerable<KeyValuePair<string, string>>, ISchemaRegistryClient)

Configure the rule executor or action

Declaration
public void Configure(IEnumerable<KeyValuePair<string, string>> config, ISchemaRegistryClient client = null)
Parameters
TypeNameDescription
IEnumerable<KeyValuePair<string, string>>config
ISchemaRegistryClientclient

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

Declaration
public void Dispose()

NewTransform(RuleContext)

Declaration
public EncryptionExecutorTransform NewTransform(RuleContext ctx)
Parameters
TypeNameDescription
RuleContextctx
Returns
TypeDescription
EncryptionExecutorTransform

Register()

Declaration
public static void Register()

Transform(RuleContext, object)

Transform the message based on the rule context

Declaration
public Task<object> Transform(RuleContext ctx, object message)
Parameters
TypeNameDescription
RuleContextctx
objectmessage
Returns
TypeDescription
Task<object>

Type()

The type of rule executor or action

Declaration
public string Type()
Returns
TypeDescription
string

Implements

IRuleExecutor
IRuleBase
IDisposable
In this article