Index

A

Accept (class in edri.api.headerkit.types) accept (edri.api.headerkit.core.Headers property) accept_encoding (edri.api.headerkit.core.Headers property) accept_language (edri.api.headerkit.core.Headers property) acceptable (edri.api.headerkit.types.AcceptItem property) (edri.api.headerkit.types.Weighted property) AcceptedResponseDirective (class in edri.dataclass.directive.http) AcceptItem (class in edri.api.headerkit.types) AccessDeniedResponseDirective (class in edri.dataclass.directive.http) ACK (edri.protocol.frame.FrameType attribute) action (edri.integrations.pydantic_ai.inspector_events.AgentInspectorActionResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdateResponse attribute) action() (edri.integrations.pydantic_ai.inspector_store.InspectorStore method) action_id (edri.integrations.pydantic_ai.inspector_events.AgentInspectorAction attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) actions (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute) ActionState (class in edri.integrations.pydantic_ai.inspector_store) activate() (edri.protocol.channel.SecureChannel method) add_component() (edri.EDRI method) add_directive() (edri.dataclass.response.Response method) additional_pipes (edri.abstract.manager.manager_base.ManagerBase property) (edri.abstract.manager.manager_priority_base.ManagerPriorityBase property) after_start() (edri.abstract.manager.manager_base.ManagerBase method) agent (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRuns attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) AGENT (edri.integrations.pydantic_ai.observability.AgentActionNamespace attribute) agent_action_policy() (edri.integrations.pydantic_ai.worker.BaseAgentWorker method) agent_configs (edri.integrations.pydantic_ai.worker.BaseAgentWorker attribute) agent_deps() (edri.integrations.pydantic_ai.worker.BaseAgentWorker method) agent_kwargs() (edri.integrations.pydantic_ai.worker.BaseAgentWorker method) AgentAction (class in edri.integrations.pydantic_ai.observability) AgentActionNamespace (class in edri.integrations.pydantic_ai.observability) AgentActionOperation (class in edri.integrations.pydantic_ai.observability) AgentActionOutcome (class in edri.integrations.pydantic_ai.observability) AgentActionPhase (class in edri.integrations.pydantic_ai.observability) AgentActionPolicy (class in edri.integrations.pydantic_ai.observability)

