Struct StateChangeBuilder 

pub struct StateChangeBuilder { /* private fields */ }

Builder for executing state changes.

Example

let db = conn
    .state_change("create-account", 1)
    .json(&CreateAccountRequest { name: "Alice" })?
    .with_correlation_id("order-12345")
    .execute()
    .await?;

Implementations

impl StateChangeBuilder

pub fn new( connection: Connection, name: String, version: StateChangeVersion, ) -> Self

Create a new state change builder.

pub fn json<T: Serialize>(self, value: &T) -> Result<Self, CommandRequestError>

Set the request body as JSON.

pub fn request(self, request: CommandRequest) -> Self

Set the raw command request.

pub fn with_transaction_id(self, transaction_id: impl Into<String>) -> Self

Set a specific transaction ID for idempotency.

pub fn with_correlation_id(self, correlation_id: impl Into<String>) -> Self

Set the correlation ID for grouping related events in a business flow.

See: https://github.com/cloudevents/spec/blob/main/cloudevents/extensions/correlation.md

pub fn with_causation_id(self, causation_id: impl Into<String>) -> Self

Set the causation ID for parent-child event relationships.

See: https://github.com/cloudevents/spec/blob/main/cloudevents/extensions/correlation.md

pub fn content_type(self, content_type: impl Into<String>) -> Self

Set the content type for the request.

If no request exists yet, creates a default request.

Example

let db = conn
    .state_change("process-xml", 1)
    .request(CommandRequest::with_body(xml_bytes))
    .content_type("application/xml")
    .execute()
    .await?;

pub fn content_schema(self, schema_url: impl Into<String>) -> Self

Set the content schema URL for the request.

If no request exists yet, creates a default request.

Example

let db = conn
    .state_change("create-account", 1)
    .json(&request)?
    .content_schema("https://example.com/schemas/create-account.json")
    .execute()
    .await?;

pub async fn execute(self) -> Result<DatabaseAtRevisionImpl, StateChangeError>

Execute the state change synchronously.

pub async fn execute_async(self) -> Result<CorrelationId, StateChangeError>

Execute the state change asynchronously.