Package info.bitrich.xchangestream.kraken

Class KrakenStreamingAdapters

java.lang.Object

info.bitrich.xchangestream.kraken.KrakenStreamingAdapters

public class KrakenStreamingAdapters
extends Object

Kraken streaming adapters

Constructor Summary

Constructors

Constructor	Description
KrakenStreamingAdapters()

Method Summary

Modifier and Type	Method	Description
static LimitOrder	adaptLimitOrder(Instrument instrument, Order.OrderType orderType, com.fasterxml.jackson.databind.JsonNode node)	Adapt a JsonNode containing two decimals into a LimitOrder
static Iterator<LimitOrder>	adaptLimitOrders(Instrument instrument, Order.OrderType orderType, com.fasterxml.jackson.databind.JsonNode node)	Adapt a JsonNode to a Stream of limit orders, the node past in here should be the body of a a/b/as/bs key.
static OrderBook	adaptOrderbookMessage(int depth, TreeSet<LimitOrder> bids, TreeSet<LimitOrder> asks, Instrument instrument, com.fasterxml.jackson.databind.node.ArrayNode arrayNode)
static Ticker	adaptSpreadMessage(Instrument instrument, com.fasterxml.jackson.databind.node.ArrayNode arrayNode)	Adapt an ArrayNode containing a spread message into a Ticker
static Ticker	adaptTickerMessage(Instrument instrument, com.fasterxml.jackson.databind.node.ArrayNode arrayNode)	Adapt an ArrayNode containing a ticker message into a Ticker
static Trade	adaptTrade(Instrument instrument, com.fasterxml.jackson.databind.JsonNode arrayNode)	Adapt an JsonNode into a single Trade
static List<Trade>	adaptTrades(Instrument instrument, com.fasterxml.jackson.databind.JsonNode arrayNode)	Adapt an JsonNode into a list of Trade

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KrakenStreamingAdapters

public KrakenStreamingAdapters()

Method Details

adaptOrderbookMessage

public static OrderBook adaptOrderbookMessage(int depth,
 TreeSet<LimitOrder> bids,
 TreeSet<LimitOrder> asks,
 Instrument instrument,
 com.fasterxml.jackson.databind.node.ArrayNode arrayNode)

adaptLimitOrders

public static Iterator<LimitOrder> adaptLimitOrders(Instrument instrument,
 Order.OrderType orderType,
 com.fasterxml.jackson.databind.JsonNode node)

Adapt a JsonNode to a Stream of limit orders, the node past in here should be the body of a a/b/as/bs key.

adaptLimitOrder

public static LimitOrder adaptLimitOrder(Instrument instrument,
 Order.OrderType orderType,
 com.fasterxml.jackson.databind.JsonNode node)

Adapt a JsonNode containing two decimals into a LimitOrder

adaptTickerMessage

public static Ticker adaptTickerMessage(Instrument instrument,
 com.fasterxml.jackson.databind.node.ArrayNode arrayNode)

Adapt an ArrayNode containing a ticker message into a Ticker

adaptSpreadMessage

public static Ticker adaptSpreadMessage(Instrument instrument,
 com.fasterxml.jackson.databind.node.ArrayNode arrayNode)

Adapt an ArrayNode containing a spread message into a Ticker

adaptTrades

public static List<Trade> adaptTrades(Instrument instrument,
 com.fasterxml.jackson.databind.JsonNode arrayNode)

Adapt an JsonNode into a list of Trade

adaptTrade

public static Trade adaptTrade(Instrument instrument,
 com.fasterxml.jackson.databind.JsonNode arrayNode)

Adapt an JsonNode into a single Trade