encryption

Jan 7, 2025

Changes in this version

+ func NewExecutor() serde.RuleExecutor

type FieldEncryptionExecutor

+ func NewExecutorWithClock(c Clock) *FieldEncryptionExecutor

Jul 10, 2024

Changes in this version

+ const Aes128Gcm

+ const Aes256Gcm

+ const Aes256Siv

+ const EncryptDekAlgorithm

+ const EncryptDekExpiryDays

+ const EncryptKekName

+ const EncryptKmsKeyID

+ const EncryptKmsType

+ const MillisInDay

+ func Register()

+ func RegisterKMSDriver(kmsDriver KMSDriver)

+ type Clock interface

+ NowUnixMilli func() int64

+ type Cryptor struct

+ DekFormat string

+ KeyTemplate *tinkpb.KeyTemplate

+ type FieldEncryptionExecutor struct

+ Client deks.Client

+ Clock Clock

+ Config map[string]string

+ func RegisterWithClock(c Clock) *FieldEncryptionExecutor

+ func (f *FieldEncryptionExecutor) Close() error

+ func (f *FieldEncryptionExecutor) Configure(clientConfig *schemaregistry.Config, config map[string]string) error

+ func (f *FieldEncryptionExecutor) NewTransform(ctx serde.RuleContext) (serde.FieldTransform, error)

+ func (f *FieldEncryptionExecutor) Type() string

+ type FieldEncryptionExecutorTransform struct

+ Cryptor Cryptor

+ DekExpiryDays int

+ Executor FieldEncryptionExecutor

+ Kek deks.Kek

+ KekName string

+ func (f *FieldEncryptionExecutorTransform) Transform(ctx serde.RuleContext, fieldCtx serde.FieldContext, fieldValue interface{}) (interface{}, error)

+ type KMSDriver interface

+ GetKeyURLPrefix func() string

+ NewKMSClient func(config map[string]string, keyURL *string) (registry.KMSClient, error)

+ func GetKMSDriver(keyURI string) (KMSDriver, error)