cocotb_benches.dau_hero_datapath_tb

Attributes

BUCKET_SHIFT
BUCKET_BITS
WINDOW
_STREAM

Functions

_merge(quotes, trades)
_golden(quotes, trades, *[, tolerance])	The full workflow through the same generic stages the datapath composes:
datapath_matches_golden(dut)
datapath_backpressure(dut)
datapath_with_tolerance(dut)
datapath_large_symbol_decodes_correctly(dut)
_start(dut) → None
_run(dut, records, *[, ready_pattern, tolerance])
_decode(w)
_send_records(dut, records) → None
_collect_output(dut, ready_pattern)
_accept_success_status(dut) → int
_s32(value) → int
_s64(value) → int

Module Contents

cocotb_benches.dau_hero_datapath_tb.BUCKET_SHIFT = 3

cocotb_benches.dau_hero_datapath_tb.BUCKET_BITS = 16

cocotb_benches.dau_hero_datapath_tb.WINDOW = 3

cocotb_benches.dau_hero_datapath_tb._STREAM

cocotb_benches.dau_hero_datapath_tb._merge(quotes, trades)

cocotb_benches.dau_hero_datapath_tb._golden(quotes, trades, *, tolerance=None)

The full workflow through the same generic stages the datapath composes: align → derive(signed_volume) → bucket+generic-aggregator → OHLCV select → roll over bar closes per symbol. Returns (symbol, count, total, total_sq).

async cocotb_benches.dau_hero_datapath_tb.datapath_matches_golden(dut)

async cocotb_benches.dau_hero_datapath_tb.datapath_backpressure(dut)

async cocotb_benches.dau_hero_datapath_tb.datapath_with_tolerance(dut)

async cocotb_benches.dau_hero_datapath_tb.datapath_large_symbol_decodes_correctly(dut)

async cocotb_benches.dau_hero_datapath_tb._start(dut) → None

async cocotb_benches.dau_hero_datapath_tb._run(dut, records, *, ready_pattern=(1,), tolerance=None)

cocotb_benches.dau_hero_datapath_tb._decode(w)

async cocotb_benches.dau_hero_datapath_tb._send_records(dut, records) → None

async cocotb_benches.dau_hero_datapath_tb._collect_output(dut, ready_pattern)

async cocotb_benches.dau_hero_datapath_tb._accept_success_status(dut) → int

cocotb_benches.dau_hero_datapath_tb._s32(value: int) → int

cocotb_benches.dau_hero_datapath_tb._s64(value: int) → int