Index _ | A | B | C | D | E | F | G | H | I | J | L | M | N | O | P | Q | R | S | T | U | V | W _ __init__() (converge.coordination.bidding.BiddingProtocol method) (converge.core.agent.Agent method) (converge.extensions.llm.AnthropicProvider method) (converge.extensions.llm.LLMAgent method) (converge.extensions.llm.MistralProvider method) (converge.extensions.llm.OpenAIProvider method) (converge.network.discovery.DiscoveryService method) (converge.policy.admission.TokenAdmission method) (converge.policy.admission.WhitelistAdmission method) (converge.policy.safety.ActionPolicy method) (converge.runtime.executor.StandardExecutor method) (converge.runtime.loop.AgentRuntime method) A accept() (converge.coordination.negotiation.NegotiationProtocol method) accept_inbound_http() (converge.extensions.connectors.WebhookConnector method) ACCEPTED (converge.coordination.negotiation.NegotiationState attribute) AcceptProposal (class in converge.core.decisions) achat() (converge.extensions.llm.LLMProvider method) ActionPolicy (class in converge.policy.safety) add() (converge.core.capability.CapabilitySet method) add_agent() (converge.core.pool.Pool method) address (converge.observability.runtime_ops.RuntimeOpsServer property) adecide() (converge.extensions.llm.LLMAgent method) admission_policy (converge.core.pool.Pool attribute), [1] admission_policy_instance (converge.core.pool.Pool attribute) AdmissionPolicy (class in converge.policy.admission) Agent (class in converge.core.agent) AgentDescriptor (class in converge.network.discovery) AgentNetwork (class in converge.network.network) AgentRuntime (class in converge.runtime.loop) agents (converge.core.pool.Pool attribute), [1] AgentState (class in converge.core.agent) allow_message() (converge.extensions.rate_limit.RateLimiter method) allow_request() (converge.extensions.connectors.CircuitBreaker method) allowed_actions (converge.policy.safety.ActionPolicy attribute) allowed_content_types (converge.extensions.connectors.WebhookSecurityPolicy attribute) amount (converge.core.decisions.SubmitBid attribute) AnthropicProvider (class in converge.extensions.llm) ASSIGNED (converge.core.task.TaskState attribute) assigned_to (converge.core.task.Task attribute), [1] atomic_put_if_absent (converge.core.store.Store attribute) (converge.extensions.storage.file.FileStore attribute) (converge.extensions.storage.memory.MemoryStore attribute) attributes (converge.core.topic.Topic attribute) auction_id (converge.core.decisions.SubmitBid attribute) AuctionType (class in converge.coordination.bidding) B base_delay_sec (converge.extensions.connectors.WebhookRetryPolicy attribute) BicameralGovernance (class in converge.policy.governance) BiddingProtocol (class in converge.coordination.bidding) bids (converge.coordination.bidding.BiddingProtocol attribute) body (converge.extensions.connectors.OutboundWebhookAction attribute) broadcast() (converge.network.network.AgentNetwork method) build_descriptor() (in module converge.network.network) BUSY (converge.core.agent.AgentState attribute) C can_admit() (converge.policy.admission.AdmissionPolicy method) (converge.policy.admission.OpenAdmission method) (converge.policy.admission.TokenAdmission method) (converge.policy.admission.WhitelistAdmission method) cancel_task() (converge.coordination.task_manager.TaskManager method) CANCELLED (converge.core.task.TaskState attribute) canonicalization (converge.extensions.connectors.ProviderProfile attribute) capabilities (converge.core.agent.Agent attribute), [1] (converge.core.capability.CapabilitySet attribute) (converge.network.discovery.AgentDescriptor attribute) (converge.network.discovery.DiscoveryQuery attribute) Capability (class in converge.core.capability) CapabilitySet (class in converge.core.capability) capacity (converge.extensions.rate_limit.TokenBucketConfig attribute) chat() (converge.extensions.llm.AnthropicProvider method) (converge.extensions.llm.LLMProvider method) (converge.extensions.llm.MistralProvider method) (converge.extensions.llm.OpenAIProvider method) CircuitBreaker (class in converge.extensions.connectors) claim() (converge.coordination.task_manager.TaskManager method) claimed_at (converge.core.task.Task attribute) ClaimTask (class in converge.core.decisions) clear() (converge.network.transport.local.LocalTransportRegistry method) CLOSED (converge.coordination.negotiation.NegotiationState attribute) COMPLETED (converge.core.task.TaskState attribute) compute_delay() (converge.extensions.connectors.WebhookRetryPolicy method) configure_logging() (in module converge.observability.logging) Consensus (class in converge.coordination.consensus) constraints (converge.core.capability.Capability attribute), [1] (converge.core.task.Task attribute), [1] content (converge.coordination.negotiation.Proposal attribute) (converge.core.decisions.SubmitBid attribute) converge.coordination.bidding module converge.coordination.consensus module converge.coordination.delegation module converge.coordination.negotiation module converge.coordination.pool_manager module converge.coordination.task_manager module converge.core.agent module converge.core.capability module converge.core.decisions module converge.core.identity module converge.core.message module converge.core.pool module converge.core.store module converge.core.task module converge.core.tools module converge.core.topic module converge.extensions.connectors module converge.extensions.crypto module converge.extensions.llm module converge.extensions.rate_limit module converge.extensions.storage.file module converge.extensions.storage.memory module converge.network.discovery module converge.network.identity_registry module converge.network.network module converge.network.transport.base module converge.network.transport.hooks module converge.network.transport.local module converge.network.transport.tcp module converge.observability.coordination_metrics module converge.observability.logging module converge.observability.metrics module converge.observability.replay module converge.observability.runtime_ops module converge.observability.tracing module converge.policy.admission module converge.policy.governance module converge.policy.safety module converge.policy.trust module converge.runtime.executor module converge.runtime.hooks module converge.runtime.loop module converge.runtime.scheduler module CoordinationMetrics (class in converge.observability.coordination_metrics) costs (converge.core.capability.Capability attribute), [1] COUNTERED (converge.coordination.negotiation.NegotiationState attribute) create_pool() (converge.coordination.pool_manager.PoolManager method) create_session() (converge.coordination.negotiation.NegotiationProtocol method) CreatePool (class in converge.core.decisions) current_proposal (converge.coordination.negotiation.NegotiationSession attribute) D deadline (converge.extensions.connectors.OutboundWebhookAction attribute) decide() (converge.core.agent.Agent method) (converge.extensions.llm.LLMAgent method) Decision (class in converge.core.decisions) decrypt() (in module converge.extensions.crypto) decrypt_payload() (converge.core.message.Message method) Delegate (class in converge.core.decisions) delegate() (converge.coordination.delegation.DelegationProtocol method) delegatee_id (converge.core.decisions.Delegate attribute) delegation_id (converge.core.decisions.RevokeDelegation attribute) DelegationProtocol (class in converge.coordination.delegation) DelegationType (class in converge.coordination.delegation) delete() (converge.core.store.Store method) (converge.extensions.storage.file.FileStore method) (converge.extensions.storage.memory.MemoryStore method) DemocraticGovernance (class in converge.policy.governance) derive_key() (in module converge.extensions.crypto) description (converge.core.capability.Capability attribute), [1] descriptors (converge.network.discovery.DiscoveryService attribute) DictatorialGovernance (class in converge.policy.governance) DIRECT (converge.coordination.delegation.DelegationType attribute) discover() (converge.network.network.AgentNetwork method) DiscoveryQuery (class in converge.network.discovery) DiscoveryService (class in converge.network.discovery) dispatch_outbound_action() (converge.extensions.connectors.WebhookConnector method) DUTCH (converge.coordination.bidding.AuctionType attribute) E emit_as (converge.extensions.connectors.ProviderProfile attribute) EmpiricalGovernance (class in converge.policy.governance) encrypt() (in module converge.extensions.crypto) encrypt_payload() (converge.core.message.Message method) ENGLISH (converge.coordination.bidding.AuctionType attribute) ERROR (converge.core.agent.AgentState attribute) evaluator (converge.core.task.Task attribute), [1] event_id (converge.extensions.connectors.InboundWebhookEvent attribute) event_id_field (converge.extensions.connectors.ProviderProfile attribute) execute() (converge.runtime.executor.Executor method) (converge.runtime.executor.StandardExecutor method) Executor (class in converge.runtime.executor) export() (converge.observability.replay.ReplayLog method) (converge.observability.tracing.SpanExporter method) F fail_task() (converge.coordination.task_manager.TaskManager method) FAILED (converge.core.task.TaskState attribute) failure_threshold (converge.extensions.connectors.CircuitBreaker attribute) FileStore (class in converge.extensions.storage.file) fingerprint (converge.core.identity.Identity attribute), [1] FIRST_PRICE_SEALED_BID (converge.coordination.bidding.AuctionType attribute) format() (converge.observability.logging.JsonFormatter method) format_prometheus() (converge.observability.metrics.MetricsCollector method) from_bytes() (converge.core.message.Message class method) from_dict() (converge.core.message.Message class method) (converge.core.topic.Topic class method) (converge.network.discovery.AgentDescriptor class method) from_public_key() (converge.core.identity.Identity class method) G gauge() (converge.observability.metrics.MetricsCollector method) generate() (converge.core.identity.Identity class method) get() (converge.core.store.Store method) (converge.core.tools.ToolRegistry method) (converge.extensions.storage.file.FileStore method) (converge.extensions.storage.memory.MemoryStore method) (converge.network.identity_registry.IdentityRegistry method) get_current_trace_id() (in module converge.observability.tracing) get_logger() (in module converge.observability.logging) get_pool() (converge.coordination.pool_manager.PoolManager method) get_pools_for_agent() (converge.coordination.pool_manager.PoolManager method) get_queue() (converge.network.transport.local.LocalTransportRegistry method) get_session() (converge.coordination.negotiation.NegotiationProtocol method) get_subscribers_for_topics() (converge.network.transport.local.LocalTransportRegistry method) get_task() (converge.coordination.task_manager.TaskManager method) get_tool_schema() (in module converge.core.tools) get_trust() (converge.policy.trust.TrustModel method) governance (converge.core.pool.Pool attribute), [1] governance_model (converge.core.pool.Pool attribute) GovernanceModel (class in converge.policy.governance) H handle_outbound_payload() (converge.extensions.connectors.WebhookGateway method) handle_post() (converge.extensions.connectors.WebhookGateway method) has() (converge.core.capability.CapabilitySet method) headers (converge.extensions.connectors.InboundWebhookEvent attribute) (converge.extensions.connectors.OutboundWebhookAction attribute) health_payload() (converge.extensions.connectors.WebhookGateway method) history (converge.coordination.negotiation.NegotiationSession attribute) HookedTransport (class in converge.network.transport.hooks) I id (converge.coordination.negotiation.NegotiationSession attribute) (converge.coordination.negotiation.Proposal attribute) (converge.core.agent.Agent attribute) (converge.core.agent.Agent property) (converge.core.message.Message attribute), [1] (converge.core.pool.Pool attribute), [1] (converge.core.task.Task attribute), [1] (converge.network.discovery.AgentDescriptor attribute) idempotency_key (converge.extensions.connectors.OutboundWebhookAction attribute) idempotency_ttl_sec (converge.extensions.connectors.WebhookSecurityPolicy attribute) Identity (class in converge.core.identity) identity (converge.core.agent.Agent attribute) IdentityRegistry (class in converge.network.identity_registry) IDLE (converge.core.agent.AgentState attribute) InboundWebhookEvent (class in converge.extensions.connectors) Inbox (class in converge.runtime.loop) inc() (converge.observability.metrics.MetricsCollector method) inputs (converge.core.task.Task attribute), [1] InvokeTool (class in converge.core.decisions) ip_allowlist (converge.extensions.connectors.WebhookSecurityPolicy attribute) is_allowed() (converge.policy.safety.ActionPolicy method) is_healthy() (converge.extensions.connectors.WebhookGateway method) (converge.runtime.loop.AgentRuntime method) is_open (converge.extensions.connectors.CircuitBreaker property) is_ready() (converge.extensions.connectors.WebhookGateway method) (converge.runtime.loop.AgentRuntime method) J jitter_ratio (converge.extensions.connectors.WebhookRetryPolicy attribute) join_pool() (converge.coordination.pool_manager.PoolManager method) JoinPool (class in converge.core.decisions) JsonFormatter (class in converge.observability.logging) L latency_ms (converge.core.capability.Capability attribute), [1] leave_pool() (converge.coordination.pool_manager.PoolManager method) LeavePool (class in converge.core.decisions) list() (converge.core.store.Store method) (converge.extensions.storage.file.FileStore method) (converge.extensions.storage.memory.MemoryStore method) list_names() (converge.core.tools.ToolRegistry method) list_pending_tasks() (converge.coordination.task_manager.TaskManager method) list_pending_tasks_for_agent() (converge.coordination.task_manager.TaskManager method) LLMAgent (class in converge.extensions.llm) LLMProvider (class in converge.extensions.llm) load() (converge.observability.replay.ReplayLog method) LocalTransport (class in converge.network.transport.local) LocalTransportRegistry (class in converge.network.transport.local) log_struct() (in module converge.observability.logging) M majority_vote() (converge.coordination.consensus.Consensus static method) max_attempts (converge.extensions.connectors.WebhookRetryPolicy attribute) max_cpu_tokens (converge.policy.safety.ResourceLimits attribute), [1] max_delay_sec (converge.extensions.connectors.WebhookRetryPolicy attribute) max_memory_mb (converge.policy.safety.ResourceLimits attribute), [1] max_network_requests (converge.policy.safety.ResourceLimits attribute), [1] max_payload_bytes (converge.extensions.connectors.WebhookSecurityPolicy attribute) MemoryStore (class in converge.extensions.storage.memory) Message (class in converge.core.message) message (converge.core.decisions.SendMessage attribute) MessageHook (class in converge.network.transport.hooks) method (converge.extensions.connectors.OutboundWebhookAction attribute) metrics_payload() (converge.extensions.connectors.WebhookGateway method) MetricsCollector (class in converge.observability.metrics) MistralProvider (class in converge.extensions.llm) module converge.coordination.bidding converge.coordination.consensus converge.coordination.delegation converge.coordination.negotiation converge.coordination.pool_manager converge.coordination.task_manager converge.core.agent converge.core.capability converge.core.decisions converge.core.identity converge.core.message converge.core.pool converge.core.store converge.core.task converge.core.tools converge.core.topic converge.extensions.connectors converge.extensions.crypto converge.extensions.llm converge.extensions.rate_limit converge.extensions.storage.file converge.extensions.storage.memory converge.network.discovery converge.network.identity_registry converge.network.network converge.network.transport.base converge.network.transport.hooks converge.network.transport.local converge.network.transport.tcp converge.observability.coordination_metrics converge.observability.logging converge.observability.metrics converge.observability.replay converge.observability.runtime_ops converge.observability.tracing converge.policy.admission converge.policy.governance converge.policy.safety converge.policy.trust converge.runtime.executor converge.runtime.hooks converge.runtime.loop converge.runtime.scheduler N name (converge.core.capability.Capability attribute), [1] (converge.core.tools.Tool property) (converge.extensions.connectors.ProviderProfile attribute) (converge.observability.tracing.Span attribute), [1] namespace (converge.core.topic.Topic attribute) NegotiationProtocol (class in converge.coordination.negotiation) NegotiationSession (class in converge.coordination.negotiation) NegotiationState (class in converge.coordination.negotiation) new_trace_id() (in module converge.observability.tracing) notify() (converge.runtime.scheduler.Scheduler method) O objective (converge.core.task.Task attribute), [1] occurred_at (converge.extensions.connectors.InboundWebhookEvent attribute) OFFLINE (converge.core.agent.AgentState attribute) on_error() (converge.extensions.rate_limit.RateLimitHook method) (converge.network.transport.hooks.MessageHook method) on_fallback_pre_send() (converge.runtime.hooks.RuntimeHook method) on_start() (converge.core.agent.Agent method) on_stop() (converge.core.agent.Agent method) on_tick() (converge.core.agent.Agent method) on_unverified_drop() (converge.runtime.hooks.RuntimeHook method) OpenAdmission (class in converge.policy.admission) OpenAIProvider (class in converge.extensions.llm) option (converge.core.decisions.Vote attribute) OutboundWebhookAction (class in converge.extensions.connectors) outputs (converge.core.task.Task attribute), [1] P params (converge.core.decisions.InvokeTool attribute) parent_id (converge.observability.tracing.Span attribute), [1] participants (converge.coordination.negotiation.NegotiationSession attribute) payload (converge.core.message.Message attribute), [1] (converge.extensions.connectors.InboundWebhookEvent attribute) PENDING (converge.core.task.TaskState attribute) pending_tasks() (converge.observability.coordination_metrics.CoordinationMetrics method) plurality_vote() (converge.coordination.consensus.Consensus static method) poll() (converge.runtime.loop.Inbox method) Pool (class in converge.core.pool) pool_created() (converge.observability.coordination_metrics.CoordinationMetrics method) pool_id (converge.core.decisions.JoinPool attribute) (converge.core.decisions.LeavePool attribute) (converge.core.task.Task attribute), [1] pool_join() (converge.observability.coordination_metrics.CoordinationMetrics method) pool_leave() (converge.observability.coordination_metrics.CoordinationMetrics method) pool_manager (converge.core.agent.Agent attribute) pool_size() (converge.observability.coordination_metrics.CoordinationMetrics method) POOLED (converge.coordination.delegation.DelegationType attribute) PoolManager (class in converge.coordination.pool_manager) post_receive() (converge.extensions.rate_limit.RateLimitHook method) (converge.network.transport.hooks.MessageHook method) pre_send() (converge.extensions.rate_limit.RateLimitHook method) (converge.network.transport.hooks.MessageHook method) priority (converge.core.task.Task attribute), [1] private_key (converge.core.identity.Identity attribute), [1] Proposal (class in converge.coordination.negotiation) proposal_content (converge.core.decisions.Propose attribute) Propose (class in converge.core.decisions) propose() (converge.coordination.negotiation.NegotiationProtocol method) PROPOSED (converge.coordination.negotiation.NegotiationState attribute) proposer_id (converge.coordination.negotiation.Proposal attribute) provider (converge.extensions.connectors.InboundWebhookEvent attribute) ProviderProfile (class in converge.extensions.connectors) public_key (converge.core.identity.Identity attribute), [1] (converge.network.discovery.AgentDescriptor attribute) push() (converge.runtime.loop.Inbox method) put() (converge.core.store.Store method) (converge.extensions.storage.file.FileStore method) (converge.extensions.storage.memory.MemoryStore method) put_if_absent() (converge.core.store.Store method) (converge.extensions.storage.file.FileStore method) (converge.extensions.storage.memory.MemoryStore method) Q query() (converge.network.discovery.DiscoveryService method) R RateLimiter (class in converge.extensions.rate_limit) RateLimitHook (class in converge.extensions.rate_limit) ready_payload() (converge.extensions.connectors.WebhookGateway method) receive() (converge.network.transport.base.Transport method) (converge.network.transport.hooks.HookedTransport method) (converge.network.transport.local.LocalTransport method) (converge.network.transport.tcp.TcpTransport method) receive_verified() (converge.network.transport.base.Transport method) (converge.network.transport.hooks.HookedTransport method) recipient (converge.core.message.Message attribute) record_failure() (converge.extensions.connectors.CircuitBreaker method) record_inbound() (converge.observability.replay.ReplayLog method) record_message() (converge.observability.replay.ReplayLog method) record_outbound() (converge.observability.replay.ReplayLog method) record_success() (converge.extensions.connectors.CircuitBreaker method) recovery_timeout_sec (converge.extensions.connectors.CircuitBreaker attribute) refill_tokens_per_sec (converge.extensions.rate_limit.TokenBucketConfig attribute) refresh_from_store() (converge.coordination.task_manager.TaskManager method) register() (converge.core.tools.ToolRegistry method) (converge.network.discovery.DiscoveryService method) (converge.network.identity_registry.IdentityRegistry method) (converge.network.transport.local.LocalTransportRegistry method) register_agent() (converge.network.network.AgentNetwork method) register_span_exporter() (in module converge.observability.tracing) reject() (converge.coordination.negotiation.NegotiationProtocol method) REJECTED (converge.coordination.negotiation.NegotiationState attribute) RejectProposal (class in converge.core.decisions) release_expired_claims() (converge.coordination.task_manager.TaskManager method) remove_agent() (converge.core.pool.Pool method) replay() (converge.observability.replay.ReplayRunner method) ReplayLog (class in converge.observability.replay) ReplayRunner (class in converge.observability.replay) report() (converge.coordination.task_manager.TaskManager method) ReportTask (class in converge.core.decisions) request_timeout_sec (converge.extensions.connectors.WebhookRetryPolicy attribute) require_mtls (converge.extensions.connectors.WebhookSecurityPolicy attribute) required_capabilities (converge.core.task.Task attribute), [1] required_payload_fields (converge.extensions.connectors.ProviderProfile attribute) resolve() (converge.coordination.bidding.BiddingProtocol method) resolve_dispute() (converge.policy.governance.BicameralGovernance method) (converge.policy.governance.DemocraticGovernance method) (converge.policy.governance.DictatorialGovernance method) (converge.policy.governance.EmpiricalGovernance method) (converge.policy.governance.GovernanceModel method) (converge.policy.governance.VetoGovernance method) ResourceLimits (class in converge.policy.safety) result (converge.core.decisions.ReportTask attribute) (converge.core.task.Task attribute), [1] revoke() (converge.coordination.delegation.DelegationProtocol method) RevokeDelegation (class in converge.core.decisions) run() (converge.core.tools.Tool method) run_outbound_dispatcher() (converge.extensions.connectors.WebhookConnector method) RUNNING (converge.core.task.TaskState attribute) RuntimeHook (class in converge.runtime.hooks) RuntimeOpsServer (class in converge.observability.runtime_ops) S Scheduler (class in converge.runtime.scheduler) scope (converge.core.decisions.Delegate attribute) SECOND_PRICE_SEALED_BID (converge.coordination.bidding.AuctionType attribute) secret_ref (converge.extensions.connectors.ProviderProfile attribute) secure_random_bytes() (in module converge.extensions.crypto) send() (converge.network.network.AgentNetwork method) (converge.network.transport.base.Transport method) (converge.network.transport.hooks.HookedTransport method) (converge.network.transport.local.LocalTransport method) (converge.network.transport.tcp.TcpTransport method) sender (converge.core.message.Message attribute), [1] SendMessage (class in converge.core.decisions) session_id (converge.core.decisions.AcceptProposal attribute) (converge.core.decisions.Propose attribute) (converge.core.decisions.RejectProposal attribute) sessions (converge.coordination.negotiation.NegotiationProtocol attribute) set_trace_id() (in module converge.observability.tracing) sign() (converge.core.message.Message method) sign_message() (converge.core.agent.Agent method) signature (converge.core.message.Message attribute), [1] signature_algorithm (converge.extensions.connectors.ProviderProfile attribute) signature_header (converge.extensions.connectors.ProviderProfile attribute) snapshot() (converge.observability.metrics.MetricsCollector method) source (converge.extensions.connectors.InboundWebhookEvent attribute) source_field (converge.extensions.connectors.ProviderProfile attribute) Span (class in converge.observability.tracing) span_id (converge.observability.tracing.Span attribute), [1] SpanExporter (class in converge.observability.tracing) spec (converge.core.decisions.CreatePool attribute) StandardExecutor (class in converge.runtime.executor) start() (converge.network.transport.base.Transport method) (converge.network.transport.hooks.HookedTransport method) (converge.network.transport.local.LocalTransport method) (converge.network.transport.tcp.TcpTransport method) (converge.observability.runtime_ops.RuntimeOpsServer method) (converge.runtime.loop.AgentRuntime method) state (converge.coordination.negotiation.NegotiationSession attribute) (converge.core.agent.Agent attribute) (converge.core.task.Task attribute), [1] stop() (converge.network.transport.base.Transport method) (converge.network.transport.hooks.HookedTransport method) (converge.network.transport.local.LocalTransport method) (converge.network.transport.tcp.TcpTransport method) (converge.observability.runtime_ops.RuntimeOpsServer method) (converge.runtime.loop.AgentRuntime method) stop_dispatcher() (converge.extensions.connectors.WebhookConnector method) Store (class in converge.core.store) strict_mode (converge.extensions.connectors.WebhookSecurityPolicy attribute) subject (converge.extensions.connectors.InboundWebhookEvent attribute) subject_field (converge.extensions.connectors.ProviderProfile attribute) submit() (converge.coordination.task_manager.TaskManager method) submit_bid() (converge.coordination.bidding.BiddingProtocol method) submit_outbound_action() (converge.extensions.connectors.WebhookConnector method) submit_outbound_message() (converge.extensions.connectors.WebhookConnector method) SubmitBid (class in converge.core.decisions) SubmitTask (class in converge.core.decisions) subscribe() (converge.network.transport.local.LocalTransportRegistry method) supports_locking (converge.core.store.Store attribute) (converge.extensions.storage.file.FileStore attribute) (converge.extensions.storage.memory.MemoryStore attribute) T target (converge.extensions.connectors.OutboundWebhookAction attribute) Task (class in converge.core.task) task (converge.core.decisions.SubmitTask attribute) task_cancelled() (converge.observability.coordination_metrics.CoordinationMetrics method) task_claimed() (converge.observability.coordination_metrics.CoordinationMetrics method) task_completed() (converge.observability.coordination_metrics.CoordinationMetrics method) task_failed() (converge.observability.coordination_metrics.CoordinationMetrics method) task_id (converge.core.decisions.ClaimTask attribute) (converge.core.decisions.ReportTask attribute) (converge.core.message.Message attribute), [1] task_manager (converge.core.agent.Agent attribute) task_submitted() (converge.observability.coordination_metrics.CoordinationMetrics method) TaskManager (class in converge.coordination.task_manager) TaskState (class in converge.core.task) TcpTransport (class in converge.network.transport.tcp) timestamp (converge.coordination.negotiation.Proposal attribute) (converge.core.message.Message attribute), [1] timestamp_header (converge.extensions.connectors.ProviderProfile attribute) timestamp_skew_limit_sec (converge.extensions.connectors.WebhookSecurityPolicy attribute) to_bytes() (converge.core.message.Message method) to_dict() (converge.core.message.Message method) (converge.core.topic.Topic method) (converge.network.discovery.AgentDescriptor method) to_provider_tools() (converge.core.tools.ToolRegistry method) TokenAdmission (class in converge.policy.admission) TokenBucketConfig (class in converge.extensions.rate_limit) Tool (class in converge.core.tools) tool_name (converge.core.decisions.InvokeTool attribute) ToolRegistry (class in converge.core.tools) Topic (class in converge.core.topic) topic (converge.core.task.Task attribute), [1] topics (converge.core.agent.Agent attribute), [1] (converge.core.message.Message attribute), [1] (converge.core.pool.Pool attribute), [1] (converge.network.discovery.AgentDescriptor attribute) (converge.network.discovery.DiscoveryQuery attribute) trace() (in module converge.observability.tracing) trace_id (converge.extensions.connectors.InboundWebhookEvent attribute) (converge.observability.tracing.Span attribute), [1] Transport (class in converge.network.transport.base) trust_model (converge.core.pool.Pool attribute) trust_threshold (converge.core.pool.Pool attribute) (converge.network.discovery.DiscoveryQuery attribute) TrustModel (class in converge.policy.trust) U unregister() (converge.network.discovery.DiscoveryService method) (converge.network.identity_registry.IdentityRegistry method) (converge.network.transport.local.LocalTransportRegistry method) unregister_agent() (converge.network.network.AgentNetwork method) unsubscribe() (converge.network.transport.local.LocalTransportRegistry method) update_trust() (converge.policy.trust.TrustModel method) url (converge.extensions.connectors.OutboundWebhookAction attribute) V validate_and_extract() (converge.extensions.connectors.WebhookSecurity method) validate_safety() (in module converge.policy.safety) verify() (converge.core.message.Message method) version (converge.core.capability.Capability attribute), [1] (converge.core.topic.Topic attribute) VetoGovernance (class in converge.policy.governance) Vote (class in converge.core.decisions) vote_id (converge.core.decisions.Vote attribute) W wait_for_work() (converge.runtime.scheduler.Scheduler method) wait_until_done() (converge.coordination.task_manager.TaskManager method) WebhookConnector (class in converge.extensions.connectors) WebhookGateway (class in converge.extensions.connectors) WebhookRetryPolicy (class in converge.extensions.connectors) WebhookSecurity (class in converge.extensions.connectors) WebhookSecurityError WebhookSecurityPolicy (class in converge.extensions.connectors) WhitelistAdmission (class in converge.policy.admission)