mcp

type ComposeIn ¶

type ComposeIn = types.ComposedRequest

ComposeIn is the input contract for pulse_compose.

type ComposeOut ¶

type ComposeOut = types.ComposedResponse

ComposeOut is the output contract for pulse_compose.

func HandleCompose(ctx context.Context, p *pulse.Pulse, in ComposeIn) (ComposeOut, error)

type Config ¶

type Config struct {
	Version string
}

Config carries the runtime configuration baked into the tool catalog at construction time. It exists so the catalog has NO dependency on process globals or package-level build state — everything a tool closure needs is threaded in explicitly.

Version is the server/build identity string. No built-in tool surfaces it today, but the adapter (mcp/gosdk) reads it to populate the MCP server's Implementation.Version rather than a package-level constant. Reserved here so the single Config value is the one place runtime identity is injected.

type DropIn ¶

type DropIn struct {
	Handle string `json:"handle" jsonschema:"Managed handle name to remove"`
}

DropIn is the input contract for pulse_drop.

type DropOut ¶

type DropOut struct {
	Handle  string `json:"handle" jsonschema:"The managed handle that was dropped"`
	Dropped bool   `json:"dropped" jsonschema:"True when the handle existed and was removed"`
}

DropOut is the output contract for pulse_drop.

func HandleDrop(ctx context.Context, p *pulse.Pulse, in DropIn) (DropOut, error)

type ErrorsLookupIn ¶

type ErrorsLookupIn struct {
	Code   string `json:"code,omitempty" jsonschema:"Exact error code identifier (e.g. 'PULSE_LOOKUP_MISS')"`
	Domain string `json:"domain,omitempty" jsonschema:"Domain prefix (PULSE, ENCODING, PROCESSING, SERVICE, DATA, CLI); case-insensitive"`
	Query  string `json:"query,omitempty" jsonschema:"Case-insensitive substring across descriptions and fixup hints"`
}

ErrorsLookupIn is the input contract for pulse_errors_lookup. At least one axis must be set; supplied axes are intersected.

type ErrorsLookupOut ¶

type ErrorsLookupOut struct {
	Results []perr.LookupResult `json:"results" jsonschema:"Matching error-code metadata records"`
}

ErrorsLookupOut is the output contract for pulse_errors_lookup.

func HandleErrorsLookup(_ context.Context, _ *pulse.Pulse, in ErrorsLookupIn) (ErrorsLookupOut, error)

type ExamplesGetIn ¶

type ExamplesGetIn struct {
	Name string `json:"name" jsonschema:"Example name from the _meta.name field (e.g. 't_test_one_sample')"`
}

ExamplesGetIn is the input contract for pulse_examples_get.

type ExamplesGetOut ¶

type ExamplesGetOut = examples.Example

ExamplesGetOut is the output contract for pulse_examples_get.

func HandleExamplesGet(_ context.Context, p *pulse.Pulse, in ExamplesGetIn) (ExamplesGetOut, error)

type ExamplesSearchIn ¶

type ExamplesSearchIn struct {
	Query    string   `json:"query,omitempty" jsonschema:"Case-insensitive substring matched against name, description, and operators"`
	Tags     []string `json:"tags,omitempty" jsonschema:"Canonical taxonomy tags; results must carry every tag (AND)"`
	Category string   `` /* 139-byte string literal not displayed */
}

ExamplesSearchIn is the input contract for pulse_examples_search. All three filters are optional and ANDed.

type ExamplesSearchOut ¶

type ExamplesSearchOut struct {
	Results []examples.ExampleSummary `json:"results" jsonschema:"Matching example summaries (name, category, tags, operators, description)"`
}

ExamplesSearchOut is the output contract for pulse_examples_search.

func HandleExamplesSearch(_ context.Context, p *pulse.Pulse, in ExamplesSearchIn) (ExamplesSearchOut, error)

type FacetIn ¶

type FacetIn struct {
	Path  string `json:"path" jsonschema:"Filesystem path to the .pulse file"`
	Field string `json:"field" jsonschema:"Field name to facet"`
}

FacetIn is the input contract for pulse_facet.

type FacetOut ¶

type FacetOut struct {
	Values []string `json:"values" jsonschema:"Distinct values for the faceted field"`
}

FacetOut is the output contract for pulse_facet.

func HandleFacet(ctx context.Context, p *pulse.Pulse, in FacetIn) (FacetOut, error)

