Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 package com.fasterxml.clustermate.api;
 
 import java.io.*;
 
Helper class that handles details of getting cluster status information from a store node.
public abstract class ClusterStatusAccessor
    protected final static long MIN_TIMEOUT_MSECS = 10L;
    public abstract ClusterStatusMessage getClusterStatus(IpAndPort iplong timeoutMsecs)
        throws IOException;
    public abstract ClusterStatusMessage getClusterStatus(String endpointlong timeoutMsecs)
        throws IOException;
    
    
Simple interface for thing used to serialize payload of cluster status end point.
    public abstract static class Converter {
        public abstract ClusterStatusMessage fromJSON(InputStream inthrows IOException;
        public abstract ClusterStatusMessage fromJSON(byte[] msgint offsetint lenthrows IOException;
        
        public abstract void asJSON(ClusterStatusMessage msgOutputStream outthrows IOException;
        public abstract byte[] asJSONBytes(ClusterStatusMessage msgOutputStream outthrows IOException;
    }
New to GrepCode? Check out our FAQ X