Index

A

achat() (ractogateway.anthropic_developer_kit.AnthropicDeveloperKit method) (ractogateway.google_developer_kit.GoogleDeveloperKit method) (ractogateway.openai_developer_kit.OpenAIDeveloperKit method) acks (ractogateway.kafka._models.KafkaProducerConfig attribute) add() (ractogateway.finetune.RactoDataset method) (ractogateway.rag.page_index._bm25.BM25Index method) (ractogateway.rag.stores.base.BaseVectorStore method) (ractogateway.rag.stores.chroma_store.ChromaStore method) (ractogateway.rag.stores.faiss_store.FAISSStore method) (ractogateway.rag.stores.in_memory_store.InMemoryVectorStore method) (ractogateway.rag.stores.milvus_store.MilvusStore method) (ractogateway.rag.stores.pgvector_store.PGVectorStore method) (ractogateway.rag.stores.pinecone_store.PineconeStore method) (ractogateway.rag.stores.qdrant_store.QdrantStore method) (ractogateway.rag.stores.weaviate_store.WeaviateStore method) add_document() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) add_texts() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) add_tool() (ractogateway.mcp.server.RactoMCPServer method) aembed() (ractogateway.google_developer_kit.GoogleDeveloperKit method) (ractogateway.openai_developer_kit.OpenAIDeveloperKit method) (ractogateway.rag.embedders.base.BaseEmbedder method) (ractogateway.rag.embedders.google_embedder.GoogleEmbedder method) (ractogateway.rag.embedders.openai_embedder.OpenAIEmbedder method) (ractogateway.rag.embedders.voyage_embedder.VoyageEmbedder method) aexecute() (ractogateway.pipelines.agent._executor.ToolExecutor method) (ractogateway.pipelines.agent.ToolExecutor method) aexecute_parallel() (ractogateway.pipelines.agent._executor.ToolExecutor method) (ractogateway.pipelines.agent.ToolExecutor method) AgentPipeline (class in ractogateway.pipelines.agent) (class in ractogateway.pipelines.agent.pipeline) AgentRateLimitExceededError, [1] AgentResult (class in ractogateway.pipelines.agent) (class in ractogateway.pipelines.agent._models) AgentStep (class in ractogateway.pipelines.agent) (class in ractogateway.pipelines.agent._models) AgentUsage (class in ractogateway.pipelines.agent) (class in ractogateway.pipelines.agent._models) aget_results() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method)

aim (ractogateway.prompts.RactoPrompt attribute) aingest() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) aingest_dir() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) aingest_text() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) answer (ractogateway.rag._models.retrieval.RAGResponse attribute) (ractogateway.rag.page_index._models.PageIndexResponse attribute) AnthropicBatchProcessor (class in ractogateway.batch.anthropic_batch) AnthropicDeveloperKit (class in ractogateway.anthropic_developer_kit) AnthropicFineTuner (class in ractogateway.finetune) anti_hallucination (ractogateway.prompts.RactoPrompt attribute) apoll_status() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method) append() (ractogateway.redis.chat_memory.RedisChatMemory method) apply_chain_of_thought() (in module ractogateway._cot) aquery() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) aretrieve() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) args (ractogateway.mcp._models.MCPClientConfig attribute) arguments (ractogateway.adapters.ToolCallResult attribute) arun() (ractogateway.adapters.BaseLLMAdapter method) (ractogateway.gateway.Gateway method) (ractogateway.mcp.agent.MCPAgent method) (ractogateway.pipelines.agent.AgentPipeline method) (ractogateway.pipelines.agent.pipeline.AgentPipeline method) astream() (ractogateway.anthropic_developer_kit.AnthropicDeveloperKit method) (ractogateway.google_developer_kit.GoogleDeveloperKit method) (ractogateway.openai_developer_kit.OpenAIDeveloperKit method) asubmit_and_wait() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method) asubmit_batch() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method) AsyncAgentPipeline (class in ractogateway.pipelines.agent) (class in ractogateway.pipelines.agent.pipeline) attachments (ractogateway.finetune.RactoTrainingMessage attribute) auto_offset_reset (ractogateway.kafka._models.KafkaConsumerConfig attribute)

B

backoff_factor (ractogateway.celery._models.RetryConfig attribute) BaseChunker (class in ractogateway.rag.chunkers.base) BaseEmbedder (class in ractogateway.rag.embedders.base) BaseLLMAdapter (class in ractogateway.adapters) BaseProcessor (class in ractogateway.rag.processors.base) BaseReader (class in ractogateway.rag.readers.base) BaseVectorStore (class in ractogateway.rag.stores.base)

batch_size (ractogateway.kafka._models.KafkaStreamConfig attribute) BatchItem (class in ractogateway.batch._models) BatchJobInfo (class in ractogateway.batch._models) BatchResult (class in ractogateway.batch._models) BatchStatus (class in ractogateway.batch._models) BM25Index (class in ractogateway.rag.page_index._bm25) bootstrap_servers (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute)

C

