Index

A

abort (angzarr_client.compensation.DelegationOptions attribute) (angzarr_client.DelegationOptions attribute) ACTUAL (in module angzarr_client.error_codes.keys) ACTUAL_RETURN_TYPE (in module angzarr_client.error_codes.keys) add_event() (angzarr_client.ScenarioContext method) (angzarr_client.testing.context.ScenarioContext method) (angzarr_client.testing.ScenarioContext method) address (angzarr_client.server.ServerHandle attribute) angzarr_client module angzarr_client.builder module angzarr_client.client module angzarr_client.compensation module angzarr_client.destinations module angzarr_client.error_codes module angzarr_client.error_codes.codes module angzarr_client.error_codes.keys module angzarr_client.error_codes.messages module angzarr_client.errors module angzarr_client.helpers module angzarr_client.identity module angzarr_client.readiness module angzarr_client.retry module angzarr_client.router module

angzarr_client.router.builder module angzarr_client.router.decorators module angzarr_client.router.dispatch module angzarr_client.router.responses module angzarr_client.router.runtime module angzarr_client.router.server module angzarr_client.router.validation module angzarr_client.server module angzarr_client.testing module angzarr_client.testing.builders module angzarr_client.testing.context module angzarr_client.testing.uuid module angzarr_client.validation module angzarr_client.wrappers module ANY_DECODE_FAILED (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) ANY_TYPE_MISMATCH (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) applies() (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) as_of_sequence() (angzarr_client.builder.QueryBuilder method) (angzarr_client.QueryBuilder method) as_of_time() (angzarr_client.builder.QueryBuilder method) (angzarr_client.QueryBuilder method)

B

build() (angzarr_client.builder.CommandBuilder method) (angzarr_client.builder.QueryBuilder method) (angzarr_client.CommandBuilder method) (angzarr_client.QueryBuilder method) (angzarr_client.Router method) (angzarr_client.router.builder.Router method) (angzarr_client.router.Router method)

BuildError, [1], [2] BusProbe (class in angzarr_client.readiness) by_correlation_id() (angzarr_client.builder.QueryBuilder method) (angzarr_client.QueryBuilder method) bytes_to_uuid_text() (in module angzarr_client.helpers)

C

cache_key() (angzarr_client.CoverBearer method) (angzarr_client.wrappers.CoverBearer method) cart_root() (in module angzarr_client) (in module angzarr_client.identity) cause (angzarr_client.ClientError attribute) (angzarr_client.errors.ClientError attribute) CAUSE (in module angzarr_client.error_codes.keys) check() (angzarr_client.readiness.BusProbe method) (angzarr_client.readiness.OutputDomainProbe method) (angzarr_client.readiness.Probe method) (angzarr_client.readiness.TransportProbe method) cleanup_socket() (in module angzarr_client) (in module angzarr_client.server) clear_events() (angzarr_client.ScenarioContext method) (angzarr_client.testing.context.ScenarioContext method) (angzarr_client.testing.ScenarioContext method) clear_result() (angzarr_client.ScenarioContext method) (angzarr_client.testing.context.ScenarioContext method) (angzarr_client.testing.ScenarioContext method) ClientError, [1] close() (angzarr_client.client.CommandHandlerClient method) (angzarr_client.client.DomainClient method) (angzarr_client.client.QueryClient method) (angzarr_client.client.SpeculativeClient method) (angzarr_client.CommandHandlerClient method) (angzarr_client.DomainClient method) (angzarr_client.QueryClient method) (angzarr_client.SpeculativeClient method) code (angzarr_client.BuildError attribute) (angzarr_client.ClientError attribute) (angzarr_client.errors.ClientError attribute) (angzarr_client.router.builder.BuildError attribute) (angzarr_client.router.BuildError attribute) code() (angzarr_client.DispatchError method) (angzarr_client.router.dispatch.DispatchError method) (angzarr_client.router.DispatchError method) COLLECTION_EMPTY (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) command() (angzarr_client.client.CommandHandlerClient method) (angzarr_client.CommandHandlerClient method) command_handler (angzarr_client.client.DomainClient attribute) (angzarr_client.DomainClient attribute) command_handler() (angzarr_client.client.SpeculativeClient method) (angzarr_client.SpeculativeClient method) (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) command_new() (angzarr_client.client.CommandHandlerClient method) (angzarr_client.CommandHandlerClient method) COMMAND_PAYLOAD_MISSING (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) command_sequence() (angzarr_client.CommandBook method) (angzarr_client.wrappers.CommandBook method) COMMAND_SEQUENCE_MISSING (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) COMMAND_TYPE_URL_MISSING (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) CommandBook (class in angzarr_client) (class in angzarr_client.wrappers) CommandBuilder (class in angzarr_client) (class in angzarr_client.builder)

