Struct Tracked 

pub struct Tracked<H> { /* private fields */ }

A server handler wrapped by AgentCat::track or track. It implements rmcp’s ServerHandler, so it is served like the handler it wraps. When AGENTCAT_ENABLED turned the handle off, it forwards every method to the wrapped handler untouched, and a tool still gets a CallContext, with no session and no agent.

Implementations

impl<H> Tracked<H>

pub fn inner(&self) -> &H

The wrapped handler.

pub fn inner_mut(&mut self) -> &mut H

The wrapped handler, mutably.

pub fn into_inner(self) -> H

Unwraps the handler.

pub fn agentcat(&self) -> &AgentCat

The handle this wrapper reports to.

pub fn publish_custom_event( &self, project_id: &str, event: CustomEvent, ) -> Result<(), Error>

where H: ServerHandler,

Publishes a custom event with the identity of this instance. It only queues the event, so it returns at once. The client is the one this instance’s initialize named (none before it, and none on a clone, which has seen no initialize); the server is what the handler’s get_info gives now, and a panic there is logged and leaves the event without server fields.

The event goes to the project of the handle, not to project_id, which only has to be non-empty. Nothing is queued while tracing is off, or by a handle that AGENTCAT_ENABLED turned off. The redact_event hook of the options runs on the event, on the runtime of the caller; the string hook does not. The event has no session unless the CustomEvent names one: it takes none from anywhere else. Inside a tool, pass CallContext::session_id in the CustomEvent to attribute the event to the call. A duration of zero or none is the time since the event was built.

use agentcat_sdk::CustomEvent;

tracked.publish_custom_event("proj_123", CustomEvent::new().resource_name("startup"))?;

Errors

Error::ProjectIdRequired when project_id is empty, except on a handle that AGENTCAT_ENABLED turned off, which returns Ok(()) and does nothing, not even call the handler’s get_info.

Trait Implementations

impl<H: Clone> Clone for Tracked<H>

fn clone(&self) -> Self

Clones the handler and the handle; the clone has seen no initialize, so it holds no client identity.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<H> Debug for Tracked<H>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Names the wrapped handler’s type, so H needs no Debug impl.

impl<H: ServerHandler> ServerHandler for Tracked<H>

fn call_tool( &self, request: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CallToolResponse, ErrorData>> + MaybeSendFuture + '_

The tool-call pipeline around the handler’s call_tool: interception, stripping, mint-back and the record of the call; on a handle that is off, the handler’s call_tool with a CallContext without session or agent.

fn get_tool(&self, name: &str) -> Option<Tool>

The injected descriptor of get_more_tools, or the handler’s tool through the pipeline, so the call path sees what the listing showed. The pipeline’s log lines are dropped: the listing logs them once. On a handle that is off, the handler’s tool.

fn ping( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture + '_

fn initialize( &self, request: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + MaybeSendFuture + '_

fn supported_protocol_versions(&self) -> Cow<'static, [ProtocolVersion]>

Return the protocol versions supported by this server.

fn discover( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<DiscoverResult, ErrorData>> + MaybeSendFuture + '_

Return this server’s discovery information.

fn complete( &self, request: CompleteRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CompleteResult, ErrorData>> + MaybeSendFuture + '_

fn set_level( &self, request: SetLevelRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture + '_

fn get_prompt( &self, request: GetPromptRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetPromptResponse, ErrorData>> + MaybeSendFuture + '_

fn list_prompts( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListPromptsResult, ErrorData>> + MaybeSendFuture + '_

fn list_resources( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourcesResult, ErrorData>> + MaybeSendFuture + '_

fn list_resource_templates( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourceTemplatesResult, ErrorData>> + MaybeSendFuture + '_

fn read_resource( &self, request: ReadResourceRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ReadResourceResponse, ErrorData>> + MaybeSendFuture + '_

fn accepted_subscription_filter( &self, requested: &SubscriptionFilter, ) -> Option<SubscriptionFilter>

Return the subset of a requested notification filter this server accepts.

fn listen( &self, context: SubscriptionContext, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture + '_

Run one established subscription until it is cancelled or closed gracefully.

fn subscribe( &self, request: SubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture + '_

👎Deprecated:

resources/subscribe is legacy-only; implement accepted_subscription_filter and listen for protocol version 2026-07-28

fn unsubscribe( &self, request: UnsubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture + '_

👎Deprecated:

resources/unsubscribe is legacy-only; subscriptions/listen is cancelled through its request lifecycle

fn list_tools( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListToolsResult, ErrorData>> + MaybeSendFuture + '_

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture + '_

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture + '_

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture + '_

fn on_initialized( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture + '_

fn on_roots_list_changed( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture + '_

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture + '_

fn get_info(&self) -> InitializeResult

fn get_task( &self, request: GetTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskResult, ErrorData>> + MaybeSendFuture + '_

SEP-2663 tasks/get: return the current DetailedTask state.

fn update_task( &self, request: UpdateTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture + '_

SEP-2663 tasks/update: accept responses to outstanding in-task input requests. Returns an empty acknowledgement on success.

fn cancel_task( &self, request: CancelTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture + '_

SEP-2663 tasks/cancel: cooperative cancellation. Returns an empty acknowledgement; the task’s observable status may lag.

fn negotiate_initialize( &self, request: &InitializeRequestParams, ) -> Result<InitializeResult, ErrorData>

Build the initialize response for request, negotiating the protocol version against Self::supported_protocol_versions.