CacheConfig (class in ractogateway.cache._models) CacheEntry (class in ractogateway.cache._models) CacheStats (class in ractogateway.cache._models) call_tool() (ractogateway.mcp.client.RactoMCPClient method) (ractogateway.mcp.multi_client.MCPMultiClient method) call_tool_sync() (ractogateway.mcp.client.RactoMCPClient method) (ractogateway.mcp.multi_client.MCPMultiClient method) cancel_job() (ractogateway.finetune.AnthropicFineTuner method) (ractogateway.finetune.OpenAIFineTuner method) CANCELLED (ractogateway.batch._models.BatchStatus attribute) CANCELLING (ractogateway.batch._models.BatchStatus attribute) char_count (ractogateway.rag.page_index._models.PageEntry attribute) chat() (ractogateway.anthropic_developer_kit.AnthropicDeveloperKit method) (ractogateway.google_developer_kit.GoogleDeveloperKit method) (ractogateway.openai_developer_kit.OpenAIDeveloperKit method) ChatMemoryConfig (class in ractogateway.redis._models) check_and_consume() (ractogateway.redis.rate_limiter.RedisRateLimiter method) ChromaStore (class in ractogateway.rag.stores.chroma_store) Chunk (class in ractogateway.rag._models.document) chunk (ractogateway.rag._models.retrieval.RetrievalResult attribute) chunk() (ractogateway.rag.chunkers.base.BaseChunker method) (ractogateway.rag.chunkers.fixed_chunker.FixedChunker method) (ractogateway.rag.chunkers.recursive_chunker.RecursiveChunker method) (ractogateway.rag.chunkers.semantic_chunker.SemanticChunker method) (ractogateway.rag.chunkers.sentence_chunker.SentenceChunker method) chunk_id (ractogateway.rag._models.document.Chunk attribute) chunk_index (ractogateway.rag._models.document.ChunkMetadata attribute) ChunkMetadata (class in ractogateway.rag._models.document) CIRCUIT_BREAK (ractogateway.pipelines.agent._models.StopReason attribute) (ractogateway.pipelines.agent.StopReason attribute) clear() (ractogateway.cache.exact_cache.ExactMatchCache method) (ractogateway.cache.semantic_cache.SemanticCache method) (ractogateway.rag.page_index._bm25.BM25Index method) (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) (ractogateway.rag.stores.base.BaseVectorStore method) (ractogateway.rag.stores.chroma_store.ChromaStore method) (ractogateway.rag.stores.faiss_store.FAISSStore method) (ractogateway.rag.stores.in_memory_store.InMemoryVectorStore method) (ractogateway.rag.stores.milvus_store.MilvusStore method) (ractogateway.rag.stores.pgvector_store.PGVectorStore method) (ractogateway.rag.stores.pinecone_store.PineconeStore method) (ractogateway.rag.stores.qdrant_store.QdrantStore method) (ractogateway.rag.stores.weaviate_store.WeaviateStore method) (ractogateway.redis.chat_memory.RedisChatMemory method) (ractogateway.redis.exact_cache.RedisExactCache method)

client_id (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute) close() (ractogateway.kafka.consumer.KafkaConsumerClient method) (ractogateway.kafka.producer.KafkaProducerClient method) collect_batch() (ractogateway.kafka.stream.KafkaStreamProcessor method) command (ractogateway.mcp._models.MCPClientConfig attribute) commit() (ractogateway.kafka.consumer.KafkaConsumerClient method) commit_on_success (ractogateway.kafka._models.KafkaStreamConfig attribute) compile() (ractogateway.prompts.RactoPrompt method) COMPLETED (ractogateway.batch._models.BatchStatus attribute) compression_type (ractogateway.kafka._models.KafkaProducerConfig attribute) constraints (ractogateway.prompts.RactoPrompt attribute) content (ractogateway.adapters.LLMResponse attribute) (ractogateway.finetune.RactoTrainingMessage attribute) (ractogateway.mcp._models.MCPToolResult attribute) (ractogateway.rag._models.document.Chunk attribute) (ractogateway.rag._models.document.Document attribute) (ractogateway.rag.page_index._models.PageEntry attribute) (ractogateway.rag.page_index._models.PageIndexResult property) CONTENT_FILTER (ractogateway.adapters.FinishReason attribute) content_hash (ractogateway.rag.page_index._models.PageEntry attribute) context (ractogateway.prompts.RactoPrompt attribute) context_used (ractogateway.rag._models.retrieval.RAGResponse attribute) (ractogateway.rag.page_index._models.PageIndexResponse attribute) CostAwareRouter (class in ractogateway.routing.router) count() (ractogateway.rag.pipeline.RactoRAG method) (ractogateway.rag.stores.base.BaseVectorStore method) (ractogateway.rag.stores.chroma_store.ChromaStore method) (ractogateway.rag.stores.faiss_store.FAISSStore method) (ractogateway.rag.stores.in_memory_store.InMemoryVectorStore method) (ractogateway.rag.stores.milvus_store.MilvusStore method) (ractogateway.rag.stores.pgvector_store.PGVectorStore method) (ractogateway.rag.stores.pinecone_store.PineconeStore method) (ractogateway.rag.stores.qdrant_store.QdrantStore method) (ractogateway.rag.stores.weaviate_store.WeaviateStore method) (ractogateway.redis.chat_memory.RedisChatMemory method) create_job() (ractogateway.finetune.AnthropicFineTuner method) (ractogateway.finetune.GeminiFineTuner method) (ractogateway.finetune.OpenAIFineTuner method) created_at (ractogateway.batch._models.BatchJobInfo attribute) (ractogateway.cache._models.CacheEntry attribute) (ractogateway.cache._models.SemanticCacheEntry attribute) custom_id (ractogateway.batch._models.BatchItem attribute) (ractogateway.batch._models.BatchResult attribute)

D

delete() (ractogateway.rag.stores.base.BaseVectorStore method) (ractogateway.rag.stores.chroma_store.ChromaStore method) (ractogateway.rag.stores.faiss_store.FAISSStore method) (ractogateway.rag.stores.in_memory_store.InMemoryVectorStore method) (ractogateway.rag.stores.milvus_store.MilvusStore method) (ractogateway.rag.stores.pgvector_store.PGVectorStore method) (ractogateway.rag.stores.pinecone_store.PineconeStore method) (ractogateway.rag.stores.qdrant_store.QdrantStore method) (ractogateway.rag.stores.weaviate_store.WeaviateStore method) delete_model() (ractogateway.finetune.GeminiFineTuner method) describe_all() (ractogateway.pipelines.agent._executor.ToolExecutor method) (ractogateway.pipelines.agent.ToolExecutor method) description (ractogateway.mcp._models.MCPServerConfig attribute) (ractogateway.tools.ToolSchema attribute)

dimension (ractogateway.rag.embedders.base.BaseEmbedder property) (ractogateway.rag.embedders.google_embedder.GoogleEmbedder property) (ractogateway.rag.embedders.openai_embedder.OpenAIEmbedder property) (ractogateway.rag.embedders.voyage_embedder.VoyageEmbedder property) doc_id (ractogateway.rag._models.document.Chunk attribute) (ractogateway.rag._models.document.ChunkMetadata attribute) (ractogateway.rag._models.document.Document attribute) (ractogateway.rag.page_index._models.PageEntry attribute) Document (class in ractogateway.rag._models.document) document_count (ractogateway.rag.page_index.pipeline.PageIndexRAG property) duration_ms (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent.AgentStep attribute)

E

