Index

A

add_days() (in module python_technical_primitives.datetime.operations) add_event() (python_outbox_core.repository.IOutboxRepository method) add_hours() (in module python_technical_primitives.datetime.operations) add_pipeline_behavior() (gridflow_python_mediator.mediator.Mediator method) (python_cqrs_dispatcher.dispatcher.CQRSDispatcher method) add_transform() (python_dto_mappers.auto_mapper.AutoMapper method) aggregate_id (python_outbox_core.events.IOutboxEvent attribute) allowed_origins (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute) AndSpecification (class in python_technical_primitives.patterns.compositions)

api_v1_str (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute) arbitrary_types_allowed (sqlalchemy_async_repositories.use_cases.create.command_model.CreateCommand.Config attribute) (sqlalchemy_async_repositories.use_cases.delete.command_model.DeleteCommand.Config attribute) (sqlalchemy_async_repositories.use_cases.exists.query_model.ExistsQuery.Config attribute) (sqlalchemy_async_repositories.use_cases.get_by_id.query_model.GetByIdQuery.Config attribute) (sqlalchemy_async_repositories.use_cases.update.command_model.UpdateCommand.Config attribute) assemble_cors_origins() (in module fastapi_config_patterns.validators) auto_map() (in module python_dto_mappers.decorators) auto_register_handlers() (in module python_cqrs_dispatcher.registry) AutoMapper (class in python_dto_mappers.auto_mapper)

B

BaseApplicationException BaseCommand (class in python_cqrs_core.base_command) BaseDatabaseSettings (class in fastapi_config_patterns.database_settings) BaseDomainEvent (class in python_domain_events.base) BaseFastAPISettings (class in fastapi_config_patterns.base_settings)

BaseMapper (class in python_dto_mappers.base) BaseQuery (class in python_cqrs_core.base_query) BaseRepository (class in sqlalchemy_async_repositories.base) batch_size (python_outbox_core.config.OutboxConfig attribute) broker (python_infrastructure_exceptions.messaging.MessageQueueError attribute) BusinessLogicError (class in python_app_exceptions.business)

C

cache_backend (python_infrastructure_exceptions.cache.CacheError attribute) CacheControlMiddleware (class in fastapi_middleware_toolkit.cache_control) CacheError (class in python_infrastructure_exceptions.cache) causation_id (python_domain_events.base.BaseDomainEvent attribute) (python_outbox_core.events.IOutboxEvent attribute) chain_map() (in module python_dto_mappers.utils) check_broker() (python_outbox_core.health_check.OutboxHealthCheck method) check_database() (python_outbox_core.health_check.OutboxHealthCheck method) check_health() (python_outbox_core.health_check.OutboxHealthCheck method) check_outbox_lag() (python_outbox_core.health_check.OutboxHealthCheck method) clear() (python_domain_events.dispatcher.InProcessEventDispatcher method) CloudEventsFormatter (class in python_outbox_core.formatters.cloudevents) code (pydantic_response_models.responses.ErrorDetail attribute) (pydantic_response_models.responses.ErrorResponse attribute) config_key (python_infrastructure_exceptions.configuration.ConfigurationError attribute) ConfigurationError configure_for_development() (in module python_structlog_config.presets) configure_for_production() (in module python_structlog_config.presets) configure_for_testing() (in module python_structlog_config.presets) configure_structlog() (in module python_structlog_config.config) consumer_group (python_outbox_core.adapters.examples.kong_simple.KongSimpleFormatter attribute) contains_surrogates() (in module postgres_data_sanitizers.string_validators)

correlation_id (python_cqrs_core.base_command.BaseCommand attribute) (python_cqrs_core.base_query.BaseQuery attribute) (python_domain_events.base.BaseDomainEvent attribute) (python_outbox_core.events.IOutboxEvent attribute) cors_allow_credentials (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute) cors_max_age (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute) count() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.interfaces.IRepository method) count_unpublished() (python_outbox_core.repository.IOutboxRepository method) CountHandler (class in sqlalchemy_async_repositories.use_cases.count.query_handler) CountQuery (class in sqlalchemy_async_repositories.use_cases.count.query_model) CQRSDispatcher (class in python_cqrs_dispatcher.dispatcher) create() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.interfaces.IRepository method) (sqlalchemy_async_repositories.use_cases.find_paginated.strategy_factory.PaginationStrategyFactory static method) create_async_engine_with_pool() (in module sqlalchemy_async_session_factory.engine) create_async_session_maker() (in module sqlalchemy_async_session_factory.session) create_health_check_endpoint() (in module fastapi_middleware_toolkit.lifespan) create_lifespan_manager() (in module fastapi_middleware_toolkit.lifespan) create_session_dependency() (in module sqlalchemy_async_session_factory.session) CreateCommand (class in sqlalchemy_async_repositories.use_cases.create.command_model) CreateCommand.Config (class in sqlalchemy_async_repositories.use_cases.create.command_model) CreateHandler (class in sqlalchemy_async_repositories.use_cases.create.command_handler)

