Package info.bitrich.xchangestream.serum.datamapper

Class EventQueueDataMapper

java.lang.Object

info.bitrich.xchangestream.serum.datamapper.DataMapper

info.bitrich.xchangestream.serum.datamapper.EventQueueDataMapper

public class EventQueueDataMapper
extends DataMapper

Field Summary

Fields inherited from class info.bitrich.xchangestream.serum.datamapper.DataMapper

market, priceDecimalPlaces, sizeDecimalPlaces, symbol

Constructor Summary

Constructors

Constructor	Description
EventQueueDataMapper(String symbol, Market market, int priceDecimalPlaces, int sizeDecimalPlaces)

Method Summary

Modifier and Type	Method	Description
BigDecimal	getFillPrice(EventQueueLayout.EventNode event, int decimalPlaces)
BigDecimal	getFillSize(EventQueueLayout.EventNode event, int decimalPlaces)
Stream<com.fasterxml.jackson.databind.JsonNode>	map(byte[] bytes, long slot, long timestamp)	We're interested only in newly added events since last update each account update publishes 'snapshot' not 'delta' so we need to figure the delta
com.fasterxml.jackson.databind.JsonNode	normalizeData(EventQueueLayout.EventNode event, long timestamp, long slot, List<String> fillIds)

Methods inherited from class java.lang.Object

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

Constructor Details

EventQueueDataMapper

public EventQueueDataMapper(String symbol,
 Market market,
 int priceDecimalPlaces,
 int sizeDecimalPlaces)

Method Details

map

public Stream<com.fasterxml.jackson.databind.JsonNode> map(byte[] bytes,
 long slot,
 long timestamp)
                                                    throws IOException

We're interested only in newly added events since last update each account update publishes 'snapshot' not 'delta' so we need to figure the delta

Throws:

IOException

getFillPrice

public BigDecimal getFillPrice(EventQueueLayout.EventNode event,
 int decimalPlaces)

getFillSize

public BigDecimal getFillSize(EventQueueLayout.EventNode event,
 int decimalPlaces)

normalizeData

public com.fasterxml.jackson.databind.JsonNode normalizeData(EventQueueLayout.EventNode event,
 long timestamp,
 long slot,
 List<String> fillIds)