AgentAuditMode (class in edri.integrations.pydantic_ai.observability) AgentBase (class in edri.integrations.pydantic_ai.agent) AgentDeps (class in edri.integrations.pydantic_ai.agent) AgentInspectorAction (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorActionResponse (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorManager (class in edri.integrations.pydantic_ai.inspector) AgentInspectorRun (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorRunResponse (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorRuns (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorRunsResponse (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorStats (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorStatsResponse (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorUpdate (class in edri.integrations.pydantic_ai.inspector_events) AgentInspectorUpdateResponse (class in edri.integrations.pydantic_ai.inspector_events) agents (edri.integrations.pydantic_ai.worker.BaseAgentWorker attribute) ALL (edri.dataclass.event.EventHandlingType attribute) all() (edri.api.headerkit.core.Headers method) amount (edri.events.edri.store.increment.Increment attribute) api() (in module edri.api.dataclass.api_event) ApiType (class in edri.config.constant) append() (edri.api.headerkit.response.ResponseHeaders method) (edri.utility.storage.Storage method) APPLICATION (edri.dataclass.worker.WorkerStopReason attribute) apply_sorting() (in module edri.integrations.sqlalchemy.sort) ARRAY_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) as_dict() (edri.api.headerkit.types.Cookies method) (edri.dataclass.event.Event method) (edri.dataclass.response.Response method) asgi() (edri.api.headerkit.response.ResponseHeaders method) AsyncManagerBase (class in edri.abstract.manager.async_manager_base) attempt (edri.integrations.pydantic_ai.observability.AgentAction attribute) attempts (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute) AttemptState (class in edri.integrations.pydantic_ai.inspector_store) audit_hooks() (in module edri.integrations.pydantic_ai.lifecycle) audited_tool_calls() (in module edri.integrations.pydantic_ai.mcp) Authorization (class in edri.api.headerkit.types) authorization (edri.api.headerkit.core.Headers property)

B

BAD_MAC (edri.protocol.errors.ErrorReason attribute) BAD_SEQ (edri.protocol.errors.ErrorReason attribute) BAD_VERSION (edri.protocol.errors.ErrorReason attribute) BadRequestResponseDirective (class in edri.dataclass.directive.http) BaseAgentWorker (class in edri.integrations.pydantic_ai.worker) best_match() (edri.api.headerkit.types.Accept method) BINARY (in module edri.integrations.pydantic_ai.normalization)

bind_deps() (edri.integrations.pydantic_ai.agent.AgentBase method) BUFFER (edri.dataclass.persistence_failure_policy.PersistenceFailurePolicy attribute) build() (edri.integrations.sqlalchemy.filter.FilterBuilder method) (edri.integrations.sqlalchemy.sort.SortBuilder static method) build_agent() (edri.integrations.pydantic_ai.agent.AgentBase method) ByteRange (class in edri.api.headerkit.types) bytes (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute)

C

Cache (class in edri.utility.cache) cache_control (edri.api.headerkit.core.Headers property) CacheControl (class in edri.api.headerkit.types) Callback (class in edri.utility.manager.store) camel2snake() (in module edri.utility.function) Cancel (class in edri.events.edri.scheduler.cancel) cancel() (edri.abstract.manager.worker_controller.WorkerController method) cancel_all() (edri.abstract.manager.worker_controller.WorkerController method) cancel_requested (edri.abstract.worker.worker.Worker property) CANCELLED (edri.dataclass.worker.WorkerExit attribute) (edri.dataclass.worker.WorkerOutcome attribute) (edri.integrations.pydantic_ai.observability.AgentActionOutcome attribute) canonical_orm_path() (in module edri.integrations.sqlalchemy.path) capabilities (edri.integrations.pydantic_ai.agent.AgentBase attribute) capture_content() (in module edri.integrations.pydantic_ai.normalization) ChangeKind (class in edri.integrations.pydantic_ai.inspector_store) clear() (edri.integrations.pydantic_ai.inspector_store.InspectorStore method) Client (class in edri.api.dataclass.client) (class in edri.events.api.group.client) CLIENT_DISCONNECT (edri.dataclass.worker.WorkerStopReason attribute) client_handshake() (in module edri.protocol.handshake) client_handshake_unauthenticated() (in module edri.protocol.handshake) close() (edri.integrations.sqlalchemy.session.ResponseAwareSession method) (edri.protocol.channel.SecureChannel method) (edri.utility.shared_memory_pipe.SharedMemoryPipe method) close_failed_pipe() (edri.abstract.manager.manager_base.ManagerBase method) close_sessions() (edri.integrations.sqlalchemy.session.ORMResolutionScope method) collect_custom_vitals() (edri.abstract.manager.manager_base.ManagerBase method) column_name (edri.integrations.sqlalchemy.sort.ResolvedSort property) COMBINE (edri.api.headerkit.policy.UnknownHeaderMode attribute) combined() (edri.api.headerkit.core.Headers method) CombineMode (class in edri.api.headerkit.types) COMMA_LIST (edri.api.headerkit.types.CombineMode attribute)

command_handler() (edri.abstract.manager.manager_priority_base.ManagerPriorityBase method) comment (edri.dataclass.directive.http.CookieResponseDirective attribute) CompareAndSet (class in edri.events.edri.store.compare_and_set) COMPAT (edri.api.headerkit.policy.ParseMode attribute) completed (edri.integrations.pydantic_ai.inspector_store.RunState property) ComponentNode (class in edri.dataclass.topology) compute_mac() (in module edri.protocol.frame) condition (edri.events.edri.store.get_callback.GetCallback attribute) ConflictResponseDirective (class in edri.dataclass.directive.http) Connection (class in edri.switch.connection) ConnectorNode (class in edri.dataclass.topology) CONTENT (edri.integrations.pydantic_ai.observability.AgentAuditMode attribute) content_length (edri.api.headerkit.core.Headers property) content_length() (edri.api.dataclass.range.RangeValue method) content_range() (edri.api.dataclass.range.RangeValue method) content_range_unsatisfied() (edri.api.dataclass.range.RangeValue static method) content_type (edri.api.headerkit.core.Headers property) CONTINUE (edri.api.middleware.MiddlewareControl.ActionType attribute) continue_processing() (edri.api.middleware.MiddlewareControl class method) conversation_id (edri.integrations.pydantic_ai.observability.AgentAction attribute) convert_type() (edri.utility.coercion.TypeCoercer method) Cookie (class in edri.api.dataclass) COOKIE (edri.api.headerkit.types.CombineMode attribute) CookieResponseDirective (class in edri.dataclass.directive.http) Cookies (class in edri.api.headerkit.types) cookies (edri.api.headerkit.core.Headers property) copy() (edri.api.headerkit.registry.Registry method) (edri.utility.normalized_default_dict.NormalizedDefaultDict method) copy_sender() (edri.dataclass.event.Event method) cpu_seconds (edri.dataclass.health_checker.Vitals attribute) CreatedResponseDirective (class in edri.dataclass.directive.http) current() (edri.integrations.sqlalchemy.session.ORMResolutionScope class method) CustomJSONEncoder (class in edri.utility.json_encoder) CYCLE (in module edri.integrations.pydantic_ai.normalization)

D

data (edri.events.edri.store.get.Get attribute) date (edri.api.headerkit.core.Headers property) DateHeader (class in edri.api.headerkit.types) DateTimeValidator (class in edri.utility.validation) DateValidator (class in edri.utility.validation) dechunked() (edri.api.headerkit.types.Cookies method) decode_header() (in module edri.protocol.frame) decode_value() (edri.api.headerkit.core.Headers method) dedupe_entries (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute) default() (edri.utility.json_encoder.CustomJSONEncoder method) default_name() (edri.integrations.pydantic_ai.agent.AgentBase class method) DEFERRED (edri.integrations.pydantic_ai.observability.AgentActionOutcome attribute) definition (edri.dataclass.health_checker.Record attribute) DEGRADED (edri.dataclass.health_checker.Status attribute) Delete (class in edri.events.edri.store.delete)

delete_cookie() (edri.api.headerkit.response.ResponseHeaders method) delivery_id (edri.switch.forwarder.ForwardMessage attribute) Demands (class in edri.events.edri.router.demands) DEMANDS (edri.protocol.frame.FrameType attribute) demands (edri.switch.connection.Connection attribute) derive_session_keys() (in module edri.protocol.handshake) describe_error() (in module edri.integrations.pydantic_ai.normalization) disable_additional_pipe() (edri.abstract.manager.manager_base.ManagerBase method) disconnect() (edri.switch.connection.Connection method) DISPATCH (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) DispatchFn (class in edri.integrations.pydantic_ai.agent) do() (edri.abstract.worker.worker.Worker method) domain (edri.dataclass.directive.http.CookieResponseDirective attribute) drain_changes() (edri.integrations.pydantic_ai.inspector_store.InspectorStore method) DuplicateHeader duration (edri.integrations.pydantic_ai.observability.AgentAction attribute)

E

edri module EDRI (class in edri) (edri.integrations.pydantic_ai.observability.AgentActionNamespace attribute) edri.abstract module edri.abstract.manager module edri.abstract.manager.async_manager_base module edri.abstract.manager.manager_base module edri.abstract.manager.manager_priority_base module edri.abstract.manager.worker module edri.abstract.manager.worker_controller module edri.abstract.worker module edri.abstract.worker.worker module edri.abstract.worker.worker_process module edri.abstract.worker.worker_thread module edri.api module edri.api.broker module edri.api.dataclass module edri.api.dataclass.api_event module edri.api.dataclass.client module edri.api.dataclass.file module edri.api.dataclass.range module edri.api.event_builder module edri.api.event_registry module edri.api.extensions module edri.api.extensions.url_extension module edri.api.extensions.url_prefix module edri.api.grpc module edri.api.grpc.directives module edri.api.grpc.export module edri.api.grpc.listener module edri.api.grpc.runtime module edri.api.grpc.schema module edri.api.grpc.type_mapping module edri.api.handlers module edri.api.handlers.base_handler module edri.api.handlers.html_handler module edri.api.handlers.http_handler module edri.api.handlers.rest_handler module edri.api.handlers.websocket_handler module edri.api.headerkit module edri.api.headerkit.core module edri.api.headerkit.defaults module edri.api.headerkit.errors module edri.api.headerkit.grammar module edri.api.headerkit.parsers module edri.api.headerkit.policy module edri.api.headerkit.registry module edri.api.headerkit.response module edri.api.headerkit.types module edri.api.listener module edri.api.middleware module edri.api.pipes module edri.cli module edri.config module edri.config.constant module edri.config.setting module edri.dataclass module edri.dataclass.directive module edri.dataclass.directive.base module edri.dataclass.directive.html module edri.dataclass.directive.http module edri.dataclass.event module edri.dataclass.health_checker module edri.dataclass.injection module edri.dataclass.persistence_failure_policy module edri.dataclass.response module edri.dataclass.topology module edri.dataclass.worker module edri.events module edri.events.api module edri.events.api.client module edri.events.api.client.documentation module edri.events.api.client.register module edri.events.api.client.unregister module edri.events.api.group module edri.events.api.group.client module edri.events.api.group.manage module edri.events.api.manage module edri.events.api.manage.list_registered module edri.events.api.manage.register module edri.events.api.manage.unregister module edri.events.api.manage.unregister_all module edri.events.edri module edri.events.edri.group module edri.events.edri.group.manager module edri.events.edri.group.router module edri.events.edri.group.scheduler module edri.events.edri.group.store module edri.events.edri.group.switch module edri.events.edri.group.test module edri.events.edri.manager module edri.events.edri.manager.restart module edri.events.edri.manager.worker_quit module edri.events.edri.manager.worker_started module edri.events.edri.router module edri.events.edri.router.demands module edri.events.edri.router.health_check module edri.events.edri.router.last_events module edri.events.edri.router.send_from module edri.events.edri.router.subscribe module edri.events.edri.router.subscribe_connector module edri.events.edri.router.subscribed_external module

edri.events.edri.router.subscribed_new module edri.events.edri.router.topology module edri.events.edri.router.unsubscribe module edri.events.edri.router.unsubscribe_all module edri.events.edri.scheduler module edri.events.edri.scheduler.cancel module edri.events.edri.scheduler.set module edri.events.edri.scheduler.set_or_update module edri.events.edri.scheduler.update module edri.events.edri.store module edri.events.edri.store.compare_and_set module edri.events.edri.store.delete module edri.events.edri.store.get module edri.events.edri.store.get_callback module edri.events.edri.store.increment module edri.events.edri.store.set module edri.events.edri.store.set_if_absent module edri.events.edri.store.store_purge module edri.integrations module edri.integrations.pydantic_ai module edri.integrations.pydantic_ai.agent module edri.integrations.pydantic_ai.inspector module edri.integrations.pydantic_ai.inspector_events module edri.integrations.pydantic_ai.inspector_store module edri.integrations.pydantic_ai.lifecycle module edri.integrations.pydantic_ai.mcp module edri.integrations.pydantic_ai.normalization module edri.integrations.pydantic_ai.observability module edri.integrations.pydantic_ai.worker module edri.integrations.sqlalchemy module edri.integrations.sqlalchemy.event module edri.integrations.sqlalchemy.filter module edri.integrations.sqlalchemy.middleware module edri.integrations.sqlalchemy.model module edri.integrations.sqlalchemy.path module edri.integrations.sqlalchemy.projection module edri.integrations.sqlalchemy.session module edri.integrations.sqlalchemy.sort module edri.integrations.sqlalchemy.validator module edri.protocol module edri.protocol.channel module edri.protocol.delivery module edri.protocol.errors module edri.protocol.frame module edri.protocol.handshake module edri.protocol.keys module edri.router module edri.router.cache module edri.router.connector module edri.router.connector.connector module edri.router.connector.socket module edri.router.health_checker module edri.router.outbound module edri.router.router module edri.router.subscription_registry module edri.router.unrouted module edri.switch module edri.switch.connection module edri.switch.forwarder module edri.switch.mailbox module edri.switch.receiver module edri.switch.sender module edri.switch.status module edri.switch.switch module edri.testing module edri.utility module edri.utility.cache module edri.utility.coercion module edri.utility.function module edri.utility.json_encoder module edri.utility.manager module edri.utility.manager.scheduler module edri.utility.manager.store module edri.utility.normalized_default_dict module edri.utility.queue module edri.utility.shared_memory_pipe module edri.utility.storage module edri.utility.transformation module edri.utility.validation module edri.utility.watcher module edri_event_id (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) EdriDocumentation (class in edri.events.api.client.documentation) EdriHealth (class in edri.events.edri.router.health_check) EdriLive (class in edri.events.edri.router.health_check) EdriReady (class in edri.events.edri.router.health_check) EdriRegister (class in edri.events.api.manage.register) EdriUnregister (class in edri.events.api.manage.unregister) enabled (edri.integrations.pydantic_ai.observability.AgentAuditMode property) encode_frame() (in module edri.protocol.frame) END (edri.integrations.pydantic_ai.observability.AgentActionPhase attribute) EntityTag (class in edri.api.headerkit.types) EntityTagSet (class in edri.api.headerkit.types) ENUM_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) EQUALITY_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) ERROR (edri.dataclass.health_checker.Status attribute) error (edri.integrations.pydantic_ai.inspector_events.AgentInspectorActionResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunsResponse attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) ERROR (edri.integrations.pydantic_ai.observability.AgentActionOutcome attribute) (edri.integrations.pydantic_ai.observability.AgentActionPhase attribute) (edri.protocol.frame.FrameType attribute) ErrorReason (class in edri.protocol.errors) errors_only (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRuns attribute) essence (edri.api.headerkit.types.MediaType property) etag (edri.api.headerkit.core.Headers property) Event (class in edri.dataclass.event) event (edri.api.middleware.MiddlewareControl attribute) (edri.events.edri.scheduler.update.Update attribute) EVENT (edri.protocol.frame.FrameType attribute) event() (in module edri.dataclass.event) event_receive() (edri.abstract.worker.worker.Worker method) event_send() (edri.abstract.worker.worker.Worker method) EventHandlingType (class in edri.dataclass.event) EventInfo (class in edri.api.broker) evicted_runs (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute) exception_message (edri.events.edri.manager.worker_quit.WorkerQuit attribute) exception_type (edri.events.edri.manager.worker_quit.WorkerQuit attribute) EXECUTE (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) execute_event_resolver() (edri.abstract.manager.manager_base.ManagerBase method) expires (edri.dataclass.directive.http.CookieResponseDirective attribute) extend() (edri.api.headerkit.response.ResponseHeaders method)

F

failed (edri.dataclass.health_checker.Vitals attribute) FAILED (edri.dataclass.response.ResponseStatus attribute) (edri.dataclass.worker.WorkerOutcome attribute) failed (edri.integrations.pydantic_ai.inspector_store.RunState property) FALSE_VALUES (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) FieldSpec (class in edri.api.headerkit.registry) File (class in edri.api.dataclass.file) FilterBuilder (class in edri.integrations.sqlalchemy.filter) FilterBuilderConfig (class in edri.integrations.sqlalchemy.filter) finalize_orm_response() (in module edri.integrations.sqlalchemy.session) find_by_pipe() (edri.abstract.manager.worker_controller.WorkerController method) fingerprint (edri.api.dataclass.file.File attribute) finish_from_quit() (edri.abstract.manager.worker_controller.WorkerController method) finish_lost() (edri.abstract.manager.worker_controller.WorkerController method) first() (edri.api.headerkit.core.Headers method) fit_text() (edri.integrations.pydantic_ai.normalization.NormalizationBudget method) flags (edri.protocol.frame.Frame attribute)

FloatValidator (class in edri.utility.validation) Forwarded (class in edri.api.headerkit.types) ForwardedElement (class in edri.api.headerkit.types) Forwarder (class in edri.switch.forwarder) ForwardMessage (class in edri.switch.forwarder) ForwardType (class in edri.switch.forwarder) found (edri.integrations.pydantic_ai.inspector_events.AgentInspectorActionResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunResponse attribute) FoundResponseDirective (class in edri.dataclass.directive.http) Frame (class in edri.protocol.frame) FrameType (class in edri.protocol.frame) framework (edri.integrations.pydantic_ai.agent.AgentBase attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) from_file() (edri.protocol.keys.KeySet class method) from_scope() (edri.api.headerkit.core.Headers class method) from_settings() (edri.protocol.keys.KeySet class method) from_time (edri.events.edri.router.subscribe.Subscribe attribute)

G

generation_id (edri.integrations.pydantic_ai.inspector_events.AgentInspectorActionResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) Get (class in edri.events.edri.store.get) get() (edri.api.headerkit.registry.Registry method) (edri.api.headerkit.types.CacheControl method) (edri.api.headerkit.types.Cookies method) (edri.utility.normalized_default_dict.NormalizedDefaultDict method) get_all() (edri.api.headerkit.types.Cookies method) get_context() (edri.dataclass.event.Event method) get_directives() (edri.dataclass.response.Response method) (edri.testing.ManagerTestHarness static method)

get_event_resolver() (edri.abstract.manager.manager_base.ManagerBase method) get_pipes() (edri.abstract.manager.manager_base.ManagerBase method) get_priority() (edri.abstract.manager.manager_priority_base.ManagerPriorityBase method) get_projection_spec() (in module edri.integrations.sqlalchemy.projection) get_resolver_cache_state() (edri.abstract.manager.manager_base.ManagerBase method) get_response() (edri.dataclass.event.Event method) get_status() (edri.dataclass.response.Response method) (edri.testing.ManagerTestHarness static method) GetCallback (class in edri.events.edri.store.get_callback) GoneResponseDirective (class in edri.dataclass.directive.http) GRPC (edri.config.constant.ApiType attribute) GRPCListener (class in edri.api.grpc.listener) GRPCResponseDirective (class in edri.dataclass.directive)

H

handle_additional_pipe_receive_error() (edri.abstract.manager.manager_base.ManagerBase method) handle_new_connection() (edri.switch.switch.Switch method) handle_pipe_receive_error() (edri.abstract.manager.manager_base.ManagerBase method) handle_resolver_exception() (edri.abstract.manager.manager_base.ManagerBase method) handle_router_pipe_receive_error() (edri.abstract.manager.manager_base.ManagerBase method) handle_worker_pipe_receive_error() (edri.abstract.manager.manager_base.ManagerBase method) has_changed() (edri.dataclass.response.Response method) has_response() (edri.dataclass.event.Event method) hash_name() (edri.dataclass.event.Event class method) Header (class in edri.api.dataclass) HEADER_FMT (edri.utility.shared_memory_pipe.SharedMemoryPipe attribute) HEADER_SIZE (edri.utility.shared_memory_pipe.SharedMemoryPipe attribute) HeaderError HeaderPolicy (class in edri.api.headerkit.policy) HeaderResponseDirective (class in edri.dataclass.directive.http)

Headers (class in edri.api.headerkit.core) HeaderTooLarge health() (edri.abstract.manager.manager_base.ManagerBase method) health_check() (edri.abstract.manager.manager_base.ManagerBase method) health_rtt_seconds (edri.dataclass.health_checker.Record attribute) HealthCheck (class in edri.events.edri.router.health_check) HealthReport (class in edri.dataclass.health_checker) HELLO_ACCEPT (edri.protocol.frame.FrameType attribute) HELLO_CLIENT (edri.protocol.frame.FrameType attribute) HELLO_SERVER (edri.protocol.frame.FrameType attribute) host (edri.api.headerkit.core.Headers property) HTML (edri.config.constant.ApiType attribute) HTMLResponseDirective (class in edri.dataclass.directive) httponly (edri.dataclass.directive.http.CookieResponseDirective attribute) HTTPResponseDirective (class in edri.dataclass.directive)

I

identifier (edri.events.edri.scheduler.set.Set attribute) (edri.events.edri.scheduler.set_or_update.SetUpdate attribute) if_none_match (edri.api.headerkit.core.Headers property) incomplete_runs (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute) IncompleteProjectionError Increment (class in edri.events.edri.store.increment) ingest() (edri.integrations.pydantic_ai.inspector_store.InspectorStore method) inject() (in module edri.utility.function) Injection (class in edri.dataclass.injection)

InspectorStore (class in edri.integrations.pydantic_ai.inspector_store) IntegerValidator (class in edri.utility.validation) InternalServerErrorResponseDirective (class in edri.dataclass.directive.base) INVALIDATED (edri.integrations.pydantic_ai.inspector_store.ChangeKind attribute) InvalidHeader is_alive() (edri.abstract.manager.worker.WorkerRuntimeProtocol method) is_file_only (edri.dataclass.response.Response property) is_loopback_only() (in module edri.config.setting) is_not_modified_request() (edri.abstract.manager.manager_base.ManagerBase method) is_router_pipe() (edri.abstract.manager.manager_base.ManagerBase method)

J

Job (class in edri.utility.manager.scheduler)

K

key (edri.events.edri.router.send_from.SendFrom attribute) key_index (edri.switch.connection.Connection attribute) KeyedFrame (class in edri.protocol.channel)

KeySet (class in edri.protocol.keys) KILLED (edri.dataclass.worker.WorkerExit attribute) kind (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdateResponse attribute)

L

last_change() (edri.utility.cache.Cache method) LAST_EVENTS (edri.protocol.frame.FrameType attribute) LastEvents (class in edri.events.edri.router.last_events) limit (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRuns attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunsResponse attribute)

list_members() (edri.api.headerkit.core.Headers method) ListRegistered (class in edri.events.api.manage.list_registered) ListValidator (class in edri.utility.validation) location (edri.dataclass.directive.http.CreatedResponseDirective attribute) LOST (edri.dataclass.worker.WorkerExit attribute)

M

main() (in module edri.cli) Manage (class in edri.events.api.group.manage) Manager (class in edri.events.edri.group.manager) manager (edri.testing.ManagerTestHarness property) MANAGER_SHUTDOWN (edri.dataclass.worker.WorkerStopReason attribute) ManagerBase (class in edri.abstract.manager.manager_base) ManagerPriorityBase (class in edri.abstract.manager.manager_priority_base) ManagerTestHarness (class in edri.testing) matches() (edri.api.headerkit.types.MediaType method) max_age (edri.api.headerkit.types.CacheControl property) (edri.dataclass.directive.http.CookieResponseDirective attribute) max_workers (edri.abstract.manager.manager_base.ManagerBase property) MCP (edri.integrations.pydantic_ai.observability.AgentActionNamespace attribute) MCP_INITIALIZE (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) MCP_PROMPTS_GET (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) MCP_PROMPTS_LIST (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) MCP_RESOURCES_LIST (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) MCP_RESOURCES_READ (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) MCP_TOOLS_CALL (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) MCP_TOOLS_LIST (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) measure() (edri.integrations.pydantic_ai.inspector_store.ActionState method) (edri.integrations.pydantic_ai.inspector_store.AttemptState method) (edri.integrations.pydantic_ai.inspector_store.RunState method) MediaType (class in edri.api.headerkit.types) MEMBERSHIP_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) merge() (edri.integrations.sqlalchemy.event.ORMEvent method) (edri.integrations.sqlalchemy.session.ResponseAwareSession method) message (edri.dataclass.directive.base.InternalServerErrorResponseDirective attribute) (edri.dataclass.directive.base.UnauthorizedResponseDirective attribute) (edri.dataclass.directive.http.AccessDeniedResponseDirective attribute) (edri.dataclass.directive.http.BadRequestResponseDirective attribute) (edri.dataclass.directive.http.ConflictResponseDirective attribute) (edri.dataclass.directive.http.GoneResponseDirective attribute) (edri.dataclass.directive.http.NotFoundResponseDirective attribute) (edri.dataclass.directive.http.NotImplementedResponseDirective attribute) (edri.dataclass.directive.http.ServiceUnavailableResponseDirective attribute) (edri.dataclass.directive.http.TooManyRequestsResponseDirective attribute) (edri.dataclass.directive.http.UnprocessableContentResponseDirective attribute) (edri.dataclass.directive.http.UnsupportedMediaTypeResponseDirective attribute) METADATA (edri.integrations.pydantic_ai.observability.AgentAuditMode attribute) method (edri.dataclass.event.Event attribute) Middleware (class in edri.api.middleware) MiddlewareControl (class in edri.api.middleware) MiddlewareControl.ActionType (class in edri.api.middleware) model (edri.integrations.pydantic_ai.observability.AgentAction attribute) MODEL (edri.integrations.pydantic_ai.observability.AgentActionNamespace attribute) model_version (edri.integrations.pydantic_ai.agent.AgentBase attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) module edri edri.abstract edri.abstract.manager edri.abstract.manager.async_manager_base edri.abstract.manager.manager_base edri.abstract.manager.manager_priority_base edri.abstract.manager.worker edri.abstract.manager.worker_controller edri.abstract.worker edri.abstract.worker.worker edri.abstract.worker.worker_process edri.abstract.worker.worker_thread edri.api edri.api.broker edri.api.dataclass edri.api.dataclass.api_event edri.api.dataclass.client edri.api.dataclass.file edri.api.dataclass.range edri.api.event_builder edri.api.event_registry edri.api.extensions edri.api.extensions.url_extension edri.api.extensions.url_prefix edri.api.grpc edri.api.grpc.directives edri.api.grpc.export edri.api.grpc.listener edri.api.grpc.runtime edri.api.grpc.schema edri.api.grpc.type_mapping edri.api.handlers edri.api.handlers.base_handler edri.api.handlers.html_handler edri.api.handlers.http_handler edri.api.handlers.rest_handler edri.api.handlers.websocket_handler edri.api.headerkit edri.api.headerkit.core edri.api.headerkit.defaults edri.api.headerkit.errors edri.api.headerkit.grammar edri.api.headerkit.parsers edri.api.headerkit.policy edri.api.headerkit.registry edri.api.headerkit.response edri.api.headerkit.types edri.api.listener edri.api.middleware edri.api.pipes edri.cli edri.config edri.config.constant edri.config.setting edri.dataclass edri.dataclass.directive edri.dataclass.directive.base edri.dataclass.directive.html edri.dataclass.directive.http edri.dataclass.event edri.dataclass.health_checker edri.dataclass.injection edri.dataclass.persistence_failure_policy edri.dataclass.response edri.dataclass.topology edri.dataclass.worker edri.events edri.events.api edri.events.api.client edri.events.api.client.documentation edri.events.api.client.register edri.events.api.client.unregister edri.events.api.group edri.events.api.group.client edri.events.api.group.manage edri.events.api.manage edri.events.api.manage.list_registered edri.events.api.manage.register edri.events.api.manage.unregister edri.events.api.manage.unregister_all edri.events.edri edri.events.edri.group edri.events.edri.group.manager edri.events.edri.group.router edri.events.edri.group.scheduler edri.events.edri.group.store edri.events.edri.group.switch edri.events.edri.group.test edri.events.edri.manager edri.events.edri.manager.restart edri.events.edri.manager.worker_quit edri.events.edri.manager.worker_started edri.events.edri.router edri.events.edri.router.demands edri.events.edri.router.health_check edri.events.edri.router.last_events edri.events.edri.router.send_from edri.events.edri.router.subscribe edri.events.edri.router.subscribe_connector edri.events.edri.router.subscribed_external edri.events.edri.router.subscribed_new edri.events.edri.router.topology edri.events.edri.router.unsubscribe edri.events.edri.router.unsubscribe_all edri.events.edri.scheduler edri.events.edri.scheduler.cancel edri.events.edri.scheduler.set edri.events.edri.scheduler.set_or_update edri.events.edri.scheduler.update edri.events.edri.store edri.events.edri.store.compare_and_set edri.events.edri.store.delete edri.events.edri.store.get edri.events.edri.store.get_callback edri.events.edri.store.increment edri.events.edri.store.set edri.events.edri.store.set_if_absent edri.events.edri.store.store_purge edri.integrations edri.integrations.pydantic_ai edri.integrations.pydantic_ai.agent edri.integrations.pydantic_ai.inspector edri.integrations.pydantic_ai.inspector_events edri.integrations.pydantic_ai.inspector_store edri.integrations.pydantic_ai.lifecycle edri.integrations.pydantic_ai.mcp edri.integrations.pydantic_ai.normalization edri.integrations.pydantic_ai.observability edri.integrations.pydantic_ai.worker edri.integrations.sqlalchemy edri.integrations.sqlalchemy.event edri.integrations.sqlalchemy.filter edri.integrations.sqlalchemy.middleware edri.integrations.sqlalchemy.model edri.integrations.sqlalchemy.path edri.integrations.sqlalchemy.projection edri.integrations.sqlalchemy.session edri.integrations.sqlalchemy.sort edri.integrations.sqlalchemy.validator edri.protocol edri.protocol.channel edri.protocol.delivery edri.protocol.errors edri.protocol.frame edri.protocol.handshake edri.protocol.keys edri.router edri.router.cache edri.router.connector edri.router.connector.connector edri.router.connector.socket edri.router.health_checker edri.router.outbound edri.router.router edri.router.subscription_registry edri.router.unrouted edri.switch edri.switch.connection edri.switch.forwarder edri.switch.mailbox edri.switch.receiver edri.switch.sender edri.switch.status edri.switch.switch edri.testing edri.utility edri.utility.cache edri.utility.coercion edri.utility.function edri.utility.json_encoder edri.utility.manager edri.utility.manager.scheduler edri.utility.manager.store edri.utility.normalized_default_dict edri.utility.queue edri.utility.shared_memory_pipe edri.utility.storage edri.utility.transformation edri.utility.validation edri.utility.watcher

MovedPermanentlyResponseDirective (class in edri.dataclass.directive.http)

N

name (edri.abstract.manager.manager_base.ManagerBase property) (edri.integrations.pydantic_ai.observability.AgentAction attribute) names() (edri.api.headerkit.core.Headers method) namespace (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) NEGATED_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) NEVER_COMBINE (edri.api.headerkit.types.CombineMode attribute) no_cache (edri.api.headerkit.types.CacheControl property) no_store (edri.api.headerkit.types.CacheControl property) NoContentResponseDirective (class in edri.dataclass.directive.http) NONE (edri.dataclass.response.ResponseStatus attribute)

NormalizationBudget (class in edri.integrations.pydantic_ai.normalization) NormalizationLimits (class in edri.integrations.pydantic_ai.observability) normalize() (in module edri.integrations.pydantic_ai.normalization) normalize_event_response() (in module edri.integrations.sqlalchemy.middleware) normalize_name() (edri.api.headerkit.core.Headers static method) NormalizedDefaultDict (class in edri.utility.normalized_default_dict) NotFoundResponseDirective (class in edri.dataclass.directive.http) NotImplementedResponseDirective (class in edri.dataclass.directive.http) NotModifiedResponseDirective (class in edri.dataclass.directive.http) NULL_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute)

O

OFF (edri.integrations.pydantic_ai.observability.AgentAuditMode attribute) offset (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRuns attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunsResponse attribute) OK (edri.dataclass.health_checker.Status attribute) (edri.dataclass.response.ResponseStatus attribute) on_resolver_idle() (edri.abstract.manager.manager_base.ManagerBase method) OPAQUE (edri.api.headerkit.types.CombineMode attribute) open_fds (edri.dataclass.health_checker.Vitals attribute) operation (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) OPTION_ALIASES (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) ORDER_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute)

orm_count() (in module edri.integrations.sqlalchemy.projection) orm_event() (in module edri.integrations.sqlalchemy.event) orm_projection() (in module edri.integrations.sqlalchemy.projection) orm_validator() (in module edri.integrations.sqlalchemy.validator) ORMEvent (class in edri.integrations.sqlalchemy.event) ORMResolutionScope (class in edri.integrations.sqlalchemy.session) OTHERS (edri.switch.forwarder.ForwardType attribute) outcome (edri.integrations.pydantic_ai.inspector_store.RunState property) (edri.integrations.pydantic_ai.observability.AgentAction attribute) output_mode (edri.integrations.pydantic_ai.agent.AgentBase attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute)

P

parent_action_id (edri.integrations.pydantic_ai.observability.AgentAction attribute) parse() (edri.api.headerkit.core.Headers method) ParseError ParseMode (class in edri.api.headerkit.policy) partial (edri.integrations.pydantic_ai.inspector_store.RunState property) PartialContentResponseDirective (class in edri.dataclass.directive.http) path (edri.dataclass.directive.html.RedirectResponseDirective property) (edri.dataclass.directive.http.CookieResponseDirective attribute) pending (edri.abstract.manager.worker_controller.WorkerController property) PENDING (edri.dataclass.worker.WorkerState attribute) PermanentRedirectResponseDirective (class in edri.dataclass.directive.http) PersistenceFailurePolicy (class in edri.dataclass.persistence_failure_policy) phase (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) pid (edri.dataclass.health_checker.Vitals attribute) pipe (edri.dataclass.health_checker.Record attribute) pipes() (edri.abstract.manager.worker_controller.WorkerController method) pop() (edri.utility.normalized_default_dict.NormalizedDefaultDict method) PrefixBase (class in edri.api.extensions.url_prefix) prepare() (edri.testing.ManagerTestHarness method) prepare_cache_response() (edri.abstract.manager.manager_base.ManagerBase method)

prepare_outgoing_event() (edri.abstract.manager.manager_base.ManagerBase method) (edri.integrations.sqlalchemy.session.SQLAlchemyManagerMixin method) prepare_resolved_event() (edri.abstract.manager.manager_base.ManagerBase method) primary (edri.protocol.keys.KeySet property) process_request() (edri.api.middleware.Middleware method) process_response() (edri.api.middleware.Middleware method) (edri.integrations.sqlalchemy.middleware.SQLAlchemyResponseMiddleware method) processed (edri.dataclass.health_checker.Vitals attribute) projection() (in module edri.integrations.sqlalchemy.projection) projection_all() (in module edri.integrations.sqlalchemy.projection) projection_one() (in module edri.integrations.sqlalchemy.projection) projection_rows() (in module edri.integrations.sqlalchemy.projection) ProjectionError ProjectionFunctionSpec (class in edri.integrations.sqlalchemy.projection) ProjectionNode (class in edri.integrations.sqlalchemy.projection) ProjectionSpec (class in edri.integrations.sqlalchemy.projection) prompt_version (edri.integrations.pydantic_ai.agent.AgentBase attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) ProtocolError provider (edri.integrations.pydantic_ai.agent.AgentBase attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute)

Q

QUEUE (edri.dataclass.worker.WorkerTimeout attribute)

queue (edri.switch.connection.Connection property) quit() (edri.abstract.manager.manager_base.ManagerBase method)

R

raise_if_cancelled() (edri.abstract.worker.worker.Worker method) RAISED (edri.dataclass.worker.WorkerExit attribute) Range (class in edri.api.headerkit.types) range (edri.api.headerkit.core.Headers property) RANGE_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) RangeNotSatisfiableResponseDirective (class in edri.dataclass.directive.http) RangeSpec (class in edri.api.dataclass.range) RangeValue (class in edri.api.dataclass.range) raw (edri.api.headerkit.core.Headers property) RAW (edri.api.headerkit.policy.UnknownHeaderMode attribute) raw_all() (edri.api.headerkit.core.Headers method) read() (edri.utility.shared_memory_pipe.SharedMemoryPipe method) read_exactly() (in module edri.protocol.frame) read_frame() (in module edri.protocol.frame) reader() (edri.utility.shared_memory_pipe.SharedMemoryPipe method) ready (edri.dataclass.health_checker.HealthReport attribute) (edri.dataclass.health_checker.Record attribute) reason (edri.dataclass.health_checker.HealthReport attribute) (edri.dataclass.health_checker.Record attribute) receive() (edri.protocol.channel.SecureChannel method) receive_any_key() (edri.protocol.channel.SecureChannel method) receive_pipe_event() (edri.abstract.manager.manager_base.ManagerBase method) receive_unkeyed() (edri.protocol.channel.SecureChannel method) received (edri.dataclass.event.SwitchInfo attribute) Receiver (class in edri.switch.receiver) Record (class in edri.dataclass.health_checker) record_resolved_event() (edri.abstract.manager.manager_base.ManagerBase method) REDACTION_FAILED (in module edri.integrations.pydantic_ai.normalization) REDIRECT (edri.api.middleware.MiddlewareControl.ActionType attribute) redirect_event() (edri.api.middleware.MiddlewareControl class method) RedirectResponseDirective (class in edri.dataclass.directive.html) Register (class in edri.events.api.client.register) register() (edri.api.headerkit.registry.Registry method) (edri.integrations.sqlalchemy.session.ORMResolutionScope method) register_events() (edri.api.middleware.Middleware static method) register_orm_session() (in module edri.integrations.sqlalchemy.session) Registry (class in edri.api.headerkit.registry) REJECT_DUPES (edri.api.headerkit.policy.UnknownHeaderMode attribute) REKEY (edri.protocol.frame.FrameType attribute) rekey() (edri.protocol.channel.SecureChannel method) relationships (edri.integrations.sqlalchemy.sort.ResolvedSort property) remove() (edri.api.headerkit.response.ResponseHeaders method) remove_response() (edri.dataclass.event.Event method) render_proto() (in module edri.api.grpc.export) renew() (edri.utility.cache.Cache method) repeat (edri.events.edri.scheduler.set.Set attribute) (edri.events.edri.scheduler.set_or_update.SetUpdate attribute) (edri.events.edri.scheduler.update.Update attribute) (edri.utility.manager.scheduler.Job attribute) REPLACE_EVENT (edri.api.middleware.MiddlewareControl.ActionType attribute) replace_event() (edri.api.middleware.MiddlewareControl class method) request (edri.integrations.pydantic_ai.observability.AgentAction attribute) REQUEST (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) request (edri.integrations.sqlalchemy.projection.ProjectionFunctionSpec property) request() (in module edri.abstract) REQUEST_USAGE_FIELDS (in module edri.integrations.pydantic_ai.normalization) REQUESTED (edri.dataclass.worker.WorkerStopReason attribute) resolve() (edri.abstract.manager.async_manager_base.AsyncManagerBase method) (edri.abstract.manager.manager_base.ManagerBase method) (edri.integrations.pydantic_ai.inspector.AgentInspectorManager method) (edri.integrations.sqlalchemy.session.SQLAlchemyManagerMixin method) (edri.testing.ManagerTestHarness method) resolve_active_pipe() (edri.abstract.manager.manager_base.ManagerBase method) resolve_audit_mode() (in module edri.integrations.pydantic_ai.observability) resolve_callback_pipe() (edri.abstract.manager.manager_base.ManagerBase method) resolve_callback_worker() (edri.abstract.manager.manager_base.ManagerBase method)