CommandHandlerClient (class in angzarr_client) (class in angzarr_client.client) CommandHandlerGrpc (class in angzarr_client) (class in angzarr_client.router.server) CommandHandlerRouter (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.runtime) CommandPage (class in angzarr_client) (class in angzarr_client.wrappers) CommandRejectedError, [1] CommandResponse (class in angzarr_client) (class in angzarr_client.wrappers) commands (angzarr_client.ProcessManagerResponse attribute) (angzarr_client.router.ProcessManagerResponse attribute) (angzarr_client.router.responses.ProcessManagerResponse attribute) (angzarr_client.router.responses.SagaHandlerResponse attribute) (angzarr_client.router.SagaHandlerResponse attribute) (angzarr_client.SagaHandlerResponse attribute) CompensationContext (class in angzarr_client) (class in angzarr_client.compensation) compute_root() (in module angzarr_client) (in module angzarr_client.identity) configure_logging() (in module angzarr_client) (in module angzarr_client.server) connect() (angzarr_client.client.CommandHandlerClient class method) (angzarr_client.client.DomainClient class method) (angzarr_client.client.QueryClient class method) (angzarr_client.client.SpeculativeClient class method) (angzarr_client.CommandHandlerClient class method) (angzarr_client.DomainClient class method) (angzarr_client.QueryClient class method) (angzarr_client.SpeculativeClient class method) CONNECTION_FAILED (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) CONNECTION_FAILED_MAX_RETRIES (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) ConnectionError, [1] CONTEXT (in module angzarr_client.error_codes.keys) correlated_metadata() (in module angzarr_client) (in module angzarr_client.helpers) correlation_id() (angzarr_client.CoverBearer method) (angzarr_client.wrappers.CoverBearer method) CORRELATION_ID_HEADER (in module angzarr_client) (in module angzarr_client.helpers) cover (angzarr_client.CommandRejectedError attribute) (angzarr_client.errors.CommandRejectedError attribute) Cover (class in angzarr_client) (class in angzarr_client.wrappers) cover() (angzarr_client.CommandBook method) (angzarr_client.EventBook method) (angzarr_client.Query method) (angzarr_client.wrappers.CommandBook method) (angzarr_client.wrappers.EventBook method) (angzarr_client.wrappers.Query method) CoverBearer (class in angzarr_client) (class in angzarr_client.wrappers) create_server() (in module angzarr_client) (in module angzarr_client.server) customer_root() (in module angzarr_client) (in module angzarr_client.identity)

D

decode_event() (in module angzarr_client.helpers) decode_typed() (angzarr_client.EventPage method) (angzarr_client.wrappers.EventPage method) DEFAULT_BIND_HOST (in module angzarr_client) (in module angzarr_client.server) DEFAULT_EDITION (in module angzarr_client) (in module angzarr_client.helpers) DEFAULT_PROBE_INTERVAL (in module angzarr_client.readiness) DEFAULT_PROBE_TIMEOUT (in module angzarr_client.readiness) default_retry_policy() (in module angzarr_client) (in module angzarr_client.retry) DEFAULT_TEST_NAMESPACE (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.uuid) deferred_header() (angzarr_client.Destinations static method) (angzarr_client.destinations.Destinations static method) delegate_to_framework() (in module angzarr_client) (in module angzarr_client.compensation) DelegationOptions (class in angzarr_client) (class in angzarr_client.compensation) destination_map() (in module angzarr_client) (in module angzarr_client.helpers) Destinations (class in angzarr_client) (class in angzarr_client.destinations) details (angzarr_client.BuildError attribute) (angzarr_client.ClientError attribute) (angzarr_client.errors.ClientError attribute) (angzarr_client.router.builder.BuildError attribute) (angzarr_client.router.BuildError attribute) details() (angzarr_client.DispatchError method) (angzarr_client.router.dispatch.DispatchError method) (angzarr_client.router.DispatchError method) dispatch() (angzarr_client.CommandHandlerRouter method) (angzarr_client.ProcessManagerRouter method) (angzarr_client.ProjectorRouter method) (angzarr_client.router.CommandHandlerRouter method) (angzarr_client.router.ProcessManagerRouter method) (angzarr_client.router.ProjectorRouter method) (angzarr_client.router.runtime.CommandHandlerRouter method) (angzarr_client.router.runtime.ProcessManagerRouter method) (angzarr_client.router.runtime.ProjectorRouter method) (angzarr_client.router.runtime.SagaRouter method) (angzarr_client.router.runtime.UpcasterRouter method) (angzarr_client.router.SagaRouter method) (angzarr_client.router.UpcasterRouter method) (angzarr_client.SagaRouter method) (angzarr_client.UpcasterRouter method)

dispatch_command() (in module angzarr_client.router.dispatch) dispatch_fact() (angzarr_client.CommandHandlerRouter method) (angzarr_client.router.CommandHandlerRouter method) (angzarr_client.router.runtime.CommandHandlerRouter method) (in module angzarr_client.router.dispatch) dispatch_key (angzarr_client.compensation.CompensationContext property) (angzarr_client.CompensationContext property) dispatch_process_manager() (in module angzarr_client.router.dispatch) dispatch_projector() (in module angzarr_client.router.dispatch) dispatch_replay() (angzarr_client.CommandHandlerRouter method) (angzarr_client.router.CommandHandlerRouter method) (angzarr_client.router.runtime.CommandHandlerRouter method) (in module angzarr_client.router.dispatch) dispatch_saga() (in module angzarr_client.router.dispatch) dispatch_upcaster() (in module angzarr_client.router.dispatch) DispatchError, [1], [2] DISTRIBUTED (angzarr_client.client.TransportMode attribute) (angzarr_client.TransportMode attribute) divergence_for() (in module angzarr_client.helpers) domain (angzarr_client.ScenarioContext attribute), [1] (angzarr_client.testing.context.ScenarioContext attribute), [1] (angzarr_client.testing.ScenarioContext attribute), [1] DOMAIN (in module angzarr_client.error_codes.keys) domain() (angzarr_client.CoverBearer method) (angzarr_client.wrappers.CoverBearer method) DomainClient (class in angzarr_client) (class in angzarr_client.client) domains (angzarr_client.Destinations property) (angzarr_client.destinations.Destinations property) DUPLICATE_COMMAND_HANDLER (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages)

