 pyRT | |
  apps | The pyRT.apps package has many fully functional real-time services: |
   DMA | The pyRT.apps.DMA package has examples for mining Direct Exchange recorded data from the DMA module: |
    AcVol | |
     Manager | #
M a n a g e r # # |
    BookDump | |
     Manager | |
    ComboCop | Chew thru tape to determine the following: |
     Combo | Combo spread w/ paths |
     Manager | Database of Combo, Paths, etc |
     Path | |
     TradeDone | |
    PrintBook | |
    TopOfBook1 | |
    TradeFilter | |
     PriceLevel | { rid1 : sec1, rid2 : sec2, .. |
     Spread | |
    WhaleFinder | |
     Manager | |
     MyBook | |
    Yellow | |
     Combo | |
     Manager | Database of Combo, Paths, etc |
     Path | |
     TradeDone | |
   feeds | The pyRT.apps.feeds package has a few utilities for gatea.feeds.xxx |
    BuildBook | |
    Drop2sql | |
    LoadDB | |
    MemoirDump | |
    MemoirSeqCheck | |
    split_pcap | |
     Filter | |
   GateaEx | The pyRT.apps.GateaEx package builds and cracks the Gatea Exchange wire protocol |
    Rewind | GateaEx atsRewind client |
     Cfg | Simple config class for connection to Rewind server |
     MySoup | Soup Connection to atsRewind server |
   warp | The pyRT.apps.warp package has many fully functional real-time services from the Data Capture (Record / Replay) platform: |
    Algo | Algorithmic-based calculations and alerts: |
     SMACrossover | Simple Moving Average
|
      Fill | A Fill |
      Manager | Dictionary of records, OMS, P&L |
      MovingAvg | Moving Average Crossover : ST / LT |
      Position | A collection of Fills - Buys and Sells - and methods for calculating realized and unrealized gains |
      Record | A registered record from the tape tape that generates a BUY or SELL signal |
      SMAConfig | SMACrossover.py config class; Configured from site.py else defaults below |
      SMARec | Calculated _SMA.BUY or _SMA.SELL record w/ stats |
      SMAUpdate | SMA Update at timer expiration |
    Filter | Real-time data stream filters: |
     BlockTrade1 | Pubish block trades:
- Exceeding $1 million (configurable)
|
      BlockTrade | #
B l o c k T r a d e # # |
      Record | |
     BlockTrade2 | Pubish block trades:
- Exceeding $1 million (configurable)
- Any other configured value (multiple streams)
|
      BlockTrade | #
B l o c k T r a d e # # |
      Record | |
     FeedAgg | |
      Manager | Dictionary of Records |
     OPRATrade4 | |
      Manager | #
M a n a g e r # # |
      OPRATrade | |
      Record | |
     Tick2TimeSeries | Convert Tick-by-Tick from Tape to Time Series in CSV
- Configurable Interval
- Configurable Fields to Dump
|
      Manager | Global d/b |
    Monitor | Data Quality Monitors: |
     Config | |
      LatencyReport | Config.py EOD Latency Report Config |
     CrossMkt | |
      CrossRec | |
      CtlChan | #
C t l C h a n # # |
      Manager | |
      QteStats | |
      Record | |
      RecStat | |
     Latency5 |
|
      Latency | |
      Manager | #
M a n a g e r # # |
      Stats | #
S t a t s # # |
     LatencyReport | |
      Bucket | #
B u c k e t # # |
      Report | |
     PriceCheck | Monitor BID, ASK, LAST for whacked-out prices |
      Alert | [ DataDict._TRADE_DATE, self._now ], [ DataDict._TRDTIM_1, self._now ], |
      Manager | Database of Google Price Offsets |
      Record | A record from the tape |
    monWarp | |
     Formatter | #
F o r m a t t e r # # |
     GLmdSinkStats | |
     GLrpyStats | |
     monWarp | |
    Simple | Simple Examples: |
     DelayOpen | Delay publication of Initial Image |
      Manager | Dictionary of Records to flip and XML connections |
     FieldMap | 'Fan out' fields at publication time as follows: |
      Manager | A little how-do-you-do to access the services of native.warpModule.API |
     HelloWorld | |
     MsgCount | Calculate and publish Message Rate every 60 secs (configurable) for user-defined data sets defined by either RegExp or ticker list |
      DataSet | |
      Manager | Collection of DataSet's |
     NickelSpreader | Simple example to widen quote spread by 0.05 (a nickel):
- Hook BID, ASK real-time fields
- Deduct a _NICKEL from BID
- Add a _NICKEL to ASK
|
     NoWarp | The simplest example : Pipe from Tape to TREP / MDDirect |
      Manager | Simple class to
- Access services of native.warpModule.API
- Ensure we always Publish without calling into Python
|
     PubStale | Publish STALE status on command from user |
      Manager | Dictionary of Records to flip and XML connections |
     QuoteWarp | Warp BID, ASK, LAST from prices in Pre-Market Risk file (scraped from Google)
- Load Pre-Market risk file from Google
- Hook BID, ASK, LAST real-time fields
- Add Offset from Pre-Market Risk File to BID, ASK, LAST
|
      Config | Config base class : Commonly used Members and Methods |
      Manager | Database of Google Price Offsets |
      Record | A record from the tape |
     ReplayCtl |
- Pipe from Tape to TREP / MDDirect
- Replay Control
|
      Manager | Simple class to
- Access services of native.warpModule.API
- Ensure we always Publish without calling into Python
|
     RestrictedList | Hook DSPLY_NAME : Add '[R]' |
      Manager | A little how-do-you-do to access the services of native.warpModule.API |
      RestMgr | HTTP REST-ful Manager |
     Snap | |
     SpreadQuote | Simple example to flip BID and ASK to break downstream apps |
      Manager | Dictionary of Records to flip and XML connections |
     TradeCount | |
      Config | #
C o n f i g # # |
      MyThread | #
M y T h r e a d # # |
      UltraConfig | |
    Stat | Statistics-based analysis: |
     PairCorrelate7 | |
      MyThread | #
M y T h r e a d # # |
      Pair | |
      PairMgr | |
      PairSet | |
      Record | |
    ValueAdded | New calculations: |
     BasketCalc1 | |
      Basket | #
B a s k e t # # |
      Record | |
     ChainMaker1 | |
      CtlChan | #
C t l C h a n # # |
      Manager | |
      MyChain | |
      Record | |
     DailyHiLo | |
      CountRec | |
      DailyRec | |
      Manager | |
      Record | |
      Snap | Site-specific |
     FeedAgg | Feed Aggregator / Conflator that conflates quotes and flushes at a user-defined interval (1-sec) or when the ticker trades |
     SyntheticBBO | National BBO Book |
      BBO | Calculated AAPL.BBO from all market centers |
      Manager | Dictionary of Records |
      PriceLevel | Price Level |
      Record | Regional Market Center like AAPL.OQ (AAPL/P) |
     TWAP | Calc and publish to 3 value added data sets
- Time-Weighted BID and ASK on every Quote Update
- Open, High, Low, Close on every Trade Update, if configured
- Candle Bar as <ticker>.BAR, if configured
|
      Manager | Dictionary of Records |
      Record | Live record from the tape |
    VendorCmp | Vendor Comparison: |
     Basic | NASDAQ Basic Comparator
|
      Bucket | Bucket of related records : DJI, RUT3K, etc |
      FieldCmp | A price field - BID, ASK, etc |
      Manager | Dictionary of records and buckets |
      MsgCount | Message Counts |
      PriceField | A price field - BID, ASK, etc |
      Record | A real-time Record - Basic or SIP - from the tape |
      RecordCmp | A ( Basic, SIP ) Record-pair |
     SeqNum1 | |
  crypto | The pyRT.crypto package has Crypto Exchange Classes : bybit, deribit, etc |
   Algo | FlashJ Algos |
    AlgoBase | AlgoBase : Base class for AlgoServer instances |
     AlgoBase | A little How-do-you-do |
     Config | Common Configurable Variables |
    BurnCPU | |
     Manager | A little How-do-you-do |
    ByHand | ByHand : FlashJ Algo |
     Context | Current Config, controlled by Cockpit |
     Manager | A little How-do-you-do |
    DreamChaser | Logic:
- Chase Bid / Ask Top of Book
- Cxl/Rpl when Market Data Changes
- Publish Stats to MDD
|
     Context | Current Config, controlled by Cockpit |
     Manager | A little How-do-you-do |
     MDDPublish | MDDirect Publisher |
     Record | Real-time Record |
    PingPong | PingPong : FlashJ Algo |
     Context | Current Config, controlled by Cockpit |
     Manager | A little How-do-you-do |
     Record | Real-time Record |
    RestSvr | AlgoServer : Rest API |
     RestMgr | HTTP REST-ful Manager |
     RestPos | Threaded Position / Wallet Query |
    SpreadMaker | Logic:
- We have 2 related coins A and B; Order doesn't matter
- You want a Cockpit-adjustable spread of 10:
- A is 11 bid at 12; B is 21 bid at 22
- Put BUY order on A for 11; SELL on B for 22; Spread is 11
|
     Context | Current Config, controlled by Cockpit |
     Manager | A little How-do-you-do |
     Record | Real-time Record |
     Spread | Spread between 2 Records |
   BybitOE | Bybit Order Entry WebSox Bridge |
    Codec | Codec : FlashJ-to-bybit and vice-versa |
    Manager | OEMsg._ORDTY_LIMIT : 'Market', |
   DeribitOE | Deribit Order Entry WebSox Bridge |
    Manager | A little How-do-you-do |
   Enum | Enumerated types for exchanges: |
    Bybit | |
    Deribit | |
   ExchSvr | CryptoOMS Exchange Server |
    Codec | Codec : FlashJ-to-Exch and vice-versa |
    Exchange | Common Exchange Stuff |
   LiveOrderDb | Common Crypto Live Order D/B |
    LiveOrder | Live Order d/b |
    LiveOrderDb | Live Order d/b |
   OEMsg | OEMsg : JSON-ified FlashJ Order Flow Messages
- NewOrder
- RplOrder
- CxlOrder
- ExecRpt
|
    _OEMsg | Common base class for all OE Messages |
    CxlOrder | Cancel Order to Exchange |
    ExecRpt | Execution Report from Exchange |
    NewOrder | New Order to Exchange |
    OEMsgException | Bad OEMsg |
    RplOrder | Replace Order to Exchange |
   util | The pyRT.crypto.util package has Crypto utilities : tapeDump / CSV data parsing and scrubbing, etc |
    BybitDict | |
    DataScrub | |
    FlashJ | |
    WebSoxSvr | |
     Manager | |
     MessageHandler | From Web |
  customers | The pyRT.customers package has customer-specific code |
   blue | The pyRT.customers.blue package has Blue Ocean-specific code |
    FIXPump | Blue Ocean Market FIX Message Pump |
     FIXToFIX | FIX-driven Pump for FIX Publication Channel |
     FIXToMDD | FIX-driven Pump for MDD Publication Channel |
    IMsgPump | Blue Ocean Market Data Abstract Message Pump |
     IFullBook | Full Book Interface : Event Receiver |
     IManager | Dictionary of records interface |
     IMsgPump | Message Pump Interface |
     ITopOfBook | |
    MemoirPump | Blue Ocean Market Memoir Message Pump |
     MemoirToFIX | Memoir-driven Pump for MDD Publication Channel |
  gatea | The pyRT.gatea library includes several modules to help your quickly build value added services atop the Gatea platforms |
   admin | XML Admin / Control Channel Stuff
- gateaReplay
- etc
|
    gateaReplay | GateaReplay XML Control Channel Web Interface
- HttpMgr : Web Server;
- HttpChan :
|
     HttpMgr | GateaReplay Control Channel Web Server |
     ReplayState |
Member | Description |
_Service | Published Service Name |
_MsgPerSec | Replay Rate : Msg/Sec; 0 = Recorded Rate |
_PubPosition | Current Publication Position |
_Now | Current time |
_TapeStart | Tape Start Time |
_TapeEnd | Tape End Time |
_TapeTkrs | Number of Tape Tickers |
_TapeRewind | Remaining Number of Msgs to Rewind |
_TapeMsgPump | Number of msgs pumped from tape |
|
   DMA | Higher-order classes to use data from native.dmaModule: |
    Manager | Abstract base class for holding Securities, Records, etc |
     Manager | Database of gatea.DMA.Security.Security by Record ID and Ticker |
    Security | Real-time Security record and Listener class to receive notification when life-cycle events - TRADE and QUOTE - are driven into the Security |
     Listener | Interested party who wishes to be notified of changes to a Security |
     Security | A Security from the tape, with useful methods for cracking and retrieving the data from the native DMA module |
   feeds | The pyRT.gatea.feeds has includes several modules for consuming market data |
    BidFX | BidFX Specific Stuff:
- BidFX : Streaming API
|
     BidFX | |
      Name | BidFX Subscription Name configured from dict |
      Pump | Streaming Session |
      Record | Cached Record, including fields |
    CITI | CITI Specific Stuff:
- Velocity : CITI Velocity API
|
     Velocity | CITI Velocity API |
      CitiRest | Common Rest API routines |
      Token | Get oAuth Token |
    common | Shared Stuff:
- DeadCache : Dead Tickers Cache to protect data source from constant re-request
|
     DeadCache | Cache of Dead Tickers |
      DeadCache | Cache of Dead Tickers |
    ErisX | ErisX Specific Stuff:
- RestAPI : Historical Rest API
|
     RestAPI | ErisX Historical Rest API |
      ErisRest | Common Rest API routines |
      OHLC | OHLC query : 52-week stuff; Response as follows: |
      Trades | Trade query : 24-hour stuff; Response as follows: |
    MDD | Gatea MDDirect Platform API |
     libMDDirect | |
      BBDailyStats | Sampled BB Daily Stats from run-time stats file |
      EdgMon | Stripped-down MDD.MONITOR.EDGE.exe to sample object counts |
      LVC | Read-only view on Last Value Cache (LVC) file |
      LVCAdmin | Control channel to LVC : Add, Refresh Tickers |
      MDDirectException | Abstract base Exception class for all MDDirect Exceptions raised here |
      MDDirectValueException | Bad MDDirect value exception |
      rtEdgeData | A container for data from rtEdgeSubscriber and LVC |
      rtEdgeField | A container for a single field of data from an rtEdgeData structure |
      rtEdgePublisher | Publication channel to MDDirect rtEdgeCache3 |
      rtEdgeSchema | Data Dictionry : FID-to-name and Name-to-FID |
      rtEdgeSubscriber | Subscription channel from an MD-Direct data source - rtEdgeCache3 or Tape File |
    memx | Members Exchange Message Cracking Stuff: |
     DataDict | |
     Depth | MEMOIR Full Book Message Cracking |
      BrokenTrade | Broken Trade - Section 5.10 |
      NonDisplayTrade | Non-display Trade - Section 5.9 |
      OrderAdd | Order Added - Section 5.5 |
      OrderDel | Order Deleted - Section 5.6 |
      OrderExec | Order Executed - Section 5.8 |
      OrderMod | Order Reduced - Section 5.7 |
      TradeCorrect | Corrected Trade - Section 5.11 |
     LastSale | MEMOIR Last Sale Message Cracking |
      TradeCancel | Trade Cancel - Section 5.6 |
      TradeCorrect | Trade Correct - Section 5.7 |
      TradeReport | Trade Report - Section 5.5 |
     Memoir | MEMOIR Message Cracking - Common Messages |
      ClearBook | Clear Book - Section 5.10 |
      Directory | Instrument Directory - Section 5.1 |
      RegSHO | Reg SHO Restriction - Section 5.2 |
      SecuritySts | Security Trading Status - Section 5.3 |
      SessionSts | Trading Session Status - Section 5.4 |
      SnapComplete | Snapshot Complete - Section 5.11 |
     SBE | MEMX-SBE Message Cracking |
      Header | Simple Binary Encoding (SBE) Header |
      Security | Timestamp w/ 2-byte Security ID |
      Timestamp | 8-byte Timestamp |
     TopOfBook | MEMOIR Top of Book Message Cracking |
      BestAsk | Best Ask - Section 5.7 |
      BestAskShort | Best Ask (Short Form) - Section 5.9 |
      BestBid | Best Bid - Section 5.6 |
      BestBidOffer | Best Bid Offer - Section 5.5 |
      BestBidShort | Best Bid (Short Form) - Section 5.8 |
     UDP | MEMX MEMX-UDP Header Message Cracking |
      Header | 18-byte UDP Header as follows: |
      SeqPkt | Sequenced Packet |
    nasdaq | NASDAQ protocols message cracking and building |
     BasicEnum | NASDAQ Basic Enumerated Types |
     BasicMsg | NASDAQ Basic Message Cracking Classes |
      AdjClosePrc | |
      Crackers | #
C r a c k e r s # # |
      Header | |
      IPOQtePeriod | |
      MWCB | |
      MWCBSts | |
      OperationalHalt | |
      Quote | |
      QuoteNxt | |
      RegSHO | |
      StockDir | |
      StockMsg | |
      SysEvt | |
      TradeCorr | |
      TradeCorrNxt | |
      TradeCxl | |
      TradeCxlNxt | |
      TradeRpt | |
      TradeRptNxt | |
      TradingAction | |
     CanadaEnum | NASDAQ Basic Canada Enumerated Types |
     CanadaMsg | NASDAQ Basic Canada Message Cracking Classes |
      Crackers | #
C r a c k e r s # # |
      Header | |
      Quote | |
      StockDir | |
      StockMsg | |
      StockStatus | |
      SysEvt | |
      TradeCorr | |
      TradeCxl | |
      TradeRpt | |
     NFIEnum | NASDAQ Fixed Income (NFI) Enumerated Types |
     NFIMsg | NASDAQ Fixed Income (NFI) Message Cracking classes |
      AddOrder | |
      BookDir | |
      BookMsg | |
      BookState | |
      ComboDir | |
      Crackers | #
C r a c k e r s # # |
      CxlOrder | |
      ExecDone | |
      ExecOrder | |
      Header | |
      OrderMsg | |
      SysEvt | |
      Trade | |
     SoupChannel | One-shot Soup protocol channel |
      SoupChannel | SoupBinTCP Channel client |
    nyse | NYSE protocols message cracking and building |
     CTFDataDict | CTF Protocol Data Dictionary including handy field and message dicts: |
     CTFMsg | CTF Message Cracker |
      CTFMsg | CTF Message Cracker |
     XDPEnum | NYSE XDP Enumerated Types |
     XDPMsg | NYSE XDP Message Cracker |
      AdjClosePrc | |
      Crackers | |
      Header | |
      IPOQtePeriod | |
      MWCB | |
      MWCBSts | |
      OperationalHalt | |
      Quote | |
      SecStatus | |
      StockDir | |
      SysEvt | |
      TimedMsg | |
      TradeCorr | |
      TradeCxl | |
      TradeCxlNxt | |
      TradeRpt | |
      TradeRptNxt | |
      TradingAction | |
    Symbology | Cross-Asset Symbology Stuff
- ForEx : FX Name Translation
|
     ForEx | FX Symbology Translation |
      ForexDef | FX Contract Definition |
   FIX | FIX protocol message cracking and building |
    EventGroups | Cracked EventGroups repeat group of FIX fields : Count = NoEvenbts |
     EventGroup | A single cracked EventGroup repeating group |
     EventGroups | Collection of EventGroup's |
    FIXDictionary | FIX Protocol Data Dictionary including handy field and message dicts: |
    MDEntries | Cracked MDEntries repeat group of FIX fields : Count = NoMDEntries |
     MDEntries | Collection of MDEntry's |
     MDEntry | A single cracked MDEntry FIX field repeat group |
    Message | FIX Message Cracker |
     FIXMsg | FIX Message Cracker |
    RepeatGroups | Cracked repeat group of FIX fields |
     RepeatGroup | A single cracked repeat group |
     RepeatGroups | Collection of RepeatGroup's |
    SecListGroups | Cracked SecListGroups repeat group of FIX fields : Count = NoRelatedSym |
     SecListGroup | A single cracked SecListGroup repeating group |
     SecListGroups | Collection of SecListGroup's |
   GateaEx | GateaEx Wire Protocol |
    Enum | GateaEx string-ified Enumerated Types |
    Messages | Any message on the GateaEx backbone |
     AddOrder | New Order added to the book |
     CxlOrder | Delete Existing Order from Book |
     Fill | Order Filled - Partially or In Full |
     Message | GateaEx Wire Message |
     Order | Base class of all Orders |
     PktHdr | GateaEx Wire Packet Header |
     Reject | Order Rejected by Matching Engine |
     RplOrder | Delete Existing Order from Book |
     Stream | GateaEx Multicast Stream : Engine or Proxy |
    OuchMsgs | NASDAQ Ouch Message Pack / Unpack |
     AddOrder | Add Order Ouch Message |
     InMsg | Base class of all inbound (to Exchange) messages |
     Msg | |
    Platform | GateaEx Platform Stuff: |
     Config | JSON Platform Config File |
     ExchSumm | Exchange Summary File from ats2db; Format: |
     MsgDef | MsgType definition |
     SecDef | Security definition |
     UsrDef | User definition |
   MktData | Commonly used Market Data Constructs:
- Calculations : Open/Hi/Lo, TWAP, etc
- Data Dictionary
- Refinitiv Enum d/b
- Chains
- Field Lists
- Gatea MD-Direct Real-Time Platform
|
    Calc | Common market data calculations: |
     CandleBar | Trade-driven calc( Open, High, Low, Close, Volume ) per interval |
     OpnHiLoCls | Trade-driven calcs : ( Open, High, Low, Close ) |
     TWAP | Time-Weighted Average Price Calculator : BID or ASK |
    Chain | Sorted and Unsorted Chain of related records |
     Chain | Chain of ticker names |
     CountLeader | Sorted collection of an increasing stat |
    DataDictionary | Dictionary of all defined fields |
     DataDictionary | Dictionary of all defined field IDs |
    FieldList | |
     Chain | FieldList for chain built from de-facto, hard-coded template |
     ChainList | List of Chain Links for a given ticker list |
     FieldList | Handy container for processing list of ( fid, value ) Fields |
     PriceWithTime | 2 Fields : Price and Time |
     VectorField | Vector field w/ minimum size |
    Fundamental | Fundamental data from a Security Master |
     SecDbColumn | A Python dictionary keyed by ticker name containing a single column of data from a Security Master dump |
    Index | Index Calculator : Weighted and Non-Weighted |
     Constituent | Index constituent : Symbol, Weighting, Value, etc |
     Index | Calculated Index such as DJI or SP500 |
    MDDirect | librtEdge C Extension in Python
|
     LVC | Read-only view on Last Value Cache (LVC) file |
     LVCAdmin | Control channel to LVC : Add, Refresh Tickers |
     rtEdgeData | A container for data from rtEdgeSubscriber and LVC |
     rtEdgeField | A container for a single field of data from an rtEdgeData structure |
     rtEdgeSchema | Data Dictionry : FID-to-name and Name-to-FID |
     rtEdgeSubscriber | Subscription channel from an MD-Direct data source - rtEdgeCache3 or Tape File |
    ReuterEnumDb | Refinitiv (aka Reuters) Enum Type d/b |
     ReuterEnumDb | Dictionary of all defined field IDs |
   net | General Purpose Network-related classes: |
    DataDog | DataDog StatsD Protocol |
     StatsD | Directed UDP channel to DataDog statsD to contribute stats |
    GLconn | Robust, auto-reconnecting asyncore-driven TCP socket connection classes |
     GLconn | A robust socket implementation that works with the asyncore-driven GLthread framework for a client connecting to a server process |
     GLlisten | Abstract base class used by the server process for handling connection requests from clients |
    GLeventQueue | Inter-thread event queue |
     GLeventQueue | |
     GLqueueReceivable | An abstract base class for receiving user-defined events from the GLeventQueue |
    GLthread | A native asyncore-driven thread capable of dispatching:
- read/write and timer events into GLconn
- Events from GLeventQueue
|
     GLthread | A native asyncore-driven thread capable of dispatching both
- read / write events from registered GLconn-based channels
- timer events,
- user-defined events from a GLeventQueue
|
    pcap | Pcap File / Record Header Cracker |
     FileHdr | Print( 'magic=%02x; compr=d; Time=d' % ( magic, compr, tm ) ) |
     PktHdr | Benop-byte network packet header : ethernet / ip / udp |
     RecHdr | 16-byte pcap Record / packet Header from following struct: |
    Pump | A gatea.sys.Thread.Thread-based asyncore pump |
     Pump | A gatea.sys.Thread.Thread-based asyncore pump |
    Socket | A gatea.net.Pump.Pump-driven TCP connection |
     Connection | A robust gatea.net.Pump.Pump-driven socket implementation that works with the gatea.net framework for either a connect()-based client or a accept()-based server process |
     Dispatchable | Abstract gatea.net.Pump.Pump-driven socket connection class |
     Listen | Abstract base class used by the server process for handling connection requests from clients |
     XmlConn | XML Connection |
   OMS | Order Management Stuff: |
    OrderBook | Live Order Book with Orders, Price Levels, etc |
     LiveOrderDB | DataBase of OrderBooks and live orders |
     Order | A single Live Order |
     OrderBook | Generic Order Book |
     PrcLvl | Gender-Neutral Price Level Container |
     PriceLevel | Price Level - Bid or Ask - with 1 or more Orders in an OrderBook |
    TradeDB | Database of Trades, indexed by Security |
     OHLC | A single OHLC |
     Security | Security w/ Trades |
     Trade | A single Trade |
     TradeDB | Trade d/b, indexed by Security |
   quant | Quant Stuff, mostly from Numerical Recipes in C: |
    CubicSpline | Cubic Spline : From Numberical Recipe in C, (c) 1986-1992 |
     CubicSpline | Cubic Spline from sampled values : 1-based (not 0-based) array results |
     CubicSurface | M x N Cubic Surface from sampled values |
   stat | Time-series Stats: |
    Correlation | Correlaton of EQUAL-LENGTH Time Series |
     Correlation | Correlation between 2 Time Series |
    TimeSeries | A time series of data points w/ variance, StdDev, mean, RSI, etc |
     StdDev | Time series where StdDev calculated once |
     TimeSeries | A series of data points w/ stats calcs |
   sys | System-level stuff: |
    asyncore | Vanilla asyncore with 2 lines of code so that dispatchers don't spin uncontrollably after handle_close |
     dispatcher | |
     dispatcher_with_send | |
     ExitNow | |
     file_dispatcher | |
     file_wrapper | |
    Digest | Event conflator to throttle events every configurable interval |
     Digester | Simple thread-safe event digester, that conflates "bursty" events that you wish to be alerted to, such as cross-market conditions or latent market data |
    GLcommon | Commonly used routines |
     Binding | A collection of event handler functions and methods to Bind() and Unbind() the handlers to a particular event |
     DSTCalendar | DST Calendar as list of [ UnixTime, gmt_offset ] tuples |
     GLelapsed | Calculates the time elapsed in millis |
    GLmmap | Memory-mapped file |
     GLmmapView | A Pythonic view of a native mmap()'ed file |
     Tail | A GLmmapView that tail a file : binary or ASCII |
    GLodbc | Resilient pyodbc connection to ODBC d/b |
     GLodbc | A connection to an ODBC data source, usually a specific database |
    OSaddin | Missing stuff from OS : SetThreadName(), etc |
    SMTP | Send E-mail / text via SMTP |
     SendText | Send text via SSL-encrypted SMTP to friendly outgoing SMTP server |
    Thread | Named thread that start and stops cleanly |
     Mutex | "Thread aware" Native Python mutex |
     Thread | Native Python thread that start and stops cleanly |
   web | Web-related classes |
    HttpServer | Embedded HTTP Server instance |
     HttpHandler | HTTP Web Server that handles GET and POST commands from clients |
     HttpManager | HTTP Server Manager : Register Handlers, etc |
    WebSockets | WebSockets consumer class |
     WebSoxConn | WebSockets connection |
   xml | XML parsing and building |
    DTD | XML DTD : Commonly used strings |
     Attribute | Common XML Attributes |
     Command | XML Channel Commands |
    GLxml | |
     Element | A parsed XML element |
     Parser | A handler for using the xml.sax XML parsing engine, and a Pythonic object representing a parsed, nested XML document |
    GLxml_sax | OSaddin- or xml.sax-driven parsing logic and classes:
- Parser
- Element
|
  native | The pyRT.native package contains Python classes to give you a Pythonic view of the native Embedded Reactor API through a single class |
   AlgoServerReactor | Embedded AlgoServer Reactor API |
    API | Context-specific API class to wrap native AlgoServer module functions |
   Constants | Hard-coded constant values and useful utilities used across all native embedded modules |
   cryptoOMSReactor | Embedded cryptoOMS Reactor API |
    API | Context-specific API class to wrap native cryptoOMS module functions |
   dmaModule | Embedded DMA Module API |
    API | Context-specific API class to wrap native DMA module functions |
    Book | Container for native (raw) Book |
    BookStats | Container for cracked native (raw) BookStats |
    LVC | Access to native DMA.lvc_getBook() API, with methods to return either a book in either raw (native) form, or in a handy Book class |
    PriceLevel | Container for native (raw) Price Level Tuple |
    PricePos | Container for a single Price Position: |
    Trade | Container for cracked native (raw) Trade |
   omniBridgeModule | Embedded omniBridge Reactor API |
    API | Context-specific API class to wrap native omniBridge module functions |
    LVC | Access to native omniBridge.lvc_Xxx() API, with methods to use both the native API as well as the FieldList class |
    Message | Handy container for populating and accessing an omniBridge message into or out of the omniBridge module |
    Order | Handy container for populating an omniBridge Order, which is of the following hard-coded fieldds: |
    Watchable | Watchable Stream : OrderBook, TopOfBook, etc |
   warpModule | Embedded warp Module API |
    API | Context-specific API class to wrap native warp module functions |
    CurrentUpdate | Access to native warp.getXxx() API to query the current update, with methods to use both the native API as well as the gatea.MktData.FieldList.FieldList class |
    LVC | Access to native warp.lvc_Xxx() API, with methods to use both the native API as well as the gatea.MktData.FieldList.FieldList class |
    RecordStat | Container for cracking raw record stat list from native warp |