Struct TimestreamWriteService 

pub struct TimestreamWriteService { /* private fields */ }

Timestream Write service handler that processes awsJson1.0 protocol requests.

Implementations

impl TimestreamWriteService

pub fn new() -> Self

Trait Implementations

impl Default for TimestreamWriteService

fn default() -> Self

Returns the “default value” for a type.

impl MockService for TimestreamWriteService

fn service_name(&self) -> &str

The service identifier (e.g., “sts”, “iam”, “s3”).

fn url_patterns(&self) -> Vec<&str>

URL patterns this service handles (as regex strings).

fn handle( &self, request: MockRequest, ) -> Pin<Box<dyn Future<Output = MockResponse> + Send + '_>>

Handle an incoming request and produce a response.

impl StatefulService for TimestreamWriteService

type StateView = TimestreamWriteStateView

Serde-compatible view of this service’s per-region state.

async fn snapshot(&self, account_id: &str, region: &str) -> Self::StateView

Take a snapshot of the state for the given account/region as a typed view.

async fn restore( &self, account_id: &str, region: &str, view: Self::StateView, ) -> Result<(), StateViewError>

Restore state for the given account/region from a typed view. Replaces the existing state entirely.

async fn merge( &self, account_id: &str, region: &str, view: Self::StateView, ) -> Result<(), StateViewError>

Merge a partial view into existing state (additive, does not remove existing resources).

fn notifier(&self) -> &StateChangeNotifier<Self::StateView>

Returns the state-change notifier embedded in this service.

async fn notify_state_changed(&self, account_id: &str, region: &str)

Take a snapshot of the given account/region and forward it to all registered listeners. Call this after any successful state mutation.