resolve_non_router_event() (edri.abstract.manager.manager_base.ManagerBase method) (edri.integrations.sqlalchemy.session.SQLAlchemyManagerMixin method) resolve_non_router_pipe() (edri.abstract.manager.manager_base.ManagerBase method) resolve_not_modified() (edri.abstract.manager.manager_base.ManagerBase method) resolve_router_event() (edri.abstract.manager.manager_base.ManagerBase method) resolve_router_pipe() (edri.abstract.manager.manager_base.ManagerBase method) resolve_unknown() (edri.abstract.manager.manager_base.ManagerBase method) resolve_worker_control_event() (edri.abstract.manager.manager_base.ManagerBase method) resolve_worker_event() (edri.abstract.manager.manager_base.ManagerBase method) ResolvedSort (class in edri.integrations.sqlalchemy.sort) resolver_idle_delay (edri.abstract.manager.manager_base.ManagerBase attribute) resolver_wait_timeout (edri.abstract.manager.manager_base.ManagerBase attribute) resource_prefix() (edri.api.extensions.url_prefix.PrefixBase class method) resources (edri.integrations.pydantic_ai.agent.AgentDeps attribute) Response (class in edri.dataclass.response) response (edri.dataclass.event.Event attribute) response() (in module edri.abstract) (in module edri.dataclass.response) response_data (edri.integrations.pydantic_ai.observability.AgentAction attribute) ResponseAwareSession (class in edri.integrations.sqlalchemy.session) ResponseDirective (class in edri.dataclass.directive) ResponseHeaders (class in edri.api.headerkit.response) ResponseStatus (class in edri.dataclass.response) REST (edri.config.constant.ApiType attribute) Restart (class in edri.events.edri.manager.restart) RESTResponseDirective (class in edri.dataclass.directive) retry_after (edri.dataclass.directive.http.TooManyRequestsResponseDirective attribute) RETURNED (edri.dataclass.worker.WorkerExit attribute) revision (edri.integrations.pydantic_ai.inspector_events.AgentInspectorActionResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) root (edri.integrations.pydantic_ai.inspector_store.RunState property) root_action_id (edri.integrations.pydantic_ai.inspector_events.AgentInspectorActionResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRun attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) Router (class in edri.events.edri.group.router) router_id (edri.dataclass.event.SwitchInfo attribute) (edri.events.edri.router.demands.Demands attribute) rss_bytes (edri.dataclass.health_checker.Vitals attribute) rss_peak_bytes (edri.dataclass.health_checker.Vitals attribute) RUN (edri.dataclass.worker.WorkerTimeout attribute) run (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunResponse attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdateResponse attribute) RUN (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) run() (edri.abstract.manager.manager_base.ManagerBase method) (edri.abstract.worker.worker.Worker method) (edri.api.grpc.listener.GRPCListener method) (edri.EDRI method) (edri.integrations.pydantic_ai.inspector_store.InspectorStore method) (edri.switch.forwarder.Forwarder method) (edri.switch.receiver.Receiver method) (edri.switch.sender.Sender method) (edri.switch.switch.Switch method) run_id (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRun attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRuns attribute) (edri.integrations.pydantic_ai.inspector_events.AgentInspectorUpdate attribute) (edri.integrations.pydantic_ai.observability.AgentAction attribute) run_resolver() (edri.abstract.manager.async_manager_base.AsyncManagerBase method) (edri.abstract.manager.manager_base.ManagerBase method) (edri.abstract.manager.manager_priority_base.ManagerPriorityBase method) run_resolver_cycle() (edri.abstract.manager.manager_base.ManagerBase method) running (edri.abstract.manager.worker_controller.WorkerController property) RUNNING (edri.dataclass.worker.WorkerState attribute) runs (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute) runs() (edri.integrations.pydantic_ai.inspector_store.InspectorStore method) RunState (class in edri.integrations.pydantic_ai.inspector_store)