type FacetSchemaIn ¶

type FacetSchemaIn = types.FacetRequest

FacetSchemaIn is the input contract for pulse_facet_schema.

type FacetSchemaOut ¶

type FacetSchemaOut = types.FacetResult

FacetSchemaOut is the output contract for pulse_facet_schema.

func HandleFacetSchema(ctx context.Context, p *pulse.Pulse, in FacetSchemaIn) (FacetSchemaOut, error)

type ImportIn ¶

type ImportIn struct {
	Source    string `json:"source" jsonschema:"Filesystem path to the source file (relative to PULSE_DATA_DIR)"`
	Format    string `json:"format,omitempty" jsonschema:"Format override: csv, tsv, ndjson, jsonarray, parquet, arrow, excel, pulse"`
	Handle    string `json:"handle,omitempty" jsonschema:"Managed handle name; defaults to source basename without extension"`
	TTL       string `` /* 127-byte string literal not displayed */
	Sheet     string `json:"sheet,omitempty" jsonschema:"Excel sheet name; ignored for non-Excel sources"`
	Overwrite bool   `json:"overwrite,omitempty" jsonschema:"Replace an existing handle of the same name. Default false."`
}

ImportIn is the input contract for pulse_import.

type ImportOut ¶

type ImportOut = imports.Result

ImportOut is the output contract for pulse_import.

func HandleImport(ctx context.Context, p *pulse.Pulse, in ImportIn) (ImportOut, error)

type ImportsListIn ¶

type ImportsListIn struct{}

ImportsListIn is the (empty) input contract for pulse_imports_list.

type ImportsListOut ¶

type ImportsListOut struct {
	Imports []imports.Entry `json:"imports" jsonschema:"Managed-import pool entries with sidecar metadata"`
}

ImportsListOut is the output contract for pulse_imports_list.

func HandleImportsList(ctx context.Context, p *pulse.Pulse, _ ImportsListIn) (ImportsListOut, error)

type InspectIn ¶

type InspectIn struct {
	Path string `json:"path" jsonschema:"Filesystem path to the .pulse file"`
}

InspectIn is the input contract for pulse_inspect.

type InspectOut ¶

type InspectOut = descriptor.InspectResult

InspectOut is the output contract for pulse_inspect.

func HandleInspect(ctx context.Context, p *pulse.Pulse, in InspectIn) (InspectOut, error)

type InvokeFunc ¶

type InvokeFunc func(ctx context.Context, p *pulse.Pulse, raw json.RawMessage) (any, error)

InvokeFunc is the type-erased entry point for one tool: it strict-decodes raw arguments into the tool's typed In struct, calls the typed handler, and returns the typed Out as any. Coded errors from the facade (or the strict-decode layer) are returned verbatim — the adapter renders a *errors.CodedError as the structured {code, message, details} envelope.

type LabelResolveIn ¶

type LabelResolveIn struct {
	Table string `json:"table" jsonschema:"Label table name (from pulse_label_tables, e.g. 'brand')"`
	Query string `json:"query,omitempty" jsonschema:"Name to resolve, case-insensitive; empty returns the first rows (browse mode)"`
	Limit int    `json:"limit,omitempty" jsonschema:"Maximum matches to return. Default 10."`
}

LabelResolveIn is the input contract for pulse_label_resolve.

type LabelResolveOut ¶

type LabelResolveOut struct {
	Matches []pulse.LabelMatch `json:"matches" jsonschema:"Ranked (key, value, score) resolution candidates"`
}

LabelResolveOut is the output contract for pulse_label_resolve.

func HandleLabelResolve(_ context.Context, p *pulse.Pulse, in LabelResolveIn) (LabelResolveOut, error)

type LabelTablesIn ¶

type LabelTablesIn struct{}

LabelTablesIn is the (empty) input contract for pulse_label_tables.

type LabelTablesOut ¶

type LabelTablesOut struct {
	Tables []pulse.LabelTableInfo `json:"tables" jsonschema:"Registered label tables (name, row count, enumerable flag)"`
}

LabelTablesOut is the output contract for pulse_label_tables.

func HandleLabelTables(_ context.Context, p *pulse.Pulse, _ LabelTablesIn) (LabelTablesOut, error)

type ManifestIn ¶

type ManifestIn struct{}

