Skip to content

VOLUME.INSPECT REPLICATION

Returns the replication status for a specific standby member on a given shard, including the current stage, cursor position, per-stage progress, and any error message.

VOLUME.INSPECT REPLICATION <volume-name> <standby-id>
ParameterTypeDescription
volume-namestringVolume identifier (e.g. bucket-shard-0). Use VOLUME.ADMIN LIST to discover names
standby-idstringFull member ID of the standby, or a unique 4-character prefix

RESP3 map with the following fields:

FieldTypeDescription
stagestringCurrent replication stage: SEGMENT_REPLICATION, CHANGE_DATA_CAPTURE, or empty string if not yet started
cursormapCurrent replication cursor (see cursor below)
statusstringReplication status: WAITING, RUNNING, DONE, STOPPED, FAILED, or empty string if not yet started
error_messagestringError description if replication has failed, or empty string
cdc_stagemapCDC stage progress (see cdc_stage below)
segment_replication_stagemapSegment replication progress (see segment_replication_stage below)
FieldTypeDescription
segment_idintegerID of the segment currently being replicated
positionintegerCurrent byte position within that segment
FieldTypeDescription
sequence_numberintegerChangelog sequence number of the CDC consumer
positionintegerByte position within the current CDC segment
FieldTypeDescription
tail_sequence_numberintegerTail changelog sequence number for segment replication
tail_next_positionintegerNext byte position after the segment tail

Reads the full replication status for the given standby and volume. Fields default to empty strings and zeroes when replication has not yet started.

It is available on the management port (default 3320).

ConditionMessage
Missing or extra parametersERR invalid number of parameters
Invalid volume name formatERR invalid volume name: <name>
Invalid member ID formatERR Invalid memberId: <id>
No member found with the given 4-character prefixERR no member found with prefix: <prefix>
More than one member matches the prefixERR more than one member found with prefix: <prefix>

Active replication (running):

127.0.0.1:3320> VOLUME.INSPECT REPLICATION bucket-shard-0 ab12
1# "stage" => "CHANGE_DATA_CAPTURE"
2# "cursor" => 1# "segment_id" => (integer) 2
2# "position" => (integer) 8192
3# "status" => "RUNNING"
4# "error_message" => ""
5# "cdc_stage" => 1# "sequence_number" => (integer) 15
2# "position" => (integer) 4096
6# "segment_replication_stage" => 1# "tail_sequence_number" => (integer) 10
2# "tail_next_position" => (integer) 6144

Replication not yet started:

127.0.0.1:3320> VOLUME.INSPECT REPLICATION bucket-shard-0 ab12
1# "stage" => ""
2# "cursor" => 1# "segment_id" => (integer) 0
2# "position" => (integer) 0
3# "status" => ""
4# "error_message" => ""
5# "cdc_stage" => 1# "sequence_number" => (integer) 0
2# "position" => (integer) 0
6# "segment_replication_stage" => 1# "tail_sequence_number" => (integer) 0
2# "tail_next_position" => (integer) 0