Index

_

__init__() (amqp.adapter.backpressure_handler.BackpressureHandler method) (amqp.adapter.backpressure_handler.ScaleRequestV1 method) (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) (amqp.adapter.data_message_factory.DataMessageFactory method) (amqp.adapter.data_parser.MultipartFormDataParser method) (amqp.adapter.file_handler.FileHandler method) (amqp.adapter.file_handler.StreamingFileHandler method) (amqp.adapter.service_message_factory.ServiceMessageFactory method) (amqp.adapter.trace_info_adapter.TraceInfoAdapter method) (amqp.adapter.type_descriptor.TypeDescriptor method) (amqp.config.amq_configuration.AMQAdapter method) (amqp.config.amq_configuration.AMQConfiguration method) (amqp.config.amq_configuration.Backpressure method) (amqp.config.amq_configuration.Dispatch method) (amqp.model.model.AMQErrorMessage method) (amqp.model.model.AMQMessage method) (amqp.model.model.AMQRoute method) (amqp.model.model.CleverMicroMessage method) (amqp.model.model.DataMessage method) (amqp.model.model.DataResponse method) (amqp.model.model.MultipartDataMessage method) (amqp.model.model.ScalingRequest method) (amqp.model.model.ServiceMessage method) (amqp.model.snowflake_id.SnowflakeId method) (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient method) (amqp.rabbitmq.user_management_service_client.UserManagementServiceException method) (amqp.router.route_database.RouteDatabase method) (amqp.router.router_base.RouterBase method) (amqp.router.router_consumer.RouterConsumer method) (amqp.router.router_producer.RouterProducer method) (amqp.service.amq_message_handler.DataMessageHandler method) (amqp.service.amq_service.AMQService method) (amqp.service.tracing.MetricsConfig method) (amqp.service.tracing.TracingConfig method)

A

adapter_prefix() (amqp.config.amq_configuration.AMQAdapter method) add_own_route() (amqp.router.router_base.RouterBase method) add_route() (amqp.router.route_database.RouteDatabase method) (amqp.router.router_base.RouterBase method) add_routes() (amqp.router.router_base.RouterBase method) add_to_map() (in module amqp.adapter.serializer) additional_attributes (amqp.service.tracing.MetricsConfig attribute) (amqp.service.tracing.TracingConfig attribute) amq_message_routing_key() (amqp.adapter.data_message_factory.DataMessageFactory static method) AMQAdapter (class in amqp.config.amq_configuration) AMQConfiguration (class in amqp.config.amq_configuration) AMQDataParser (class in amqp.adapter.data_parser) AMQErrorMessage (class in amqp.model.model) AMQMessage (class in amqp.model.model) amqp module amqp.adapter module amqp.adapter.amq_route_factory module amqp.adapter.backpressure_handler module amqp.adapter.cleverthis_service_adapter module amqp.adapter.consul_global_id_generator module amqp.adapter.data_message_factory module amqp.adapter.data_parser module amqp.adapter.data_response_factory module amqp.adapter.file_handler module amqp.adapter.logging_utils module amqp.adapter.pydantic_serializer module amqp.adapter.serializer module amqp.adapter.service_message_factory module amqp.adapter.trace_info_adapter module amqp.adapter.type_descriptor module amqp.config module

amqp.config.amq_configuration module amqp.model module amqp.model.model module amqp.model.service_message_type module amqp.model.snowflake_id module amqp.rabbitmq module amqp.rabbitmq.rabbit_mq_client module amqp.rabbitmq.user_management_service_client module amqp.router module amqp.router.route_database module amqp.router.router_base module amqp.router.router_consumer module amqp.router.router_producer module amqp.router.utils module amqp.service module amqp.service.amq_message_handler module amqp.service.amq_service module amqp.service.tracing module AMQResponse (in module amqp.model.model) AMQResponseFactory (in module amqp.adapter.data_response_factory) AMQRoute (class in amqp.model.model) AMQRouteFactory (class in amqp.adapter.amq_route_factory) AMQService (class in amqp.service.amq_service) as_base64() (amqp.adapter.service_message_factory.ServiceMessageFactory method) as_string() (amqp.model.model.AMQRoute method) (amqp.model.snowflake_id.SnowflakeId method) await_future() (in module amqp.router.utils) await_result() (in module amqp.router.utils)

