cocotb_benches.dau_grouped_aggregation_tb
=========================================

.. py:module:: cocotb_benches.dau_grouped_aggregation_tb


Attributes
----------

.. autoapisummary::

   cocotb_benches.dau_grouped_aggregation_tb._OHLCV_ROWS


Functions
---------

.. autoapisummary::

   cocotb_benches.dau_grouped_aggregation_tb.grouped_ohlcv_bars_match_golden
   cocotb_benches.dau_grouped_aggregation_tb.grouped_backpressure_on_both_sides
   cocotb_benches.dau_grouped_aggregation_tb.grouped_single_group_and_single_row
   cocotb_benches.dau_grouped_aggregation_tb.grouped_reappearing_key_emits_partials
   cocotb_benches.dau_grouped_aggregation_tb.grouped_key_change_on_final_row
   cocotb_benches.dau_grouped_aggregation_tb.grouped_int64_sum_accumulates_extremes
   cocotb_benches.dau_grouped_aggregation_tb.grouped_repeated_batches_reset_state
   cocotb_benches.dau_grouped_aggregation_tb.grouped_reserved_mode_reports_config_error
   cocotb_benches.dau_grouped_aggregation_tb.grouped_truncated_stream_reports_stream_error
   cocotb_benches.dau_grouped_aggregation_tb._start
   cocotb_benches.dau_grouped_aggregation_tb._apply_config
   cocotb_benches.dau_grouped_aggregation_tb._run_grouped
   cocotb_benches.dau_grouped_aggregation_tb._decode_group
   cocotb_benches.dau_grouped_aggregation_tb._send_rows
   cocotb_benches.dau_grouped_aggregation_tb._collect_output
   cocotb_benches.dau_grouped_aggregation_tb._accept_success_status
   cocotb_benches.dau_grouped_aggregation_tb._expect_error
   cocotb_benches.dau_grouped_aggregation_tb._signed32
   cocotb_benches.dau_grouped_aggregation_tb._signed64


Module Contents
---------------

.. py:data:: _OHLCV_ROWS

.. py:function:: grouped_ohlcv_bars_match_golden(dut)
   :async:


.. py:function:: grouped_backpressure_on_both_sides(dut)
   :async:


.. py:function:: grouped_single_group_and_single_row(dut)
   :async:


.. py:function:: grouped_reappearing_key_emits_partials(dut)
   :async:


.. py:function:: grouped_key_change_on_final_row(dut)
   :async:


.. py:function:: grouped_int64_sum_accumulates_extremes(dut)
   :async:


.. py:function:: grouped_repeated_batches_reset_state(dut)
   :async:


.. py:function:: grouped_reserved_mode_reports_config_error(dut)
   :async:


.. py:function:: grouped_truncated_stream_reports_stream_error(dut)
   :async:


.. py:function:: _start(dut) -> None
   :async:


.. py:function:: _apply_config(dut, *, row_count: int) -> None

.. py:function:: _run_grouped(dut, rows, *, ready_pattern=(1, ))
   :async:


.. py:function:: _decode_group(words: list[int]) -> dau_core.operators.GroupAggregate

.. py:function:: _send_rows(dut, rows) -> None
   :async:


.. py:function:: _collect_output(dut, ready_pattern) -> list[int]
   :async:


.. py:function:: _accept_success_status(dut) -> int
   :async:


.. py:function:: _expect_error(dut, code: dau_core.operators.GroupedAggregationErrorCode) -> None
   :async:


.. py:function:: _signed32(value: int) -> int

.. py:function:: _signed64(value: int) -> int