S

safe_val() (edri.utility.validation.StringValidator static method) samesite (edri.dataclass.directive.http.CookieResponseDirective attribute) Scheduler (class in edri.events.edri.group.scheduler) Scope (class in edri.api.dataclass) secure (edri.dataclass.directive.http.CookieResponseDirective attribute) SecureChannel (class in edri.protocol.channel) seed() (edri.utility.cache.Cache method) SeeOtherResponseDirective (class in edri.dataclass.directive.http) send() (edri.protocol.channel.SecureChannel method) send_to_router() (edri.abstract.manager.manager_base.ManagerBase method) send_unkeyed() (edri.protocol.channel.SecureChannel method) Sender (class in edri.switch.sender) SendFrom (class in edri.events.edri.router.send_from) serve_status() (in module edri.switch.status) server_handshake() (in module edri.protocol.handshake) server_handshake_unauthenticated() (in module edri.protocol.handshake) ServiceUnavailableResponseDirective (class in edri.dataclass.directive.http) Set (class in edri.events.edri.scheduler.set) (class in edri.events.edri.store.set) set() (edri.api.headerkit.response.ResponseHeaders method) set_content_type() (edri.api.headerkit.response.ResponseHeaders method) set_cookie() (edri.api.headerkit.response.ResponseHeaders method) set_date() (edri.api.headerkit.response.ResponseHeaders method) set_response() (edri.dataclass.event.Event method) set_status() (edri.dataclass.response.Response method) setdefault() (edri.utility.normalized_default_dict.NormalizedDefaultDict method) SetIfAbsent (class in edri.events.edri.store.set_if_absent) setup() (edri.abstract.worker.worker.Worker method) (edri.integrations.pydantic_ai.worker.BaseAgentWorker method) SetUpdate (class in edri.events.edri.scheduler.set_or_update) SharedMemoryPipe (class in edri.utility.shared_memory_pipe) should_send_resolved_event() (edri.abstract.manager.manager_base.ManagerBase method) since (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRuns attribute) SINGLETON (edri.api.headerkit.types.CombineMode attribute) singleton() (edri.api.headerkit.core.Headers method) singleton_raw() (edri.api.headerkit.core.Headers method) snake2camel() (in module edri.utility.function) solve_req_get_action() (edri.integrations.pydantic_ai.inspector.AgentInspectorManager method) solve_req_get_run() (edri.integrations.pydantic_ai.inspector.AgentInspectorManager method) solve_req_get_stats() (edri.integrations.pydantic_ai.inspector.AgentInspectorManager method) solve_req_list_runs() (edri.integrations.pydantic_ai.inspector.AgentInspectorManager method) solve_req_observe() (edri.integrations.pydantic_ai.inspector.AgentInspectorManager method) SortBuilder (class in edri.integrations.sqlalchemy.sort) source (edri.switch.forwarder.ForwardMessage attribute) source_connection (edri.switch.forwarder.ForwardMessage attribute) SPECIFIC (edri.dataclass.event.EventHandlingType attribute) (edri.switch.forwarder.ForwardType attribute) specificity (edri.api.headerkit.types.AcceptItem property) spend() (edri.integrations.pydantic_ai.normalization.NormalizationBudget method) SQLAlchemyManager (class in edri.integrations.sqlalchemy.session) SQLAlchemyManagerMixin (class in edri.integrations.sqlalchemy.session)

