package alice.datasegment;

import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.Future;

import org.msgpack.type.Value;

public abstract class DataSegmentManager {
	ConcurrentHashMap<String, DataSegmentKey> dataSegments = new ConcurrentHashMap<String, DataSegmentKey>();
	
	public abstract void put(String key, Value val);
	public Future<Value> take(String key) {
		return take(key, 0);
	}
	public abstract Future<Value> take(String key, int index);
	public Future<Value> peek(String key) {
		return peek(key, 0);
	}
	public abstract Future<Value> peek(String key, int index);
	public abstract void delete(String key);
	
}