package com.cloudera.flume.agent;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.cloudera.flume.conf.FlumeConfigData;
import com.cloudera.flume.handlers.endtoend.AckListener;
import com.cloudera.flume.reporter.ReportEvent;
public void close()
throws IOException;
public FlumeConfigData
getConfig(LogicalNode n)
throws IOException;
public boolean checkAck(String ackid)
throws IOException;
public boolean heartbeat(LogicalNode n)
throws IOException;
public void acknowledge(String group)
throws IOException;
public Map<String, Integer>
getChokeMap(String physNode)
throws IOException;
public void putReports(Map<String, ReportEvent> reports)
throws IOException;
}