Struct DynamoClient 

pub struct DynamoClient { /* private fields */ }

DynamoDB client wrapper with integrated VIL semantic logging.

Every operation automatically emits a db_log! entry with:

• db_hash — FxHash of "dynamodb"
• table_hash — FxHash of the table name
• duration_ns — Wall-clock time of the operation
• rows_affected — Items returned/affected
• op_type — 0=GET 1=PUT 2=UPDATE 3=DELETE 4=QUERY 5=SCAN
• error_code — 0 on success, non-zero on fault

Implementations

impl DynamoClient

pub async fn new(config: DynamoConfig) -> DynamoResult<Self>

Build a DynamoClient from DynamoConfig.

Loads AWS credentials from the environment / instance profile.

pub fn raw_client(&self) -> &Client

Access the underlying aws_sdk_dynamodb::Client.

pub fn db_hash(&self) -> u32

Return the cached db_hash.

pub fn pool_id(&self) -> u16

Return the pool_id.

impl DynamoClient

pub async fn get_item( &self, table: &str, key: HashMap<String, AttributeValue>, ) -> DynamoResult<Option<HashMap<String, AttributeValue>>>

Fetch a single item from table by its primary key key.

Returns None if no item matched. Emits db_log! with op_type = 0 (GET).

pub async fn put_item( &self, table: &str, item: HashMap<String, AttributeValue>, ) -> DynamoResult<()>

Write item into table, replacing any existing item with the same key.

Emits db_log! with op_type = 1 (PUT).

pub async fn delete_item( &self, table: &str, key: HashMap<String, AttributeValue>, ) -> DynamoResult<()>

Delete the item identified by key from table.

Emits db_log! with op_type = 3 (DELETE).

pub async fn query( &self, table: &str, key_condition: &str, expr_attr_values: HashMap<String, AttributeValue>, ) -> DynamoResult<Vec<HashMap<String, AttributeValue>>>

Run a Query against table using the given key-condition expression.

Returns a Vec of attribute maps. Emits db_log! with op_type = 4 (QUERY).

pub async fn scan( &self, table: &str, filter_expression: Option<&str>, expr_attr_values: Option<HashMap<String, AttributeValue>>, ) -> DynamoResult<Vec<HashMap<String, AttributeValue>>>

Scan all items in table, with an optional filter expression.

Returns a Vec of attribute maps. Emits db_log! with op_type = 5 (SCAN).

pub async fn update_item( &self, table: &str, key: HashMap<String, AttributeValue>, update_expression: &str, expr_attr_values: HashMap<String, AttributeValue>, ) -> DynamoResult<()>

Update an item in table using an update expression.

Emits db_log! with op_type = 2 (UPDATE).