D

data (pydantic_response_models.responses.SuccessResponse attribute) data_content_type (python_outbox_core.formatters.cloudevents.CloudEventsFormatter attribute) data_version (python_outbox_core.events.IOutboxEvent attribute) database_url (fastapi_config_patterns.database_settings.BaseDatabaseSettings attribute) DatabaseError (class in python_infrastructure_exceptions.database) days_until() (in module python_technical_primitives.datetime.operations) db (sqlalchemy_async_repositories.base.BaseRepository attribute) (sqlalchemy_async_repositories.use_cases.count.query_handler.CountHandler attribute) (sqlalchemy_async_repositories.use_cases.create.command_handler.CreateHandler attribute) (sqlalchemy_async_repositories.use_cases.delete.command_handler.DeleteHandler attribute) (sqlalchemy_async_repositories.use_cases.exists.query_handler.ExistsHandler attribute) (sqlalchemy_async_repositories.use_cases.find_paginated.query_handler.FindPaginatedHandler attribute) (sqlalchemy_async_repositories.use_cases.get_all.query_handler.GetAllHandler attribute) (sqlalchemy_async_repositories.use_cases.get_by_id.query_handler.GetByIdHandler attribute) (sqlalchemy_async_repositories.use_cases.update.command_handler.UpdateHandler attribute) debug (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute) default_cache_control (fastapi_middleware_toolkit.cache_control.CacheControlMiddleware attribute)

default_topic (python_outbox_core.adapters.examples.kafka_routing.PartitionKeyRouter attribute) DEGRADED (python_outbox_core.health_check.HealthStatus attribute) delete() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.interfaces.IRepository method) DeleteCommand (class in sqlalchemy_async_repositories.use_cases.delete.command_model) DeleteCommand.Config (class in sqlalchemy_async_repositories.use_cases.delete.command_model) DeleteHandler (class in sqlalchemy_async_repositories.use_cases.delete.command_handler) description (python_technical_primitives.patterns.base.Specification attribute) (python_technical_primitives.patterns.compositions.AndSpecification attribute) (python_technical_primitives.patterns.compositions.NotSpecification attribute) (python_technical_primitives.patterns.compositions.OrSpecification attribute) details (pydantic_response_models.responses.ErrorResponse attribute) (python_app_exceptions.base.BaseApplicationException attribute) (python_infrastructure_exceptions.base.InfrastructureException attribute) direction (sqlalchemy_async_repositories.pagination.models.SortSpec attribute) dispatch() (fastapi_middleware_toolkit.cache_control.CacheControlMiddleware method) (python_domain_events.dispatcher.InProcessEventDispatcher method)

E

email_field() (in module pydantic_response_models.fields) enable_health_check (python_outbox_core.config.OutboxConfig attribute) enable_metrics (python_outbox_core.config.OutboxConfig attribute) enrich_metadata() (python_outbox_core.adapters.examples.kafka_routing.KafkaRoutingFormatter method) (python_outbox_core.adapters.examples.kong_simple.KongSimpleFormatter method) (python_outbox_core.formatters.cloudevents.CloudEventsFormatter method) entity (sqlalchemy_async_repositories.use_cases.create.command_model.CreateCommand attribute) (sqlalchemy_async_repositories.use_cases.update.command_model.UpdateCommand attribute) entity_id (sqlalchemy_async_repositories.use_cases.delete.command_model.DeleteCommand attribute) (sqlalchemy_async_repositories.use_cases.exists.query_model.ExistsQuery attribute) (sqlalchemy_async_repositories.use_cases.get_by_id.query_model.GetByIdQuery attribute) env_prefix (python_outbox_core.config.OutboxConfig.Config attribute) error (pydantic_response_models.responses.ErrorResponse attribute) error_handler (python_outbox_core.publisher.base.OutboxPublisherBase attribute) ErrorDetail (class in pydantic_response_models.responses) ErrorResponse (class in pydantic_response_models.responses) errors (python_technical_primitives.patterns.base.Specification property) escape_null_chars() (in module postgres_data_sanitizers.escape) event_id (python_domain_events.base.BaseDomainEvent attribute) (python_outbox_core.events.IOutboxEvent attribute)

