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
Type Name Description
IDekRegistryClient client
IClock clock

Fields

EncryptAlternateKmsKeyIds

Declaration
public static readonly string EncryptAlternateKmsKeyIds
Field Value
Type Description
string

EncryptDekAlgorithm

Declaration
public static readonly string EncryptDekAlgorithm
Field Value
Type Description
string

EncryptDekExpiryDays

Declaration
public static readonly string EncryptDekExpiryDays
Field Value
Type Description
string

EncryptKekName

Declaration
public static readonly string EncryptKekName
Field Value
Type Description
string

EncryptKmsKeyid

Declaration
public static readonly string EncryptKmsKeyid
Field Value
Type Description
string

EncryptKmsType

Declaration
public static readonly string EncryptKmsType
Field Value
Type Description
string

KmsTypeSuffix

Declaration
public static readonly string KmsTypeSuffix
Field Value
Type Description
string

RuleType

Declaration
public static readonly string RuleType
Field Value
Type Description
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
Type Name Description
IEnumerable<KeyValuePair<string, string>> config
ISchemaRegistryClient client

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
Type Name Description
RuleContext ctx
Returns
Type Description
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
Type Name Description
RuleContext ctx
object message
Returns
Type Description
Task<object>

Type()

The type of rule executor or action

Declaration
public string Type()
Returns
Type Description
string

Implements

IRuleExecutor
IRuleBase
IDisposable
In this article