ManifestIn is the (empty) input contract for pulse_manifest.

type ManifestOut ¶

type ManifestOut = descriptor.Manifest

ManifestOut is the output contract for pulse_manifest (the slim manifest is the same struct as the full one).

func HandleManifest(ctx context.Context, p *pulse.Pulse, _ ManifestIn) (ManifestOut, error)

type PredictIn ¶

type PredictIn = types.Request

PredictIn is the input contract for pulse_predict.

type PredictOut ¶

type PredictOut = descriptor.PredictResult

PredictOut is the output contract for pulse_predict.

func HandlePredict(ctx context.Context, p *pulse.Pulse, in PredictIn) (PredictOut, error)

type ProcessChainIn ¶

type ProcessChainIn = types.ChainRequest

ProcessChainIn is the input contract for pulse_process_chain.

type ProcessChainOut ¶

type ProcessChainOut = types.ChainResponse

ProcessChainOut is the output contract for pulse_process_chain.

func HandleProcessChain(ctx context.Context, p *pulse.Pulse, in ProcessChainIn) (ProcessChainOut, error)

type ProcessIn ¶

type ProcessIn = types.Request

ProcessIn is the input contract for pulse_process.

type ProcessOut ¶

type ProcessOut = types.Response

ProcessOut is the output contract for pulse_process.

func HandleProcess(ctx context.Context, p *pulse.Pulse, in ProcessIn) (ProcessOut, error)

type SampleIn ¶

type SampleIn struct {
	Path  string `json:"path" jsonschema:"Filesystem path to the .pulse file"`
	Count int    `json:"count,omitempty" jsonschema:"Maximum rows to return (default 10)"`
}

SampleIn is the input contract for pulse_sample.

type SampleOut ¶

type SampleOut struct {
	Rows []map[string]any `json:"rows" jsonschema:"Sampled rows, each a field-name to value map"`
}

SampleOut is the output contract for pulse_sample.

func HandleSample(ctx context.Context, p *pulse.Pulse, in SampleIn) (SampleOut, error)

type SkillsGetIn ¶

type SkillsGetIn struct {
	Name string `json:"name" jsonschema:"Skill name (e.g. 'aggregation-design')"`
}

SkillsGetIn is the input contract for pulse_skills_get.

type SkillsGetOut ¶

type SkillsGetOut struct {
	Body string `json:"body" jsonschema:"Markdown body of the named skill"`
}

SkillsGetOut is the output contract for pulse_skills_get.

func HandleSkillsGet(_ context.Context, _ *pulse.Pulse, in SkillsGetIn) (SkillsGetOut, error)

type SkillsListIn ¶

type SkillsListIn struct{}

SkillsListIn is the (empty) input contract for pulse_skills_list.

type SkillsListOut ¶

type SkillsListOut struct {
	Skills []skills.Metadata `json:"skills" jsonschema:"Embedded skill-pack entries (name, description, applies_to)"`
}

SkillsListOut is the output contract for pulse_skills_list.

func HandleSkillsList(_ context.Context, _ *pulse.Pulse, _ SkillsListIn) (SkillsListOut, error)

type ToolDescriptor ¶

type ToolDescriptor struct {
	Name         string
	Description  string
	InputSchema  json.RawMessage
	OutputSchema json.RawMessage
	Invoke       InvokeFunc
}

ToolDescriptor is the SDK-free, type-erased descriptor for one registered MCP tool. It pairs the reflected input/output JSON Schemas (json.RawMessage, so no consumer needs the schema reflector) with an Invoke closure that round-trips raw JSON arguments through the typed handler. The go-sdk adapter mounts these onto a server via the low-level Server.AddTool path.

func Tools(cfg Config) []ToolDescriptor

type ToolSchema ¶

type ToolSchema struct {
	Name         string          `json:"name"`
	Description  string          `json:"description"`
	InputSchema  json.RawMessage `json:"input_schema"`
	OutputSchema json.RawMessage `json:"output_schema"`
}

ToolSchema is the reflected, SDK-free descriptor for one registered MCP tool: its name, description, and the input/output JSON Schemas (draft 2020-12) reflected from the typed In/Out contract structs. The schemas are carried as json.RawMessage so consumers — and the thin go-sdk adapter — never need to import the schema reflector or any MCP SDK.

func SchemaFor(name string) (ToolSchema, bool)

func Schemas() []ToolSchema