event_type (python_domain_events.base.BaseDomainEvent attribute) (python_outbox_core.events.IOutboxEvent attribute) execute() (sqlalchemy_async_repositories.pagination.strategies.base.IPaginationStrategy method) (sqlalchemy_async_repositories.pagination.strategies.fastcrud_strategy.FastCRUDStrategy method) (sqlalchemy_async_repositories.pagination.strategies.native_strategy.NativeStrategy method) (sqlalchemy_async_repositories.use_cases.count.query_handler.CountHandler method) (sqlalchemy_async_repositories.use_cases.create.command_handler.CreateHandler method) (sqlalchemy_async_repositories.use_cases.delete.command_handler.DeleteHandler method) (sqlalchemy_async_repositories.use_cases.exists.query_handler.ExistsHandler method) (sqlalchemy_async_repositories.use_cases.find_paginated.query_handler.FindPaginatedHandler method) (sqlalchemy_async_repositories.use_cases.get_all.query_handler.GetAllHandler method) (sqlalchemy_async_repositories.use_cases.get_by_id.query_handler.GetByIdHandler method) (sqlalchemy_async_repositories.use_cases.update.command_handler.UpdateHandler method) exists() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.interfaces.IRepository method) ExistsHandler (class in sqlalchemy_async_repositories.use_cases.exists.query_handler) ExistsQuery (class in sqlalchemy_async_repositories.use_cases.exists.query_model) ExistsQuery.Config (class in sqlalchemy_async_repositories.use_cases.exists.query_model) ExternalServiceError (class in python_infrastructure_exceptions.external_services) extract_changed_fields() (in module python_dto_mappers.utils) extract_extension() (in module python_technical_primitives.text.operations)

F

fastapi_config_patterns module fastapi_config_patterns.base_settings module fastapi_config_patterns.database_settings module fastapi_config_patterns.validators module fastapi_middleware_toolkit module fastapi_middleware_toolkit.cache_control module fastapi_middleware_toolkit.cors module fastapi_middleware_toolkit.error_handlers module fastapi_middleware_toolkit.lifespan module

FastCRUDStrategy (class in sqlalchemy_async_repositories.pagination.strategies.fastcrud_strategy) field (pydantic_response_models.responses.ErrorDetail attribute) (sqlalchemy_async_repositories.pagination.models.FilterSpec attribute) (sqlalchemy_async_repositories.pagination.models.SortSpec attribute) field_transform() (in module python_dto_mappers.decorators) filters (sqlalchemy_async_repositories.use_cases.find_paginated.query_model.FindPaginatedQuery attribute) FilterSpec (class in sqlalchemy_async_repositories.pagination.models) find_paginated() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.pagination.router.PaginationRouter method) find_paginated_fastcrud() (in module sqlalchemy_async_repositories.pagination_fastcrud) find_paginated_native() (in module sqlalchemy_async_repositories.pagination_native) FindPaginatedHandler (class in sqlalchemy_async_repositories.use_cases.find_paginated.query_handler) FindPaginatedQuery (class in sqlalchemy_async_repositories.use_cases.find_paginated.query_model) format() (python_outbox_core.formatters.base.IEventFormatter method) (python_outbox_core.formatters.cloudevents.CloudEventsFormatter method) from_iso_string() (in module python_technical_primitives.datetime.operations) frozen (python_outbox_core.config.OutboxConfig.Config attribute)

G

get_all() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.interfaces.IRepository method) get_backend_info() (sqlalchemy_async_repositories.use_cases.find_paginated.query_handler.FindPaginatedHandler method) get_backend_name() (sqlalchemy_async_repositories.use_cases.find_paginated.strategy_factory.PaginationStrategyFactory static method) get_by_id() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.interfaces.IRepository method) get_content_type() (python_outbox_core.formatters.base.IEventFormatter method) (python_outbox_core.formatters.cloudevents.CloudEventsFormatter method) get_logger() (in module python_structlog_config.config) get_pagination_backend_info() (sqlalchemy_async_repositories.base.BaseRepository method) get_partition_key() (python_outbox_core.events.IOutboxEvent method) get_unpublished() (python_outbox_core.repository.IOutboxRepository method) GetAllHandler (class in sqlalchemy_async_repositories.use_cases.get_all.query_handler) GetAllQuery (class in sqlalchemy_async_repositories.use_cases.get_all.query_model)

GetByIdHandler (class in sqlalchemy_async_repositories.use_cases.get_by_id.query_handler) GetByIdQuery (class in sqlalchemy_async_repositories.use_cases.get_by_id.query_model) GetByIdQuery.Config (class in sqlalchemy_async_repositories.use_cases.get_by_id.query_model) gridflow_python_mediator module gridflow_python_mediator.behaviors module gridflow_python_mediator.behaviors.observability module gridflow_python_mediator.behaviors.protocol module gridflow_python_mediator.behaviors.validation_behavior module gridflow_python_mediator.mediator module

H

handle() (gridflow_python_mediator.behaviors.observability.LoggingBehavior method) (gridflow_python_mediator.behaviors.observability.TimingBehavior method) (gridflow_python_mediator.behaviors.protocol.PipelineBehavior method) (gridflow_python_mediator.behaviors.validation_behavior.ValidationBehavior method) (python_cqrs_core.command.ICommandHandler method) (python_cqrs_core.query.IQueryHandler method) (python_domain_events.handler.IDomainEventHandler method) (python_outbox_core.publisher.error_handler.OutboxErrorHandler method)

has_fastcrud() (in module sqlalchemy_async_repositories.pagination.models) has_next (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute) has_prev (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute) HealthStatus (class in python_outbox_core.health_check) HEALTHY (python_outbox_core.health_check.HealthStatus attribute) host (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute)

I

