Added support for checkAndRepairCdcStreams
command
This commit is contained in:
parent
18f8acc60e
commit
b067f194f6
|
@ -476,6 +476,12 @@ public class StorageService extends MetricsMBean implements StorageServiceMBean,
|
|||
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
|
||||
* specified.
|
||||
|
|
|
@ -213,6 +213,7 @@ public interface StorageServiceMBean extends NotificationEmitter {
|
|||
|
||||
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
|
||||
* specified.
|
||||
|
|
Loading…
Reference in New Issue
Block a user