com.xxdb.replicator

Class ReplicatorStreamStatus

java.lang.Object

com.xxdb.comm.ErrorCodeInfo

com.xxdb.replicator.ReplicatorStreamStatus

public class ReplicatorStreamStatus
extends ErrorCodeInfo

Status information for a single stream replication target. Tracks the number of rows inserted, dumped, and any error messages. Extends ErrorCodeInfo to provide consistent error handling.

Nested Class Summary

Nested classes/interfaces inherited from class com.xxdb.comm.ErrorCodeInfo

ErrorCodeInfo.Code

Constructor Summary

Constructors

Constructor and Description
ReplicatorStreamStatus() Creates a new ReplicatorStreamStatus with default values.
ReplicatorStreamStatus(long insertedRows, long dumpedRows, ErrorCodeInfo errorInfo) Creates a new ReplicatorStreamStatus with the specified values.

Method Summary

Modifier and Type	Method and Description
long	getDumpedRows() Gets the number of rows that have been successfully written to the server.
long	getInsertedRows() Gets the total number of rows that have been inserted into the queue.
long	getPendingRows() Gets the number of rows waiting in the queue (not yet written).
void	setDumpedRows(long dumpedRows) Sets the number of rows successfully written.
void	setError(ErrorCodeInfo errorInfo) Sets error information from another ErrorCodeInfo.
void	setInsertedRows(long insertedRows) Sets the total number of rows inserted.
String	toString()

Methods inherited from class com.xxdb.comm.ErrorCodeInfo

clearError, formatApiCode, getErrorCode, getErrorInfo, hasError, set, set, set, set, setErrorCode, setErrorInfo, succeed

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicatorStreamStatus

public ReplicatorStreamStatus()

Creates a new ReplicatorStreamStatus with default values.

ReplicatorStreamStatus

public ReplicatorStreamStatus(long insertedRows,
                              long dumpedRows,
                              ErrorCodeInfo errorInfo)

Creates a new ReplicatorStreamStatus with the specified values.

Parameters:

insertedRows - The total number of rows inserted into the queue

dumpedRows - The number of rows successfully written to the server

errorInfo - ErrorCodeInfo containing error code and message

Method Detail

getInsertedRows

public long getInsertedRows()

Gets the total number of rows that have been inserted into the queue.

Returns:

The number of inserted rows

setInsertedRows

public void setInsertedRows(long insertedRows)

Sets the total number of rows inserted.

Parameters:

insertedRows - The number of inserted rows

getDumpedRows

public long getDumpedRows()

Gets the number of rows that have been successfully written to the server.

Returns:

The number of dumped rows

setDumpedRows

public void setDumpedRows(long dumpedRows)

Sets the number of rows successfully written.

Parameters:

dumpedRows - The number of dumped rows

getPendingRows

public long getPendingRows()

Gets the number of rows waiting in the queue (not yet written).

Returns:

The number of pending rows

setError

public void setError(ErrorCodeInfo errorInfo)

Sets error information from another ErrorCodeInfo.

Parameters:

errorInfo - The error information to copy

toString

public String toString()

Overrides:

toString in class ErrorCodeInfo