Struct Kit 

pub struct Kit<M, I = Local, E = Open, T = Unmetered, S = InProcessTasks> { /* private fields */ }

A module ready to serve, with the seams its calls go through.

Implementations

impl<M: Module, I: Identity> Kit<M, I>

pub fn new(module: M, identity: I) -> Self

The module with the open-source entitlements, metering and task store.

impl<M: Module, I: Identity, E: Entitlements, T: Metering, S: TaskStore> Kit<M, I, E, T, S>

pub fn with_entitlements<E2: Entitlements>( self, entitlements: E2, ) -> Kit<M, I, E2, T, S>

pub fn with_metering<T2: Metering>(self, metering: T2) -> Kit<M, I, E, T2, S>

pub fn with_changes(self, changes: impl ChangeFeed) -> Self

Carries resource changes through changes instead of within this process, for listeners on other instances.

pub fn with_tasks<S2: TaskStore>(self, tasks: S2) -> Kit<M, I, E, T, S2>

pub fn manifest(&self) -> &Manifest

pub fn tools(&self) -> impl Iterator<Item = &Tool>

Every registered operation, in registration order.

pub fn instructions(&self) -> Option<&'static str>

The module’s guidance for a model, if it gave any.

pub fn looks(&self) -> &Looks

How the server shows to people.

pub fn apps(&self) -> &[App]

Every registered MCP App page.

pub fn resources(&self) -> impl Iterator<Item = &Resource>

Every registered resource and resource template.

pub async fn read( &self, uri: &str, bearer: Option<&str>, ) -> Result<Body, CallError>

Reads the resource at uri for the caller holding bearer.

pub fn prompts(&self) -> impl Iterator<Item = &Prompt>

Every registered prompt.

pub async fn prompt( &self, name: &str, bearer: Option<&str>, arguments: JsonObject, ) -> Result<Vec<Message>, CallError>

Fills prompt name from arguments for the caller holding bearer.

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

The registered operation name.

pub async fn call( &self, name: &str, bearer: Option<&str>, arguments: JsonObject, ) -> Result<Reply, CallError>

Calls operation name for the caller holding bearer, and waits for its result.

pub async fn start( self: &Arc<Self>, name: &str, bearer: Option<&str>, arguments: JsonObject, ) -> Result<StoredTask, CallError>

Starts operation name as a task for the caller holding bearer, and returns it while the operation runs.

pub async fn update( self: &Arc<Self>, bearer: Option<&str>, id: &str, answers: BTreeMap<String, Value>, ) -> Result<StoredTask, CallError>

Gives a task that asked for input the user’s answers and runs its operation again with them. A task not waiting for input is left as it is, as are answers to questions it did not ask.

pub async fn task( &self, bearer: Option<&str>, id: &str, ) -> Result<StoredTask, CallError>

The caller’s task id.

pub async fn cancel( &self, bearer: Option<&str>, id: &str, ) -> Result<StoredTask, CallError>

Marks the caller’s task id cancelled. Cooperative: the operation sees Ctx::is_cancelled when it runs in this process, stops where its state is whole, and its result is discarded; the kit never stops it between two awaits.

impl<M: Module, I: Identity, E: Entitlements, T: Metering, S: TaskStore> Kit<M, I, E, T, S>

pub async fn serve_stdio(self) -> Result<()>

Serves this kit over stdin and stdout until the client disconnects.