Versions in this module Expand all Collapse all v0 v0.6.12 Dec 12, 2023 Changes in this version + const ConsumerCryptoFailureActionConsume + const ConsumerCryptoFailureActionDiscard + const ConsumerCryptoFailureActionFail + const ProducerCryptoFailureActionFail + const ProducerCryptoFailureActionSend + type DefaultMessageCrypto struct + func NewDefaultMessageCrypto(logCtx string, keyGenNeeded bool, logger log.Logger) (*DefaultMessageCrypto, error) + func (d *DefaultMessageCrypto) AddPublicKeyCipher(keyNames []string, keyReader KeyReader) error + func (d *DefaultMessageCrypto) Decrypt(msgMetadata MessageMetadataSupplier, payload []byte, keyReader KeyReader) ([]byte, error) + func (d *DefaultMessageCrypto) Encrypt(encKeys []string, keyReader KeyReader, msgMetadata MessageMetadataSupplier, ...) ([]byte, error) + func (d *DefaultMessageCrypto) RemoveKeyCipher(keyName string) bool + type EncryptionKeyInfo struct + func NewEncryptionKeyInfo(name string, key []byte, metadata map[string]string) *EncryptionKeyInfo + func (eci *EncryptionKeyInfo) Key() []byte + func (eci *EncryptionKeyInfo) Metadata() map[string]string + func (eci *EncryptionKeyInfo) Name() string + type FileKeyReader struct + func NewFileKeyReader(publicKeyPath, privateKeyPath string) *FileKeyReader + func (d *FileKeyReader) PrivateKey(keyName string, keyMeta map[string]string) (*EncryptionKeyInfo, error) + func (d *FileKeyReader) PublicKey(keyName string, keyMeta map[string]string) (*EncryptionKeyInfo, error) + type KeyReader interface + PrivateKey func(keyName string, metadata map[string]string) (*EncryptionKeyInfo, error) + PublicKey func(keyName string, metadata map[string]string) (*EncryptionKeyInfo, error) + type MessageCrypto interface + AddPublicKeyCipher func(keyNames []string, keyReader KeyReader) error + Decrypt func(msgMetadata MessageMetadataSupplier, payload []byte, KeyReader KeyReader) ([]byte, error) + Encrypt func(encKeys []string, KeyReader KeyReader, msgMetadata MessageMetadataSupplier, ...) ([]byte, error) + RemoveKeyCipher func(keyName string) bool + type MessageMetadata struct + func (m *MessageMetadata) EncryptionKeys() []EncryptionKeyInfo + func (m *MessageMetadata) EncryptionParam() []byte + func (m *MessageMetadata) SetEncryptionParam(param []byte) + func (m *MessageMetadata) UpsertEncryptionKey(keyInfo EncryptionKeyInfo) + type MessageMetadataSupplier interface + EncryptionKeys func() []EncryptionKeyInfo + EncryptionParam func() []byte + SetEncryptionParam func([]byte) + UpsertEncryptionKey func(EncryptionKeyInfo) + func NewMessageMetadataSupplier(messageMetadata *pb.MessageMetadata) MessageMetadataSupplier