SQLAlchemyModelMixin (class in edri.integrations.sqlalchemy.model) SQLAlchemyPathError SQLAlchemyResponseMiddleware (class in edri.integrations.sqlalchemy.middleware) START (edri.dataclass.worker.WorkerTimeout attribute) (edri.integrations.pydantic_ai.observability.AgentActionPhase attribute) start() (edri.abstract.manager.manager_base.ManagerBase method) (edri.abstract.manager.worker.WorkerRuntimeProtocol method) (edri.abstract.manager.worker_controller.WorkerController method) start_api() (edri.EDRI method) start_broker() (edri.EDRI method) start_connector() (edri.EDRI method) start_grpc() (edri.EDRI method) start_missing (edri.integrations.pydantic_ai.inspector_store.ActionState property) (edri.integrations.pydantic_ai.inspector_store.AttemptState property) start_scheduler() (edri.EDRI method) start_store() (edri.EDRI method) start_watcher() (edri.EDRI method) start_worker() (edri.abstract.manager.manager_base.ManagerBase method) started() (edri.abstract.manager.worker_controller.WorkerController method) STARTING (edri.dataclass.worker.WorkerState attribute) stats() (edri.integrations.pydantic_ai.inspector_store.InspectorStore method) Status (class in edri.dataclass.health_checker) status (edri.dataclass.health_checker.HealthReport attribute) (edri.dataclass.health_checker.Record attribute) status() (edri.switch.switch.Switch method) STOP (edri.api.middleware.MiddlewareControl.ActionType attribute) stop_processing() (edri.api.middleware.MiddlewareControl class method) stop_resolver() (edri.abstract.manager.manager_base.ManagerBase method) stopping (edri.abstract.manager.worker_controller.WorkerController property) STOPPING (edri.dataclass.worker.WorkerState attribute) Storage (class in edri.utility.storage) Store (class in edri.events.edri.group.store) store_get() (edri.abstract.manager.manager_base.ManagerBase method) StoreChange (class in edri.integrations.pydantic_ai.inspector_store) StoreLimits (class in edri.integrations.pydantic_ai.inspector_store) StorePurge (class in edri.events.edri.store.store_purge) StoreStats (class in edri.integrations.pydantic_ai.inspector_store) STRICT (edri.api.headerkit.policy.ParseMode attribute) STRING_MATCH_OPS (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) StringTransformer (class in edri.utility.transformation) StringValidator (class in edri.utility.validation) Subscribe (class in edri.events.edri.router.subscribe) SubscribeConnector (class in edri.events.edri.router.subscribe_connector) SUBSCRIBED (edri.dataclass.event.EventHandlingType attribute) SubscribedExternal (class in edri.events.edri.router.subscribed_external) SubscribedNew (class in edri.events.edri.router.subscribed_new) SUCCEEDED (edri.dataclass.worker.WorkerOutcome attribute) SUCCESS (edri.integrations.pydantic_ai.observability.AgentActionOutcome attribute) Switch (class in edri.events.edri.group.switch) (class in edri.switch.switch) SwitchInfo (class in edri.dataclass.event)

