Struct DynamoTable 

pub struct DynamoTable {

    pub name: String,
    pub arn: String,
    pub key_schema: Vec<KeySchemaElement>,
    pub attribute_definitions: Vec<AttributeDefinition>,
    pub provisioned_throughput: ProvisionedThroughput,
    pub items: Vec<HashMap<String, AttributeValue>>,
    pub gsi: Vec<GlobalSecondaryIndex>,
    pub lsi: Vec<LocalSecondaryIndex>,
    pub tags: HashMap<String, String>,
    pub created_at: DateTime<Utc>,
    pub status: String,
    pub item_count: i64,
    pub size_bytes: i64,
    pub billing_mode: String,
    pub ttl_attribute: Option<String>,
    pub ttl_enabled: bool,
    pub resource_policy: Option<String>,
    pub pitr_enabled: bool,
    pub kinesis_destinations: Vec<KinesisDestination>,
    pub contributor_insights_status: String,
    pub contributor_insights_counters: HashMap<String, u64>,
    pub stream_enabled: bool,
    pub stream_view_type: Option<String>,
    pub stream_arn: Option<String>,
    pub stream_records: Arc<RwLock<Vec<StreamRecord>>>,
    pub sse_type: Option<String>,
    pub sse_kms_key_arn: Option<String>,
}

Fields

name: String

arn: String

key_schema: Vec<KeySchemaElement>

attribute_definitions: Vec<AttributeDefinition>

provisioned_throughput: ProvisionedThroughput

items: Vec<HashMap<String, AttributeValue>>

gsi: Vec<GlobalSecondaryIndex>

lsi: Vec<LocalSecondaryIndex>

tags: HashMap<String, String>

created_at: DateTime<Utc>

status: String

item_count: i64

size_bytes: i64

billing_mode: String

ttl_attribute: Option<String>

ttl_enabled: bool

resource_policy: Option<String>

pitr_enabled: bool

PITR enabled

kinesis_destinations: Vec<KinesisDestination>

Kinesis streaming destinations: stream_arn -> status

contributor_insights_status: String

Contributor insights status

contributor_insights_counters: HashMap<String, u64>

Contributor insights: partition key access counters (key_value_string -> count)

stream_enabled: bool

DynamoDB Streams configuration

stream_view_type: Option<String>

stream_arn: Option<String>

stream_records: Arc<RwLock<Vec<StreamRecord>>>

Stream records (retained for 24 hours)

sse_type: Option<String>

Server-side encryption type: AES256 (owned) or KMS

sse_kms_key_arn: Option<String>

KMS key ARN for SSE (only when sse_type is KMS)

Implementations

impl DynamoTable

pub fn hash_key_name(&self) -> &str

Get the hash key attribute name from the key schema.

pub fn range_key_name(&self) -> Option<&str>

Get the range key attribute name from the key schema (if any).

pub fn find_item_index( &self, key: &HashMap<String, AttributeValue>, ) -> Option<usize>

Find an item index by its primary key.

pub fn record_key_access(&mut self, key: &HashMap<String, AttributeValue>)

Record a partition key access for contributor insights. Only records if contributor insights is enabled.

pub fn record_item_access(&mut self, item: &HashMap<String, AttributeValue>)

Record a partition key access from a full item (extracts the key first).

pub fn top_contributors(&self, n: usize) -> Vec<(&str, u64)>

Get top N contributors sorted by access count (descending).

pub fn recalculate_stats(&mut self)

Recalculate item_count and size_bytes from the items vec.

Trait Implementations

impl Clone for DynamoTable

fn clone(&self) -> DynamoTable

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DynamoTable

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

Formats the value using the given formatter.