ICommand (class in python_cqrs_core.command) ICommandHandler (class in python_cqrs_core.command) IDomainEventHandler (class in python_domain_events.handler) IEventFormatter (class in python_outbox_core.formatters.base) IEventPublisher (class in python_outbox_core.publisher.interface) InfrastructureException InProcessEventDispatcher (class in python_domain_events.dispatcher) InvalidInputError IOutboxEvent (class in python_outbox_core.events) IOutboxEvent.Config (class in python_outbox_core.events) IOutboxRepository (class in python_outbox_core.repository) IPaginationStrategy (class in sqlalchemy_async_repositories.pagination.strategies.base)

IQuery (class in python_cqrs_core.query) IQueryHandler (class in python_cqrs_core.query) IRepository (class in sqlalchemy_async_repositories.interfaces) is_expired() (in module python_technical_primitives.datetime.operations) is_fastcrud_available() (sqlalchemy_async_repositories.use_cases.find_paginated.strategy_factory.PaginationStrategyFactory static method) is_satisfied_by() (python_technical_primitives.patterns.base.Specification method) (python_technical_primitives.patterns.compositions.AndSpecification method) (python_technical_primitives.patterns.compositions.NotSpecification method) (python_technical_primitives.patterns.compositions.OrSpecification method) is_transient_error() (python_outbox_core.publisher.error_handler.OutboxErrorHandler method) is_valid_email() (in module python_technical_primitives.text.operations) items (pydantic_response_models.responses.PaginatedResponse attribute) (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute)

J

json_encoders (python_outbox_core.events.IOutboxEvent.Config attribute)

K

KafkaRoutingFormatter (class in python_outbox_core.adapters.examples.kafka_routing) key (python_infrastructure_exceptions.cache.CacheError attribute)

kong_namespace (python_outbox_core.adapters.examples.kong_simple.KongSimpleFormatter attribute) KongSimpleFormatter (class in python_outbox_core.adapters.examples.kong_simple)

L

left (python_technical_primitives.patterns.compositions.AndSpecification attribute) (python_technical_primitives.patterns.compositions.OrSpecification attribute) limit (sqlalchemy_async_repositories.use_cases.get_all.query_model.GetAllQuery attribute) log_batch_complete() (python_outbox_core.publisher.metrics.OutboxMetrics method) log_batch_started() (python_outbox_core.publisher.metrics.OutboxMetrics method) log_no_events() (python_outbox_core.publisher.metrics.OutboxMetrics method) log_success() (python_outbox_core.publisher.metrics.OutboxMetrics method)

logger (in module fastapi_middleware_toolkit.cache_control) (in module fastapi_middleware_toolkit.error_handlers) (in module fastapi_middleware_toolkit.lifespan) (in module gridflow_python_mediator.behaviors.observability) (in module python_domain_events.dispatcher) (python_outbox_core.publisher.error_handler.OutboxErrorHandler attribute) (python_outbox_core.publisher.metrics.OutboxMetrics attribute) LoggingBehavior (class in gridflow_python_mediator.behaviors.observability)

M

