List of all items

Structs

• lifecycle::BackendTriple

Macros

• async_broker_suite
• async_client_data_store_suite
• async_concurrency_suite
• async_isolation_suite
• async_lifecycle_suite
• async_orchestrator_suite
• async_state_backend_suite
• async_trigger_suite
• broker_suite
• client_data_store_suite
• concurrency_suite
• lifecycle_suite
• orchestrator_suite
• state_backend_suite
• trigger_suite

Functions

• broker::test_batch_route
• broker::test_count_invocations
• broker::test_count_per_task
• broker::test_fifo_ordering
• broker::test_global_queue_language_fallback
• broker::test_language_routing
• broker::test_per_task_isolation
• broker::test_purge_all
• broker::test_purge_per_task
• broker::test_retrieve_empty
• broker::test_route_and_retrieve
• client_data_store::test_backend_name
• client_data_store::test_large_value
• client_data_store::test_multiple_keys
• client_data_store::test_purge_removes_all
• client_data_store::test_retrieve_missing_key_errors
• client_data_store::test_store_and_retrieve
• client_data_store::test_upsert_semantics
• concurrency::test_multi_pair_argument_cc
• concurrency::test_sentinel_empty_args
• concurrency::test_try_acquire_after_release
• concurrency::test_try_acquire_slot_at_limit
• concurrency::test_try_acquire_slot_under_limit
• concurrency::test_unlimited_cc_always_acquires
• helpers::generate_invocation_ids
• helpers::test_foreign_task_id
• helpers::test_task_id
• isolation::test_broker_isolation
• isolation::test_client_data_store_isolation
• isolation::test_orchestrator_isolation
• isolation::test_state_backend_isolation
• isolation::test_trigger_store_isolation
• lifecycle::test_broker_orchestrator_consistency
• lifecycle::test_full_lifecycle_failure
• lifecycle::test_full_lifecycle_success
• lifecycle::test_multiple_invocations
• lifecycle::test_purge_all_backends
• orchestrator::test_atomic_service_timeline
• orchestrator::test_cc_argument_same_args_blocked
• orchestrator::test_cc_key_arguments_subset
• orchestrator::test_cc_task_blocks_duplicate
• orchestrator::test_concurrency_control
• orchestrator::test_count_invocations
• orchestrator::test_filter_by_status
• orchestrator::test_get_active_runner_ids
• orchestrator::test_get_invocation_ids_paginated
• orchestrator::test_get_invocations_by_status
• orchestrator::test_get_invocations_by_task
• orchestrator::test_get_missing_invocation
• orchestrator::test_invalid_status_transition
• orchestrator::test_ownership_violation
• orchestrator::test_purge
• orchestrator::test_register_invocation
• orchestrator::test_stale_pending_detection
• orchestrator::test_stale_running_detection
• orchestrator::test_status_transitions
• orchestrator::test_terminal_state_no_transition
• state_backend::test_get_call
• state_backend::test_get_result_none
• state_backend::test_history
• state_backend::test_purge
• state_backend::test_store_and_get_error
• state_backend::test_store_and_get_result
• state_backend::test_upsert_and_get
• trigger::test_claim_trigger_run_dedup
• trigger::test_cron_execution_history
• trigger::test_cron_execution_optimistic_lock
• trigger::test_cron_sequential_executions
• trigger::test_get_all_conditions
• trigger::test_get_conditions_for_task
• trigger::test_get_cron_conditions
• trigger::test_get_event_conditions
• trigger::test_get_triggers_for_condition
• trigger::test_multiple_cron_conditions
• trigger::test_purge_clears_all
• trigger::test_register_and_get_condition
• trigger::test_register_and_get_trigger
• trigger::test_remove_triggers_for_task
• trigger::test_trigger_and_logic
• trigger::test_valid_condition_lifecycle