Struct cipherstash_dynamodb::encrypted_table::EncryptedTable

pub struct EncryptedTable<D = Dynamo> { /* private fields */ }

Implementations

impl<D> EncryptedTable<D>

pub fn cipher(&self) -> &Encryption<impl Credentials<Token = ServiceToken>>

impl EncryptedTable<Headless>

pub async fn init_headless() -> Result<Self, InitError>

impl<D> EncryptedTable<D>

pub fn query<S>(&self) -> QueryBuilder<S, &Self>

where S: Searchable,

pub async fn unseal_all( &self, items: impl IntoIterator<Item = HashMap<String, AttributeValue>>, spec: UnsealSpec<'_>, ) -> Result<Vec<Unsealed>, DecryptError>

pub async fn unseal( &self, item: HashMap<String, AttributeValue>, spec: UnsealSpec<'_>, ) -> Result<Unsealed, DecryptError>

pub async fn decrypt_all<T: Decryptable>( &self, items: impl IntoIterator<Item = HashMap<String, AttributeValue>>, ) -> Result<Vec<T>, DecryptError>

pub async fn decrypt<T: Decryptable>( &self, item: HashMap<String, AttributeValue>, ) -> Result<T, DecryptError>

pub async fn create_delete_patch( &self, delete: PreparedDelete, ) -> Result<DynamoRecordPatch, DeleteError>

pub async fn create_put_patch( &self, record: PreparedRecord, index_predicate: impl FnMut(&str, &TableAttribute) -> bool, ) -> Result<DynamoRecordPatch, PutError>

Create a DynamoRecordPatch used to insert records into DynamoDB.

This will create a root record with all attributes and index records that only include attributes specified by the index_predicate. Use this predicate to only project certain attributes into the index.

This patch will also include multiple delete items to remove any index keys that could be remaining in the database after updating a record.

pub fn encrypt_primary_key_parts( &self, prepared_primary_key: PreparedPrimaryKey, ) -> Result<PrimaryKeyParts, PrimaryKeyError>

Take a prepared primary key and encrypt it to get the PrimaryKeyParts which can be used for retrieval.

impl EncryptedTable<Dynamo>

pub async fn init( db: Client, table_name: impl Into<String>, ) -> Result<Self, InitError>

pub async fn get<T>( &self, k: impl Into<T::PrimaryKey>, ) -> Result<Option<T>, GetError>

where T: Decryptable + Identifiable,

pub async fn delete<E: Searchable + Identifiable>( &self, k: impl Into<E::PrimaryKey>, ) -> Result<(), DeleteError>

pub async fn put<T>(&self, record: T) -> Result<(), PutError>

where T: Searchable + Identifiable,