map() (python_dto_mappers.auto_mapper.AutoMapper method) (python_dto_mappers.base.BaseMapper method) (python_dto_mappers.base.Mapper method) map_datetime_to_iso() (in module python_dto_mappers.field_mappers.datetime_mapping) map_iso_to_datetime() (in module python_dto_mappers.field_mappers.datetime_mapping) map_nested_object() (in module python_dto_mappers.field_mappers.object_mapping) mapped_fields (python_dto_mappers.auto_mapper.AutoMapper property) Mapper (class in python_dto_mappers.base) mark_failed() (python_outbox_core.repository.IOutboxRepository method) mark_published() (python_outbox_core.repository.IOutboxRepository method) max_retries (python_outbox_core.publisher.error_handler.OutboxErrorHandler attribute) max_retry_count (python_outbox_core.config.OutboxConfig attribute) Mediator (class in gridflow_python_mediator.mediator) message (pydantic_response_models.responses.ErrorDetail attribute) (pydantic_response_models.responses.MessageResponse attribute) (pydantic_response_models.responses.SuccessResponse attribute) (python_app_exceptions.base.BaseApplicationException attribute) (python_infrastructure_exceptions.base.InfrastructureException attribute) MessageQueueError (class in python_infrastructure_exceptions.messaging) MessageResponse (class in pydantic_response_models.responses) metadata (python_domain_events.base.BaseDomainEvent attribute) metrics (python_outbox_core.publisher.base.OutboxPublisherBase attribute) model_class (sqlalchemy_async_repositories.base.BaseRepository attribute) (sqlalchemy_async_repositories.use_cases.count.query_handler.CountHandler attribute) (sqlalchemy_async_repositories.use_cases.delete.command_handler.DeleteHandler attribute) (sqlalchemy_async_repositories.use_cases.exists.query_handler.ExistsHandler attribute) (sqlalchemy_async_repositories.use_cases.find_paginated.query_handler.FindPaginatedHandler attribute) (sqlalchemy_async_repositories.use_cases.get_all.query_handler.GetAllHandler attribute) (sqlalchemy_async_repositories.use_cases.get_by_id.query_handler.GetByIdHandler attribute) model_config (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute) (fastapi_config_patterns.database_settings.BaseDatabaseSettings attribute) (python_cqrs_core.base_command.BaseCommand attribute) (python_cqrs_core.base_query.BaseQuery attribute) (python_domain_events.base.BaseDomainEvent attribute) (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute) module fastapi_config_patterns fastapi_config_patterns.base_settings fastapi_config_patterns.database_settings fastapi_config_patterns.validators fastapi_middleware_toolkit fastapi_middleware_toolkit.cache_control fastapi_middleware_toolkit.cors fastapi_middleware_toolkit.error_handlers fastapi_middleware_toolkit.lifespan gridflow_python_mediator gridflow_python_mediator.behaviors gridflow_python_mediator.behaviors.observability gridflow_python_mediator.behaviors.protocol gridflow_python_mediator.behaviors.validation_behavior gridflow_python_mediator.mediator postgres_data_sanitizers postgres_data_sanitizers.escape postgres_data_sanitizers.sanitize postgres_data_sanitizers.string_validators postgres_data_sanitizers.validate pydantic_response_models pydantic_response_models.fields pydantic_response_models.responses python_app_exceptions python_app_exceptions.base python_app_exceptions.business python_app_exceptions.retry python_app_exceptions.validation python_cqrs_core python_cqrs_core.base_command python_cqrs_core.base_query python_cqrs_core.command python_cqrs_core.query python_cqrs_dispatcher python_cqrs_dispatcher.dispatcher python_cqrs_dispatcher.registry python_domain_events python_domain_events.base python_domain_events.dispatcher python_domain_events.handler python_dto_mappers python_dto_mappers.auto_mapper python_dto_mappers.base python_dto_mappers.decorators python_dto_mappers.field_mappers python_dto_mappers.field_mappers.datetime_mapping python_dto_mappers.field_mappers.object_mapping python_dto_mappers.field_mappers.text_case python_dto_mappers.utils python_infrastructure_exceptions python_infrastructure_exceptions.base python_infrastructure_exceptions.cache python_infrastructure_exceptions.configuration python_infrastructure_exceptions.database python_infrastructure_exceptions.external_services python_infrastructure_exceptions.messaging python_input_validation python_input_validation.sanitizers python_input_validation.validators python_outbox_core python_outbox_core.adapters python_outbox_core.adapters.examples python_outbox_core.adapters.examples.kafka_routing python_outbox_core.adapters.examples.kong_simple python_outbox_core.config python_outbox_core.events python_outbox_core.formatters python_outbox_core.formatters.base python_outbox_core.formatters.cloudevents python_outbox_core.health_check python_outbox_core.publisher python_outbox_core.publisher.base python_outbox_core.publisher.error_handler python_outbox_core.publisher.interface python_outbox_core.publisher.metrics python_outbox_core.repository python_structlog_config python_structlog_config.config python_structlog_config.integrations python_structlog_config.presets python_technical_primitives python_technical_primitives.datetime python_technical_primitives.datetime.operations python_technical_primitives.patterns python_technical_primitives.patterns.base python_technical_primitives.patterns.compositions python_technical_primitives.text python_technical_primitives.text.operations sqlalchemy_async_repositories sqlalchemy_async_repositories.base sqlalchemy_async_repositories.interfaces sqlalchemy_async_repositories.pagination sqlalchemy_async_repositories.pagination.models sqlalchemy_async_repositories.pagination.router sqlalchemy_async_repositories.pagination.strategies sqlalchemy_async_repositories.pagination.strategies.base sqlalchemy_async_repositories.pagination.strategies.fastcrud_strategy sqlalchemy_async_repositories.pagination.strategies.native_strategy sqlalchemy_async_repositories.pagination_fastcrud sqlalchemy_async_repositories.pagination_native sqlalchemy_async_repositories.use_cases sqlalchemy_async_repositories.use_cases.count sqlalchemy_async_repositories.use_cases.count.query_handler sqlalchemy_async_repositories.use_cases.count.query_model sqlalchemy_async_repositories.use_cases.create sqlalchemy_async_repositories.use_cases.create.command_handler sqlalchemy_async_repositories.use_cases.create.command_model sqlalchemy_async_repositories.use_cases.delete sqlalchemy_async_repositories.use_cases.delete.command_handler sqlalchemy_async_repositories.use_cases.delete.command_model sqlalchemy_async_repositories.use_cases.exists sqlalchemy_async_repositories.use_cases.exists.query_handler sqlalchemy_async_repositories.use_cases.exists.query_model sqlalchemy_async_repositories.use_cases.find_paginated sqlalchemy_async_repositories.use_cases.find_paginated.query_handler sqlalchemy_async_repositories.use_cases.find_paginated.query_model sqlalchemy_async_repositories.use_cases.find_paginated.strategy_factory sqlalchemy_async_repositories.use_cases.get_all sqlalchemy_async_repositories.use_cases.get_all.query_handler sqlalchemy_async_repositories.use_cases.get_all.query_model sqlalchemy_async_repositories.use_cases.get_by_id sqlalchemy_async_repositories.use_cases.get_by_id.query_handler sqlalchemy_async_repositories.use_cases.get_by_id.query_model sqlalchemy_async_repositories.use_cases.update sqlalchemy_async_repositories.use_cases.update.command_handler sqlalchemy_async_repositories.use_cases.update.command_model sqlalchemy_async_session_factory sqlalchemy_async_session_factory.engine sqlalchemy_async_session_factory.session sqlalchemy_async_session_factory.utils

