package com.cloudera.flume.master;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import com.cloudera.flume.conf.FlumeConfigData;
import com.google.common.collect.Multimap;
abstract public void init()
throws IOException, InterruptedException;
abstract public void shutdown()
throws IOException;
abstract public void setConfig(String host, String flowid, String source,
String sink) throws IOException;
abstract public FlumeConfigData
getConfig(String logical);
abstract public Map<String, FlumeConfigData>
getConfigs();
abstract public void addLogicalNode(String physNode, String logicNode);
abstract public void addChokeLimit(String physNode, String chokeID,
int limit);
abstract public Map<String, Integer>
getChokeMap(String physNode);
abstract public void bulkSetConfig(Map<String, FlumeConfigData> configs)
throws IOException;
}