T

tag() (edri.utility.cache.Cache method) TemporaryRedirectResponseDirective (class in edri.dataclass.directive.http) terminal_missing (edri.integrations.pydantic_ai.inspector_store.ActionState property) (edri.integrations.pydantic_ai.inspector_store.AttemptState property) TERMINATED (edri.dataclass.worker.WorkerExit attribute) TERMINATING (edri.dataclass.worker.WorkerState attribute) Test (class in edri.events.edri.group.test) threads (edri.dataclass.health_checker.Vitals attribute) TIMED_OUT (edri.dataclass.worker.WorkerOutcome attribute) TIMEOUT (edri.dataclass.worker.WorkerStopReason attribute) (edri.integrations.pydantic_ai.observability.AgentActionOutcome attribute) timestamp (edri.dataclass.health_checker.Record attribute) TimeValidator (class in edri.utility.validation) to_json() (edri.integrations.sqlalchemy.model.SQLAlchemyModelMixin method) TOO_DEEP (in module edri.integrations.pydantic_ai.normalization) TOO_LARGE (edri.protocol.errors.ErrorReason attribute)

TOOL (edri.integrations.pydantic_ai.observability.AgentActionNamespace attribute) tool_result (edri.integrations.pydantic_ai.agent.ToolResponse property) ToolResponse (class in edri.integrations.pydantic_ai.agent) TooManyRequestsResponseDirective (class in edri.dataclass.directive.http) Topology (class in edri.events.edri.router.topology) TOTAL (edri.dataclass.worker.WorkerTimeout attribute) total (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRunsResponse attribute) traceback (edri.events.edri.manager.worker_quit.WorkerQuit attribute) transcript_mac() (in module edri.protocol.handshake) trimmed_runs (edri.integrations.pydantic_ai.inspector_events.AgentInspectorStatsResponse attribute) TRUE_VALUES (edri.integrations.sqlalchemy.filter.FilterBuilder attribute) TRUNCATED (in module edri.integrations.pydantic_ai.normalization) ttl (edri.events.edri.store.compare_and_set.CompareAndSet attribute) (edri.events.edri.store.increment.Increment attribute) (edri.events.edri.store.set.Set attribute) (edri.events.edri.store.set_if_absent.SetIfAbsent attribute) TypeCoercer (class in edri.utility.coercion)

