Struct cipherstash_dynamodb::encryption::Encryption

pub struct Encryption<C = ServiceCredentials>
where
    C: Credentials<Token = ServiceToken>,
{
    pub index_key: IndexKey,
    /* private fields */
}

Fields

index_key: IndexKey

Implementations

impl<Creds> Encryption<Creds>

where Creds: Credentials<Token = ServiceToken>,

pub fn new( root_key: IndexKey, client: ZeroKMS<Creds, ClientKey>, ) -> Encryption<Creds>

pub async fn encrypt<T>( &self, items: impl IntoIterator<Item = T>, ) -> Result<Vec<EncryptedRecord>, EncryptionError>

where T: Into<BytesWithDescriptor>,

pub async fn encrypt_impl<T>( &self, items: impl IntoIterator<Item = T>, ) -> Result<Vec<EncryptedRecord>, EncryptionError>

where T: Into<BytesWithDescriptor>,

pub async fn encrypt_single( &self, target: PlaintextTarget, ) -> Result<EncryptedRecord, EncryptionError>

pub async fn encrypt_single_impl( &self, target: PlaintextTarget, ) -> Result<EncryptedRecord, EncryptionError>

pub async fn decrypt_single( &self, ciphertext: EncryptedRecord, ) -> Result<Plaintext, EncryptionError>

pub async fn decrypt_single_impl( &self, ciphertext: EncryptedRecord, ) -> Result<Plaintext, EncryptionError>

pub async fn maybe_decrypt_hex<C>( &self, ciphertexts: impl IntoIterator<Item = Option<C>>, ) -> Result<Vec<Option<Plaintext>>, EncryptionError>

where C: AsRef<[u8]>,

Like decrypt but doesn’t expect all values to be decryptable. This only means that a given input is None or the slice is not a serialized [EncryptedRecord]. In the future this could also cover cases where the caller is not authorized to decrypt a given value.

As it stands, this function will return an Error if any valid ciphertexts fail to decrypt.

Items in the returned vec wil be in the same order as the input but any values that are unable to be decrypted will be returned as None.

Encrypted records must be encoded with hex.

pub async fn maybe_decrypt_hex_impl<I, C>( &self, ciphertexts: I, ) -> Result<Vec<Option<Plaintext>>, EncryptionError>

where I: IntoIterator<Item = Option<C>>, C: AsRef<[u8]>,

pub async fn decrypt( &self, ciphertexts: impl IntoIterator<Item = EncryptedRecord>, ) -> Result<Vec<Plaintext>, EncryptionError>

pub async fn decrypt_impl( &self, ciphertexts: impl IntoIterator<Item = EncryptedRecord>, ) -> Result<Vec<Plaintext>, EncryptionError>

pub fn index( &self, value: &Plaintext, index_type: &IndexType, ) -> Result<IndexTerm, EncryptionError>

pub fn index_all( &self, target: &PlaintextTarget, ) -> Result<Vec<IndexTerm>, EncryptionError>

pub fn compound_index( &self, index: &CompoundIndex<impl ComposableIndex + Send>, input: impl Into<ComposablePlaintext>, salt: Option<impl AsRef<[u8]>>, term_length: usize, ) -> Result<IndexTerm, EncryptionError>

pub fn compound_query( &self, index: &CompoundIndex<impl ComposableIndex + Send>, input: impl Into<ComposablePlaintext>, salt: Option<impl AsRef<[u8]>>, term_length: usize, ) -> Result<IndexTerm, EncryptionError>

pub fn index_for_operator( &self, value: &Plaintext, index_type: &IndexType, operator: &Operator, cast_type: &ColumnType, ) -> Result<IndexTerm, EncryptionError>