Functions — github.com/Harmeet10000/AgentNexus-LangChain-FastAPI

hub / github.com/Harmeet10000/AgentNexus-LangChain-FastAPI / functions

Functions1,424 in github.com/Harmeet10000/AgentNexus-LangChain-FastAPI

⨍ Functions 1,424◇ Types & classes 479↳ Endpoints 62

↓ 4 callersMethodkeys

(self, pattern: str)

src/app/utils/cache/redis_protocol_adapter.py:39

↓ 4 callersMethodmark_idempotency_failed_permanently

( self, idempotency_key: str, *, metadata: dict[str, Any] | None = None, )

src/app/connections/celery.py:98

↓ 4 callersMethodping

(self, server_name: str)

src/mcp_core/client/manager.py:70

↓ 4 callersFunctionprocess_ingestion_document

Chunk, embed, and upsert search chunks for a document.

src/app/features/search/service.py:284

↓ 4 callersMethodput

Store embedding in cache.

src/app/shared/rag/document_processing/embedder.py:312

↓ 4 callersMethodrefresh

(self, refresh_token: str)

src/app/features/auth/service.py:165

↓ 4 callersMethodrun_with_circuit_breaker

( self, name: str, operation, )

src/app/connections/celery.py:115

↓ 4 callersFunctionsearch

