Added support for `checkAndRepairCdcStreams` command
This commit is contained in:
parent
78c3b7627f
commit
b2e4796901
|
@ -476,6 +476,12 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
|
||||||
return client.getListInetAddressValue("");
|
return client.getListInetAddressValue("");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public void checkAndRepairCdcStreams() throws IOException {
|
||||||
|
log(" checkAndRepairCdcStreams() throws IOException");
|
||||||
|
client.post("/storage_service/cdc_streams_check_and_repair");
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Takes the snapshot for the given keyspaces. A snapshot name must be
|
* Takes the snapshot for the given keyspaces. A snapshot name must be
|
||||||
* specified.
|
* specified.
|
||||||
|
|
|
@ -213,6 +213,7 @@ public interface StorageServiceMBean extends NotificationEmitter {
|
||||||
|
|
||||||
public List<InetAddress> getNaturalEndpoints(String keyspaceName, ByteBuffer key);
|
public List<InetAddress> getNaturalEndpoints(String keyspaceName, ByteBuffer key);
|
||||||
|
|
||||||
|
public void checkAndRepairCdcStreams() throws IOException;
|
||||||
/**
|
/**
|
||||||
* Takes the snapshot for the given keyspaces. A snapshot name must be
|
* Takes the snapshot for the given keyspaces. A snapshot name must be
|
||||||
* specified.
|
* specified.
|
||||||
|
|
Loading…
Reference in New Issue