package com.cloudera.flume.master;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.cloudera.flume.conf.FlumeSpecException;
import com.cloudera.flume.conf.FlumeConfigData;
import com.cloudera.flume.reporter.Reportable;
import com.google.common.collect.Multimap;
public FlumeConfigData
getConfig(String host);
public void start()
throws IOException;
public void stop()
throws IOException;
public void setConfig(String host, String flowid, String source, String sink)
throws IOException, FlumeSpecException;
throws IOException;
public Map<String, Integer>
getChokeMap(String physNode);
public void refresh(String logicalNode)
throws IOException;
public void addChokeLimit(String physNode, String chokeID,
int limit);
}