Index

A

advance() (oxberrypis.parsing.parsers.XDPChannelUnpacker method)

C

ChannelPublisher (class in oxberrypis.net.controller.channel) ChannelPublishersThread (class in oxberrypis.net.controller.publisher) ChannelPublisherThread (class in oxberrypis.net.controller.channel) ChannelStockMsgsGenerator (class in oxberrypis.net.controller.channel) close() (oxberrypis.net.components.SynchronizedPublisher method) (oxberrypis.net.components.SynchronizedSubscriber method)

Controller (class in oxberrypis.net.controller) create_setup_rpi_msg() (oxberrypis.net.controller.init.Initializer method) create_setup_rpi_msg_serialized() (oxberrypis.net.controller.init.Initializer method) create_setup_visualisation_msg() (oxberrypis.net.controller.init.Initializer method)

D

decrease_key() (oxberrypis.orderbook.fibonacci_heap.FibonacciHeap method)

E

extract() (oxberrypis.orderbook.fibonacci_heap.FibonacciHeap method)

F

FibonacciHeap (class in oxberrypis.orderbook.fibonacci_heap) FibonacciHeapNode (class in oxberrypis.orderbook.fibonacci_heap) FieldsGenerator (class in oxberrypis.parsing.fields)

FileXDPChannelUnpacker (class in oxberrypis.parsing.parsers) front() (oxberrypis.orderbook.fibonacci_heap.FibonacciHeap method)

G

generate_stock_msgs() (oxberrypis.net.controller.channel.ChannelStockMsgsGenerator method) get_channel_path() (oxberrypis.parsing.parsers.FileXDPChannelUnpacker class method) get_channel_unpacker() (oxberrypis.parsing.parsers.FileXDPChannelUnpacker class method) get_datetime() (oxberrypis.parsing.headers.PacketHeader method)

get_msg_cls() (oxberrypis.parsing.headers.MsgHeader method) get_msg_size() (oxberrypis.parsing.headers.MsgHeader method) get_pkt_format_string() (in module oxberrypis.parsing.utils) get_pkt_namedtuple() (in module oxberrypis.parsing.utils)

H

handle_data() (oxberrypis.net.rpi.subscriber.StockMessagesSubscriber method) handle_stock_data() (oxberrypis.net.rpi.handlers.ToVisualisation method) (oxberrypis.net.rpi.handlers.UpdateMatchingEngines method)

handshake() (oxberrypis.net.components.SynchronizedPublisher method) header_size (oxberrypis.parsing.headers.MsgHeader attribute)

I

Initializer (class in oxberrypis.net.controller.init) InitializerThread (class in oxberrypis.net.controller.init) insert() (oxberrypis.orderbook.fibonacci_heap.FibonacciHeap method)

is_empty() (oxberrypis.orderbook.fibonacci_heap.FibonacciHeap method) is_known() (oxberrypis.parsing.headers.MsgHeader method)

L

LinkedList (class in oxberrypis.orderbook.linked_list)

LinkedListNode (class in oxberrypis.orderbook.linked_list)

M

make_price_message() (oxberrypis.net.rpi.handlers.ToVisualisation method) MatchingEngine (class in oxberrypis.orderbook.matching_engine)

MsgHeader (class in oxberrypis.parsing.headers)

O

OBAddOrderMsg (class in oxberrypis.parsing.messages) OBDeleteMsg (class in oxberrypis.parsing.messages) OBExecutionMsg (class in oxberrypis.parsing.messages) OBModifyMsg (class in oxberrypis.parsing.messages) open_stream() (oxberrypis.parsing.parsers.FileXDPChannelUnpacker method) OrderBook (class in oxberrypis.orderbook.book) oxberrypis.net (module) oxberrypis.net.components (module) oxberrypis.net.controller (module) oxberrypis.net.controller.channel (module) oxberrypis.net.controller.init (module) oxberrypis.net.controller.msgs_factories (module) oxberrypis.net.controller.publisher (module) oxberrypis.net.rpi (module)

oxberrypis.net.rpi.handlers (module) oxberrypis.net.rpi.subscriber (module) oxberrypis.orderbook (module) oxberrypis.orderbook.book (module) oxberrypis.orderbook.fibonacci_heap (module) oxberrypis.orderbook.linked_list (module) oxberrypis.orderbook.matching_engine (module) oxberrypis.orderbook.order (module) oxberrypis.parsing (module) oxberrypis.parsing.fields (module) oxberrypis.parsing.headers (module) oxberrypis.parsing.messages (module) oxberrypis.parsing.parsers (module) oxberrypis.parsing.utils (module)

P

PacketHeader (class in oxberrypis.parsing.headers) parse() (oxberrypis.parsing.parsers.XDPChannelUnpacker method) parse_cls_from_stream() (oxberrypis.parsing.parsers.XDPChannelUnpacker method) parse_msg() (oxberrypis.parsing.parsers.XDPChannelUnpacker method) parse_packet() (oxberrypis.parsing.parsers.XDPChannelUnpacker method) ping() (oxberrypis.net.components.SynchronizedPublisher method)

PrintingHandler (class in oxberrypis.net.rpi.handlers) ProxyThread (class in oxberrypis.net.controller.publisher) publish() (oxberrypis.net.components.SynchronizedPublisher method) publish_enveloped() (oxberrypis.net.components.SynchronizedPublisher method) PubSubProxy (class in oxberrypis.net.components)

R

recv() (oxberrypis.net.components.SynchronizedSubscriber method) recv_multipart() (oxberrypis.net.components.SynchronizedSubscriber method)

register_known_msg() (oxberrypis.parsing.headers.MsgHeader class method) run() (oxberrypis.net.controller.channel.ChannelPublisher method) (oxberrypis.net.controller.Controller method) (oxberrypis.net.controller.channel.ChannelPublisherThread method) (oxberrypis.net.controller.init.Initializer method) (oxberrypis.net.controller.init.InitializerThread method) (oxberrypis.net.controller.publisher.ChannelPublishersThread method) (oxberrypis.net.controller.publisher.ProxyThread method) (oxberrypis.net.rpi.subscriber.StockMessagesSubscriber method)

S

StockMessageAddFactory (class in oxberrypis.net.controller.msgs_factories) StockMessageDeleteFactory (class in oxberrypis.net.controller.msgs_factories) StockMessageExecutionFactory (class in oxberrypis.net.controller.msgs_factories) StockMessageFactory (class in oxberrypis.net.controller.msgs_factories) StockMessageModifyFactory (class in oxberrypis.net.controller.msgs_factories) StockMessagesFactory (class in oxberrypis.net.controller.msgs_factories) StockMessagesSubscriber (class in oxberrypis.net.rpi.subscriber)

StockMessageTradeFactory (class in oxberrypis.net.controller.msgs_factories) subscribe() (oxberrypis.net.components.SynchronizedSubscriber method) sync() (oxberrypis.net.components.SynchronizedPublisher method) (oxberrypis.net.components.SynchronizedSubscriber method) sync_reply_handler() (oxberrypis.net.rpi.subscriber.StockMessagesSubscriber method) SynchronizedPublisher (class in oxberrypis.net.components) SynchronizedSubscriber (class in oxberrypis.net.components)

T

ToVisualisation (class in oxberrypis.net.rpi.handlers)

TradeMsg (class in oxberrypis.parsing.messages)

U

unsubscribe() (oxberrypis.net.components.SynchronizedSubscriber method)

UpdateMatchingEngines (class in oxberrypis.net.rpi.handlers)

X

XDPChannelUnpacker (class in oxberrypis.parsing.parsers)