pub(crate) fn new<R: AppDataResponse, N: RaftNetwork<D>, S: RaftStorage<D, R>>(
        id: NodeId,
        target: NodeId,
        term: u64,
        config: Arc<Config>,
        last_log: LogId,
        commit_index: u64,
        network: Arc<N>,
        storage: Arc<S>,
        replication_tx: mpsc::UnboundedSender<(ReplicaEvent<S::SnapshotData>, Span)>,
    ) -> Self {
        ReplicationCore::spawn(
            id,
            target,
            term,
            config,
            last_log,
            commit_index,
            network,
            storage,
            replication_tx,
        )
    }
/// Create a new replication stream for the target peer.
Create a new replication stream for the target peer.
Create a new replication stream for the target peer .
pub(crate) fn new<R: AppDataResponse, N: RaftNetwork<D>, S: RaftStorage<D, R>>(
        id: NodeId,
        target: NodeId,
        term: u64,
        config: Arc<Config>,
        last_log: LogId,
        commit_index: u64,
        network: Arc<N>,
        storage: Arc<S>,
        replication_tx: mpsc::UnboundedSender<(ReplicaEvent<S::SnapshotData>, Span)>,
    ) -> Self {
        ReplicationCore::spawn(
            id,
            target,
            term,
            config,
            last_log,
            commit_index,
            network,
            storage,
            replication_tx,
        )
    }
pub ( crate ) fn new < R : AppDataResponse , N : RaftNetwork < D > , S : RaftStorage < D , R > > ( id : NodeId , target : NodeId , term : u64 , config : Arc < Config > , last_log : LogId , commit_index : u64 , network : Arc < N > , storage : Arc < S > , replication_tx : mpsc :: UnboundedSender < ( ReplicaEvent < S :: SnapshotData > , Span ) > , ) -> Self { ReplicationCore :: spawn ( id , target , term , config , last_log , commit_index , network , storage , replication_tx , ) }
Create a new replication stream for the target peer.
Create a new replication stream for the target peer .
id
NodeId
target
NodeId
term
u64
config
Arc<Config>
last_log
LogId
commit_index
u64
network
Arc<N>
storage
Arc<S>
replication_tx
mpsc::UnboundedSender<(ReplicaEvent<S::SnapshotData>, Span)>
id
NodeId
target
NodeId
term
u64
config
Arc<Config>
last_log
LogId
commit_index
u64
network
Arc<N>
storage
Arc<S>
replication_tx
mpsc::UnboundedSender<(ReplicaEvent<S::SnapshotData>, Span)>