E

edition() (angzarr_client.builder.QueryBuilder method) (angzarr_client.CoverBearer method) (angzarr_client.QueryBuilder method) (angzarr_client.wrappers.CoverBearer method) emit_compensation_events() (in module angzarr_client) (in module angzarr_client.compensation) emit_system_event (angzarr_client.compensation.DelegationOptions attribute) (angzarr_client.DelegationOptions attribute) EMPTY_PM_TRIGGER (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) EMPTY_SAGA_SOURCE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) ENDPOINT (in module angzarr_client.error_codes.keys) ENDPOINT_INVALID_URI (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) ENDPOINT_PARSE_FAILED (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) ENTITY_ALREADY_EXISTS (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) ENTITY_NOT_FOUND (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) ENV_BIND_ADDRESS (in module angzarr_client) (in module angzarr_client.server) ENV_BUS_ENDPOINT (in module angzarr_client.readiness) ENV_INTERVAL (in module angzarr_client.readiness) ENV_TIMEOUT (in module angzarr_client.readiness) ENV_VAR (in module angzarr_client.error_codes.keys) error (angzarr_client.ScenarioContext attribute), [1] (angzarr_client.testing.context.ScenarioContext attribute), [1] (angzarr_client.testing.ScenarioContext attribute), [1] error_code (angzarr_client.DispatchError attribute) (angzarr_client.router.dispatch.DispatchError attribute) (angzarr_client.router.DispatchError attribute) escalate (angzarr_client.compensation.DelegationOptions attribute) (angzarr_client.DelegationOptions attribute) event_book() (angzarr_client.ScenarioContext method) (angzarr_client.testing.context.ScenarioContext method) (angzarr_client.testing.ScenarioContext method)

EventBook (class in angzarr_client) (class in angzarr_client.wrappers) EventPage (class in angzarr_client) (class in angzarr_client.wrappers) events (angzarr_client.RejectionHandlerResponse attribute) (angzarr_client.router.RejectionHandlerResponse attribute) (angzarr_client.router.responses.RejectionHandlerResponse attribute) (angzarr_client.router.responses.SagaHandlerResponse attribute) (angzarr_client.router.SagaHandlerResponse attribute) (angzarr_client.SagaHandlerResponse attribute) (angzarr_client.ScenarioContext attribute), [1] (angzarr_client.testing.context.ScenarioContext attribute), [1] (angzarr_client.testing.ScenarioContext attribute), [1] events() (angzarr_client.CommandResponse method) (angzarr_client.wrappers.CommandResponse method) events_book() (angzarr_client.CommandResponse method) (angzarr_client.wrappers.CommandResponse method) events_from_response() (in module angzarr_client.helpers) execute() (angzarr_client.builder.CommandBuilder method) (angzarr_client.client.DomainClient method) (angzarr_client.CommandBuilder method) (angzarr_client.DomainClient method) (angzarr_client.ExponentialBackoffRetry method) (angzarr_client.retry.ExponentialBackoffRetry method) (angzarr_client.retry.RetryPolicy method) (angzarr_client.RetryPolicy method) execute_with_mode() (angzarr_client.client.DomainClient method) (angzarr_client.DomainClient method) EXPECTED (in module angzarr_client.error_codes.keys) EXPECTED_KIND (in module angzarr_client.error_codes.keys) ExponentialBackoffRetry (class in angzarr_client) (class in angzarr_client.retry) extras (angzarr_client.DispatchError attribute) (angzarr_client.router.dispatch.DispatchError attribute) (angzarr_client.router.DispatchError attribute)

F

F (in module angzarr_client.router.decorators) Factory (in module angzarr_client.router.dispatch) (in module angzarr_client.router.runtime) facts (angzarr_client.ProcessManagerResponse attribute) (angzarr_client.router.ProcessManagerResponse attribute) (angzarr_client.router.responses.ProcessManagerResponse attribute) FIELD (in module angzarr_client.error_codes.keys) first_command() (angzarr_client.CommandBook method) (angzarr_client.wrappers.CommandBook method) first_page() (angzarr_client.EventBook method) (angzarr_client.wrappers.EventBook method) for_domain() (angzarr_client.client.DomainClient class method) (angzarr_client.DomainClient class method) (angzarr_client.readiness.OutputDomainProbe class method) from_channel() (angzarr_client.client.CommandHandlerClient class method) (angzarr_client.client.DomainClient class method) (angzarr_client.client.QueryClient class method) (angzarr_client.client.SpeculativeClient class method) (angzarr_client.CommandHandlerClient class method) (angzarr_client.DomainClient class method) (angzarr_client.QueryClient class method) (angzarr_client.SpeculativeClient class method) from_clients() (angzarr_client.client.DomainClient class method) (angzarr_client.DomainClient class method) from_env() (angzarr_client.client.CommandHandlerClient class method) (angzarr_client.client.DomainClient class method) (angzarr_client.client.QueryClient class method) (angzarr_client.client.SpeculativeClient class method) (angzarr_client.CommandHandlerClient class method) (angzarr_client.DomainClient class method) (angzarr_client.QueryClient class method) (angzarr_client.readiness.BusProbe class method) (angzarr_client.server.ServerConfig class method) (angzarr_client.ServerConfig class method) (angzarr_client.SpeculativeClient class method)

