handleRpcInvocation handle rpc request

traverse all the keys in the map and change the hump to underline

Put node put

isContainer returns true if the process is running in a container.

isCredentialConfigKey determines if it is a credential configuration key

loadClusterPolicyByName is a shared implementation for loading cluster policies by service/cluster name

maintainSSEPipe maintains the SSE pipe connection with keepalive

makeHS256JWT creates a signed JWT token for testing

mergeFilterConfig merges config into an existing filter

newNacosListener creates a new Nacos service listener.

normalizeAddress normalizes the address by ensuring it has the correct port. If the port field is empty, it will check if the address already has a po

normalizeConfigKeys normalizes snake_case keys to camelCase for consistent processing

normalizeHTTPFilterNames rewrites legacy filter names to the actual plugin kind names

parseConfigKey parses configuration key name Returns: keyType, id, group, dataId

publish: clone from store -> build new config -> atomic switch

readServiceNameOfCluster get service name of k8s

copied from https://github.com/containerd/cgroups/blob/318312a373405e5e91134d8063d04d59768a1bff/utils.go#L243

reconcile coordinates logic: discover services, compute diffs, bind watchers

refreshServiceListenerIfNeeded refreshes service listener as needed

resetNacosTemplateConfigs resets template configurations and their referenced credential configurations

runDelta start 2 goroutine to and watch change

reset timer or publish directly

sendMessageToSSEPipe sends a message to the SSE pipe

setLoggerLevel changes the level at runtime without rebuilding the logger.

setupFilterWithoutFile is a helper function for testing. It simulates the core logic of PrepareFilterChain by creating an OPA Rego instance and prepar

waitForPortAvailable waits until the port is available (not in use)

waitForPortAvailable waits until the port is available (not in use)

withTempPromRegistry swaps the global Prometheus registerer/gatherer with a fresh registry for test isolation.

AcceptSSE gets if client accepts text/event-stream

ActiveSessionCount returns the number of active sessions

AddReqNum add request total num

AllSessionIDs returns all active session IDs

Apply return a new filter factory by name & conf

Apply prepares the MCP server and tool registry.

BizBatchCreateResourceMethod batch create method below one resource

BizCreateCluster create cluster

BizCreateListener create Listener

BizDeleteCluster delete cluster

BizDeleteListener delete Listener

BizDeleteMethodInfo delete method

BizDeleteResourceInfo delete resource

BizGetBaseInfo get base info

BizGetCluster get cluster

BizGetListener get Listener

BizGetResourceList get resource list

BizSetBaseInfo create or modify base info

BizUpdateCluster create cluster

BizUpdateListener create Listener

BuildController builds a provider controller based on registry protocol.

Call performs the gRPC call after doing reflection to obtain type information.

CheckUpdate checks if the configuration has changed and needs to be reloaded.