com.xxdb.replicator

Class ReplicatorStatus

java.lang.Object

com.xxdb.replicator.ReplicatorStatus

public class ReplicatorStatus
extends Object

Overall status information for the StreamReplicator. Contains aggregated statistics and per-host status information.

Constructor Summary

Constructors

Constructor and Description
ReplicatorStatus() Creates a new ReplicatorStatus with default values.
ReplicatorStatus(Map<String,ReplicatorStreamStatus> hostStatuses) Creates a new ReplicatorStatus with the specified values.

Method Summary

Modifier and Type	Method and Description
ReplicatorStreamStatus	getHostStatus(String label) Gets the status for a specific host.
Map<String,ReplicatorStreamStatus>	getHostStatuses() Gets an unmodifiable map of host labels to their status information.
long	getTotalDumpedRows() Gets the total number of dumped rows across all hosts.
long	getTotalPendingRows() Gets the total number of pending rows across all hosts.
long	getTotalRows() Gets the total number of rows inserted across all hosts.
boolean	hasAnyError() Checks if any host has an error.
void	setHostStatus(String label, ReplicatorStreamStatus status) Adds or updates the status for a specific host.
void	setHostStatuses(Map<String,ReplicatorStreamStatus> hostStatuses) Sets the host statuses map.
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReplicatorStatus

public ReplicatorStatus()

Creates a new ReplicatorStatus with default values.

ReplicatorStatus

public ReplicatorStatus(Map<String,ReplicatorStreamStatus> hostStatuses)

Creates a new ReplicatorStatus with the specified values.

Parameters:

hostStatuses - A map of host label to ReplicatorStreamStatus

Method Detail

getTotalRows

public long getTotalRows()

Gets the total number of rows inserted across all hosts. This value is calculated in real-time from host statuses.

Returns:

The total number of rows

getHostStatuses

public Map<String,ReplicatorStreamStatus> getHostStatuses()

Gets an unmodifiable map of host labels to their status information.

Returns:

A map of host label to ReplicatorStreamStatus

setHostStatuses

public void setHostStatuses(Map<String,ReplicatorStreamStatus> hostStatuses)

Sets the host statuses map.

Parameters:

hostStatuses - A map of host label to ReplicatorStreamStatus

getHostStatus

public ReplicatorStreamStatus getHostStatus(String label)

Gets the status for a specific host.

Parameters:

label - The host label

Returns:

The ReplicatorStreamStatus for the host, or null if not found

setHostStatus

public void setHostStatus(String label,
                          ReplicatorStreamStatus status)

Adds or updates the status for a specific host.

Parameters:

label - The host label

status - The status information

getTotalDumpedRows

public long getTotalDumpedRows()

Gets the total number of dumped rows across all hosts.

Returns:

The sum of dumped rows from all hosts

getTotalPendingRows

public long getTotalPendingRows()

Gets the total number of pending rows across all hosts.

Returns:

The sum of pending rows from all hosts

hasAnyError

public boolean hasAnyError()

Checks if any host has an error.

Returns:

true if any host has an error, false otherwise

toString

public String toString()

Overrides:

toString in class Object