Trait PartitionsManagerProxyInterface

pub trait PartitionsManagerProxyInterface: Send + Sync {
    type GetBlockInfoResponseFut: Future<Output = Result<PartitionsManagerGetBlockInfoResult, Error>> + Send;
    type CreateTransactionResponseFut: Future<Output = Result<PartitionsManagerCreateTransactionResult, Error>> + Send;
    type CommitTransactionResponseFut: Future<Output = Result<PartitionsManagerCommitTransactionResult, Error>> + Send;
    type AddPartitionResponseFut: Future<Output = Result<PartitionsManagerAddPartitionResult, Error>> + Send;

    // Required methods
    fn get_block_info(&self) -> Self::GetBlockInfoResponseFut;
    fn create_transaction(&self) -> Self::CreateTransactionResponseFut;
    fn commit_transaction(
        &self,
        transaction: EventPair,
    ) -> Self::CommitTransactionResponseFut;
    fn add_partition(
        &self,
        payload: PartitionsManagerAddPartitionRequest,
    ) -> Self::AddPartitionResponseFut;
}

Required Associated Types

type GetBlockInfoResponseFut: Future<Output = Result<PartitionsManagerGetBlockInfoResult, Error>> + Send

type CreateTransactionResponseFut: Future<Output = Result<PartitionsManagerCreateTransactionResult, Error>> + Send

type CommitTransactionResponseFut: Future<Output = Result<PartitionsManagerCommitTransactionResult, Error>> + Send

type AddPartitionResponseFut: Future<Output = Result<PartitionsManagerAddPartitionResult, Error>> + Send

Required Methods

fn get_block_info(&self) -> Self::GetBlockInfoResponseFut

fn create_transaction(&self) -> Self::CreateTransactionResponseFut

fn commit_transaction( &self, transaction: EventPair, ) -> Self::CommitTransactionResponseFut

fn add_partition( &self, payload: PartitionsManagerAddPartitionRequest, ) -> Self::AddPartitionResponseFut

Implementors

impl PartitionsManagerProxyInterface for PartitionsManagerProxy

type GetBlockInfoResponseFut = QueryResponseFut<Result<(u64, u32), i32>>

type CreateTransactionResponseFut = QueryResponseFut<Result<EventPair, i32>>

type CommitTransactionResponseFut = QueryResponseFut<Result<(), i32>>

type AddPartitionResponseFut = QueryResponseFut<Result<(), i32>>