crypto

Oct 27, 2021

Changes in this version

+ type Decryptor interface

+ Decrypt func(payload []byte, msgID *pb.MessageIdData, msgMetadata *pb.MessageMetadata) ([]byte, error)

+ func NewConsumerDecryptor(keyReader crypto.KeyReader, messageCrypto crypto.MessageCrypto, ...) Decryptor

+ func NewNoopDecryptor() Decryptor

+ type Encryptor interface

+ Encrypt func([]byte, *pb.MessageMetadata) ([]byte, error)

+ func NewNoopEncryptor() Encryptor

+ func NewProducerEncryptor(keys []string, keyReader crypto.KeyReader, messageCrypto crypto.MessageCrypto, ...) Encryptor