Struct Subscription 

pub struct Subscription { /* private fields */ }

A subscription to a replication stream.

Manages the lifecycle of subscribing to a feeder’s replication stream: connecting, receiving entries, tracking progress, and shutting down.

Implementations

impl Subscription

pub fn new(config: SubscriptionConfig) -> Self

Create a new subscription with the given configuration.

pub fn get_state(&self) -> SubscriptionState

Get the current subscription state.

pub fn get_current_vlsn(&self) -> u64

Get the most recently processed VLSN.

pub fn get_entries_received(&self) -> u64

Get the total number of entries received.

pub fn get_config(&self) -> &SubscriptionConfig

Get the subscription configuration.

pub fn start(&self) -> Result<()>

Start the subscription by connecting to the feeder.

Which calls SubscriptionThread.start(), which in turn invokes RepUtils.openSocket(feederAddr) to establish a TCP connection to the feeder node.

Transitions: Idle → Connecting → Active on success, or Idle → Connecting → Error if the connection attempt fails.

pub fn get_connection(&self) -> Option<TcpStream>

Get the live TCP connection to the feeder, if connected.

Returns a cloned handle to the underlying TcpStream. Callers use this to send/receive replication protocol messages.

pub fn process_entry(&self, vlsn: u64, _entry_type: u8, _data: Vec<u8>)

Process an incoming replicated entry.

Updates the current VLSN and entry count. In the full implementation, this would also invoke the subscription callback.

pub fn mark_caught_up(&self)

Mark the subscription as caught up with the master.

pub fn mark_error(&self)

Transition the subscription to the error state.

pub fn shutdown(&self)

Shutdown the subscription.

Closes the TCP connection to the feeder (if open) and marks the subscription as shut down. which stops the SubscriptionThread and closes the feeder socket.

pub fn is_shutdown(&self) -> bool

Whether shutdown has been requested.