from_notification() (angzarr_client.compensation.CompensationContext class method) (angzarr_client.CompensationContext class method) from_proto() (angzarr_client.Destinations class method) (angzarr_client.destinations.Destinations class method) from_stub() (angzarr_client.client.CommandHandlerClient class method) (angzarr_client.client.QueryClient class method) (angzarr_client.CommandHandlerClient class method) (angzarr_client.QueryClient class method) from_stubs() (angzarr_client.client.SpeculativeClient class method) (angzarr_client.SpeculativeClient class method) fulfillment_root() (in module angzarr_client) (in module angzarr_client.identity) full_type_name() (in module angzarr_client.helpers) full_type_url (in module angzarr_client) (in module angzarr_client.helpers) full_type_url_for() (in module angzarr_client) (in module angzarr_client.helpers)

G

get_event_book() (angzarr_client.builder.QueryBuilder method) (angzarr_client.client.DomainClient method) (angzarr_client.client.QueryClient method) (angzarr_client.DomainClient method) (angzarr_client.QueryBuilder method) (angzarr_client.QueryClient method) get_events() (angzarr_client.builder.QueryBuilder method) (angzarr_client.client.DomainClient method) (angzarr_client.client.QueryClient method) (angzarr_client.DomainClient method) (angzarr_client.QueryBuilder method) (angzarr_client.QueryClient method)

get_pages() (angzarr_client.builder.QueryBuilder method) (angzarr_client.QueryBuilder method) get_transport_config() (in module angzarr_client) (in module angzarr_client.server) grpc_code (angzarr_client.errors.GRPCError property) (angzarr_client.GRPCError property) grpc_details (angzarr_client.errors.GRPCError property) (angzarr_client.GRPCError property) GRPC_ERROR (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) GRPCError, [1]

H

handle() (angzarr_client.client.CommandHandlerClient method) (angzarr_client.CommandHandlerClient method) Handle() (angzarr_client.CommandHandlerGrpc method) (angzarr_client.ProcessManagerGrpc method) (angzarr_client.ProjectorGrpc method) (angzarr_client.router.server.CommandHandlerGrpc method) (angzarr_client.router.server.ProcessManagerGrpc method) (angzarr_client.router.server.ProjectorGrpc method) (angzarr_client.router.server.SagaGrpc method) (angzarr_client.SagaGrpc method) handle_command() (angzarr_client.client.CommandHandlerClient method) (angzarr_client.CommandHandlerClient method) handle_sync_speculative() (angzarr_client.client.CommandHandlerClient method) (angzarr_client.CommandHandlerClient method) HandleFact() (angzarr_client.CommandHandlerGrpc method) (angzarr_client.router.server.CommandHandlerGrpc method) HANDLER_CLASS (in module angzarr_client.error_codes.keys) HANDLER_FIELD_EMPTY_LIST (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) HANDLER_FIELD_EMPTY_STRING (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) HANDLER_KIND (in module angzarr_client.error_codes.keys) HANDLER_STATE_NOT_TYPE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) HANDLER_UNKNOWN_KIND (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages)

HANDLER_WRONG_REQUEST_KIND (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) HANDLER_WRONG_RESPONSE_KIND (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) handles() (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) handles_fact() (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) HandleSpeculative() (angzarr_client.ProjectorGrpc method) (angzarr_client.router.server.ProjectorGrpc method) has_async_outputs() (angzarr_client.ProcessManagerRouter method) (angzarr_client.router.ProcessManagerRouter method) (angzarr_client.router.runtime.ProcessManagerRouter method) (angzarr_client.router.runtime.SagaRouter method) (angzarr_client.router.SagaRouter method) (angzarr_client.SagaRouter method) has_correlation_id() (angzarr_client.CoverBearer method) (angzarr_client.wrappers.CoverBearer method) has_domain() (angzarr_client.Destinations method) (angzarr_client.destinations.Destinations method) header() (angzarr_client.CommandPage method) (angzarr_client.EventPage method) (angzarr_client.wrappers.CommandPage method) (angzarr_client.wrappers.EventPage method) health_servicer (angzarr_client.server.ServerHandle attribute)

I