U

UnauthorizedResponseDirective (class in edri.dataclass.directive.base) unknown_field_policy (edri.integrations.sqlalchemy.filter.FilterBuilderConfig attribute) UNKNOWN_ROUTER (edri.protocol.errors.ErrorReason attribute) UnknownHeaderMode (class in edri.api.headerkit.policy) UnprocessableContentResponseDirective (class in edri.dataclass.directive.http) Unregister (class in edri.events.api.client.unregister) UnregisterAll (class in edri.events.api.manage.unregister_all) UnroutedEvent (class in edri.dataclass.topology) Unsubscribe (class in edri.events.edri.router.unsubscribe) UnsubscribeAll (class in edri.events.edri.router.unsubscribe_all)

UNSUPPORTED (in module edri.integrations.pydantic_ai.normalization) UnsupportedMediaTypeResponseDirective (class in edri.dataclass.directive.http) until (edri.integrations.pydantic_ai.inspector_events.AgentInspectorRuns attribute) Update (class in edri.events.edri.scheduler.update) update() (edri.utility.normalized_default_dict.NormalizedDefaultDict method) UPDATED (edri.integrations.pydantic_ai.inspector_store.ChangeKind attribute) uptime_seconds (edri.dataclass.health_checker.Vitals attribute) url_prefix() (edri.api.extensions.url_prefix.PrefixBase static method) usage (edri.integrations.pydantic_ai.observability.AgentAction attribute) USAGE_FIELDS (in module edri.integrations.pydantic_ai.normalization) usage_snapshot() (in module edri.integrations.pydantic_ai.normalization)