N

NativeStrategy (class in sqlalchemy_async_repositories.pagination.strategies.native_strategy)

normalize_whitespace() (in module python_technical_primitives.text.operations) NotSpecification (class in python_technical_primitives.patterns.compositions)

O

occurred_at (python_domain_events.base.BaseDomainEvent attribute) (python_outbox_core.events.IOutboxEvent attribute) offset (python_cqrs_core.base_query.PaginatedQuery property) (sqlalchemy_async_repositories.use_cases.get_all.query_model.GetAllQuery attribute) operator (sqlalchemy_async_repositories.pagination.models.FilterSpec attribute) OrSpecification (class in python_technical_primitives.patterns.compositions)

OutboxConfig (class in python_outbox_core.config) OutboxConfig.Config (class in python_outbox_core.config) OutboxErrorHandler (class in python_outbox_core.publisher.error_handler) OutboxHealthCheck (class in python_outbox_core.health_check) OutboxMetrics (class in python_outbox_core.publisher.metrics) OutboxPublisherBase (class in python_outbox_core.publisher.base)

P

page (pydantic_response_models.responses.PaginatedResponse attribute) (python_cqrs_core.base_query.PaginatedQuery attribute) (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute) (sqlalchemy_async_repositories.use_cases.find_paginated.query_model.FindPaginatedQuery attribute) page_size (pydantic_response_models.responses.PaginatedResponse attribute) (python_cqrs_core.base_query.PaginatedQuery attribute) (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute) (sqlalchemy_async_repositories.use_cases.find_paginated.query_model.FindPaginatedQuery attribute) pages (pydantic_response_models.responses.PaginatedResponse attribute) (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute) PaginatedQuery (class in python_cqrs_core.base_query) PaginatedResponse (class in pydantic_response_models.responses) PaginatedResult (class in sqlalchemy_async_repositories.pagination.models) PaginationRouter (class in sqlalchemy_async_repositories.pagination.router) PaginationStrategyFactory (class in sqlalchemy_async_repositories.use_cases.find_paginated.strategy_factory) PartitionKeyRouter (class in python_outbox_core.adapters.examples.kafka_routing) PipelineBehavior (class in gridflow_python_mediator.behaviors.protocol) poll_interval_seconds (python_outbox_core.config.OutboxConfig attribute) port (fastapi_config_patterns.base_settings.BaseFastAPISettings attribute) postgres_data_sanitizers module postgres_data_sanitizers.escape module postgres_data_sanitizers.sanitize module postgres_data_sanitizers.string_validators module postgres_data_sanitizers.validate module publish() (python_outbox_core.publisher.interface.IEventPublisher method) publish_batch() (python_outbox_core.publisher.base.OutboxPublisherBase method) publisher (python_outbox_core.publisher.base.OutboxPublisherBase attribute) pydantic_response_models module pydantic_response_models.fields module pydantic_response_models.responses module python_app_exceptions module python_app_exceptions.base module python_app_exceptions.business module python_app_exceptions.retry module python_app_exceptions.validation module python_cqrs_core module python_cqrs_core.base_command module python_cqrs_core.base_query module python_cqrs_core.command module python_cqrs_core.query module python_cqrs_dispatcher module python_cqrs_dispatcher.dispatcher module python_cqrs_dispatcher.registry module python_domain_events module python_domain_events.base module python_domain_events.dispatcher module python_domain_events.handler module python_dto_mappers module python_dto_mappers.auto_mapper module python_dto_mappers.base module python_dto_mappers.decorators module python_dto_mappers.field_mappers module python_dto_mappers.field_mappers.datetime_mapping module

python_dto_mappers.field_mappers.object_mapping module python_dto_mappers.field_mappers.text_case module python_dto_mappers.utils module python_infrastructure_exceptions module python_infrastructure_exceptions.base module python_infrastructure_exceptions.cache module python_infrastructure_exceptions.configuration module python_infrastructure_exceptions.database module python_infrastructure_exceptions.external_services module python_infrastructure_exceptions.messaging module python_input_validation module python_input_validation.sanitizers module python_input_validation.validators module python_outbox_core module python_outbox_core.adapters module python_outbox_core.adapters.examples module python_outbox_core.adapters.examples.kafka_routing module python_outbox_core.adapters.examples.kong_simple module python_outbox_core.config module python_outbox_core.events module python_outbox_core.formatters module python_outbox_core.formatters.base module python_outbox_core.formatters.cloudevents module python_outbox_core.health_check module python_outbox_core.publisher module python_outbox_core.publisher.base module python_outbox_core.publisher.error_handler module python_outbox_core.publisher.interface module python_outbox_core.publisher.metrics module python_outbox_core.repository module python_structlog_config module python_structlog_config.config module python_structlog_config.integrations module python_structlog_config.presets module python_technical_primitives module python_technical_primitives.datetime module python_technical_primitives.datetime.operations module python_technical_primitives.patterns module python_technical_primitives.patterns.base module python_technical_primitives.patterns.compositions module python_technical_primitives.text module python_technical_primitives.text.operations module