idempotency_key() (in module angzarr_client.helpers) implicit_edition() (in module angzarr_client) (in module angzarr_client.helpers) INPUT (in module angzarr_client.error_codes.keys) invalid_argument() (angzarr_client.CommandRejectedError static method) (angzarr_client.errors.CommandRejectedError static method) INVALID_PORT (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) INVALID_TRANSPORT_MODE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) InvalidArgumentError, [1] InvalidTimestampError, [1] INVENTORY_PRODUCT_NAMESPACE (in module angzarr_client) (in module angzarr_client.identity) inventory_product_root() (in module angzarr_client) (in module angzarr_client.identity) inventory_root() (in module angzarr_client) (in module angzarr_client.identity) is_bound() (angzarr_client.readiness.TransportSignal method) is_connection_error() (angzarr_client.ClientError method) (angzarr_client.ConnectionError method) (angzarr_client.errors.ClientError method) (angzarr_client.errors.ConnectionError method) (angzarr_client.errors.GRPCError method) (angzarr_client.errors.TransportError method) (angzarr_client.GRPCError method) (angzarr_client.TransportError method)

is_deferred() (angzarr_client.CommandPage method) (angzarr_client.EventPage method) (angzarr_client.wrappers.CommandPage method) (angzarr_client.wrappers.EventPage method) is_empty() (angzarr_client.EventBook method) (angzarr_client.wrappers.EventBook method) is_invalid_argument() (angzarr_client.ClientError method) (angzarr_client.CommandRejectedError method) (angzarr_client.errors.ClientError method) (angzarr_client.errors.CommandRejectedError method) (angzarr_client.errors.GRPCError method) (angzarr_client.errors.InvalidArgumentError method) (angzarr_client.GRPCError method) (angzarr_client.InvalidArgumentError method) is_not_found() (angzarr_client.ClientError method) (angzarr_client.CommandRejectedError method) (angzarr_client.errors.ClientError method) (angzarr_client.errors.CommandRejectedError method) (angzarr_client.errors.GRPCError method) (angzarr_client.GRPCError method) is_notification() (in module angzarr_client) (in module angzarr_client.compensation) is_precondition_failed() (angzarr_client.ClientError method) (angzarr_client.CommandRejectedError method) (angzarr_client.errors.ClientError method) (angzarr_client.errors.CommandRejectedError method) (angzarr_client.errors.GRPCError method) (angzarr_client.GRPCError method)

J

jitter (angzarr_client.ExponentialBackoffRetry attribute) (angzarr_client.retry.ExponentialBackoffRetry attribute)

L

last_page() (angzarr_client.EventBook method) (angzarr_client.wrappers.EventBook method)

M

make_command_book() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.builders) make_command_page() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.builders) make_cover() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.builders) make_event_book() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.builders) make_event_page() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.builders) make_timestamp() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.builders) mark_bound() (angzarr_client.readiness.TransportSignal method) max_attempts (angzarr_client.ExponentialBackoffRetry attribute) (angzarr_client.retry.ExponentialBackoffRetry attribute) max_delay (angzarr_client.ExponentialBackoffRetry attribute) (angzarr_client.retry.ExponentialBackoffRetry attribute) merge_strategy() (angzarr_client.CommandBook method) (angzarr_client.CommandPage method) (angzarr_client.wrappers.CommandBook method) (angzarr_client.wrappers.CommandPage method) message (angzarr_client.BuildError attribute) (angzarr_client.ClientError attribute) (angzarr_client.errors.ClientError attribute) (angzarr_client.router.builder.BuildError attribute) (angzarr_client.router.BuildError attribute) META_ANGZARR_DOMAIN (in module angzarr_client) (in module angzarr_client.helpers) min_delay (angzarr_client.ExponentialBackoffRetry attribute) (angzarr_client.retry.ExponentialBackoffRetry attribute) MISSING_COMMAND_BOOK (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) MISSING_COMMAND_PAGE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) MISSING_COMMAND_PAYLOAD (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages)

MISSING_DESTINATION_SEQUENCE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) MISSING_PM_EVENT_PAYLOAD (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) MISSING_PM_TRIGGER (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) MISSING_SAGA_EVENT_PAYLOAD (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) MISSING_SAGA_SOURCE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) MIXED_HANDLER_KINDS (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) module angzarr_client angzarr_client.builder angzarr_client.client angzarr_client.compensation angzarr_client.destinations angzarr_client.error_codes angzarr_client.error_codes.codes angzarr_client.error_codes.keys angzarr_client.error_codes.messages angzarr_client.errors angzarr_client.helpers angzarr_client.identity angzarr_client.readiness angzarr_client.retry angzarr_client.router angzarr_client.router.builder angzarr_client.router.decorators angzarr_client.router.dispatch angzarr_client.router.responses angzarr_client.router.runtime angzarr_client.router.server angzarr_client.router.validation angzarr_client.server angzarr_client.testing angzarr_client.testing.builders angzarr_client.testing.context angzarr_client.testing.uuid angzarr_client.validation angzarr_client.wrappers

N

name (angzarr_client.CommandHandlerRouter property) (angzarr_client.readiness.BusProbe property) (angzarr_client.readiness.OutputDomainProbe property) (angzarr_client.readiness.Probe property) (angzarr_client.readiness.TransportProbe property) (angzarr_client.Router attribute) (angzarr_client.router.builder.Router attribute) (angzarr_client.router.CommandHandlerRouter property) (angzarr_client.router.Router attribute) (angzarr_client.router.runtime.CommandHandlerRouter property) new() (angzarr_client.readiness.TransportProbe class method) new_command_book() (in module angzarr_client.helpers) new_command_page() (in module angzarr_client.helpers)

