Struct DynamoDbLockClient 

pub struct DynamoDbLockClient { /* private fields */ }

Lock client backed by DynamoDb.

Implementations

impl DynamoDbLockClient

pub fn try_new( sdk_config: &SdkConfig, lock_table_name: Option<String>, billing_mode: Option<String>, max_elapsed_request_time: Option<String>, dynamodb_override_endpoint: Option<String>, dynamodb_override_region: Option<String>, dynamodb_override_access_key_id: Option<String>, dynamodb_override_secret_access_key: Option<String>, dynamodb_override_session_token: Option<String>, ) -> Result<Self, DynamoDbConfigError>

Creates a new DynamoDbLockClient from the supplied storage options.

pub async fn try_create_lock_table( &self, ) -> Result<CreateLockTableResult, LockClientError>

Create the lock table where DynamoDb stores the commit information for all delta tables.

Transparently handles the case where that table already exists, so it’s safe to call. After create_table operation is executed, the table state in DynamoDb is creating, and it’s not immediately useable. This method does not wait for the table state to become active, so transient failures might occur when immediately using the lock client.

pub fn get_lock_table_name(&self) -> String

Get the name of the lock table for transactional commits used by the DynamoDb lock client.

pub fn get_dynamodb_config(&self) -> &DynamoDbConfig

pub async fn get_commit_entry( &self, table_path: &str, version: i64, ) -> Result<Option<CommitEntry>, LockClientError>

Read a log entry from DynamoDb.

pub async fn put_commit_entry( &self, table_path: &str, entry: &CommitEntry, ) -> Result<(), LockClientError>

write new entry to to DynamoDb lock table.

pub async fn get_latest_entry( &self, table_path: &str, ) -> Result<Option<CommitEntry>, LockClientError>

Get the latest entry (entry with highest version).

pub async fn get_latest_entries( &self, table_path: &str, limit: i64, ) -> Result<Vec<CommitEntry>, LockClientError>

Find the latest entry in the lock table for the delta table on the specified table_path.

pub async fn update_commit_entry( &self, version: i64, table_path: &str, ) -> Result<UpdateLogEntryResult, LockClientError>

Update existing log entry

pub async fn delete_commit_entry( &self, version: i64, table_path: &str, ) -> Result<(), LockClientError>

Delete existing log entry if it is not already complete

Trait Implementations

impl Debug for DynamoDbLockClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.