B

BACKPRESSURE (amqp.model.service_message_type.ServiceMessageType attribute) Backpressure (class in amqp.config.amq_configuration) backpressure() (amqp.service.amq_service.AMQService method) backpressure_monitor_loop() (amqp.adapter.backpressure_handler.BackpressureHandler method)

BackpressureHandler (class in amqp.adapter.backpressure_handler) base64body() (amqp.model.model.CleverMicroMessage method) body() (amqp.model.model.CleverMicroMessage method) bytes_to_long() (in module amqp.adapter.serializer)

C

call_cleverthis_api() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) call_service() (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient method) check_overload_condition() (amqp.adapter.backpressure_handler.BackpressureHandler method) cleanup() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) (amqp.router.router_consumer.RouterConsumer method) (amqp.service.amq_service.AMQService method) CLEVER_AMQP_CLIENT_VERSION (amqp.service.amq_service.AMQService attribute) CleverMicroMessage (class in amqp.model.model) CleverThisServiceAdapter (class in amqp.adapter.cleverthis_service_adapter) clone_and_adapt_route() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) close() (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient method) collect_trace_info() (in module amqp.service.amq_message_handler)

command() (amqp.service.amq_service.AMQService method) component_name (amqp.model.model.AMQRoute attribute) connection (amqp.model.model.AMQMessage property) content_type() (amqp.model.model.CleverMicroMessage method) create_async_response_message() (amqp.adapter.data_response_factory.DataResponseFactory static method) create_produce_span() (amqp.adapter.trace_info_adapter.TraceInfoAdapter static method) create_request_message() (amqp.adapter.data_message_factory.DataMessageFactory method) create_resource() (in module amqp.service.tracing) create_rpc_message() (amqp.adapter.data_message_factory.DataMessageFactory method) create_span() (in module amqp.service.tracing) csv_as_list() (in module amqp.adapter.serializer) current_availability (amqp.adapter.backpressure_handler.BackpressureHandler attribute) (amqp.model.model.ScalingRequest attribute)

D

d_field() (amqp.model.model.CleverMicroMessage method) data_message_generator() (amqp.service.amq_service.AMQService method) DataMessage (class in amqp.model.model) DataMessageFactory (class in amqp.adapter.data_message_factory) DataMessageHandler (class in amqp.service.amq_message_handler) DataMessageMagicByte (class in amqp.model.model) DataResponse (class in amqp.model.model) DataResponseFactory (class in amqp.adapter.data_response_factory) debug (amqp.service.tracing.TracingConfig attribute) decrease_current_load() (amqp.adapter.backpressure_handler.BackpressureHandler method)

DEFAULT_CONTENT_TYPE (amqp.model.model.CleverMicroMessage attribute) delete() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) deserialize_object() (in module amqp.adapter.pydantic_serializer) Dispatch (class in amqp.config.amq_configuration) DLQ_ARGS (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient attribute) domain() (amqp.model.model.DataMessage method) download_buffer() (amqp.adapter.file_handler.FileHandler method) (amqp.adapter.file_handler.StreamingFileHandler method) download_file() (amqp.adapter.file_handler.FileHandler method) (amqp.adapter.file_handler.StreamingFileHandler method)

E

ensure_directory_exists() (amqp.adapter.file_handler.FileHandler method) ensure_trace_info() (amqp.service.amq_message_handler.DataMessageHandler method) error() (amqp.model.model.DataResponse method)

error_cause() (amqp.model.model.DataResponse method) exchange (amqp.model.model.AMQRoute attribute) EXCHANGE_NAME (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient attribute) export_interval_millis (amqp.service.tracing.MetricsConfig attribute)

F