Q

query (python_infrastructure_exceptions.database.DatabaseError attribute)

R

rate_limit_tier (python_outbox_core.adapters.examples.kong_simple.KongSimpleFormatter attribute) register() (python_domain_events.dispatcher.InProcessEventDispatcher method) register_command_handler() (python_cqrs_dispatcher.dispatcher.CQRSDispatcher method) register_handler() (gridflow_python_mediator.mediator.Mediator method) register_handlers() (in module python_cqrs_dispatcher.registry) register_query_handler() (python_cqrs_dispatcher.dispatcher.CQRSDispatcher method) repository (python_outbox_core.publisher.base.OutboxPublisherBase attribute) request_id (python_cqrs_core.base_command.BaseCommand attribute) (python_cqrs_core.base_query.BaseQuery attribute) requested_at (python_cqrs_core.base_command.BaseCommand attribute) (python_cqrs_core.base_query.BaseQuery attribute)

requested_by (python_cqrs_core.base_command.BaseCommand attribute) (python_cqrs_core.base_query.BaseQuery attribute) retry_after (python_app_exceptions.retry.RetryableError attribute) retry_backoff_multiplier (python_outbox_core.config.OutboxConfig attribute) RetryableError (class in python_app_exceptions.retry) RetryExhaustedException (class in python_app_exceptions.retry) right (python_technical_primitives.patterns.compositions.AndSpecification attribute) (python_technical_primitives.patterns.compositions.OrSpecification attribute) route() (python_outbox_core.adapters.examples.kafka_routing.PartitionKeyRouter method)

S

sanitize_dict_for_postgres() (in module postgres_data_sanitizers.sanitize) sanitize_email() (in module python_input_validation.sanitizers) sanitize_filename() (in module python_technical_primitives.text.operations) sanitize_text_input() (in module python_input_validation.sanitizers) schedule_publishing() (python_outbox_core.publisher.base.OutboxPublisherBase method) send() (gridflow_python_mediator.mediator.Mediator method) send_command() (python_cqrs_dispatcher.dispatcher.CQRSDispatcher method) send_query() (python_cqrs_dispatcher.dispatcher.CQRSDispatcher method) service_name (python_infrastructure_exceptions.external_services.ExternalServiceError attribute) setup_cache_control_middleware() (in module fastapi_middleware_toolkit.cache_control) setup_cors_middleware() (in module fastapi_middleware_toolkit.cors) setup_error_handlers() (in module fastapi_middleware_toolkit.error_handlers) setup_otel_logging() (in module python_structlog_config.integrations) setup_pool_event_handlers() (in module sqlalchemy_async_session_factory.utils) setup_sentry_logging() (in module python_structlog_config.integrations) should_retry() (python_outbox_core.publisher.error_handler.OutboxErrorHandler method) sort (sqlalchemy_async_repositories.use_cases.find_paginated.query_model.FindPaginatedQuery attribute) SortSpec (class in sqlalchemy_async_repositories.pagination.models) source (python_outbox_core.events.IOutboxEvent attribute) (python_outbox_core.formatters.cloudevents.CloudEventsFormatter attribute) source_type (python_dto_mappers.auto_mapper.AutoMapper property) (python_dto_mappers.base.BaseMapper attribute) spec (python_technical_primitives.patterns.compositions.NotSpecification attribute) Specification (class in python_technical_primitives.patterns.base) sqlalchemy_async_repositories module sqlalchemy_async_repositories.base module sqlalchemy_async_repositories.interfaces module sqlalchemy_async_repositories.pagination module sqlalchemy_async_repositories.pagination.models module sqlalchemy_async_repositories.pagination.router module sqlalchemy_async_repositories.pagination.strategies module sqlalchemy_async_repositories.pagination.strategies.base module sqlalchemy_async_repositories.pagination.strategies.fastcrud_strategy module sqlalchemy_async_repositories.pagination.strategies.native_strategy module sqlalchemy_async_repositories.pagination_fastcrud module sqlalchemy_async_repositories.pagination_native module sqlalchemy_async_repositories.use_cases module sqlalchemy_async_repositories.use_cases.count module sqlalchemy_async_repositories.use_cases.count.query_handler module sqlalchemy_async_repositories.use_cases.count.query_model module sqlalchemy_async_repositories.use_cases.create module