embed() (ractogateway.google_developer_kit.GoogleDeveloperKit method) (ractogateway.openai_developer_kit.OpenAIDeveloperKit method) (ractogateway.rag.embedders.base.BaseEmbedder method) (ractogateway.rag.embedders.google_embedder.GoogleEmbedder method) (ractogateway.rag.embedders.openai_embedder.OpenAIEmbedder method) (ractogateway.rag.embedders.voyage_embedder.VoyageEmbedder method) embedder (ractogateway.rag.pipeline.RactoRAG property) embedding (ractogateway.rag._models.document.Chunk attribute) enable_auto_commit (ractogateway.kafka._models.KafkaConsumerConfig attribute) end_char (ractogateway.rag._models.document.ChunkMetadata attribute) entry (ractogateway.rag.page_index._models.PageIndexResult attribute) entry_count (ractogateway.rag.page_index._bm25.BM25Index property) (ractogateway.rag.page_index.pipeline.PageIndexRAG property) entry_id (ractogateway.rag.page_index._models.PageEntry attribute) env (ractogateway.mcp._models.MCPClientConfig attribute) ERROR (ractogateway.adapters.FinishReason attribute) error (ractogateway.batch._models.BatchResult attribute) (ractogateway.celery._models.TaskResult attribute) (ractogateway.pipelines.agent._models.AgentResult attribute)

ERROR (ractogateway.pipelines.agent._models.StopReason attribute) error (ractogateway.pipelines.agent.AgentResult attribute) ERROR (ractogateway.pipelines.agent.StopReason attribute) estimate_tokens() (ractogateway.truncation.truncator.TokenTruncator method) ExactMatchCache (class in ractogateway.cache.exact_cache) examples (ractogateway.prompts.RactoPrompt attribute) execute() (ractogateway.pipelines.agent._executor.ToolExecutor method) (ractogateway.pipelines.agent.ToolExecutor method) EXPIRED (ractogateway.batch._models.BatchStatus attribute) export_jsonl() (ractogateway.finetune.RactoDataset method) extend() (ractogateway.finetune.RactoDataset method) extra (ractogateway.batch._models.BatchItem attribute) (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute) (ractogateway.rag._models.document.ChunkMetadata attribute) (ractogateway.rag.page_index._models.PageEntry attribute) extract_keywords() (in module ractogateway.rag.page_index._bm25)

F

FAILED (ractogateway.batch._models.BatchStatus attribute) FAILURE (ractogateway.celery._models.TaskStatus attribute) FAISSStore (class in ractogateway.rag.stores.faiss_store) FileReaderRegistry (class in ractogateway.rag.readers.registry) filters (ractogateway.rag._models.retrieval.RetrievalConfig attribute) final_answer (ractogateway.pipelines.agent._models.AgentResult attribute) (ractogateway.pipelines.agent.AgentResult attribute) FINALIZING (ractogateway.batch._models.BatchStatus attribute) finish_reason (ractogateway.adapters.LLMResponse attribute) FINISHED (ractogateway.pipelines.agent._models.StopReason attribute) (ractogateway.pipelines.agent.StopReason attribute)

FinishReason (class in ractogateway.adapters) FixedChunker (class in ractogateway.rag.chunkers.fixed_chunker) flush() (ractogateway.kafka.producer.KafkaProducerClient method) from_conversation() (ractogateway.finetune.RactoTrainingExample class method) from_jsonl() (ractogateway.finetune.RactoDataset class method) from_mcp() (ractogateway.mcp.agent.MCPAgent class method) from_pair() (ractogateway.finetune.RactoTrainingExample class method) from_pairs() (ractogateway.finetune.RactoDataset class method) from_registry() (ractogateway.mcp.server.RactoMCPServer class method)

G

Gateway (class in ractogateway.gateway) GeminiFineTuner (class in ractogateway.finetune) generate() (ractogateway.celery.worker.RactoCeleryWorker method) get() (ractogateway.cache.exact_cache.ExactMatchCache method) (ractogateway.cache.semantic_cache.SemanticCache method) (ractogateway.redis.exact_cache.RedisExactCache method) get_asgi_app() (ractogateway.mcp.server.RactoMCPServer method) get_callable() (ractogateway.tools.ToolRegistry method) get_history() (ractogateway.redis.chat_memory.RedisChatMemory method) get_model() (ractogateway.finetune.GeminiFineTuner method) get_observations() (ractogateway.pipelines.agent._models.AgentResult method) (ractogateway.pipelines.agent.AgentResult method) get_reader() (ractogateway.rag.readers.registry.FileReaderRegistry method)

get_remaining() (ractogateway.redis.rate_limiter.RedisRateLimiter method) get_result() (ractogateway.celery.worker.RactoCeleryWorker method) get_results() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method) get_schema() (ractogateway.tools.ToolRegistry method) get_status() (ractogateway.finetune.AnthropicFineTuner method) (ractogateway.finetune.OpenAIFineTuner method) get_tool_calls() (ractogateway.pipelines.agent._models.AgentResult method) (ractogateway.pipelines.agent.AgentResult method) goal (ractogateway.pipelines.agent._models.AgentResult attribute) (ractogateway.pipelines.agent.AgentResult attribute) GoogleDeveloperKit (class in ractogateway.google_developer_kit) GoogleEmbedder (class in ractogateway.rag.embedders.google_embedder) group_id (ractogateway.kafka._models.KafkaConsumerConfig attribute)

H

headers (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaPublishRequest attribute) hit_count (ractogateway.cache._models.CacheEntry attribute) (ractogateway.cache._models.SemanticCacheEntry attribute)

hit_rate (ractogateway.cache._models.CacheStats property) hits (ractogateway.cache._models.CacheStats attribute) HtmlReader (class in ractogateway.rag.readers.html_reader)

I

id (ractogateway.adapters.ToolCallResult attribute) ImageReader (class in ractogateway.rag.readers.image_reader) IN_PROGRESS (ractogateway.batch._models.BatchStatus attribute) ingest() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) ingest_dir() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) ingest_document() (ractogateway.celery.worker.RactoCeleryWorker method)

ingest_text() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) initial_delay_s (ractogateway.celery._models.RetryConfig attribute) InMemoryVectorStore (class in ractogateway.rag.stores.in_memory_store) invalidate() (ractogateway.cache.exact_cache.ExactMatchCache method) (ractogateway.redis.exact_cache.RedisExactCache method) is_error (ractogateway.mcp._models.MCPToolResult attribute) is_finish (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent.AgentStep attribute)

