public static class CanaryTool.StdOutSink extends Object implements CanaryTool.Sink
Modifier and Type | Field and Description |
---|---|
private AtomicLong |
readFailureCount |
private Map<String,String> |
readFailures |
private AtomicLong |
readSuccessCount |
private AtomicLong |
writeFailureCount |
private Map<String,String> |
writeFailures |
private AtomicLong |
writeSuccessCount |
Constructor and Description |
---|
StdOutSink() |
Modifier and Type | Method and Description |
---|---|
long |
getReadFailureCount() |
Map<String,String> |
getReadFailures() |
long |
getReadSuccessCount() |
long |
getWriteFailureCount() |
Map<String,String> |
getWriteFailures() |
long |
getWriteSuccessCount() |
long |
incReadFailureCount() |
long |
incReadSuccessCount() |
long |
incWriteFailureCount() |
long |
incWriteSuccessCount() |
void |
updateReadFailures(String regionName,
String serverName) |
void |
updateWriteFailures(String regionName,
String serverName) |
private AtomicLong readFailureCount
private AtomicLong writeFailureCount
private AtomicLong readSuccessCount
private AtomicLong writeSuccessCount
private Map<String,String> readFailures
private Map<String,String> writeFailures
public StdOutSink()
public long getReadFailureCount()
getReadFailureCount
in interface CanaryTool.Sink
public long incReadFailureCount()
incReadFailureCount
in interface CanaryTool.Sink
public Map<String,String> getReadFailures()
getReadFailures
in interface CanaryTool.Sink
public void updateReadFailures(String regionName, String serverName)
updateReadFailures
in interface CanaryTool.Sink
public long getWriteFailureCount()
getWriteFailureCount
in interface CanaryTool.Sink
public long incWriteFailureCount()
incWriteFailureCount
in interface CanaryTool.Sink
public Map<String,String> getWriteFailures()
getWriteFailures
in interface CanaryTool.Sink
public void updateWriteFailures(String regionName, String serverName)
updateWriteFailures
in interface CanaryTool.Sink
public long getReadSuccessCount()
getReadSuccessCount
in interface CanaryTool.Sink
public long incReadSuccessCount()
incReadSuccessCount
in interface CanaryTool.Sink
public long getWriteSuccessCount()
getWriteSuccessCount
in interface CanaryTool.Sink
public long incWriteSuccessCount()
incWriteSuccessCount
in interface CanaryTool.Sink
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.