Struct TimestreamWriteState 

pub struct TimestreamWriteState {
    pub databases: HashMap<String, Database>,
    pub tables: HashMap<(String, String), Table>,
    pub batch_load_tasks: HashMap<String, BatchLoadTask>,
}

In-memory state for the Timestream Write service.

Fields

databases: HashMap<String, Database>

Databases keyed by database name.

tables: HashMap<(String, String), Table>

Tables keyed by (database_name, table_name).

batch_load_tasks: HashMap<String, BatchLoadTask>

Batch load tasks keyed by task_id.

Implementations

impl TimestreamWriteState

pub fn create_database( &mut self, database_name: &str, account_id: &str, region: &str, kms_key_id: Option<&str>, ) -> Result<&Database, TimestreamWriteError>

pub fn describe_database( &self, database_name: &str, ) -> Result<&Database, TimestreamWriteError>

pub fn delete_database( &mut self, database_name: &str, ) -> Result<(), TimestreamWriteError>

pub fn list_databases(&self) -> Vec<&Database>

pub fn update_database( &mut self, database_name: &str, kms_key_id: &str, ) -> Result<&Database, TimestreamWriteError>

pub fn create_table( &mut self, database_name: &str, table_name: &str, account_id: &str, region: &str, retention_properties: Option<RetentionProperties>, magnetic_store_write_properties: Option<MagneticStoreWriteProperties>, ) -> Result<&Table, TimestreamWriteError>

pub fn describe_table( &self, database_name: &str, table_name: &str, ) -> Result<&Table, TimestreamWriteError>

pub fn delete_table( &mut self, database_name: &str, table_name: &str, ) -> Result<(), TimestreamWriteError>

pub fn list_tables( &self, database_name: &str, ) -> Result<Vec<&Table>, TimestreamWriteError>

pub fn update_table( &mut self, database_name: &str, table_name: &str, retention_properties: Option<RetentionProperties>, magnetic_store_write_properties: Option<MagneticStoreWriteProperties>, ) -> Result<&Table, TimestreamWriteError>

pub fn write_records( &mut self, database_name: &str, table_name: &str, records: Vec<Record>, ) -> Result<i32, TimestreamWriteError>

pub fn tag_resource( &mut self, resource_arn: &str, tags: HashMap<String, String>, ) -> Result<(), TimestreamWriteError>

pub fn untag_resource( &mut self, resource_arn: &str, tag_keys: &[String], ) -> Result<(), TimestreamWriteError>

pub fn list_tags_for_resource( &self, resource_arn: &str, ) -> Result<&HashMap<String, String>, TimestreamWriteError>

pub fn create_batch_load_task( &mut self, task_id: String, database_name: &str, table_name: &str, data_source_configuration: Value, report_configuration: Value, data_model_configuration: Option<Value>, ) -> &BatchLoadTask

pub fn describe_batch_load_task( &self, task_id: &str, ) -> Result<&BatchLoadTask, TimestreamWriteError>

pub fn list_batch_load_tasks( &self, task_status_filter: Option<&str>, ) -> Vec<&BatchLoadTask>

pub fn resume_batch_load_task( &mut self, task_id: &str, ) -> Result<(), TimestreamWriteError>

Trait Implementations

impl Debug for TimestreamWriteState

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

Formats the value using the given formatter.

impl Default for TimestreamWriteState

fn default() -> TimestreamWriteState

Returns the “default value” for a type.

impl From<&TimestreamWriteState> for TimestreamWriteStateView

fn from(state: &TimestreamWriteState) -> Self

Converts to this type from the input type.

impl From<TimestreamWriteStateView> for TimestreamWriteState

fn from(view: TimestreamWriteStateView) -> Self

Converts to this type from the input type.