sqlalchemy_async_repositories.use_cases.create.command_handler module sqlalchemy_async_repositories.use_cases.create.command_model module sqlalchemy_async_repositories.use_cases.delete module sqlalchemy_async_repositories.use_cases.delete.command_handler module sqlalchemy_async_repositories.use_cases.delete.command_model module sqlalchemy_async_repositories.use_cases.exists module sqlalchemy_async_repositories.use_cases.exists.query_handler module sqlalchemy_async_repositories.use_cases.exists.query_model module sqlalchemy_async_repositories.use_cases.find_paginated module sqlalchemy_async_repositories.use_cases.find_paginated.query_handler module sqlalchemy_async_repositories.use_cases.find_paginated.query_model module sqlalchemy_async_repositories.use_cases.find_paginated.strategy_factory module sqlalchemy_async_repositories.use_cases.get_all module sqlalchemy_async_repositories.use_cases.get_all.query_handler module sqlalchemy_async_repositories.use_cases.get_all.query_model module sqlalchemy_async_repositories.use_cases.get_by_id module sqlalchemy_async_repositories.use_cases.get_by_id.query_handler module sqlalchemy_async_repositories.use_cases.get_by_id.query_model module sqlalchemy_async_repositories.use_cases.update module sqlalchemy_async_repositories.use_cases.update.command_handler module sqlalchemy_async_repositories.use_cases.update.command_model module sqlalchemy_async_session_factory module sqlalchemy_async_session_factory.engine module sqlalchemy_async_session_factory.session module sqlalchemy_async_session_factory.utils module status_code (python_infrastructure_exceptions.external_services.ExternalServiceError attribute) strategy (sqlalchemy_async_repositories.use_cases.find_paginated.query_handler.FindPaginatedHandler attribute) success (pydantic_response_models.responses.ErrorResponse attribute) (pydantic_response_models.responses.MessageResponse attribute) (pydantic_response_models.responses.SuccessResponse attribute) SuccessResponse (class in pydantic_response_models.responses) suppress_pool_warnings() (in module sqlalchemy_async_session_factory.utils)

T

T (in module pydantic_response_models.responses) (in module python_technical_primitives.patterns.base) (in module python_technical_primitives.patterns.compositions) (in module sqlalchemy_async_repositories.base) (in module sqlalchemy_async_repositories.interfaces) (in module sqlalchemy_async_repositories.pagination.models) (in module sqlalchemy_async_repositories.use_cases.create.command_model) target_type (python_dto_mappers.auto_mapper.AutoMapper property) (python_dto_mappers.base.BaseMapper attribute) TCommand (in module python_cqrs_core.command) TEvent (in module python_domain_events.handler) TimingBehavior (class in gridflow_python_mediator.behaviors.observability) to_iso_string() (in module python_technical_primitives.datetime.operations) to_lower() (in module python_dto_mappers.field_mappers.text_case) to_lower_case() (in module python_technical_primitives.text.operations) to_message() (python_outbox_core.events.IOutboxEvent method) to_sentence_case() (in module python_dto_mappers.field_mappers.text_case) (in module python_technical_primitives.text.operations)

to_title_case() (in module python_dto_mappers.field_mappers.text_case) to_upper() (in module python_dto_mappers.field_mappers.text_case) to_upper_case() (in module python_technical_primitives.text.operations) token_field() (in module pydantic_response_models.fields) topic (python_infrastructure_exceptions.messaging.MessageQueueError attribute) topic_prefix (python_outbox_core.adapters.examples.kafka_routing.PartitionKeyRouter attribute) total (pydantic_response_models.responses.PaginatedResponse attribute) (sqlalchemy_async_repositories.pagination.models.PaginatedResult attribute) TQuery (in module python_cqrs_core.query) TRequest (in module gridflow_python_mediator.mediator) TResult (in module gridflow_python_mediator.mediator) (in module python_cqrs_core.command) (in module python_cqrs_core.query) truncate() (in module python_technical_primitives.text.operations) TSource (in module python_dto_mappers.base) TTarget (in module python_dto_mappers.base)

U

unescape_dict_from_postgres() (in module postgres_data_sanitizers.sanitize) unescape_null_chars() (in module postgres_data_sanitizers.escape) UNHEALTHY (python_outbox_core.health_check.HealthStatus attribute) update() (sqlalchemy_async_repositories.base.BaseRepository method) (sqlalchemy_async_repositories.interfaces.IRepository method)

UpdateCommand (class in sqlalchemy_async_repositories.use_cases.update.command_model) UpdateCommand.Config (class in sqlalchemy_async_repositories.use_cases.update.command_model) UpdateHandler (class in sqlalchemy_async_repositories.use_cases.update.command_handler) utc_now() (in module python_technical_primitives.datetime.operations)

V

validate_email_format() (in module python_input_validation.validators) validate_postgres_text() (in module postgres_data_sanitizers.validate) validate_string_length() (in module python_input_validation.validators)

ValidationBehavior (class in gridflow_python_mediator.behaviors.validation_behavior) ValidationError value (sqlalchemy_async_repositories.pagination.models.FilterSpec attribute)