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);
}