FileHandler (class in amqp.adapter.file_handler) find_route() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) (amqp.router.route_database.RouteDatabase method) (amqp.router.router_base.RouterBase method) find_route_by_message() (amqp.router.router_base.RouterBase method) find_route_by_service() (amqp.router.route_database.RouteDatabase method) (amqp.router.router_base.RouterBase method) FORMAT (amqp.model.model.AMQRoute attribute)

format_message_type() (amqp.adapter.service_message_factory.ServiceMessageFactory method) from_bytes() (amqp.adapter.data_message_factory.DataMessageFactory static method) (amqp.adapter.data_response_factory.DataResponseFactory static method) (amqp.adapter.service_message_factory.ServiceMessageFactory method) from_hex() (amqp.model.snowflake_id.SnowflakeId static method) from_json() (amqp.model.model.ScalingRequest class method) from_stream() (amqp.adapter.data_message_factory.DataMessageFactory static method) from_string() (amqp.adapter.amq_route_factory.AMQRouteFactory static method)

G

generate_fallback_id() (in module amqp.adapter.consul_global_id_generator) generate_snowflake_id() (amqp.adapter.data_message_factory.DataMessageFactory method) get() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) get_bits() (amqp.model.snowflake_id.SnowflakeId method) get_bytes() (amqp.model.snowflake_id.SnowflakeId method) get_config_values() (in module amqp.adapter.consul_global_id_generator) get_consume_queue_name() (amqp.router.router_producer.RouterProducer method) get_content_type() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) get_context_info() (in module amqp.adapter.logging_utils) get_current_user() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) get_default_trace_state() (in module amqp.service.amq_message_handler) get_endpoint() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method)

get_instance() (amqp.adapter.data_message_factory.DataMessageFactory class method) get_reply_to_queue_name() (amqp.router.router_producer.RouterProducer method) get_response_queue_name() (amqp.router.router_producer.RouterProducer method) get_routes() (amqp.router.route_database.RouteDatabase method) (amqp.router.router_base.RouterBase method) get_routing_key() (amqp.router.router_base.RouterBase method) get_timestamp_from_id() (amqp.adapter.data_message_factory.DataMessageFactory static method) get_unique_instance_id() (amqp.config.amq_configuration.AMQConfiguration method) (amqp.service.amq_service.AMQService method) (in module amqp.adapter.consul_global_id_generator) group_routes_by_method() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) GROUP_SERVICE (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient attribute)

H

handle_backpressure_overload_event() (amqp.adapter.backpressure_handler.BackpressureHandler method) handle_body_payload() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) handle_no_body_payload() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) handle_routing_data_message() (amqp.router.router_producer.RouterProducer method)

handle_routing_data_request_message() (amqp.router.router_consumer.RouterConsumer method) head() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) headers() (amqp.model.model.CleverMicroMessage method) HTTP_REQUEST (amqp.model.model.DataMessageMagicByte attribute)

I

id (amqp.model.model.ServiceMessage attribute) id() (amqp.model.model.CleverMicroMessage method) IDLE (amqp.model.model.ScalingRequestAlert attribute) inbound_data_message_callback_as_thread() (amqp.service.amq_message_handler.DataMessageHandler method) inbound_data_message_callback_no_thread() (amqp.service.amq_message_handler.DataMessageHandler method) increase_current_load() (amqp.adapter.backpressure_handler.BackpressureHandler method) init() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) (amqp.service.amq_service.AMQService method) init_internal_routing_paths() (amqp.router.router_producer.RouterProducer method)

init_routing_paths_consumer() (amqp.router.router_consumer.RouterConsumer method) initialize() (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient method) initialize_telemetry() (in module amqp.service.tracing) insecure (amqp.service.tracing.TracingConfig attribute) instantiate() (amqp.adapter.type_descriptor.TypeDescriptor method) invoke_command() (in module amqp.service.amq_message_handler) is_likely_json() (in module amqp.adapter.cleverthis_service_adapter) is_open() (amqp.router.router_producer.RouterProducer method) is_valid() (amqp.model.model.ServiceMessage method)

K

key (amqp.model.model.AMQRoute attribute)

L