J

job_id (ractogateway.batch._models.BatchJobInfo attribute)

K

KafkaAuditEvent (class in ractogateway.kafka._models) KafkaAuditLogger (class in ractogateway.kafka.audit) KafkaConsumerClient (class in ractogateway.kafka.consumer) KafkaConsumerConfig (class in ractogateway.kafka._models) KafkaMessage (class in ractogateway.kafka._models) KafkaProducerClient (class in ractogateway.kafka.producer) KafkaProducerConfig (class in ractogateway.kafka._models) KafkaProduceResult (class in ractogateway.kafka._models) KafkaPublishRequest (class in ractogateway.kafka._models)

KafkaStreamConfig (class in ractogateway.kafka._models) KafkaStreamProcessor (class in ractogateway.kafka.stream) keep_first_n (ractogateway.truncation._models.TruncationConfig attribute) keep_last_n (ractogateway.truncation._models.TruncationConfig attribute) key (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaPublishRequest attribute) key_prefix (ractogateway.redis._models.ChatMemoryConfig attribute) (ractogateway.redis._models.RateLimitConfig attribute) keywords (ractogateway.rag.page_index._models.PageEntry attribute)

L

Lemmatizer (class in ractogateway.rag.processors.lemmatizer) LENGTH (ractogateway.adapters.FinishReason attribute) linger_ms (ractogateway.kafka._models.KafkaProducerConfig attribute) list_events() (ractogateway.finetune.OpenAIFineTuner method) list_jobs() (ractogateway.finetune.AnthropicFineTuner method) (ractogateway.finetune.OpenAIFineTuner method) list_models() (ractogateway.finetune.GeminiFineTuner method)

list_tools() (ractogateway.mcp.client.RactoMCPClient method) (ractogateway.mcp.multi_client.MCPMultiClient method) list_tools_sync() (ractogateway.mcp.client.RactoMCPClient method) (ractogateway.mcp.multi_client.MCPMultiClient method) LLMResponse (class in ractogateway.adapters) load() (ractogateway.rag.page_index.pipeline.PageIndexRAG class method) (ractogateway.rag.stores.faiss_store.FAISSStore method) log() (ractogateway.kafka.audit.KafkaAuditLogger method)

M

make_finish_tool() (in module ractogateway.pipelines.agent) (in module ractogateway.pipelines.agent._executor) make_http_tool() (in module ractogateway.pipelines.agent) (in module ractogateway.pipelines.agent._executor) make_memory_tools() (in module ractogateway.pipelines.agent) (in module ractogateway.pipelines.agent._executor) make_rag_tool() (in module ractogateway.pipelines.agent) (in module ractogateway.pipelines.agent._executor) make_rag_tool_async() (in module ractogateway.pipelines.agent) (in module ractogateway.pipelines.agent._executor) make_sql_tool() (in module ractogateway.pipelines.agent) (in module ractogateway.pipelines.agent._executor) matched_terms (ractogateway.rag.page_index._models.PageIndexResult attribute) max_context_tokens (ractogateway.truncation._models.TruncationConfig attribute) max_delay_s (ractogateway.celery._models.RetryConfig attribute) max_poll_records (ractogateway.kafka._models.KafkaConsumerConfig attribute) max_retries (ractogateway.celery._models.RetryConfig attribute) max_score (ractogateway.routing._models.RoutingTier attribute) max_size (ractogateway.cache._models.CacheConfig attribute) (ractogateway.cache._models.SemanticCacheConfig attribute) MAX_STEPS (ractogateway.pipelines.agent._models.StopReason attribute) (ractogateway.pipelines.agent.StopReason attribute) max_tokens (ractogateway.batch._models.BatchItem attribute) max_tokens_per_minute (ractogateway.redis._models.RateLimitConfig attribute) max_turns (ractogateway.mcp.agent.MCPAgent property) (ractogateway.redis._models.ChatMemoryConfig attribute) max_wait_ms (ractogateway.kafka._models.KafkaStreamConfig attribute) MCPAgent (class in ractogateway.mcp.agent) MCPClientConfig (class in ractogateway.mcp._models) MCPMultiClient (class in ractogateway.mcp.multi_client) MCPServerConfig (class in ractogateway.mcp._models) MCPToolResult (class in ractogateway.mcp._models) metadata (ractogateway.kafka._models.KafkaAuditEvent attribute) (ractogateway.rag._models.document.Chunk attribute) (ractogateway.rag._models.document.Document attribute) MilvusStore (class in ractogateway.rag.stores.milvus_store) misses (ractogateway.cache._models.CacheStats attribute) model (ractogateway.kafka._models.KafkaAuditEvent attribute) (ractogateway.routing._models.RoutingTier attribute) model_config (ractogateway.adapters.LLMResponse attribute) (ractogateway.adapters.ToolCallResult attribute) (ractogateway.batch._models.BatchItem attribute) (ractogateway.batch._models.BatchJobInfo attribute) (ractogateway.batch._models.BatchResult attribute) (ractogateway.cache._models.CacheConfig attribute) (ractogateway.cache._models.CacheEntry attribute) (ractogateway.cache._models.CacheStats attribute) (ractogateway.cache._models.SemanticCacheConfig attribute) (ractogateway.cache._models.SemanticCacheEntry attribute) (ractogateway.celery._models.RetryConfig attribute) (ractogateway.celery._models.TaskResult attribute) (ractogateway.kafka._models.KafkaAuditEvent attribute) (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute) (ractogateway.kafka._models.KafkaProduceResult attribute) (ractogateway.kafka._models.KafkaPublishRequest attribute) (ractogateway.kafka._models.KafkaStreamConfig attribute) (ractogateway.mcp._models.MCPClientConfig attribute) (ractogateway.mcp._models.MCPServerConfig attribute) (ractogateway.mcp._models.MCPToolResult attribute) (ractogateway.pipelines.agent._models.AgentResult attribute) (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent._models.AgentUsage attribute) (ractogateway.pipelines.agent.AgentResult attribute) (ractogateway.pipelines.agent.AgentStep attribute) (ractogateway.pipelines.agent.AgentUsage attribute) (ractogateway.prompts.RactoPrompt attribute) (ractogateway.rag._models.document.Chunk attribute) (ractogateway.rag._models.document.ChunkMetadata attribute) (ractogateway.rag._models.document.Document attribute) (ractogateway.rag._models.retrieval.RAGResponse attribute) (ractogateway.rag._models.retrieval.RetrievalConfig attribute) (ractogateway.rag._models.retrieval.RetrievalResult attribute) (ractogateway.rag.page_index._models.PageEntry attribute) (ractogateway.rag.page_index._models.PageIndexResponse attribute) (ractogateway.rag.page_index._models.PageIndexResult attribute) (ractogateway.redis._models.ChatMemoryConfig attribute) (ractogateway.redis._models.RateLimitConfig attribute) (ractogateway.routing._models.RoutingTier attribute) (ractogateway.tools.ToolSchema attribute) (ractogateway.truncation._models.TruncationConfig attribute)

