Tool Name

Purpose/Description

Arguments

rag

Search the knowledge base using RAG (Retrieval-Augmented Generation) with scoping.

query: str, corpus_id: List[int] | None = None , documents_id: List[int] | None = None

contextualize

Expand and clarify chunk context for deeper relevance analysis.

chunk_ids: List[int], before: int, after: int, max_tokens = 2048

ingest_crawl_job

Ingest a completed crawl job into the knowledge base as a new corpus.

crawl_job_id: int

embed_corpus

Embed all documents in a corpus to enable semantic search and retrieval.

corpus_id: int

list_corpora

List all corpora in the knowledge base.

per_page: int = 15, page: int = 1, sort: str = "id|created_at|updated_at|name", order: str = "asc|desc"

destroy_corpus

Destroy a corpus and all its associated documents and chunks.

corpus_id: int

list_documents

List all documents, or within a specific corpus.

corpus_id: int | None = None

destroy_document

Destroy a document by ID and all its associated chunks.

document_id: int

Tool Name

Purpose/Description

Arguments

create_job

Define a new CrawlJob in an IDLE state.

start_urls: List[str], depth: int = 3

start_job

Enqueue a CrawlJob by its ID to be run by the Scrapy engine.

crawl_job_id: int

monitor_job

Follow a CrawlJob, reporting process to the client, for a max time.

crawl_job_id: int, timeout: float = 30.0

get_job

Get extra information about a specific CrawlJob by its ID.

job_id: int

list_jobs

List all CrawlJobs and their metadata.

per_page: int = 15, page: int = 1, sort: str = None, order: str = None

get_job_logs

Get detailed logs for a specific CrawlJob by its ID.

per_page: int = 15, page: int = 1, sort: str = None, order: str = None

Tool Name

Purpose/Description

Arguments

select

Execute a SQL SELECT query and return rows.

query: str, params: Dict[str, Any] = {}

delete

Execute a SQL DELETE query.

query: str, params: Dict[str, Any] = {}

insert

Execute a SQL INSERT query.

query: str, params: Dict[str, Any] = {}

update

Execute a SQL UPDATE query.

query: str, params: Dict[str, Any] = {}

upsert

Execute a SQL UPSERT (INSERT ... ON CONFLICT UPDATE) query.

query: str, params: Dict[str, Any] = {}

create_extension_if_not_exists

Create a PostgreSQL extension if it does not exist.

extension_name: str

create_or_replace_function

Create or replace a PostgreSQL function.

sql: str

drop_function

Drop a PostgreSQL function by name.

function_name: str

list_functions

List all functions in the specified schema.

schema: str = "public"

http_request

Make an HTTP request using the pg_http extension.

url: str, method: str = "GET", headers: Dict[str, str] = {}, body: Dict[str, Any] = {}