cocotb_benches.dau_grouped_aggregation_tb

Attributes

_OHLCV_ROWS

Functions

grouped_ohlcv_bars_match_golden(dut)
grouped_backpressure_on_both_sides(dut)
grouped_single_group_and_single_row(dut)
grouped_reappearing_key_emits_partials(dut)
grouped_key_change_on_final_row(dut)
grouped_int64_sum_accumulates_extremes(dut)
grouped_repeated_batches_reset_state(dut)
grouped_reserved_mode_reports_config_error(dut)
grouped_truncated_stream_reports_stream_error(dut)
_start(dut) → None
_apply_config(dut, *, row_count) → None
_run_grouped(dut, rows, *[, ready_pattern])
_decode_group(words) → dau_core.operators.GroupAggregate
_send_rows(dut, rows) → None
_collect_output(dut, ready_pattern) → list[int]
_accept_success_status(dut) → int
_expect_error(dut, code) → None
_signed32(value) → int
_signed64(value) → int

Module Contents

cocotb_benches.dau_grouped_aggregation_tb._OHLCV_ROWS

async cocotb_benches.dau_grouped_aggregation_tb.grouped_ohlcv_bars_match_golden(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_backpressure_on_both_sides(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_single_group_and_single_row(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_reappearing_key_emits_partials(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_key_change_on_final_row(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_int64_sum_accumulates_extremes(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_repeated_batches_reset_state(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_reserved_mode_reports_config_error(dut)

async cocotb_benches.dau_grouped_aggregation_tb.grouped_truncated_stream_reports_stream_error(dut)

async cocotb_benches.dau_grouped_aggregation_tb._start(dut) → None

cocotb_benches.dau_grouped_aggregation_tb._apply_config(dut, *, row_count: int) → None

async cocotb_benches.dau_grouped_aggregation_tb._run_grouped(dut, rows, *, ready_pattern=(1,))

cocotb_benches.dau_grouped_aggregation_tb._decode_group(words: list[int]) → dau_core.operators.GroupAggregate

async cocotb_benches.dau_grouped_aggregation_tb._send_rows(dut, rows) → None

async cocotb_benches.dau_grouped_aggregation_tb._collect_output(dut, ready_pattern) → list[int]

async cocotb_benches.dau_grouped_aggregation_tb._accept_success_status(dut) → int

async cocotb_benches.dau_grouped_aggregation_tb._expect_error(dut, code: dau_core.operators.GroupedAggregationErrorCode) → None

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

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