crypto

Documentation

Index

• type Decryptor
  • func NewConsumerDecryptor(keyReader crypto.KeyReader, messageCrypto crypto.MessageCrypto, ...) Decryptor
  • func NewNoopDecryptor() Decryptor
• type Encryptor
  • func NewNoopEncryptor() Encryptor
  • func NewProducerEncryptor(keys []string, keyReader crypto.KeyReader, messageCrypto crypto.MessageCrypto, ...) Encryptor

Types

type Decryptor

type Decryptor interface {
	Decrypt(payload []byte, msgID *pb.MessageIdData, msgMetadata *pb.MessageMetadata) ([]byte, error)
}

Decryptor support decrypting of message

func NewConsumerDecryptor

func NewConsumerDecryptor(keyReader crypto.KeyReader,
	messageCrypto crypto.MessageCrypto,
	logger log.Logger) Decryptor

func NewNoopDecryptor

func NewNoopDecryptor() Decryptor

type Encryptor

type Encryptor interface {
	Encrypt([]byte, *pb.MessageMetadata) ([]byte, error)
}

Encryptor support encryption

func NewNoopEncryptor

func NewNoopEncryptor() Encryptor

func NewProducerEncryptor

func NewProducerEncryptor(keys []string,
	keyReader crypto.KeyReader,
	messageCrypto crypto.MessageCrypto,
	producerCryptoFailureAction int,
	logger log.Logger) Encryptor