Knowledge Wiki Orchestrata Ultimate

Orchestrata Ultimate › Tests › Reference › kernel › test_dispatcher_expanded

Tests reference — tests/kernel/test_dispatcher_expanded.py

Module of tests/kernel, split out because the directory page would be too large.

Prose pending.

tests/kernel/test_dispatcher_expanded.py

source · 43 tests · 668 lines

Expanded tests for kernel.dispatcher.

Covers: agents.volk_registry, core.base.traces, cxp.proto_codec, cxp.servicer, cxp.transport, kernel.dispatcher, core.packet/ (package)

Kind Name Line Description
class TestDispatchStatus 104
method TestDispatchStatus.test_values 105
class TestDispatchAttempt 113
method TestDispatchAttempt.test_to_dict 114
class TestDispatchResult 131
method TestDispatchResult.test_success 132
method TestDispatchResult.test_add_attempt 143
method TestDispatchResult.test_to_dict 161
class TestMessageDispatcherInit 175
method TestMessageDispatcherInit.test_default_init 176
method TestMessageDispatcherInit.test_custom_init 183
class TestMessageDispatcherSelectProtocol 190
method TestMessageDispatcherSelectProtocol.test_select_cxp 191
method TestMessageDispatcherSelectProtocol.test_select_grpc 196
method TestMessageDispatcherSelectProtocol.test_select_ws 201
method TestMessageDispatcherSelectProtocol.test_select_http_fallback 206
class TestMessageDispatcherParseGrpcEndpoint 212
method TestMessageDispatcherParseGrpcEndpoint.test_parse_with_scheme 213
method TestMessageDispatcherParseGrpcEndpoint.test_parse_without_scheme 221
method TestMessageDispatcherParseGrpcEndpoint.test_parse_default_port_uses_env_cxp_grpc_port 227
method TestMessageDispatcherParseGrpcEndpoint.test_parse_cxp_scheme 237
method TestMessageDispatcherParseGrpcEndpoint.test_parse_empty_endpoint_raises 243
method TestMessageDispatcherParseGrpcEndpoint.test_parse_none_endpoint_raises 248
method TestMessageDispatcherParseGrpcEndpoint.test_parse_non_numeric_port_raises 253
method TestMessageDispatcherParseGrpcEndpoint.test_parse_port_zero_raises 258
method TestMessageDispatcherParseGrpcEndpoint.test_parse_port_above_range_raises 263
method TestMessageDispatcherParseGrpcEndpoint.test_parse_empty_host_raises 268
method TestMessageDispatcherParseGrpcEndpoint.test_parse_missing_port_uses_env_cxp_grpc_port 273
class TestMessageDispatcherSerializePacket 284
method TestMessageDispatcherSerializePacket.test_serialize_success 285
method TestMessageDispatcherSerializePacket.test_serialize_failure 291
class TestMessageDispatcherDispatch 306
method TestMessageDispatcherDispatch.test_dispatch_success 308 dispatch() over real gRPC succeeds when the server acks success.
method TestMessageDispatcherDispatch.test_dispatch_failure_with_retries 328 dispatch() retries (max_retries+1 attempts) when the server NACKs.
method TestMessageDispatcherDispatch.test_dispatch_timeout 348 dispatch() records a TIMEOUT when the server handler exceeds timeout.
method TestMessageDispatcherDispatch.test_dispatch_transport_error 370 dispatch() to a dead endpoint records FAILED attempts with an error.
method TestMessageDispatcherDispatch.test_dispatch_succeeds_after_one_retry_records_backoff 389 dispatch() must retry with exponential backoff and stop as soon as
class TestMessageDispatcherDispatchByProtocol 437
method TestMessageDispatcherDispatchByProtocol.test_dispatch_grpc 439
method TestMessageDispatcherDispatchByProtocol.test_dispatch_ws 453
method TestMessageDispatcherDispatchByProtocol.test_dispatch_http_success 474 HTTP dispatch to a live server returning 2xx succeeds (returns True).
method TestMessageDispatcherDispatchByProtocol.test_dispatch_http_error_status_returns_false 505 HTTP dispatch to a server returning non-2xx yields False, not an exception.
method TestMessageDispatcherDispatchByProtocol.test_dispatch_http_connection_error_propagates 530 HTTP dispatch to an unreachable endpoint logs and re-raises the aiohttp
method TestMessageDispatcherDispatchByProtocol.test_dispatch_cxp 550
method TestMessageDispatcherDispatchByProtocol.test_dispatch_unknown 564
class TestMessageDispatcherSendGrpc 580
method TestMessageDispatcherSendGrpc.test_send_grpc_success 582 _send_grpc_packet against a real server returns True on success ack.
method TestMessageDispatcherSendGrpc.test_send_grpc_failure 607 _send_grpc_packet returns False when the server NACKs.
class TestMessageDispatcherParseWsAck 630
method TestMessageDispatcherParseWsAck.test_parse_ok 631
method TestMessageDispatcherParseWsAck.test_parse_nack 635
method TestMessageDispatcherParseWsAck.test_parse_invalid_json 639
class TestMessageDispatcherGetHistory 644
method TestMessageDispatcherGetHistory.test_get_history_all 645
method TestMessageDispatcherGetHistory.test_get_history_by_id 649