ProtocolVersion gets MCP protocol version

QueryServicesByName get service by serviceName from remote registry center

ReLoad filter configs

RegisterDubboFilterPlugin registers dubbo filter.

Remove remove key and value from trie. logic delete can't release memory, rebuild if necessary when lake of memory.

RemoveListener removes the listener of the registry

ReplaceAllTools replaces the entire tools set with the provided slice (full sync)

SendMethodNotFound sends a method not found error response

SendServerNotification sends a server notification to the client via SSE stream

SetDebounceTime dynamically adjusts debounce time

SetInvocation set invocation

SetRegistry will store the registry by name

SetRoute set route

SetSvcListener set the listener to the registry

SetValueRegex compile the regex, disable regex if it failed

SingletonDubboClient singleton dubbo clent

StoreMCPDataInParams stores MCP data in HttpContext.Params for passing through the filter chain

Subscribe message with specified broker and Topic, then handle msg with handler which send msg to real consumers

Subscribe subscribe the service event from remote registry center

Subscribe monitors the target registry.

SupportsSSE checks if the Accept header includes text/event-stream

ToRoute route ID is cluster name, so equal with endpoint name and routerMatch prefix is also service name

Unsubscribe unsubscribe from remote registry center

Unsubscribe stops monitoring the target registry.

Validate performs basic semantic checks on the configuration.

VariableName extract VariableName (:id, name = id)

Write write log into out put path

Writer writer msg into chan

applyMergedConfig applies merged configuration to the registry

buildFactory creates a FilterFactory for testing with default configuration

buildFactoryWithHS256 creates a FilterFactory with HS256 JWKS for testing

==================== Configuration Key Helper Functions ==================== buildSystemConfigKey constructs system configuration key name Format: sys

calculateCurrentMergedTools calculates merged tools from all current servers

cleanup closes the filter chain and other resources. It's designed to be called once.

cleanupExpiredSessions removes expired sessions

断开连接

createDefaultHttpWorker create http listener

createDynamicResourceManger create dynamic resource manager or nil if not config

createExploreServerVersionConfig creates the explore server version configuration

Test data generation functions createMcpServerVersionConfig creates a basic MCP server version configuration JSON

escapeParam performs minimal escaping suitable for WWW-Authenticate param values

generateSessionID generates a unique session ID

getCluster returns the cluster configuration by its name.

getDecompressedReader returns an io.ReadCloser that decompresses the body based on the encoding.

getNacosConfigClient initializes and returns a Nacos config client.