V

VALIDATE (edri.integrations.pydantic_ai.observability.AgentActionOperation attribute) value (edri.api.headerkit.types.AcceptItem property) verify_frame() (in module edri.protocol.frame)

version (edri.dataclass.directive.http.CookieResponseDirective attribute) (edri.integrations.pydantic_ai.agent.AgentBase attribute) Vitals (class in edri.dataclass.health_checker) vitals (edri.dataclass.health_checker.Record attribute)

W

wait_cancelled() (edri.abstract.worker.worker.Worker method) wait_for_active_pipes() (edri.abstract.manager.manager_base.ManagerBase method) WARNING (edri.dataclass.health_checker.Status attribute) WebSocketResponseDirective (class in edri.dataclass.directive) Weighted (class in edri.api.headerkit.types) when (edri.events.edri.scheduler.update.Update attribute) Worker (class in edri.abstract.manager.worker) (class in edri.abstract.worker.worker) WorkerCancelled WorkerController (class in edri.abstract.manager.worker_controller) WorkerExit (class in edri.dataclass.worker) WorkerFactoryProtocol (class in edri.abstract.manager.worker) WorkerNotFoundError WorkerOutcome (class in edri.dataclass.worker) WorkerPolicy (class in edri.dataclass.worker)

WorkerProcess (class in edri.abstract.worker.worker_process) WorkerQuit (class in edri.events.edri.manager.worker_quit) WorkerRuntimeProtocol (class in edri.abstract.manager.worker) workers_limit (edri.dataclass.health_checker.Vitals attribute) workers_oldest_age_seconds (edri.dataclass.health_checker.Vitals attribute) workers_pending (edri.dataclass.health_checker.Vitals attribute) workers_running (edri.dataclass.health_checker.Vitals attribute) WorkerStarted (class in edri.events.edri.manager.worker_started) WorkerState (class in edri.dataclass.worker) WorkerStopReason (class in edri.dataclass.worker) WorkerThread (class in edri.abstract.worker.worker_thread) WorkerTimeout (class in edri.dataclass.worker) WorkerView (class in edri.abstract.manager.worker_controller) write() (edri.utility.shared_memory_pipe.SharedMemoryPipe method) WS (edri.config.constant.ApiType attribute)