new_cover() (in module angzarr_client.helpers) next_sequence() (angzarr_client.EventBook method) (angzarr_client.wrappers.EventBook method) NO_HANDLER_REGISTERED (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) not_found() (angzarr_client.CommandRejectedError static method) (angzarr_client.errors.CommandRejectedError static method) notification (angzarr_client.RejectionHandlerResponse attribute) (angzarr_client.router.RejectionHandlerResponse attribute) (angzarr_client.router.responses.RejectionHandlerResponse attribute) NOTIFICATION_DECODE_FAILED (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) now() (in module angzarr_client) (in module angzarr_client.helpers)

O

on_retry (angzarr_client.ExponentialBackoffRetry attribute) (angzarr_client.retry.ExponentialBackoffRetry attribute) order_root() (in module angzarr_client) (in module angzarr_client.identity) OTHER_KIND (in module angzarr_client.error_codes.keys) output_domains() (angzarr_client.ProcessManagerRouter method) (angzarr_client.router.ProcessManagerRouter method) (angzarr_client.router.runtime.ProcessManagerRouter method) (angzarr_client.router.runtime.SagaRouter method) (angzarr_client.router.SagaRouter method) (angzarr_client.SagaRouter method)

OutputDomainProbe (class in angzarr_client.readiness)

P

pack_event() (in module angzarr_client.testing) (in module angzarr_client.testing.builders) pages() (angzarr_client.CommandBook method) (angzarr_client.EventBook method) (angzarr_client.wrappers.CommandBook method) (angzarr_client.wrappers.EventBook method) parse_timestamp() (in module angzarr_client) (in module angzarr_client.helpers) payload() (angzarr_client.CommandPage method) (angzarr_client.EventPage method) (angzarr_client.wrappers.CommandPage method) (angzarr_client.wrappers.EventPage method) pm_delegate_to_framework() (in module angzarr_client) (in module angzarr_client.compensation) pm_emit_compensation_events() (in module angzarr_client) (in module angzarr_client.compensation) PM_HANDLER_WRONG_RETURN_TYPE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) PM_INVALID_TYPE_URL (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) PMRevocationResponse (class in angzarr_client) (class in angzarr_client.compensation) port (angzarr_client.server.ServerConfig attribute) (angzarr_client.ServerConfig attribute) precondition_failed() (angzarr_client.CommandRejectedError static method) (angzarr_client.errors.CommandRejectedError static method) Probe (class in angzarr_client.readiness) probe_config_from_env() (in module angzarr_client.readiness) process_events (angzarr_client.compensation.PMRevocationResponse attribute) (angzarr_client.PMRevocationResponse attribute) (angzarr_client.ProcessManagerResponse attribute) (angzarr_client.router.ProcessManagerResponse attribute) (angzarr_client.router.responses.ProcessManagerResponse attribute) process_manager() (angzarr_client.client.SpeculativeClient method) (angzarr_client.SpeculativeClient method) (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) ProcessManagerGrpc (class in angzarr_client) (class in angzarr_client.router.server) ProcessManagerResponse (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.responses)

ProcessManagerRouter (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.runtime) product_root() (in module angzarr_client) (in module angzarr_client.identity) PROJECTION_DOMAIN_PREFIX (in module angzarr_client) (in module angzarr_client.helpers) PROJECTION_TYPE_URL (in module angzarr_client) (in module angzarr_client.helpers) projector() (angzarr_client.client.SpeculativeClient method) (angzarr_client.SpeculativeClient method) (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) ProjectorGrpc (class in angzarr_client) (class in angzarr_client.router.server) ProjectorRouter (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.runtime) proto() (angzarr_client.CommandBook method) (angzarr_client.CommandPage method) (angzarr_client.CommandResponse method) (angzarr_client.Cover method) (angzarr_client.EventBook method) (angzarr_client.EventPage method) (angzarr_client.Query method) (angzarr_client.Wrapped method) (angzarr_client.wrappers.CommandBook method) (angzarr_client.wrappers.CommandPage method) (angzarr_client.wrappers.CommandResponse method) (angzarr_client.wrappers.Cover method) (angzarr_client.wrappers.EventBook method) (angzarr_client.wrappers.EventPage method) (angzarr_client.wrappers.Query method) (angzarr_client.wrappers.Wrapped method) proto_to_uuid() (in module angzarr_client) (in module angzarr_client.helpers) PROTO_UUID_INVALID (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) proto_uuid_to_hex() (in module angzarr_client) (in module angzarr_client.helpers) proto_uuid_to_text() (in module angzarr_client.helpers)

Q

query (angzarr_client.client.DomainClient attribute) (angzarr_client.DomainClient attribute) Query (class in angzarr_client) (class in angzarr_client.wrappers) query() (angzarr_client.client.QueryClient method) (angzarr_client.QueryClient method)

query_domain() (angzarr_client.client.QueryClient method) (angzarr_client.QueryClient method) QueryBuilder (class in angzarr_client) (class in angzarr_client.builder) QueryClient (class in angzarr_client) (class in angzarr_client.client)