last_backpressure_event (amqp.adapter.backpressure_handler.BackpressureHandler attribute) last_backpressure_event_time (amqp.adapter.backpressure_handler.BackpressureHandler attribute) list_users_in_group() (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient method) logging_debug() (in module amqp.adapter.logging_utils)

logging_error() (in module amqp.adapter.logging_utils) logging_info() (in module amqp.adapter.logging_utils) logging_warning() (in module amqp.adapter.logging_utils) long_to_bytes() (in module amqp.adapter.serializer)

M

m_field() (amqp.model.model.CleverMicroMessage method) MACHINE_ID_BITS (amqp.adapter.data_message_factory.DataMessageFactory attribute) MACHINE_ID_MASK (amqp.adapter.data_message_factory.DataMessageFactory attribute) magic() (amqp.model.model.CleverMicroMessage method) map_as_string() (in module amqp.adapter.serializer) map_with_list_as_string() (in module amqp.adapter.serializer) matches() (amqp.router.route_database.RouteDatabase method) max_availability (amqp.model.model.ScalingRequest attribute) MAX_WAIT (amqp.service.amq_service.AMQService attribute) merge_extra_init_data() (in module amqp.adapter.type_descriptor) message (amqp.model.model.ServiceMessage attribute) message_type (amqp.model.model.ServiceMessage attribute) method() (amqp.model.model.DataMessage method) MetricsConfig (class in amqp.service.tracing) module amqp amqp.adapter amqp.adapter.amq_route_factory amqp.adapter.backpressure_handler amqp.adapter.cleverthis_service_adapter amqp.adapter.consul_global_id_generator amqp.adapter.data_message_factory amqp.adapter.data_parser amqp.adapter.data_response_factory amqp.adapter.file_handler amqp.adapter.logging_utils amqp.adapter.pydantic_serializer amqp.adapter.serializer amqp.adapter.service_message_factory amqp.adapter.trace_info_adapter amqp.adapter.type_descriptor amqp.config amqp.config.amq_configuration amqp.model amqp.model.model amqp.model.service_message_type amqp.model.snowflake_id amqp.rabbitmq amqp.rabbitmq.rabbit_mq_client amqp.rabbitmq.user_management_service_client amqp.router amqp.router.route_database amqp.router.router_base amqp.router.router_consumer amqp.router.router_producer amqp.router.utils amqp.service amqp.service.amq_message_handler amqp.service.amq_service amqp.service.tracing

MultipartDataMessage (class in amqp.model.model) MultipartFormDataParser (class in amqp.adapter.data_parser)

O

object_or_list_as_string() (in module amqp.adapter.serializer) of() (amqp.adapter.data_response_factory.DataResponseFactory static method) (amqp.adapter.service_message_factory.ServiceMessageFactory method) of_error_message() (amqp.adapter.data_response_factory.DataResponseFactory static method) on_field() (amqp.adapter.data_parser.MultipartFormDataParser method) on_file() (amqp.adapter.data_parser.MultipartFormDataParser method)

on_message() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) (amqp.adapter.file_handler.FileHandler method) (amqp.adapter.file_handler.StreamingFileHandler method) on_rpc() (amqp.service.amq_message_handler.DataMessageHandler method) options() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) otlp_endpoint (amqp.service.tracing.TracingConfig attribute) OVERLOAD (amqp.model.model.ScalingRequestAlert attribute)

P

p_field() (amqp.model.model.CleverMicroMessage method) parse_get_url() (amqp.adapter.data_parser.AMQDataParser static method) parse_map_list_string() (in module amqp.adapter.serializer) parse_map_string() (in module amqp.adapter.serializer) parse_request_body() (amqp.adapter.data_parser.AMQDataParser static method) parse_url_query() (in module amqp.adapter.pydantic_serializer) patch() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) path() (amqp.model.model.DataMessage method) pattern() (amqp.router.route_database.RouteDatabase method) payload_type (amqp.model.model.ServiceMessage attribute) PERMISSION_SERVICE (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient attribute) post() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) PREFETCH_COUNT (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient attribute)

