test_stream_codec

Functions

test_encode_int32_column_round_trips_batch_descriptor_and_payload() → None
test_encode_rejects_payload_length_that_does_not_match_row_count() → None
test_encode_rejects_unsupported_logical_type() → None
test_encode_column_round_trips_supported_fixed_width_types(...) → None
test_decode_rejects_malformed_payload_window() → None
test_encode_column_round_trips_operation_descriptor() → None
test_decode_scalar_result_interprets_single_row_payload() → None

Module Contents

test_stream_codec.test_encode_int32_column_round_trips_batch_descriptor_and_payload() → None

test_stream_codec.test_encode_rejects_payload_length_that_does_not_match_row_count() → None

test_stream_codec.test_encode_rejects_unsupported_logical_type() → None

test_stream_codec.test_encode_column_round_trips_supported_fixed_width_types(logical_type: dau_core.stream.LogicalType, payload: bytes) → None

test_stream_codec.test_decode_rejects_malformed_payload_window() → None

test_stream_codec.test_encode_column_round_trips_operation_descriptor() → None

test_stream_codec.test_decode_scalar_result_interprets_single_row_payload() → None