R

range() (angzarr_client.builder.QueryBuilder method) (angzarr_client.QueryBuilder method) range_selection() (in module angzarr_client.helpers) range_to() (angzarr_client.builder.QueryBuilder method) (angzarr_client.QueryBuilder method) rejected() (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) rejected_command (angzarr_client.compensation.CompensationContext attribute) (angzarr_client.CompensationContext attribute) rejected_command_type (angzarr_client.compensation.CompensationContext property) (angzarr_client.CompensationContext property) REJECTION_NOTIFICATION_DECODE_FAILED (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) rejection_reason (angzarr_client.compensation.CompensationContext attribute) (angzarr_client.CompensationContext attribute) RejectionHandlerResponse (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.responses) Replay() (angzarr_client.CommandHandlerGrpc method) (angzarr_client.router.server.CommandHandlerGrpc method) require_exists() (in module angzarr_client) (in module angzarr_client.validation) require_non_negative() (in module angzarr_client) (in module angzarr_client.validation) require_not_empty() (in module angzarr_client) (in module angzarr_client.validation) require_not_empty_str() (in module angzarr_client) (in module angzarr_client.validation) require_not_exists() (in module angzarr_client) (in module angzarr_client.validation) require_positive() (in module angzarr_client) (in module angzarr_client.validation) require_status() (in module angzarr_client) (in module angzarr_client.validation) require_status_not() (in module angzarr_client) (in module angzarr_client.validation) reset() (angzarr_client.ScenarioContext method) (angzarr_client.testing.context.ScenarioContext method) (angzarr_client.testing.ScenarioContext method)

resolve_bind_address() (in module angzarr_client) (in module angzarr_client.server) resolve_ch_endpoint() (in module angzarr_client) (in module angzarr_client.client) result (angzarr_client.ScenarioContext attribute), [1] (angzarr_client.testing.context.ScenarioContext attribute), [1] (angzarr_client.testing.ScenarioContext attribute), [1] RetryPolicy (class in angzarr_client) (class in angzarr_client.retry) revocation (angzarr_client.compensation.PMRevocationResponse attribute) (angzarr_client.PMRevocationResponse attribute) root (angzarr_client.ScenarioContext attribute), [1] (angzarr_client.testing.context.ScenarioContext attribute), [1] (angzarr_client.testing.ScenarioContext attribute), [1] root_id_hex() (angzarr_client.CoverBearer method) (angzarr_client.wrappers.CoverBearer method) root_uuid() (angzarr_client.CoverBearer method) (angzarr_client.wrappers.CoverBearer method) Router (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.builder) ROUTER_NAME (in module angzarr_client.error_codes.keys) ROUTER_NO_HANDLERS (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) routing_key() (angzarr_client.CoverBearer method) (angzarr_client.wrappers.CoverBearer method) run_command_handler_server() (in module angzarr_client) (in module angzarr_client.server) run_process_manager_server() (in module angzarr_client) (in module angzarr_client.server) run_projector_server() (in module angzarr_client) (in module angzarr_client.server) run_saga_server() (in module angzarr_client) (in module angzarr_client.server) run_server() (in module angzarr_client) (in module angzarr_client.server) run_supervisor() (in module angzarr_client.readiness) run_upcaster_server() (in module angzarr_client) (in module angzarr_client.server)

S

S (in module angzarr_client.router.runtime) saga() (angzarr_client.client.SpeculativeClient method) (angzarr_client.SpeculativeClient method) (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) SAGA_HANDLER_UNSUPPORTED_RETURN_TYPE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) SAGA_INVALID_TYPE_URL (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) SagaGrpc (class in angzarr_client) (class in angzarr_client.router.server) SagaHandlerResponse (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.responses) SagaRouter (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.runtime) ScenarioContext (class in angzarr_client) (class in angzarr_client.testing) (class in angzarr_client.testing.context) send_to_dead_letter (angzarr_client.compensation.DelegationOptions attribute) (angzarr_client.DelegationOptions attribute) sequence_for() (angzarr_client.Destinations method) (angzarr_client.destinations.Destinations method) sequence_num() (angzarr_client.CommandPage method) (angzarr_client.EventPage method) (angzarr_client.wrappers.CommandPage method) (angzarr_client.wrappers.EventPage method) sequences (angzarr_client.Destinations attribute) (angzarr_client.destinations.Destinations attribute) server (angzarr_client.server.ServerHandle attribute) ServerConfig (class in angzarr_client) (class in angzarr_client.server) ServerHandle (class in angzarr_client.server) source_aggregate (angzarr_client.compensation.CompensationContext attribute) (angzarr_client.CompensationContext attribute) source_domain (angzarr_client.compensation.CompensationContext property) (angzarr_client.CompensationContext property)