PREFIX (amqp.config.amq_configuration.AMQAdapter attribute) (amqp.config.amq_configuration.Backpressure attribute) (amqp.config.amq_configuration.Dispatch attribute) primary_key (amqp.model.model.AMQRoute property) process_form_data() (amqp.adapter.data_parser.AMQDataParser static method) prometheus_host (amqp.service.tracing.MetricsConfig attribute) prometheus_port (amqp.service.tracing.MetricsConfig attribute) publish_backpressure_request() (amqp.adapter.backpressure_handler.BackpressureHandler method) publish_file() (amqp.adapter.file_handler.FileHandler method) (amqp.adapter.file_handler.StreamingFileHandler method) publish_service_message() (amqp.router.router_producer.RouterProducer method) put() (amqp.adapter.cleverthis_service_adapter.CleverThisServiceAdapter method) python_type_to_json() (in module amqp.adapter.pydantic_serializer)

Q

query_user_by_id() (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient method)

queue (amqp.model.model.AMQRoute attribute)

R

RabbitMQClient (class in amqp.rabbitmq.rabbit_mq_client) read_long() (in module amqp.adapter.serializer) recipient_name (amqp.model.model.ServiceMessage attribute) reconstitute_data_message() (amqp.service.amq_message_handler.DataMessageHandler method) record_duration() (amqp.service.amq_message_handler.DataMessageHandler method) register_data_reply_callback() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) register_inbound_routes() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) register_route() (amqp.router.router_consumer.RouterConsumer method) register_routes() (amqp.service.amq_service.AMQService method) reinitialize_if_disconnected() (amqp.service.amq_service.AMQService method) remove_outstanding_future() (amqp.service.amq_service.AMQService method) remove_route() (amqp.router.route_database.RouteDatabase method) (amqp.router.router_base.RouterBase method) remove_route_on_cleanup() (amqp.router.router_consumer.RouterConsumer method) remove_routes() (amqp.router.router_base.RouterBase method) reply_received_callback() (amqp.service.amq_message_handler.DataMessageHandler method) reply_to (amqp.model.model.ServiceMessage attribute) request_routes() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) request_routes_from_adapters() (amqp.router.router_producer.RouterProducer method)

request_type (amqp.model.model.ScalingRequest attribute) response_code() (amqp.model.model.DataResponse method) RESPONSE_QUEUE_NAME (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient attribute) return_address() (amqp.model.model.CleverMicroMessage method) RouteDatabase (class in amqp.router.route_database) RouterBase (class in amqp.router.router_base) RouterConsumer (class in amqp.router.router_consumer) RouterProducer (class in amqp.router.router_producer) ROUTING_DATA (amqp.model.service_message_type.ServiceMessageType attribute) ROUTING_DATA_REMOVE (amqp.model.service_message_type.ServiceMessageType attribute) ROUTING_DATA_REPLACE (amqp.model.service_message_type.ServiceMessageType attribute) ROUTING_DATA_REQUEST (amqp.model.service_message_type.ServiceMessageType attribute) routing_key() (amqp.model.model.DataMessage method) rpc() (amqp.service.amq_service.AMQService method) RPC_REQUEST (amqp.model.model.DataMessageMagicByte attribute) RS (in module amqp.model.model) run() (amqp.service.amq_service.AMQService method) run_http_request_magic() (amqp.service.amq_message_handler.DataMessageHandler method) run_rpc_request() (amqp.service.amq_message_handler.DataMessageHandler method)

S

safe_rsplit() (amqp.adapter.data_message_factory.DataMessageFactory method) sanitize_as_rabbitmq_domain_name() (in module amqp.router.utils) sanitize_as_rabbitmq_name() (in module amqp.router.utils) SCALE_DOWN (amqp.model.model.ScalingRequestAlert attribute) SCALE_UP (amqp.model.model.ScalingRequestAlert attribute) ScaleRequestV1 (class in amqp.adapter.backpressure_handler) ScalingRequest (class in amqp.model.model) ScalingRequestAlert (class in amqp.model.model) send_command() (amqp.service.amq_message_handler.DataMessageHandler method) send_message() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) send_reply() (amqp.service.amq_message_handler.DataMessageHandler method) send_rpc() (amqp.service.amq_message_handler.DataMessageHandler method) SEQUENCE_BITS (amqp.adapter.data_message_factory.DataMessageFactory attribute) SEQUENCE_MASK (amqp.adapter.data_message_factory.DataMessageFactory attribute) serialize() (amqp.adapter.data_message_factory.DataMessageFactory static method) (amqp.adapter.data_response_factory.DataResponseFactory static method) (amqp.adapter.service_message_factory.ServiceMessageFactory method) (amqp.model.model.AMQErrorMessage method) serialize_object() (in module amqp.adapter.pydantic_serializer)

