feldera_types/
transaction.rs

1use serde::{Deserialize, Serialize};
2use utoipa::ToSchema;
3
4pub type TransactionId = i64;
5
6/// Response to a `/start_transaction` request.
7#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, ToSchema)]
8pub struct StartTransactionResponse {
9    pub transaction_id: i64,
10}
11
12impl StartTransactionResponse {
13    pub fn new(transaction_id: TransactionId) -> Self {
14        Self { transaction_id }
15    }
16}