source_event_sequence (angzarr_client.compensation.CompensationContext attribute) (angzarr_client.CompensationContext attribute) source_root (angzarr_client.compensation.CompensationContext property) (angzarr_client.CompensationContext property) speculative (angzarr_client.client.DomainClient attribute) (angzarr_client.DomainClient attribute) SpeculativeClient (class in angzarr_client) (class in angzarr_client.client) stamp_command() (angzarr_client.Destinations method) (angzarr_client.destinations.Destinations method) STANDALONE (angzarr_client.client.TransportMode attribute) (angzarr_client.TransportMode attribute) state (angzarr_client.ScenarioContext attribute), [1] (angzarr_client.testing.context.ScenarioContext attribute), [1] (angzarr_client.testing.ScenarioContext attribute), [1] state_factory() (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) status() (angzarr_client.errors.GRPCError method) (angzarr_client.GRPCError method) status_code (angzarr_client.CommandRejectedError attribute) (angzarr_client.errors.CommandRejectedError attribute) STATUS_FORBIDDEN (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) STATUS_MISMATCH (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) supports_handle_fact() (angzarr_client.CommandHandlerRouter method) (angzarr_client.router.CommandHandlerRouter method) (angzarr_client.router.runtime.CommandHandlerRouter method) supports_replay() (angzarr_client.CommandHandlerRouter method) (angzarr_client.router.CommandHandlerRouter method) (angzarr_client.router.runtime.CommandHandlerRouter method) sync_output_domains() (angzarr_client.ProcessManagerRouter method) (angzarr_client.router.ProcessManagerRouter method) (angzarr_client.router.runtime.ProcessManagerRouter method) (angzarr_client.router.runtime.SagaRouter method) (angzarr_client.router.SagaRouter method) (angzarr_client.SagaRouter method)

T

T (in module angzarr_client.helpers) (in module angzarr_client.retry) (in module angzarr_client.router.decorators) (in module angzarr_client.wrappers) temporal_by_sequence() (in module angzarr_client.helpers) temporal_by_time() (in module angzarr_client.helpers) testing_pack_event() (in module angzarr_client) TIMESTAMP_PARSE_FAILED (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) to_proto_bytes() (in module angzarr_client) (in module angzarr_client.identity) TRANSPORT_ERROR (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) transport_signal (angzarr_client.server.ServerHandle attribute) TransportError, [1] TransportMode (class in angzarr_client) (class in angzarr_client.client) TransportProbe (class in angzarr_client.readiness)

TransportSignal (class in angzarr_client.readiness) try_unpack() (in module angzarr_client.helpers) type_matches() (in module angzarr_client.helpers) type_name_from_url() (in module angzarr_client) (in module angzarr_client.helpers) TYPE_URL (in module angzarr_client.error_codes.keys) type_url() (angzarr_client.CommandPage method) (angzarr_client.EventPage method) (angzarr_client.wrappers.CommandPage method) (angzarr_client.wrappers.EventPage method) (in module angzarr_client) (in module angzarr_client.helpers) type_url_matches() (in module angzarr_client) (in module angzarr_client.helpers) type_url_matches_exact (in module angzarr_client) (in module angzarr_client.helpers) TYPE_URL_PREFIX (in module angzarr_client) (in module angzarr_client.helpers) (in module angzarr_client.wrappers)

U

uds_path (angzarr_client.server.ServerConfig attribute) (angzarr_client.ServerConfig attribute) UNKNOWN_DOMAIN (in module angzarr_client) (in module angzarr_client.helpers) (in module angzarr_client.wrappers) unpack() (in module angzarr_client.helpers) Upcast() (angzarr_client.router.server.UpcasterGrpc method) (angzarr_client.UpcasterGrpc method) upcaster() (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) UPCASTER_WRONG_RESPONSE_KIND (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) UpcasterGrpc (class in angzarr_client) (class in angzarr_client.router.server) UpcasterRouter (class in angzarr_client) (class in angzarr_client.router) (class in angzarr_client.router.runtime)

upcasts() (in module angzarr_client) (in module angzarr_client.router) (in module angzarr_client.router.decorators) uuid_for() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.uuid) uuid_obj_for() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.uuid) uuid_str_for() (in module angzarr_client) (in module angzarr_client.testing) (in module angzarr_client.testing.uuid) uuid_to_proto() (in module angzarr_client) (in module angzarr_client.helpers)

V

validate_handler() (in module angzarr_client.router.validation) VALUE_EMPTY (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages)

VALUE_NOT_NON_NEGATIVE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages) VALUE_NOT_POSITIVE (in module angzarr_client.error_codes.codes) (in module angzarr_client.error_codes.messages)

W

WILDCARD_DOMAIN (in module angzarr_client) (in module angzarr_client.helpers) wire_name() (in module angzarr_client.helpers) with_command() (angzarr_client.builder.CommandBuilder method) (angzarr_client.CommandBuilder method) with_correlation_id() (angzarr_client.builder.CommandBuilder method) (angzarr_client.CommandBuilder method) with_edition (angzarr_client.builder.QueryBuilder attribute) (angzarr_client.QueryBuilder attribute)

with_handler() (angzarr_client.Router method) (angzarr_client.router.builder.Router method) (angzarr_client.router.Router method) with_merge_strategy() (angzarr_client.builder.CommandBuilder method) (angzarr_client.CommandBuilder method) with_sequence() (angzarr_client.builder.CommandBuilder method) (angzarr_client.CommandBuilder method) Wrapped (class in angzarr_client) (class in angzarr_client.wrappers)