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

↓ 2 callersFunction_state_signer

()

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

↓ 2 callersMethod_to_crawl_result

Convert crawl4ai result to domain CrawlResult.

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

↓ 2 callersFunction_vector_literal

(embedding: list[float])

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

↓ 2 callersFunction_vector_literal

(embedding: list[float])

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

↓ 2 callersMethodabort_multipart_upload

(self, *, key: str, upload_id: str)

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

↓ 2 callersMethodask

( self, *, user_id: str, payload: documents_dto.UnifiedAskRequest, req

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

↓ 2 callersMethodbuild

(self)

src/app/shared/langchain_layer/agents/middlewares/guardrails.py:89

↓ 2 callersFunctionbuild_chunk_rows

( *, document_id: str, user_id: str, chunks: Sequence[dict[str, Any]] )

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

↓ 2 callersFunctionbuild_s3_uri

(*, bucket: str, key: str)

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

↓ 2 callersFunctioncheck_gpu_available

Check if GPU is available for accelerated processing.

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

↓ 2 callersMethodcheck_limit

Evaluates the rate limit using GCRA. Raises TooManyRequestsException if exceeded.

src/app/utils/rate_limit/service.py:58

↓ 2 callersMethodcheck_rate_limit

Check if rate limit is exceeded.

src/app/features/crawler/service.py:72

↓ 2 callersFunctionchunk_document_simple

Simple paragraph-based chunking without semantic splitting. Args: content: Document content title: Document title so

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

↓ 2 callersFunctionclean_databases

Clean existing data from databases.

src/app/shared/rag/document_processing/ingest_v2.py:371

↓ 2 callersMethodclose

(self)

src/mcp_core/client/manager.py:178

↓ 2 callersFunctionclose_graphiti

Close Graphiti instance and clean up resources. Args: graphiti: Graphiti instance to close (can be None).

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

↓ 2 callersMethodcomplete_multipart_upload

( self, *, key: str, upload_id: str, parts: list[dict[str, Any]],

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

↓ 2 callersMethodcopy_object

(self, *, source_key: str, destination_key: str)

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

↓ 2 callersFunctioncreate_access_token

Return (encoded_jwt, expires_in_seconds).

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

↓ 2 callersFunctioncreate_redis_client

Create and return a configured async Redis client. The client is connection-pooled and intended to live for the entire process lifetime.

src/app/connections/redis.py:11

↓ 2 callersMethoddegraded

(cls, name: str, message: str, latency_ms: float = 0.0)

src/app/utils/response_type.py:88

↓ 2 callersMethoddiscover_servers

(self)

src/mcp_core/client/manager.py:52

↓ 2 callersFunctionexecute_tool_safely

Execute a research tool and convert failures into model-visible observations.

src/app/shared/langgraph_layer/open_deep_search/graph.py:323

↓ 2 callersFunctionextract_with_graphiti

Extract entities and relationships using Graphiti. Args: text: Input text to extract from document_id: Source document ident

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

↓ 2 callersMethodfind_by_id

(self, user_id: str)

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

↓ 2 callersMethodforgot_password

(self, email: str)

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

↓ 2 callersMethodget

(self, *args: object, **kwargs: object)

src/app/connections/celery_reliability.py:29

↓ 2 callersFunctionget_bound_mcp_parent_app

()

src/mcp_core/server/tools.py:34

↓ 2 callersFunctionget_circuit_breaker_state

( redis_client: RedisClientProtocol, name: str, *, namespace: str = CIRCUIT_BREAKER_NAMESPACE,

src/app/connections/celery_reliability.py:203

↓ 2 callersFunctionget_crawl_url_tool

()

src/app/shared/langchain_layer/agents/tools/crawl.py:113

↓ 2 callersFunctionget_crawler

Get a WebCrawler domain service instance. Creates a new WebCrawler with optional Redis for caching. The underlying AsyncWebCrawler browser is

src/app/connections/crawl4ai.py:49

↓ 2 callersFunctionget_crawler_config

Get crawler configuration from settings.

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

↓ 2 callersFunctionget_key_name

Generate a namespaced cache key from object type and args. Args: object_type: Entity type (e.g., 'user', 'token') *args: Argument

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

↓ 2 callersMethodget_markdown_generator

Get DefaultMarkdownGenerator with configured options and optional content filter.

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

↓ 2 callersFunctionget_mcp_server

()

src/mcp_core/server/factory.py:31

↓ 2 callersFunctionget_notes_from_tool_calls

Extract notes from tool call messages.

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

↓ 2 callersFunctionget_oauth_config

(provider: str)

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

↓ 2 callersFunctionget_rate_limiter

Get rate limiter instance.

src/app/shared/services/rate_limiter.py:147

↓ 2 callersMethodget_remaining

Get remaining rate limit quota.

src/app/shared/services/rate_limiter.py:116

↓ 2 callersFunctionget_shared_httpx_client

Return a process-wide async HTTPX client for non-request runtimes.

src/app/connections/httpx_client.py:60

↓ 2 callersFunctionget_shared_tavily_http_client

Return a process-wide async HTTPX client for Tavily requests. Used for non-request runtimes like background tasks and Celery workers.

src/app/connections/tavily.py:16

↓ 2 callersMethodget_signed_put_url

( self, *, key: str, content_type: str, expires_in: int = 900, )

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

↓ 2 callersFunctionget_tool_registry

Get the tool registry instance.

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

↓ 2 callersFunctionget_web_search_tool

Get web search tool instance.

src/app/shared/langchain_layer/agents/tools/web_search.py:73

↓ 2 callersMethodincrement_rate_limit

Increment rate limit counter.

src/app/features/crawler/service.py:80

↓ 2 callersMethodingest_document

Create or deduplicate a document, then enqueue chunk/embed work.

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

↓ 2 callersFunctioningest_single_document

Ingest a single document. Args: file_path: Path to the document file config: Ingestion configuration db_pool: Databa

src/app/shared/rag/document_processing/ingest_v2.py:148

↓ 2 callersMethodis_open

(self, now: float)

src/mcp_core/common/models.py:80

↓ 2 callersFunctionis_token_limit_exceeded

Detect common Gemini context limit errors.

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

↓ 2 callersMethodlist_sessions

( self, user_id: str, current_session_id: str | None = None, )

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

↓ 2 callersMethodlogout

(self, refresh_token: str)

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

↓ 2 callersFunctionnormalizeWhitespace

(text string)

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

↓ 2 callersFunctionparseRuleSet

(raw string)

src/lynk/internal/adapters/cli/lint_command.go:75

↓ 2 callersMethodreceive_json

( self, websocket: WebSocket, context: WebSocketSecurityContext, )

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

↓ 2 callersFunctionrecord_circuit_breaker_failure

( redis_client: RedisClientProtocol, name: str, *, failure_threshold: int, recovery_timeou

src/app/connections/celery_reliability.py:269

↓ 2 callersFunctionrecord_circuit_breaker_success

( redis_client: RedisClientProtocol, name: str, *, namespace: str = CIRCUIT_BREAKER_NAMESPACE,

src/app/connections/celery_reliability.py:260

↓ 2 callersMethodregister

(self, t: BaseTool, *, tags: list[str] | None = None)

src/app/shared/langchain_layer/agents/tools/base.py:68

↓ 2 callersMethodrerank

( self, query: str, chunks: list[RetrievedChunk], *, limit: int = 5,

src/app/shared/langgraph_layer/retrieval_kb/reranker.py:29

↓ 2 callersMethodrevoke_all_sessions

( self, user_id: str, except_session_id: str | None = None, )

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

↓ 2 callersFunctionsanitize_url

Sanitize and normalize a URL.

src/app/shared/crawler/validator.py:103

↓ 2 callersMethodsearch_for_precedent_chains

( self, query: str, user_id: str, jurisdiction: str = "India", num_res

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

↓ 2 callersMethodset_active

( self, user_id: str, *, is_active: bool, requesting_admin_id: str,

src/app/features/users/service.py:100

↓ 2 callersFunctionsetup_graphiti

Create a Graphiti instance with its own Neo4j connection pool. NOTE: Graphiti creates its own driver internally (does not accept an existing

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

↓ 2 callersFunctionsetup_graphiti_indices

Create indices and constraints in Neo4j. Call once at lifespan startup after creating the Graphiti instance. Args: graphiti: Initial

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

↓ 2 callersFunctionshutdown_otel

()

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

↓ 2 callersFunctionsplitSectionHeading

(text string)

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

↓ 2 callersMethodto_crawler_run_config

Convert to Crawl4AI CrawlerRunConfig kwargs.

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

↓ 2 callersMethodtouch_connection

(self, context: WebSocketSecurityContext)

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

↓ 2 callersFunctiontrim_by_token_count

Trim messages to fit within max_tokens. Preserves the SystemMessage when keep_system=True. Uses LangChain's built-in trim_messages.

src/app/shared/langchain_layer/messages.py:40

↓ 2 callersFunctiontruncate_content

Truncate content to maximum length with warning.

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

↓ 2 callersMethodupload_part

( self, *, key: str, upload_id: str, part_number: int, body: b

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

↓ 2 callersMethodupsert_chunks

(self, rows: list[dict[str, Any]])

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

↓ 2 callersFunctionusage

()

src/lynk/cmd/lynk/main.go:25

↓ 2 callersFunctionvalidate_url

Validate URL for security (SSRF protection). Returns: tuple: (is_valid, error_message)

src/app/shared/crawler/validator.py:58

↓ 2 callersMethodverify_access

(self)

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

↓ 1 callersFunctionBuildSectionIndex

(doc *model.Document)

src/lynk/internal/support/analyze/sections.go:5

↓ 1 callersMethodCode

()

src/lynk/internal/core/ports/rule.go:6

↓ 1 callersFunctionExtractDefinitions

(doc *model.Document)

src/lynk/internal/support/analyze/definitions.go:12

↓ 1 callersFunctionExtractDisputeResolutionFacts

(doc *model.Document)

src/lynk/internal/support/analyze/dispute.go:9

↓ 1 callersFunctionExtractSectionReferences

(text string)

src/lynk/internal/support/analyze/references.go:7

↓ 1 callersMethodFiltered

(filter RuleFilter)

src/lynk/internal/core/service/lint_service.go:28

↓ 1 callersMethodLint

(path string)

src/lynk/internal/core/service/lint_service.go:45

↓ 1 callersFunctionNewLintService

(source ports.DocumentSource, rules []ports.Rule)

src/lynk/internal/core/service/lint_service.go:16

↓ 1 callersMethodRender

(writer io.Writer, result model.LintResult)

src/lynk/internal/core/ports/result_renderer.go:10

↓ 1 callersMethod__aenter__

(self)

src/mcp_core/testing.py:18

↓ 1 callersMethod__aexit__

(self, *args: Any)

src/mcp_core/testing.py:25

↓ 1 callersMethod_acquire_execution_slot

( self, settings: CircuitBreakerSettings, keys: CircuitBreakerKeys, )

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

↓ 1 callersFunction_append_search_filter_args

Append FT.SEARCH numeric and geo filters.

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

↓ 1 callersFunction_append_search_highlight_args

Append FT.SEARCH highlight options.

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

↓ 1 callersFunction_append_search_summarize_args

Append FT.SEARCH summarize options.

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

↓ 1 callersMethod_apply_rate_limits

( self, websocket: WebSocket, context: WebSocketSecurityContext, )

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

↓ 1 callersMethod_arun

Run the web search tool. Args: query: Search query max_results: Maximum number of results (max 10)

src/app/shared/langchain_layer/agents/tools/web_search.py:27

↓ 1 callersFunction_batched

(values: Sequence[T], batch_size: int)

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

↓ 1 callersFunction_batched

(values: Sequence[TextChunk], batch_size: int)

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

↓ 1 callersFunction_bloom_filter_exists

Return whether a Redis Bloom filter already exists.

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

↓ 1 callersFunction_build

(prompt: str)

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

↓ 1 callersFunction_build_answer_cache_key

( *, query: str, doc_ids_filter: list[str], jurisdiction: str | None, contract_type: str |

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

↓ 1 callersFunction_build_bm25_statement

(metadata_filter: dict[str, Any])

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

↓ 1 callersFunction_build_cache_key

(kind: str, payload: UnifiedSearchRequest)

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

↓ 1 callersFunction_build_cache_key

(kind: str, payload: HybridSearchRequest)

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

← previous next →201–300 of 1,424, ranked by callers