ParseMapSource parses the source parameter config in the mappingParams the source parameter in config could be queryStrings.*, headers.*, requestBody.

Start the listener service

Kind returns the unique kind name to represent itself.

OnDecode decode bytes received from getty server

ResetGlobalState resets all global singletons (for testing)

newTestHTTPContext creates a mock HttpContext for testing

GetAPI returns the method to the caller

NewTrie

WithError transform err to RetData

CreateNetworkFilterChain create network filter chain

EXPECT returns an object that allows the caller to indicate expected use.

GetChildren gets children by @path

PickEndpoint picks an endpoint from the cluster by its name and load balancing policy.

Success creates a successful JSON-RPC response

@Tags Config @Summary determine the configuration type of the current operation @Description internal function, no external documentation required get

pre-allocate proper memory according to the params' usability.

Apply validates the configuration.

Close closes this listener

GetOrInitDynamicConsumer returns the global dynamic consumer singleton

GetURIParams returns the values retrieved from the rawURL

NewToolRegistry creates a new tool registry

PrepareFilterChain create filter and append it to FilterChain Be Careful !!! Do not pass the Factory's config pointer to the Filter instance, Factory

PrepareFilterChain prepares the filter chain for a new request by dynamically creating a Filter

ResetDebounceState resets debounce state (mainly for testing)

SendInternalError sends an internal server error response

Apply to init client

Close the listener service forcefully

Decode is the core logic of the filter. It converts HTTP request data into a standard OPA input format and evaluates the policy.

FindAPI return if api has path in trie,or nil

GetMapValue return the value from map base on the path

GetOrInitRegistry returns the global tool registry singleton

NewContentNegotiator creates a new content negotiator

NewLocalMemoryAPIDiscoveryService creates a new LocalMemoryApiDiscoveryService instance

PrepareFilterChain prepares the filter chain.

WatchAndHandle watch the target path and handle the event

newTestHTTPContext creates a test HTTP context

AllExtensionsForType returns all known extension fields that extend the given message type name.

DeepCopy returns a new independent copy of Config Deep copy slices/maps to avoid sharing pointers with the factory

FindSymbol returns a descriptor for the given fully-qualified symbol name.

GetBootstrap get config global, need a better name

GetDebounceInfo returns debounce state information (for debugging/monitoring)

Handle gRPC invocation

RegisterRetryPolicy makes a retry policy implementation available by name. This function is called from init() functions in files that define a policy

Subscribe monitors the target registry.

Unsubscribe stops monitoring the target registry.

WithRet transform data to RetData

calculateFingerprint calculates a robust fingerprint for the configuration using SHA256

Note: TestValidateMCPProtocolVersion removed - version negotiation now happens during initialize request/response per MCP spec, not at HTTP header lev

sendResponseWithFormat sends response in the negotiated format