model_post_init() (ractogateway.cache._models.SemanticCacheEntry method) (ractogateway.truncation._models.TruncationConfig method) module ractogateway._cot ractogateway.adapters ractogateway.batch._models ractogateway.batch.anthropic_batch ractogateway.batch.openai_batch ractogateway.cache._models ractogateway.cache.exact_cache ractogateway.cache.semantic_cache ractogateway.celery._models ractogateway.celery.worker ractogateway.finetune ractogateway.gateway ractogateway.kafka._models ractogateway.kafka.audit ractogateway.kafka.consumer ractogateway.kafka.producer ractogateway.kafka.stream ractogateway.mcp._models ractogateway.mcp.agent ractogateway.mcp.client ractogateway.mcp.multi_client ractogateway.mcp.server ractogateway.pipelines.agent ractogateway.pipelines.agent._executor ractogateway.pipelines.agent._models ractogateway.pipelines.agent.pipeline ractogateway.prompts ractogateway.rag._models.document ractogateway.rag._models.retrieval ractogateway.rag.chunkers.base ractogateway.rag.chunkers.fixed_chunker ractogateway.rag.chunkers.recursive_chunker ractogateway.rag.chunkers.semantic_chunker ractogateway.rag.chunkers.sentence_chunker ractogateway.rag.embedders.base ractogateway.rag.embedders.google_embedder ractogateway.rag.embedders.openai_embedder ractogateway.rag.embedders.voyage_embedder ractogateway.rag.page_index._bm25 ractogateway.rag.page_index._models ractogateway.rag.processors.base ractogateway.rag.processors.cleaner ractogateway.rag.processors.lemmatizer ractogateway.rag.processors.pipeline ractogateway.rag.readers.base ractogateway.rag.readers.html_reader ractogateway.rag.readers.image_reader ractogateway.rag.readers.pdf_reader ractogateway.rag.readers.registry ractogateway.rag.readers.spreadsheet_reader ractogateway.rag.readers.text_reader ractogateway.rag.readers.word_reader ractogateway.rag.stores.base ractogateway.rag.stores.chroma_store ractogateway.rag.stores.faiss_store ractogateway.rag.stores.in_memory_store ractogateway.rag.stores.milvus_store ractogateway.rag.stores.pgvector_store ractogateway.rag.stores.pinecone_store ractogateway.rag.stores.qdrant_store ractogateway.rag.stores.weaviate_store ractogateway.redis._models ractogateway.redis.chat_memory ractogateway.redis.exact_cache ractogateway.redis.rate_limiter ractogateway.routing._models ractogateway.routing.router ractogateway.tools ractogateway.truncation._models ractogateway.truncation.truncator

N

name (ractogateway.adapters.ToolCallResult attribute) (ractogateway.mcp._models.MCPServerConfig attribute) (ractogateway.tools.ToolSchema attribute)

names (ractogateway.pipelines.agent._executor.ToolExecutor property) (ractogateway.pipelines.agent.ToolExecutor property)

O

observation (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent.AgentStep attribute) ocr_applied (ractogateway.rag.page_index._models.PageEntry attribute) ocr_confidence (ractogateway.rag.page_index._models.PageEntry attribute) offset (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaProduceResult attribute)

ok (ractogateway.batch._models.BatchResult property) (ractogateway.celery._models.TaskResult property) OpenAIBatchProcessor (class in ractogateway.batch.openai_batch) OpenAIDeveloperKit (class in ractogateway.openai_developer_kit) OpenAIEmbedder (class in ractogateway.rag.embedders.openai_embedder) OpenAIFineTuner (class in ractogateway.finetune) output_format (ractogateway.prompts.RactoPrompt attribute)

P

page (ractogateway.rag._models.document.ChunkMetadata attribute) page_number (ractogateway.rag.page_index._models.PageEntry attribute) PageEntry (class in ractogateway.rag.page_index._models) PageIndexRAG (class in ractogateway.rag.page_index.pipeline) PageIndexResponse (class in ractogateway.rag.page_index._models) PageIndexResult (class in ractogateway.rag.page_index._models) pages (ractogateway.rag.page_index._models.PageIndexResponse property) parallel_batch() (ractogateway.celery.worker.RactoCeleryWorker method) parameters (ractogateway.tools.ToolSchema attribute) parsed (ractogateway.adapters.LLMResponse attribute) parsed_output (ractogateway.pipelines.agent._models.AgentResult attribute) (ractogateway.pipelines.agent.AgentResult attribute) partition (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaProduceResult attribute) (ractogateway.kafka._models.KafkaPublishRequest attribute) PdfReader (class in ractogateway.rag.readers.pdf_reader) PENDING (ractogateway.batch._models.BatchStatus attribute) (ractogateway.celery._models.TaskStatus attribute) PGVectorStore (class in ractogateway.rag.stores.pgvector_store) PineconeStore (class in ractogateway.rag.stores.pinecone_store) poll() (ractogateway.kafka.consumer.KafkaConsumerClient method) poll_status() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method)

