rseata-tc 0.1.2

rust seata
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use crate::types::ConnectionId;
use async_trait::async_trait;
use rseata_core::branch::BranchType;
use rseata_core::resource::{DefaultResource, Resource};
use rseata_core::types::{ClientId, ResourceId};
use rseata_proto::rseata_proto::proto::ResourceInstruction;
use tokio::sync::mpsc::Sender;
use tonic::Status;

#[derive(Clone)]
pub struct TCResource {
    pub connection_id: ConnectionId,
    pub resource: DefaultResource,
    pub response_tx: Sender<Result<ResourceInstruction, Status>>,
}

#[async_trait]
impl Resource for TCResource {
    async fn get_resource_group_id(&self) -> String {
        self.resource.get_resource_group_id().await
    }

    async fn get_resource_id(&self) -> ResourceId {
        self.resource.get_resource_id().await
    }

    async fn get_branch_type(&self) -> BranchType {
        self.resource.get_branch_type().await
    }

    async fn get_client_id(&self) -> ClientId {
        self.resource.get_client_id().await
    }
}