Search the web using Tavily. Args: query: The search query max_results: Maximum number of results (capped by TAVILY_MAX_RESULTS_L

src/app/shared/services/tavily.py:99

↓ 4 callersMethodsearch

( self, query: str, max_results: int = 10, include_answer: bool = True )

src/app/shared/services/tavily.py:200

↓ 4 callersFunctionsend_template

Send a Resend hosted template email. Raises ExternalServiceException on API or network failure.

src/app/shared/services/mailer.py:40

↓ 3 callersFunctionRead

(path string)

src/lynk/internal/adapters/docx/reader.go:48

↓ 3 callersMethod__init__

( self, *, redis: Redis, settings: Settings, user_limiter: WebSocketRa

src/app/features/auth/websocket_security.py:124

↓ 3 callersMethod_build_config

(self, *, thread_id: str, context: Any | None = None)

src/app/shared/langchain_layer/agents/factory.py:323

↓ 3 callersMethod_connect

(self, server_name: str)

src/mcp_core/client/manager.py:194

↓ 3 callersFunction_flatten_warnings

( raw_groups: list, )

src/app/features/documents/service.py:904

↓ 3 callersFunction_get_profile_service

Resolve ProfileService with storage from app.state.

src/app/features/profile/router.py:27

↓ 3 callersFunction_get_sdk_client

Cached SDK client (handles pooling internally).

src/app/shared/rag/pageindex/client.py:57

↓ 3 callersFunction_rank_rows

(rows: Sequence[dict[str, Any]])

src/app/features/search/repository.py:500

↓ 3 callersFunction_read_optional_string

Read an optional string from a mapping.

src/app/shared/services/tavily.py:73

↓ 3 callersFunction_read_string

Read a required string from a mapping.

src/app/shared/services/tavily.py:67

↓ 3 callersFunction_redis_key

(key: str)

src/app/shared/langchain_layer/agents/tools/idempotency.py:202

↓ 3 callersFunction_score_and_convert

Convert a raw graphiti-core result to GraphitiSearchResult. Multi-objective score (Section 18.6): score = w1 * semantic_similarity + w2 * r

src/app/shared/rag/graphiti/client.py:515

↓ 3 callersFunction_send_json_response

( send: Callable[[dict[str, Any]], Any], *, status_code: int, payload: dict[str, Any], hea

src/mcp_core/server/middleware.py:19

↓ 3 callersFunction_structured

(llm: Any, schema: type[Any])

src/app/shared/langgraph_layer/retrieval_kb/graph.py:71

↓ 3 callersFunction_tool_catalog

()

src/mcp_core/server/tools.py:88

↓ 3 callersFunctionbuild_circuit_breaker_key

( name: str, *, namespace: str = CIRCUIT_BREAKER_NAMESPACE, )

src/app/connections/celery_reliability.py:195

↓ 3 callersFunctionbuild_s3_key

( *, prefix: str, user_id: str, document_id: str, content_hash: str, filename: str )

src/app/shared/services/storage.py:692

↓ 3 callersFunctioncreate_document_converter

Create Docling converter with appropriate pipeline.

src/app/shared/rag/document_processing/docling_enhanced.py:55

↓ 3 callersFunctioncreate_hybrid_chunker

Create HybridChunker instance.

src/app/shared/rag/document_processing/chunker.py:28

↓ 3 callersMethodcreate_multipart_upload

( self, *, key: str, content_type: str, metadata: dict[str, str] | Non

src/app/shared/services/storage.py:418

↓ 3 callersMethoddelete

(self, namespace: str, key: str)

src/app/utils/cache/redis_protocol_adapter.py:36

↓ 3 callersMethoddelete_object

(self, *, key: str)

src/app/shared/services/storage.py:122

↓ 3 callersFunctiondeserialize_data

Deserialize JSON string. Args: value: JSON string or bytes Returns: Deserialized Python object Raises: Database

src/app/utils/cache/redis_func.py:104

↓ 3 callersFunctionextract

Extract entities and relationships from text. Args: text: Input text to extract from document_id: Source document identifier

src/app/shared/rag/document_processing/entity_extractor.py:315

↓ 3 callersMethodextract_structured

Extract structured data from content using Gemini. Args: content: Content to extract from schema_type: Prede

src/app/shared/crawler/processor.py:177

↓ 3 callersFunctionextract_with_fallback

Fallback extraction using simple NLP patterns.

src/app/shared/rag/document_processing/entity_extractor.py:110

↓ 3 callersMethodfind_by_email

(self, email: str)

src/app/features/auth/repository.py:61

↓ 3 callersMethodfrom_settings

(cls, settings: Settings)

src/app/shared/services/storage.py:267

↓ 3 callersFunctiongenerate_embedding

Generate embedding for a single text. Args: text: Text to embed model: Gemini embedding model to use max_retries: Ma

src/app/shared/rag/document_processing/embedder.py:32

↓ 3 callersFunctiongenerate_token

Cryptographically secure URL-safe token for email delivery.

src/app/features/auth/security.py:55

↓ 3 callersFunctionget_all_tools

Assemble research tools (Tavily search + Crawl4AI + reflection).

src/app/shared/langgraph_layer/open_deep_search/utils.py:246

↓ 3 callersFunctionget_cached_user

Get user profile with caching strategy. 1. Check cache first (fast) 2. If miss, fetch from DB (slow) 3. Update cache for next time

src/app/examples/redis_examples.py:81

↓ 3 callersFunctionget_client_identifier

Get client identifier from request (IP or user ID).

src/app/features/crawler/router.py:24

↓ 3 callersMethodget_object

(self, *, key: str)

src/app/shared/services/storage.py:120

↓ 3 callersFunctionget_processor

Get a Gemini processor instance.

src/app/shared/crawler/processor.py:332

↓ 3 callersMethodget_server_status

(self, server_name: str)

src/mcp_core/client/manager.py:55

↓ 3 callersMethodget_session

(self, session_id: str)

src/app/features/auth/repository.py:286

↓ 3 callersFunctionget_tokenizer

Initialize tokenizer for token-aware chunking.

src/app/shared/rag/document_processing/chunker.py:22

↓ 3 callersMethodget_tools

Get all registered tools.

src/app/shared/langchain_layer/agents/tools/registry.py:15

↓ 3 callersFunctionget_user_from_db

Simulate database lookup.

src/app/examples/redis_examples.py:64

↓ 3 callersFunctionkey_from_s3_uri

(uri: str)

src/app/shared/services/storage.py:703

↓ 3 callersMethodput

Store a value in the graph with embeddings.

src/app/shared/langchain_layer/agents/memory/cognee_client.py:283

↓ 3 callersMethodput_object

( self, *, key: str, data: bytes, content_type: str, metadata:

src/app/shared/services/storage.py:111

↓ 3 callersMethodreset_password

(self, token: str, new_password: str)

src/app/features/auth/service.py:277

↓ 3 callersMethodrevoke_session

( self, session_id: str, user_id: str, )

src/app/features/auth/service.py:393

↓ 3 callersFunctionrun_with_circuit_breaker

Execute an operation unless the circuit breaker is open.

src/app/connections/celery_reliability.py:299

↓ 3 callersMethodsearch

Semantic search within a namespace with optional filtering.

src/app/shared/langchain_layer/agents/memory/cognee_client.py:299

↓ 3 callersFunctionserialize_idempotency_record

( status: IdempotencyStatus, *, task_id: str | None = None, updated_at: str | None = None,

src/app/connections/celery_reliability.py:80

↓ 3 callersFunctionset_cache

Cache a value with expiration. Args: redis: Redis client instance object_type: Entity type for namespacing key: Cache key

src/app/utils/cache/redis_func.py:130

↓ 3 callersFunctionset_circuit_breaker_state

( redis_client: RedisClientProtocol, name: str, state: CircuitBreakerState, *, recovery_ti

src/app/connections/celery_reliability.py:218

↓ 3 callersFunctionsetup_otel

(service_name: str | None = None)

src/app/shared/otel/__init__.py:23

↓ 3 callersFunctionsplit_by_header

Split markdown by a specific header pattern.

src/app/shared/crawler/chunker.py:19

↓ 3 callersMethodsummarize

Summarize content using Gemini. Args: content: Content to summarize max_length: Maximum summary length in ch

src/app/shared/crawler/processor.py:139

↓ 3 callersMethodto_browser_config

Convert to Crawl4AI BrowserConfig kwargs.

src/app/shared/crawler/config.py:81

↓ 3 callersFunctionto_sorted_key_bytes

(data: dict[str, object])

src/app/utils/json_serializer.py:24

↓ 3 callersMethodupdate_document_status

( self, *, document_id: str, status: str, title: str | None = None,

src/app/features/documents/repository.py:169

↓ 3 callersMethodvalidate

Validate kwargs against registered model, or fall back to LegacyTaskPayload.

src/app/connections/celery_registry.py:77

↓ 3 callersFunctionverify_password

(hashed: str, plain: str)

src/app/features/auth/security.py:38

↓ 2 callersFunction_answer_cache_key

(rewritten_query: str, doc_ids_filter: list[str])

src/app/shared/langgraph_layer/retrieval_kb/nodes.py:382

↓ 2 callersFunction_build_analysis_context

(state: LegalAgentState)

src/app/shared/langgraph_layer/agent_saul/nodes.py:581

↓ 2 callersFunction_build_context_section

(chunks: list[SearchChunkRecord])

src/app/features/search/rag.py:95

↓ 2 callersFunction_build_embedding_model_gemini_full

Build a Gemini embedding model with full configuration. Args: model_name: Embedding model (e.g., "embedding-001").

src/app/shared/langchain_layer/models.py:172

↓ 2 callersFunction_build_request_meta

Build request metadata from the current request context.

src/app/utils/http_response.py:20

↓ 2 callersFunction_build_search_items

( fused_results: Sequence[RankedChunk], chunk_lookup: dict[str, SearchChunkRecord], )

src/app/features/search/service.py:395

↓ 2 callersFunction_compute_decay

Compute the weighted decay score for an entity or clause.

src/tasks/memory_decay_reconciliation_tasks.py:51

↓ 2 callersFunction_contract_metadata_json

(metadata: ContractMetadata, source: str)

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:797

↓ 2 callersMethod_create_session

( self, user: User, device_name: str | None = None, ip: str | None = None,

src/app/features/auth/service.py:434

↓ 2 callersFunction_error

(message: str, **metadata: Any)

src/mcp_core/server/tools.py:59

↓ 2 callersFunction_extract_entities_simple

Simple pattern-based entity extraction.

src/app/shared/rag/document_processing/entity_extractor.py:131

↓ 2 callersMethod_get_cache_key

Generate cache key for URL.

src/app/shared/crawler/crawler.py:61

↓ 2 callersFunction_graphiti_add_episode

( *, graphiti: Any, name: str, body: str, source_description: str, group_id: str, )

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:750

↓ 2 callersMethod_hash_text

Generate hash for text.

src/app/shared/rag/document_processing/embedder.py:325

↓ 2 callersMethod_is_pdf_url

Check if URL points to a PDF.

src/app/shared/crawler/crawler.py:167

↓ 2 callersFunction_is_table_line

(line: str)

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:862

↓ 2 callersFunction_keywords

(text_value: str)

src/app/shared/langgraph_layer/ingestion_kb/nodes.py:830

↓ 2 callersMethod_now_ms

(self)

src/app/shared/circuit_breaker/service.py:164

↓ 2 callersFunction_process_embeddings_individually

Process texts individually as fallback. Args: texts: List of texts to embed model: Embedding model to use retry_dela

src/app/shared/rag/document_processing/embedder.py:145

↓ 2 callersMethod_publish

( self, row: dict[str, object], session: AsyncSession, )

src/app/shared/outbox/relay.py:110

↓ 2 callersMethod_publish_outbox_event

( self, aggregate_type: str, aggregate_id: str, event_type: str, paylo

src/app/features/auth/service.py:482

↓ 2 callersFunction_read_int_field

( *, decision: Mapping[str, object], field_name: str, fallback: int, )

src/app/shared/langchain_layer/agents/memory/memory_scope.py:119

↓ 2 callersFunction_read_iterable_field

( *, decision: Mapping[str, object], field_name: str, fallback: tuple[StrEnum, ...], )

src/app/shared/langchain_layer/agents/memory/memory_scope.py:223

↓ 2 callersFunction_reconciliation_failure

(error: AppError)

src/app/shared/langgraph_layer/reconciliation/nodes.py:39

↓ 2 callersMethod_record_failure

(self, server_name: str, error: str)

src/mcp_core/client/manager.py:270

↓ 2 callersMethod_record_success

(self, server_name: str)

src/mcp_core/client/manager.py:287

↓ 2 callersFunction_redis_error_contains

Case-insensitive Redis error matching for command capability checks.

src/app/utils/cache/redis_func.py:40

↓ 2 callersFunction_response_text

(response: object)

src/app/shared/crawler/processor.py:301

↓ 2 callersFunction_row_to_record

(row: object)

src/app/shared/langgraph_layer/reconciliation/nodes.py:354

↓ 2 callersFunction_run_reconciliation_async

Run reconciliation sequentially for each user id.

src/tasks/memory_decay_reconciliation_tasks.py:145

↓ 2 callersFunction_server_name

()

src/mcp_core/server/factory.py:17

↓ 2 callersFunction_simple_fallback_chunk

Simple fallback chunking when HybridChunker can't be used. Args: content: Content to chunk base_metadata: Base metadata for

src/app/shared/rag/document_processing/chunker.py:112

← previous next →101–200 of 1,424, ranked by callers