package com.xcong.excoin.processor;
|
|
|
import com.huobi.client.model.Candlestick;
|
import com.xcong.excoin.trade.ExchangeTrade;
|
import com.xcong.excoin.utils.RedisUtils;
|
|
import java.util.List;
|
import java.util.Map;
|
|
public interface CoinProcessor {
|
|
void setIsHalt(boolean status);
|
|
void setIsStopKLine(boolean stop);
|
|
boolean isStopKline();
|
/**
|
* 处理新生成的交易信息
|
* @param trades
|
* @return
|
*/
|
void process(List<ExchangeTrade> trades);
|
|
void processTrade(Candlestick kLine, ExchangeTrade exchangeTrade);
|
/**
|
* 添加存储器
|
* @param storage
|
*/
|
void addHandler(MarketHandler storage);
|
|
CoinThumb getThumb();
|
|
void setMarketService(MarketService service);
|
|
void generateKLine(int range, int field, long time);
|
|
Candlestick getKLine();
|
|
void initializeThumb();
|
|
void autoGenerate();
|
|
void resetThumb();
|
|
// void setExchangeRate(CoinExchangeRate coinExchangeRate);
|
|
void update24HVolume(long time);
|
|
//void initializeUsdRate();
|
Map<String,Candlestick> getCurrentKlineMap();
|
|
void setRedisUtils(RedisUtils redisUtils);
|
}
|