poll_timeout_ms (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaStreamConfig attribute) process() (ractogateway.rag.processors.base.BaseProcessor method) (ractogateway.rag.processors.cleaner.TextCleaner method) (ractogateway.rag.processors.lemmatizer.Lemmatizer method) (ractogateway.rag.processors.pipeline.ProcessingPipeline method) process_once() (ractogateway.kafka.stream.KafkaStreamProcessor method) ProcessingPipeline (class in ractogateway.rag.processors.pipeline) prompt (ractogateway.kafka._models.KafkaAuditEvent attribute) provider (ractogateway.adapters.BaseLLMAdapter attribute) (ractogateway.anthropic_developer_kit.AnthropicDeveloperKit attribute) (ractogateway.batch._models.BatchJobInfo attribute) (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor attribute) (ractogateway.batch.openai_batch.OpenAIBatchProcessor attribute) (ractogateway.google_developer_kit.GoogleDeveloperKit attribute) (ractogateway.openai_developer_kit.OpenAIDeveloperKit attribute) publish() (ractogateway.kafka.producer.KafkaProducerClient method) publish_json() (ractogateway.kafka.producer.KafkaProducerClient method) put() (ractogateway.cache.exact_cache.ExactMatchCache method) (ractogateway.cache.semantic_cache.SemanticCache method) (ractogateway.redis.exact_cache.RedisExactCache method)

Q

QdrantStore (class in ractogateway.rag.stores.qdrant_store) query (ractogateway.rag._models.retrieval.RAGResponse attribute) (ractogateway.rag._models.retrieval.RetrievalConfig attribute) (ractogateway.rag.page_index._models.PageIndexResponse attribute)

query() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method)

R

RactoCeleryWorker (class in ractogateway.celery.worker) RactoDataset (class in ractogateway.finetune) ractogateway._cot module ractogateway.adapters module ractogateway.batch._models module ractogateway.batch.anthropic_batch module ractogateway.batch.openai_batch module ractogateway.cache._models module ractogateway.cache.exact_cache module ractogateway.cache.semantic_cache module ractogateway.celery._models module ractogateway.celery.worker module ractogateway.finetune module ractogateway.gateway module ractogateway.kafka._models module ractogateway.kafka.audit module ractogateway.kafka.consumer module ractogateway.kafka.producer module ractogateway.kafka.stream module ractogateway.mcp._models module ractogateway.mcp.agent module ractogateway.mcp.client module ractogateway.mcp.multi_client module ractogateway.mcp.server module ractogateway.pipelines.agent module ractogateway.pipelines.agent._executor module ractogateway.pipelines.agent._models module ractogateway.pipelines.agent.pipeline module ractogateway.prompts module ractogateway.rag._models.document module ractogateway.rag._models.retrieval module ractogateway.rag.chunkers.base module ractogateway.rag.chunkers.fixed_chunker module ractogateway.rag.chunkers.recursive_chunker module ractogateway.rag.chunkers.semantic_chunker module ractogateway.rag.chunkers.sentence_chunker module ractogateway.rag.embedders.base module ractogateway.rag.embedders.google_embedder module ractogateway.rag.embedders.openai_embedder module ractogateway.rag.embedders.voyage_embedder module ractogateway.rag.page_index._bm25 module ractogateway.rag.page_index._models module ractogateway.rag.processors.base module ractogateway.rag.processors.cleaner module ractogateway.rag.processors.lemmatizer module ractogateway.rag.processors.pipeline module ractogateway.rag.readers.base module ractogateway.rag.readers.html_reader module ractogateway.rag.readers.image_reader module ractogateway.rag.readers.pdf_reader module ractogateway.rag.readers.registry module ractogateway.rag.readers.spreadsheet_reader module

ractogateway.rag.readers.text_reader module ractogateway.rag.readers.word_reader module ractogateway.rag.stores.base module ractogateway.rag.stores.chroma_store module ractogateway.rag.stores.faiss_store module ractogateway.rag.stores.in_memory_store module ractogateway.rag.stores.milvus_store module ractogateway.rag.stores.pgvector_store module ractogateway.rag.stores.pinecone_store module ractogateway.rag.stores.qdrant_store module ractogateway.rag.stores.weaviate_store module ractogateway.redis._models module ractogateway.redis.chat_memory module ractogateway.redis.exact_cache module ractogateway.redis.rate_limiter module ractogateway.routing._models module ractogateway.routing.router module ractogateway.tools module ractogateway.truncation._models module ractogateway.truncation.truncator module RactoMCPClient (class in ractogateway.mcp.client) RactoMCPServer (class in ractogateway.mcp.server) RactoPrompt (class in ractogateway.prompts) RactoRAG (class in ractogateway.rag.pipeline) RactoTrainingExample (class in ractogateway.finetune) RactoTrainingMessage (class in ractogateway.finetune) RAGResponse (class in ractogateway.rag._models.retrieval) rank (ractogateway.rag._models.retrieval.RetrievalResult attribute) (ractogateway.rag.page_index._models.PageIndexResult attribute) RateLimitConfig (class in ractogateway.redis._models) raw (ractogateway.adapters.LLMResponse attribute) (ractogateway.batch._models.BatchJobInfo attribute) (ractogateway.batch._models.BatchResult attribute) read() (ractogateway.rag.readers.base.BaseReader method) (ractogateway.rag.readers.registry.FileReaderRegistry method) RecursiveChunker (class in ractogateway.rag.chunkers.recursive_chunker) RedisChatMemory (class in ractogateway.redis.chat_memory) RedisExactCache (class in ractogateway.redis.exact_cache) RedisRateLimiter (class in ractogateway.redis.rate_limiter) register() (ractogateway.rag.readers.registry.FileReaderRegistry method) (ractogateway.tools.ToolRegistry method) registered_tools (ractogateway.pipelines.agent.AgentPipeline property) (ractogateway.pipelines.agent.AsyncAgentPipeline property) (ractogateway.pipelines.agent.pipeline.AgentPipeline property) (ractogateway.pipelines.agent.pipeline.AsyncAgentPipeline property) registry (ractogateway.mcp.agent.MCPAgent property) remove() (ractogateway.rag.page_index._bm25.BM25Index method) remove_document() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) request_count (ractogateway.batch._models.BatchJobInfo attribute) request_id (ractogateway.kafka._models.KafkaAuditEvent attribute) request_timeout_ms (ractogateway.kafka._models.KafkaProducerConfig attribute) reset() (ractogateway.redis.rate_limiter.RedisRateLimiter method) resolve_limit() (ractogateway.truncation._models.TruncationConfig method) response (ractogateway.batch._models.BatchResult attribute) (ractogateway.cache._models.CacheEntry attribute) (ractogateway.cache._models.SemanticCacheEntry attribute) (ractogateway.kafka._models.KafkaAuditEvent attribute) result (ractogateway.celery._models.TaskResult attribute) results (ractogateway.rag.page_index._models.PageIndexResponse property) retries (ractogateway.kafka._models.KafkaProducerConfig attribute) RetrievalConfig (class in ractogateway.rag._models.retrieval) RetrievalResult (class in ractogateway.rag._models.retrieval) retrieve() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.pipeline.RactoRAG method) RETRY (ractogateway.celery._models.TaskStatus attribute) RetryConfig (class in ractogateway.celery._models) REVOKED (ractogateway.celery._models.TaskStatus attribute) role (ractogateway.finetune.RactoTrainingMessage attribute) (ractogateway.prompts.RactoPrompt attribute) route() (ractogateway.routing.router.CostAwareRouter method) RoutingTier (class in ractogateway.routing._models) run() (ractogateway.adapters.BaseLLMAdapter method) (ractogateway.gateway.Gateway method) (ractogateway.kafka.stream.KafkaStreamProcessor method) (ractogateway.mcp.agent.MCPAgent method) (ractogateway.mcp.server.RactoMCPServer method) (ractogateway.pipelines.agent.AgentPipeline method) (ractogateway.pipelines.agent.AsyncAgentPipeline method) (ractogateway.pipelines.agent.pipeline.AgentPipeline method) (ractogateway.pipelines.agent.pipeline.AsyncAgentPipeline method) run_pipeline() (ractogateway.finetune.AnthropicFineTuner method) (ractogateway.finetune.GeminiFineTuner method) (ractogateway.finetune.OpenAIFineTuner method)

