crypto

Oct 27, 2021

Changes in this version

type MessageMetadata

+ func (m *MessageMetadata) UpsertEncryptionKey(keyInfo EncryptionKeyInfo)

type MessageMetadataSupplier

+ UpsertEncryptionKey func(EncryptionKeyInfo)

Jul 19, 2021

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