removeServerConfig removes server configuration

replacePromptArguments replaces parameter placeholders in prompt content

reportTotalDurationMetric calculates and reports the total request-response duration.

reportUpstreamMetrics reads attempt data from context and reports endpoint-level metrics.

reportWithOTel reports metrics using OpenTelemetry.

reportWithPrometheus reports metrics using Prometheus.

resolveRegistryAddresses resolves registry service names to IP addresses from k8s endpoints

routeRequest routes the request to a backend service using path and method.

request EDS for the allResourceNames

runXDSServer starts an xDS server at the given port.

sendMCPResponse sends an MCP response and updates the target response

sendMethodNotAllowed sends a 405 Method Not Allowed response

sendNotAcceptable sends a 406 Not Acceptable response

sendSSEResponse sends response via SSE stream

sendToolsListChangedNotification sends notification to a specific session

serveGrpc runs the gRPC server on the provided listener

sessionExists checks if a session exists

setMapWithPath set the value to the target map. If the origin targetMap has {"abc": "cde": {"f":1, "g":2}} and the path is abc, value is "123", then t

splitClusterName splits a cluster name in format "namespace-servicename" into parts

splitSSEEvent finds the next complete SSE event (ending in \n\n) in a byte slice.

startCleanupRoutine starts the session cleanup routine

toNacosInstance convert to registry's service instance

toOTelAttributes converts map[string]string to OpenTelemetry attributes.

toZookeeperInstance convert to registry's service instance

updateLogger swaps the underlying logger atomically.

validAll route multiple provider verification

validAny route single provider verification

validate validate and make apiType

validateRoute validates a single route, returning an error if invalid.

validateRoutes performs basic validation on the provided routes.

waitForActiveRequests waits for active requests to complete until deadline

watchForServices periodically polls Nacos to discover new services to subscribe to. The actual instance updates for subscribed services are push-based

wrapListener wraps a listener callback

writeHS256JWKS creates a temporary JWKS file with HS256 key for testing

write log to file or console

writeOAuthError responds with JSON {error, error_description}