cocotb_benches.dau_arrow_lite_stream_aggregation_tb

Functions

arrow_lite_sum_round_trips_through_result_stream(dut)
arrow_lite_count_outputs_uint64_result(dut)
arrow_lite_malformed_descriptor_reports_error(dut)
_encode_int32_column(values, opcode) → bytes
_words_from_bytes(data) → list[int]
_reset(dut) → None
_send_words(dut, words) → None
_collect_output_words(dut) → list[int]
_accept_success_status(dut) → None
_result_logical_type(words) → int
_result_payload(words) → int

Module Contents

async cocotb_benches.dau_arrow_lite_stream_aggregation_tb.arrow_lite_sum_round_trips_through_result_stream(dut)

async cocotb_benches.dau_arrow_lite_stream_aggregation_tb.arrow_lite_count_outputs_uint64_result(dut)

async cocotb_benches.dau_arrow_lite_stream_aggregation_tb.arrow_lite_malformed_descriptor_reports_error(dut)

cocotb_benches.dau_arrow_lite_stream_aggregation_tb._encode_int32_column(values: list[int], opcode: dau_core.stream.OperationCode) → bytes

cocotb_benches.dau_arrow_lite_stream_aggregation_tb._words_from_bytes(data: bytes) → list[int]

async cocotb_benches.dau_arrow_lite_stream_aggregation_tb._reset(dut) → None

async cocotb_benches.dau_arrow_lite_stream_aggregation_tb._send_words(dut, words: list[int]) → None

async cocotb_benches.dau_arrow_lite_stream_aggregation_tb._collect_output_words(dut) → list[int]

async cocotb_benches.dau_arrow_lite_stream_aggregation_tb._accept_success_status(dut) → None

cocotb_benches.dau_arrow_lite_stream_aggregation_tb._result_logical_type(words: list[int]) → int

cocotb_benches.dau_arrow_lite_stream_aggregation_tb._result_payload(words: list[int]) → int