Struct ReplicationProtocol 

pub struct ReplicationProtocol { /* private fields */ }

Repository replication protocol.

Handles incoming P2P messages and coordinates repository synchronization.

Implementations

impl ReplicationProtocol

pub fn new() -> Self

Create a new replication protocol instance.

pub fn set_handler(&mut self, handler: Arc<dyn ReplicationHandler>)

Set the message handler for sending responses.

pub fn repos(&self) -> Arc<RwLock<HashMap<String, Arc<Repository>>>>

Get the repository store reference.

pub fn register_repo(&self, key: String, repo: Arc<Repository>)

Register a repository for replication.

pub fn get_repo(&self, key: &str) -> Option<Arc<Repository>>

Get a repository by key.

pub fn get_or_create_repo(&self, key: &str) -> Arc<Repository>

Get or create a repository by key.

pub fn handle_message( &self, peer_id: &[u8], data: &[u8], ) -> Result<Option<Message>>

Handle an incoming message from a peer.

Returns an optional response message.

pub fn broadcast_update( &self, repo_key: &str, new_objects: Vec<ObjectId>, refs: Vec<(String, ObjectId)>, )

Broadcast a repository update to all peers.

Called after a push to notify peers about new objects.

pub fn broadcast_ref_update( &self, repo_key: &str, ref_name: &str, old_id: ObjectId, new_id: ObjectId, )

Broadcast a reference update to all peers.

pub fn get_repo_state(&self, key: &str) -> Option<RepoState>

Get repository state summary for a given repo.

Trait Implementations

impl Default for ReplicationProtocol

fn default() -> Self

Returns the “default value” for a type.