S

safety_margin (ractogateway.truncation._models.TruncationConfig attribute) sasl_mechanism (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute) sasl_plain_password (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute) sasl_plain_username (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute) save() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.stores.faiss_store.FAISSStore method) schemas (ractogateway.tools.ToolRegistry property) score (ractogateway.rag._models.retrieval.RetrievalResult attribute) (ractogateway.rag.page_index._models.PageIndexResult attribute) score() (ractogateway.rag.page_index._bm25.BM25Index method) (ractogateway.routing.router.CostAwareRouter method) search() (ractogateway.rag.page_index.pipeline.PageIndexRAG method) (ractogateway.rag.stores.base.BaseVectorStore method) (ractogateway.rag.stores.chroma_store.ChromaStore method) (ractogateway.rag.stores.faiss_store.FAISSStore method) (ractogateway.rag.stores.in_memory_store.InMemoryVectorStore method) (ractogateway.rag.stores.milvus_store.MilvusStore method) (ractogateway.rag.stores.pgvector_store.PGVectorStore method) (ractogateway.rag.stores.pinecone_store.PineconeStore method) (ractogateway.rag.stores.qdrant_store.QdrantStore method) (ractogateway.rag.stores.weaviate_store.WeaviateStore method) section_title (ractogateway.rag.page_index._models.PageEntry attribute) security_protocol (ractogateway.kafka._models.KafkaConsumerConfig attribute) (ractogateway.kafka._models.KafkaProducerConfig attribute) SemanticCache (class in ractogateway.cache.semantic_cache) SemanticCacheConfig (class in ractogateway.cache._models) SemanticCacheEntry (class in ractogateway.cache._models) SemanticChunker (class in ractogateway.rag.chunkers.semantic_chunker) SentenceChunker (class in ractogateway.rag.chunkers.sentence_chunker) server_count (ractogateway.mcp.multi_client.MCPMultiClient property) session_timeout_ms (ractogateway.kafka._models.KafkaConsumerConfig attribute) shuffle() (ractogateway.finetune.RactoDataset method) size (ractogateway.cache._models.CacheStats attribute) source (ractogateway.rag._models.document.ChunkMetadata attribute) (ractogateway.rag._models.document.Document attribute) (ractogateway.rag.page_index._models.PageEntry attribute) sources (ractogateway.rag._models.retrieval.RAGResponse attribute) (ractogateway.rag.page_index._models.PageIndexResponse attribute) split() (ractogateway.finetune.RactoDataset method)

SpreadsheetReader (class in ractogateway.rag.readers.spreadsheet_reader) start_char (ractogateway.rag._models.document.ChunkMetadata attribute) STARTED (ractogateway.celery._models.TaskStatus attribute) stats (ractogateway.cache.exact_cache.ExactMatchCache property) (ractogateway.cache.semantic_cache.SemanticCache property) (ractogateway.redis.exact_cache.RedisExactCache property) status (ractogateway.batch._models.BatchJobInfo attribute) (ractogateway.celery._models.TaskResult attribute) step_num (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent.AgentStep attribute) steps (ractogateway.pipelines.agent._models.AgentResult attribute) (ractogateway.pipelines.agent.AgentResult attribute) steps_taken (ractogateway.pipelines.agent._models.AgentUsage attribute) (ractogateway.pipelines.agent.AgentUsage attribute) STOP (ractogateway.adapters.FinishReason attribute) stop_reason (ractogateway.pipelines.agent._models.AgentResult attribute) (ractogateway.pipelines.agent.AgentResult attribute) StopReason (class in ractogateway.pipelines.agent) (class in ractogateway.pipelines.agent._models) store (ractogateway.rag.pipeline.RactoRAG property) stream() (ractogateway.anthropic_developer_kit.AnthropicDeveloperKit method) (ractogateway.google_developer_kit.GoogleDeveloperKit method) (ractogateway.openai_developer_kit.OpenAIDeveloperKit method) submit_and_wait() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method) submit_batch() (ractogateway.batch.anthropic_batch.AnthropicBatchProcessor method) (ractogateway.batch.openai_batch.OpenAIBatchProcessor method) succeeded() (ractogateway.pipelines.agent._models.AgentResult method) (ractogateway.pipelines.agent.AgentResult method) SUCCESS (ractogateway.celery._models.TaskStatus attribute) summary() (ractogateway.finetune.RactoDataset method) supported_extensions (ractogateway.rag.readers.base.BaseReader property) (ractogateway.rag.readers.html_reader.HtmlReader property) (ractogateway.rag.readers.image_reader.ImageReader property) (ractogateway.rag.readers.pdf_reader.PdfReader property) (ractogateway.rag.readers.registry.FileReaderRegistry property) (ractogateway.rag.readers.spreadsheet_reader.SpreadsheetReader property) (ractogateway.rag.readers.text_reader.TextReader property) (ractogateway.rag.readers.word_reader.WordReader property) system_prompt (ractogateway.pipelines.agent.AgentPipeline property) (ractogateway.pipelines.agent.AsyncAgentPipeline property) (ractogateway.pipelines.agent.pipeline.AgentPipeline property) (ractogateway.pipelines.agent.pipeline.AsyncAgentPipeline property)

