Struct RtkServer 

pub struct RtkServer {
    pub(crate) tool_router: ToolRouter<Self>,
    pub(crate) config: Config,
}

The MCP server. Holds the generated tool router plus the resolved settings.

Fields

tool_router: ToolRouter<Self>

config: Config

Implementations

impl RtkServer

pub fn new(project_dir: &Path) -> Self

Build a server, loading settings relative to project_dir.

pub(crate) fn run(&self, args: &[String]) -> Result<String, ErrorData>

Run rtk with args and return its output as the tool result.

stderr is folded into the result rather than dropped: rtk puts its advisory notices there, and a tool that silently discards the only explanation of an empty result is worse than a noisy one.

impl RtkServer

pub fn rtk_gain_tool_attr() -> Tool

Generated tool metadata function for rtk_gain

pub(crate) fn rtk_gain( &self, Parameters: Parameters<GainRequest>, ) -> Pin<Box<dyn Future<Output = Result<String, ErrorData>> + Send + '_>>

Token-savings analytics.

pub fn rtk_discover_tool_attr() -> Tool

Generated tool metadata function for rtk_discover

pub(crate) fn rtk_discover( &self, Parameters: Parameters<DiscoverRequest>, ) -> Pin<Box<dyn Future<Output = Result<String, ErrorData>> + Send + '_>>

Missed-optimization analysis over past sessions.

pub fn rtk_check_tool_attr() -> Tool

Generated tool metadata function for rtk_check

pub(crate) fn rtk_check( &self, Parameters: Parameters<CheckRequest>, ) -> Pin<Box<dyn Future<Output = Result<String, ErrorData>> + Send + '_>>

Dry-run the rewrite engine.

pub fn rtk_proxy_tool_attr() -> Tool

Generated tool metadata function for rtk_proxy

pub(crate) fn rtk_proxy( &self, Parameters: Parameters<ProxyRequest>, ) -> Pin<Box<dyn Future<Output = Result<String, ErrorData>> + Send + '_>>

Execute a command unoptimized, but still counted.

This is the one tool here that runs something. It exists for the case rtk’s own docs call out — debugging rtk itself, when you need a command to bypass the rewrite rules while still being tracked in the statistics. It takes an argv vector and spawns it directly, so no shell metacharacter is ever interpreted.

pub(crate) fn tool_router() -> ToolRouter<Self>

Trait Implementations

impl Clone for RtkServer

fn clone(&self) -> RtkServer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RtkServer

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

Formats the value using the given formatter.

impl ServerHandler for RtkServer

fn get_info(&self) -> ServerConfig

async fn call_tool( &self, request: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> Result<CallToolResponse, ErrorData>

Handle a tools/call request from a client.

async fn list_tools( &self, _request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, ErrorData>

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

Get a tool definition by name.

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 negotiate_initialize( &self, request: &InitializeRequestParams, ) -> Result<InitializeResult, ErrorData>

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

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 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_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.