Struct cipherstash_dynamodb::encrypted_table::EncryptedTable

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

Implementations

impl<D> EncryptedTable<D>

pub fn cipher(&self) -> Arc<ZeroKmsCipher>

impl EncryptedTable<Headless>

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

pub async fn init_headless_with_zerokms_config( zerokms_config: ZeroKMSConfig<ClientKey>, ) -> Result<Self, InitError>

impl<D> EncryptedTable<D>

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

where S: Searchable,

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

where T: Decryptable + Identifiable,

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

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

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

pub async fn create_put_patch( &self, record: PreparedRecord, dataset_id: Option<DatasetId>, index_predicate: impl FnMut(&AttributeName, &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.

impl EncryptedTable<Dynamo>

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

pub async fn init_with_zerokms_config( zerokms_config: ZeroKMSConfig<ClientKey>, 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,

Get a record from the table by primary key from the default dataset.

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

where T: Decryptable + Identifiable,

Get a record from the table by primary key from a specific dataset.

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

Delete a record from the table by primary key from the default dataset.

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

Delete a record from the table by primary key from a specific dataset.

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

where T: Searchable + Identifiable,

Put a record into the table using the default dataset.

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

where T: Searchable + Identifiable,

Put a record into the table using a specific dataset.