T

task_id (ractogateway.celery._models.TaskResult attribute) TaskResult (class in ractogateway.celery._models) TaskStatus (class in ractogateway.celery._models) temperature (ractogateway.batch._models.BatchItem attribute) text (ractogateway.rag.page_index._models.PageEntry property) (ractogateway.rag.page_index._models.PageIndexResult property) TextCleaner (class in ractogateway.rag.processors.cleaner) TextReader (class in ractogateway.rag.readers.text_reader) thinking (ractogateway.adapters.LLMResponse attribute) thought (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent.AgentStep attribute) threshold (ractogateway.cache._models.SemanticCacheConfig attribute) tiers (ractogateway.routing.router.CostAwareRouter property) timestamp_ms (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaProduceResult attribute) (ractogateway.kafka._models.KafkaPublishRequest attribute) timestamp_utc (ractogateway.kafka._models.KafkaAuditEvent attribute) to_anthropic() (ractogateway.finetune.RactoTrainingMessage method) to_anthropic_dict() (ractogateway.finetune.RactoTrainingExample method) to_gemini_dict() (ractogateway.finetune.RactoTrainingExample method) to_gemini_parts() (ractogateway.finetune.RactoTrainingMessage method) to_json() (ractogateway.pipelines.agent._models.AgentResult method) (ractogateway.pipelines.agent.AgentResult method) to_json_schema() (ractogateway.tools.ToolSchema method) to_jsonl_string() (ractogateway.finetune.RactoDataset method) to_markdown() (ractogateway.pipelines.agent._models.AgentResult method) (ractogateway.pipelines.agent.AgentResult method) to_messages() (ractogateway.prompts.RactoPrompt method) to_openai() (ractogateway.finetune.RactoTrainingMessage method) to_openai_dict() (ractogateway.finetune.RactoTrainingExample method) to_registry() (ractogateway.mcp.client.RactoMCPClient method) (ractogateway.mcp.multi_client.MCPMultiClient method) token_counter (ractogateway.truncation._models.TruncationConfig attribute) TokenTruncator (class in ractogateway.truncation.truncator) tone (ractogateway.prompts.RactoPrompt attribute) tool() (in module ractogateway.tools)

TOOL_CALL (ractogateway.adapters.FinishReason attribute) tool_calls (ractogateway.adapters.LLMResponse attribute) tool_input (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent.AgentStep attribute) tool_name (ractogateway.pipelines.agent._models.AgentStep attribute) (ractogateway.pipelines.agent.AgentStep attribute) tool_names (ractogateway.mcp.multi_client.MCPMultiClient property) (ractogateway.mcp.server.RactoMCPServer property) ToolCallResult (class in ractogateway.adapters) ToolExecutor (class in ractogateway.pipelines.agent) (class in ractogateway.pipelines.agent._executor) ToolRegistry (class in ractogateway.tools) tools (ractogateway.tools.ToolRegistry property) tools_called (ractogateway.pipelines.agent._models.AgentUsage attribute) (ractogateway.pipelines.agent.AgentUsage attribute) ToolSchema (class in ractogateway.tools) top_k (ractogateway.rag._models.retrieval.RetrievalConfig attribute) topic (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaProduceResult attribute) (ractogateway.kafka._models.KafkaPublishRequest attribute) (ractogateway.kafka.audit.KafkaAuditLogger property) topics (ractogateway.kafka._models.KafkaConsumerConfig attribute) total (ractogateway.cache._models.CacheStats property) total_chunks (ractogateway.rag._models.document.ChunkMetadata attribute) total_input_tokens (ractogateway.pipelines.agent._models.AgentUsage attribute) (ractogateway.pipelines.agent.AgentUsage attribute) total_output_tokens (ractogateway.pipelines.agent._models.AgentUsage attribute) (ractogateway.pipelines.agent.AgentUsage attribute) total_tokens (ractogateway.pipelines.agent._models.AgentUsage property) (ractogateway.pipelines.agent.AgentUsage property) translate_tools() (ractogateway.adapters.BaseLLMAdapter method) transport (ractogateway.mcp._models.MCPClientConfig attribute) truncate() (ractogateway.truncation.truncator.TokenTruncator method) TruncationConfig (class in ractogateway.truncation._models) ttl_seconds (ractogateway.cache._models.CacheConfig attribute) (ractogateway.cache._models.SemanticCacheConfig attribute) (ractogateway.redis._models.ChatMemoryConfig attribute)

U

upload_dataset() (ractogateway.finetune.AnthropicFineTuner method) (ractogateway.finetune.OpenAIFineTuner method) url (ractogateway.mcp._models.MCPClientConfig attribute) usage (ractogateway.adapters.LLMResponse attribute) (ractogateway.pipelines.agent._models.AgentResult attribute) (ractogateway.pipelines.agent.AgentResult attribute)

user_id (ractogateway.kafka._models.KafkaAuditEvent attribute) user_message (ractogateway.batch._models.BatchItem attribute)

V

validate() (ractogateway.finetune.RactoDataset method) value (ractogateway.kafka._models.KafkaMessage attribute) (ractogateway.kafka._models.KafkaPublishRequest attribute)

vector (ractogateway.cache._models.SemanticCacheEntry attribute) version (ractogateway.mcp._models.MCPServerConfig attribute) VoyageEmbedder (class in ractogateway.rag.embedders.voyage_embedder)

W

wait() (ractogateway.celery.worker.RactoCeleryWorker method) wait_for_completion() (ractogateway.finetune.AnthropicFineTuner method) (ractogateway.finetune.GeminiFineTuner method) (ractogateway.finetune.OpenAIFineTuner method)

wait_for_publish (ractogateway.kafka._models.KafkaStreamConfig attribute) wait_parallel() (ractogateway.celery.worker.RactoCeleryWorker method) WeaviateStore (class in ractogateway.rag.stores.weaviate_store) WordReader (class in ractogateway.rag.readers.word_reader)