cocotb_benches.dau_asof_backward_tb

Attributes

_QUOTES
_TRADES

Functions

_merge(quotes, trades)	Host pre-merge: one (symbol, time)-sorted stream, quote-before-trade at
_expected(quotes, trades, *[, tolerance])	The tile's golden is the generic keyed as-of join over the merged stream
asof_tile_matches_golden(dut)
asof_tile_backpressure_both_sides(dut)
asof_tile_tolerance_drops_stale_quotes(dut)
asof_tile_all_misses_emit_nothing(dut)
asof_tile_int64_time_axis(dut)
asof_tile_reappearing_symbol_resets_quote(dut)
asof_tile_marks_output_last_on_final_row_after_trailing_miss(dut)
asof_tile_extreme_timestamp_age_misses(dut)
asof_tile_truncated_record_reports_stream_error(dut)
_start(dut) → None
_run(dut, records, *[, ready_pattern, tolerance])
_decode_row(words)
_send_records(dut, records) → None
_collect_output(dut, ready_pattern)
_collect_with_last(dut)
_accept_success_status(dut) → int
_expect_error(dut) → None
_signed32(value) → int
_signed64(value) → int

Module Contents

cocotb_benches.dau_asof_backward_tb._QUOTES = [(570, 100, 10, 12), (570, 105, 11, 13), (570, 120, 9, 11), (571, 100, 50, 52), (571, 110, 51, 54)]

cocotb_benches.dau_asof_backward_tb._TRADES = [(570, 99, 11, 5), (570, 100, 12, 3), (570, 107, 13, 2), (570, 130, 8, 1), (571, 105, 53, 7),...

cocotb_benches.dau_asof_backward_tb._merge(quotes, trades)

Host pre-merge: one (symbol, time)-sorted stream, quote-before-trade at equal (symbol, time). Records are (is_trade, symbol, time, a, b).

cocotb_benches.dau_asof_backward_tb._expected(quotes, trades, *, tolerance=None)

The tile’s golden is the generic keyed as-of join over the merged stream (quote = build {bid, ask}, trade = probe {price, size}) — the joined row (key, time, probe_a, probe_b, build_a, build_b) is the market row the bench decodes.

async cocotb_benches.dau_asof_backward_tb.asof_tile_matches_golden(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_backpressure_both_sides(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_tolerance_drops_stale_quotes(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_all_misses_emit_nothing(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_int64_time_axis(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_reappearing_symbol_resets_quote(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_marks_output_last_on_final_row_after_trailing_miss(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_extreme_timestamp_age_misses(dut)

async cocotb_benches.dau_asof_backward_tb.asof_tile_truncated_record_reports_stream_error(dut)

async cocotb_benches.dau_asof_backward_tb._start(dut) → None

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

cocotb_benches.dau_asof_backward_tb._decode_row(words)

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

async cocotb_benches.dau_asof_backward_tb._collect_output(dut, ready_pattern)

async cocotb_benches.dau_asof_backward_tb._collect_with_last(dut)

async cocotb_benches.dau_asof_backward_tb._accept_success_status(dut) → int

async cocotb_benches.dau_asof_backward_tb._expect_error(dut) → None

cocotb_benches.dau_asof_backward_tb._signed32(value: int) → int

cocotb_benches.dau_asof_backward_tb._signed64(value: int) → int