org.apache.hadoop.hbase.tool
Interface Canary.Sink

All Known Subinterfaces:

Canary.ExtendedSink

All Known Implementing Classes:

Canary.RegionServerStdOutSink, Canary.StdOutSink, Canary.ZookeeperStdOutSink

Enclosing class:

Canary

public static interface Canary.Sink

Method Summary

long	getReadFailureCount()
Map<String,String>	getReadFailures()
long	getWriteFailureCount()
Map<String,String>	getWriteFailures()
long	incReadFailureCount()
void	publishReadFailure(HRegionInfo region, Exception e)
void	publishReadFailure(HRegionInfo region, HColumnDescriptor column, Exception e)
void	publishReadTiming(HRegionInfo region, HColumnDescriptor column, long msTime)
void	publishWriteFailure(HRegionInfo region, Exception e)
void	publishWriteFailure(HRegionInfo region, HColumnDescriptor column, Exception e)
void	publishWriteTiming(HRegionInfo region, HColumnDescriptor column, long msTime)
void	updateReadFailedHostList(HRegionInfo region, String serverName)
void	updateWriteFailedHostList(HRegionInfo region, String serverName)

Method Detail

getReadFailureCount

long getReadFailureCount()

incReadFailureCount

long incReadFailureCount()

publishReadFailure

void publishReadFailure(HRegionInfo region,
                        Exception e)

publishReadFailure

void publishReadFailure(HRegionInfo region,
                        HColumnDescriptor column,
                        Exception e)

updateReadFailedHostList

void updateReadFailedHostList(HRegionInfo region,
                              String serverName)

getReadFailures

Map<String,String> getReadFailures()

publishReadTiming

void publishReadTiming(HRegionInfo region,
                       HColumnDescriptor column,
                       long msTime)

getWriteFailureCount

long getWriteFailureCount()

publishWriteFailure

void publishWriteFailure(HRegionInfo region,
                         Exception e)

publishWriteFailure

void publishWriteFailure(HRegionInfo region,
                         HColumnDescriptor column,
                         Exception e)

publishWriteTiming

void publishWriteTiming(HRegionInfo region,
                        HColumnDescriptor column,
                        long msTime)

updateWriteFailedHostList

void updateWriteFailedHostList(HRegionInfo region,
                               String serverName)

getWriteFailures

Map<String,String> getWriteFailures()