service_id (amqp.model.model.ScalingRequest attribute) service_name (amqp.service.tracing.TracingConfig attribute) service_version (amqp.service.tracing.TracingConfig attribute) ServiceMessage (class in amqp.model.model) ServiceMessageFactory (class in amqp.adapter.service_message_factory) ServiceMessageType (class in amqp.model.service_message_type) set_outstanding_future() (amqp.service.amq_service.AMQService method) set_route_added_notifier() (amqp.router.router_base.RouterBase method) set_text() (in module amqp.service.amq_message_handler) setup_amq_channel() (amqp.rabbitmq.rabbit_mq_client.RabbitMQClient method) setup_metrics_provider() (in module amqp.service.tracing) setup_otlp_exporter() (in module amqp.service.tracing) setup_trace_provider() (in module amqp.service.tracing) snowflake_epoch (amqp.adapter.data_message_factory.DataMessageFactory attribute) SNOWFLAKE_ID_BITS (amqp.adapter.data_message_factory.DataMessageFactory attribute) SNOWFLAKE_ID_WIDTH (amqp.model.snowflake_id.SnowflakeId attribute) SnowflakeId (class in amqp.model.snowflake_id) start_backpressure_monitor() (amqp.adapter.backpressure_handler.BackpressureHandler method) str_to_bool() (in module amqp.adapter.serializer) StreamingFileHandler (class in amqp.adapter.file_handler)

T

task_id (amqp.model.model.ScalingRequest attribute) TENANT_SERVICE (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient attribute) timeout (amqp.model.model.AMQRoute attribute) TIMESTAMP_BITS (amqp.adapter.data_message_factory.DataMessageFactory attribute) to_json() (amqp.adapter.backpressure_handler.ScaleRequestV1 method) (amqp.model.model.ScalingRequest method) to_string() (amqp.adapter.data_message_factory.DataMessageFactory static method) (amqp.adapter.service_message_factory.ServiceMessageFactory method)

TOKEN_SERVICE (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient attribute) trace_info (amqp.model.model.ServiceMessage attribute) trace_info() (amqp.model.model.CleverMicroMessage method) TraceInfoAdapter (class in amqp.adapter.trace_info_adapter) TracingConfig (class in amqp.service.tracing) try_deserialize_object() (in module amqp.adapter.pydantic_serializer) TypeDescriptor (class in amqp.adapter.type_descriptor)

U

UNKNOWN (amqp.model.service_message_type.ServiceMessageType attribute) unwrap_route_list() (amqp.router.router_base.RouterBase method) UPDATE (amqp.model.model.ScalingRequestAlert attribute) update_backpressure_value() (amqp.adapter.backpressure_handler.BackpressureHandler method)

update_current_availability() (amqp.adapter.backpressure_handler.BackpressureHandler method) update_last_backpressure_event_time() (amqp.adapter.backpressure_handler.BackpressureHandler method) USER_SERVICE (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient attribute) UserManagementServiceClient (class in amqp.rabbitmq.user_management_service_client) UserManagementServiceException

V

valid_until (amqp.model.model.AMQRoute attribute) validate() (amqp.adapter.amq_route_factory.AMQRouteFactory static method)

validate_token() (amqp.rabbitmq.user_management_service_client.UserManagementServiceClient method) version (amqp.model.model.ScalingRequest attribute)

W

wrap_own_routes() (amqp.router.router_base.RouterBase method)

wrap_routes() (amqp.router.route_database.RouteDatabase method) (amqp.router.router_base.RouterBase method)