MCPcopy Create free account

hub / github.com/apache/dubbo-go-pixiu / functions

Functions3,410 in github.com/apache/dubbo-go-pixiu

⨍ Functions 3,410◇ Types & classes 888
↓ 3 callersMethodGetAllListener
()
pkg/adapter/llmregistry/registry/base/baseregistry.go:67
↓ 3 callersMethodGetCds
()
pkg/server/controls/controls.go:43
↓ 3 callersMethodGetClient
GetClient a factory method to get a client according to apiType .
pkg/pool/pool.go:72
↓ 3 callersMethodGetClusterManager
()
pkg/server/pixiu_start.go:60
↓ 3 callersMethodGetConfig
()
pkg/config/xds/model/filter.pb.go:94
↓ 3 callersMethodGetConnection
()
pkg/config/xds/apiclient/grpc.go:345
↓ 3 callersMethodGetContent
GetContent gets content by @path
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:268
↓ 3 callersMethodGetFactory
GetFactory get all filter from manager
pkg/common/extension/filter/filter_manager.go:67
↓ 3 callersMethodGetLds
()
pkg/server/controls/controls.go:42
↓ 3 callersMethodGetMethod
()
pkg/context/base_context.go:42
↓ 3 callersMethodGetNode
()
pkg/server/controls/controls.go:44
↓ 3 callersMethodGetSvcListener
GetSvcListener returns existing listener or nil
pkg/adapter/llmregistry/registry/base/baseregistry.go:90
↓ 3 callersMethodGetUniqKey
()
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:72
↓ 3 callersMethodGetUserByName
(ctx context.Context, in *GetUserByNameRequest, opts ...grpc.CallOption)
tools/benchmark/protocol/grpc/proto/hello_grpc_grpc.pb.go:47
↓ 3 callersFunctionHotReload
HotReload rebuilds from a new zap.Config (e.g., re-read YAML).
pkg/logger/logger.go:157
↓ 3 callersMethodMap
nolint
pkg/client/dubbo/mapper.go:131
↓ 3 callersMethodMatch
Match match resource via url path
pkg/filter/sentinel/matcher.go:50
↓ 3 callersMethodNamespacedName
()
controllers/internal/types/namespacednamekind.go:35
↓ 3 callersFunctionNewDefaultConfig
()
controllers/internal/controller/config/config.go:78
↓ 3 callersFunctionNewJWT
New jwt instance
admin/controller/auth/auth.go:94
↓ 3 callersFunctionNewMockClusterManager
NewMockClusterManager creates a new mock instance.
pkg/server/controls/mocks/mocks.go:45
↓ 3 callersFunctionNewMockClusterStore
NewMockClusterStore creates a new mock instance.
pkg/server/controls/mocks/mocks.go:247
↓ 3 callersFunctionNewResponseBuilder
NewResponseBuilder returns the singleton ResponseBuilder instance
pkg/filter/mcp/mcpserver/response.go:46
↓ 3 callersMethodParseAndSetSessionHeader
ParseAndSetSessionHeader parses Mcp-Session-Id header and sets session ID
pkg/filter/mcp/mcpserver/context.go:186
↓ 3 callersMethodPopulate
Populate Magelev hashing look up table.
pkg/cluster/loadbalancer/maglev/permutation.go:91
↓ 3 callersMethodProvider
Provider returns the provider configuration by name
pkg/filter/auth/mcp/internal/validator/validator.go:329
↓ 3 callersMethodRemoveSession
RemoveSession removes a session and cleans up resources
pkg/filter/mcp/mcpserver/transport/session_manager.go:111
↓ 3 callersMethodReset
Reset reset http context
pkg/context/http/context.go:90
↓ 3 callersFunctionResolveTimeStr2Time
(currentV string, defaultV time.Duration)
pkg/common/util/stringutil/stringutil.go:125
↓ 3 callersMethodUpdateCluster
(cluster *model.ClusterConfig)
pkg/server/controls/controls.go:28
↓ 3 callersFunctionValidateNacosAddresses
ValidateNacosAddresses validates comma-separated Nacos addresses
pkg/adapter/mcpserver/common/util/url.go:188
↓ 3 callersMethodWarnf
(fmt string, args ...any)
pkg/logger/triple.go:49
↓ 3 callersFunctionWithLookUpTable
(tableSize, nodeCount int, function func(*LookUpTable))
pkg/cluster/loadbalancer/maglev/permutation_test.go:31
↓ 3 callersMethodWriteHeader
(statusCode int)
pkg/common/http/manager_test.go:276
↓ 3 callersMethodZkClient
()
pkg/remote/zookeeper/client.go:78
↓ 3 callersFunction_createHiddenIframe
(target, uri)
admin/web/public/static/js/protocolcheck.js:79
↓ 3 callersFunctionaddAPIFromMethod
(fullPath string, method config.Method, headers map[string]string, localSrv APIDiscoveryService)
pkg/filter/http/apiconfig/api/discovery_service.go:244
↓ 3 callersFunctionaddAPIFromResource
(resource config.Resource, localSrv APIDiscoveryService, groupPath string, parentPath string, fullHeaders map[
pkg/filter/http/apiconfig/api/discovery_service.go:224
↓ 3 callersFunctionappendParam
(target *bytes.Buffer, url *dubboCommon.URL, key string)
pkg/adapter/dubboregistry/registry/nacos/interface_listener.go:202
↓ 3 callersMethodcancelListenToConfig
cancelListenToConfig cancels configuration listening
pkg/adapter/mcpserver/registry/nacos/client.go:590
↓ 3 callersFunctioncheckConsistency
(t *testing.T, table *LookUpTable)
pkg/cluster/loadbalancer/maglev/permutation_test.go:264
↓ 3 callersMethodcheckGatewayClass
(obj client.Object)
controllers/internal/controller/gateway_controller.go:233
↓ 3 callersFunctioncheckMissingEndpoint
(t *testing.T, table *LookUpTable)
pkg/cluster/loadbalancer/maglev/permutation_test.go:250
↓ 3 callersFunctioncheckUnPopulateSlot
(t *testing.T, table *LookUpTable)
pkg/cluster/loadbalancer/maglev/permutation_test.go:239
↓ 3 callersMethodcreateApiManager
(config *model.ApiConfigSource, node *model.Node, resourceType apiclient.ResourceTypeName)
pkg/config/xds/xds.go:56
↓ 3 callersFunctioncreateCredentialConfig
createCredentialConfig creates credential configuration JSON
pkg/adapter/mcpserver/registry/nacos/client_test.go:106
↓ 3 callersFunctioncreateEndpoint
(id int)
pkg/cluster/loadbalancer/maglev/permutation_test.go:48
↓ 3 callersFunctioncreateTableWithNodes
(tableSize, nodeCount int)
pkg/cluster/loadbalancer/maglev/permutation_test.go:39
↓ 3 callersFunctioncreateTestContext
(req *http.Request, recorder *httptest.ResponseRecorder)
pkg/filter/mcp/mcpserver/filter_sse_test.go:375
↓ 3 callersFunctionextractDecision
extractDecision extracts the allow decision from OPA result Supports multiple formats: 1. Boolean: true/false 2. Object with "allow" field: {allow: tr
pkg/filter/opa/opa.go:326
↓ 3 callersFunctionfile_cluster_proto_init
()
pkg/config/xds/model/cluster.pb.go:508
↓ 3 callersFunctionfile_listener_proto_init
()
pkg/config/xds/model/listener.pb.go:233
↓ 3 callersFunctiongenerateURL
(instance nacosModel.Instance)
pkg/adapter/dubboregistry/registry/nacos/service_listener.go:180
↓ 3 callersFunctiongetCheckResourceRegexp
()
pkg/config/api_config.go:598
↓ 3 callersFunctiongetExtractMethodRegexp
()
pkg/config/api_config.go:602
↓ 3 callersFunctiongetInternetExplorerVersion
()
admin/web/public/static/js/protocolcheck.js:234
↓ 3 callersFunctiongetNacosClient
()
pkg/configcenter/load_test.go:57
↓ 3 callersFunctiongetNextFallbackEndpoint
getNextFallbackEndpoint checks if fallback is enabled and returns the next endpoint.
pkg/filter/llm/proxy/filter.go:373
↓ 3 callersMethodgetNode
(fullPath string)
pkg/router/route.go:238
↓ 3 callersFunctiongetResourceMethodPrefixKey
(path string, unpublished bool)
admin/logic/logic.go:550
↓ 3 callersMethodgetURLs
(nmis nacosModel.Instance)
pkg/adapter/dubboregistry/registry/nacos/application_service_listener.go:174
↓ 3 callersFunctiongetWasmServiceByName
GetWasmServiceByName get WasmService By Name
pkg/wasm/manager.go:61
↓ 3 callersMethodhandle
(endpoint *model.Endpoint, action remoting.EventType)
pkg/adapter/llmregistry/registry/nacos/listener.go:222
↓ 3 callersMethodhandle
(url *dubboCommon.URL, action remoting.EventType)
pkg/adapter/dubboregistry/registry/nacos/application_service_listener.go:138
↓ 3 callersMethodhandle
(url *dubboCommon.URL, action remoting.EventType)
pkg/adapter/dubboregistry/registry/nacos/service_listener.go:133
↓ 3 callersMethodhandleEvent
(children []string)
pkg/adapter/springcloud/servicediscovery/zookeeper/application_listener.go:126
↓ 3 callersMethodhandleEvent
(children []string)
pkg/adapter/springcloud/servicediscovery/zookeeper/service_listener.go:111
↓ 3 callersMethodhandleEvent
(children []string)
pkg/adapter/dubboregistry/registry/zookeeper/application_listener.go:134
↓ 3 callersMethodhandleEvent
(children []string)
pkg/adapter/dubboregistry/registry/zookeeper/application_service_listener.go:132
↓ 3 callersMethodhandleEvent
(basePath string)
pkg/adapter/dubboregistry/registry/zookeeper/interface_listener.go:134
↓ 3 callersMethodhandleEvent
whenever it is called, the children node changed and refresh the api configuration.
pkg/adapter/dubboregistry/registry/zookeeper/service_listener.go:127
↓ 3 callersFunctionjoinLabels
joinLabels creates a consistent key from label keys
pkg/prometheus/prometheus.go:593
↓ 3 callersFunctionloopGetId
(k string)
admin/logic/logic.go:571
↓ 3 callersMethodmakeNode
()
pkg/config/xds/apiclient/grpc.go:134
↓ 3 callersMethodmatch
(path string)
pkg/filter/sentinel/matcher.go:25
↓ 3 callersFunctionmatchesController
(controllerName string)
controllers/internal/controller/gatewayclass_controller.go:148
↓ 3 callersFunctionnewNoRetryPolicy
(config map[string]any)
pkg/cluster/retry/noretry/no_retry.go:45
↓ 3 callersFunctionnewZKRegistry
(regConfig model.Registry, adapterListener common.RegistryEventListener)
pkg/adapter/dubboregistry/registry/zookeeper/registry.go:64
↓ 3 callersMethodonChange
onChange is the callback function triggered when the configuration changes in Nacos.
pkg/configcenter/nacos_load.go:139
↓ 3 callersMethodparseAndReportTokens
parseAndReportTokens parses a JSON data chunk and reports token usage metrics.
pkg/filter/llm/tokenizer/tokenizer.go:298
↓ 3 callersFunctionparseDurationWithDefault
parseDurationWithDefault parses a string duration and returns a default if empty or invalid.
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:330
↓ 3 callersMethodpopulate
()
pkg/cluster/loadbalancer/maglev/permutation.go:99
↓ 3 callersMethodput
(key string, isReal bool, bizInfo any)
pkg/common/router/trie/trie.go:286
↓ 3 callersMethodresolve
Resolve is the function calls resolver.Resolve.
pkg/filter/http/remote/call.go:190
↓ 3 callersFunctionsetCommonTarget
(target *dubboTarget, pos int, value any, targetType string)
pkg/client/dubbo/mapper.go:223
↓ 3 callersMethodstart
()
pkg/cmd/deployer.go:23
↓ 3 callersFunctiontestSetup
()
pkg/adapter/llmregistry/registry/nacos/listener_test.go:115
↓ 3 callersMethodtriggerMcpServerChange
triggerMcpServerChange triggers MCP server change notification
pkg/adapter/mcpserver/registry/nacos/client.go:493
↓ 3 callersMethodunauthorized
unauthorized writes 401 with WWW-Authenticate including resource metadata URL
pkg/filter/auth/mcp/filter.go:186
↓ 3 callersFunctionz
()
admin/web/src/utils/three.js:38
↓ 2 callersMethodAddAPI
(router.API)
pkg/filter/http/apiconfig/api/discovery_service.go:36
↓ 2 callersMethodAddAPI
AddAPI adds a method to the router tree
pkg/filter/http/apiconfig/api/discovery_service.go:59
↓ 2 callersMethodAddCluster
(c *model.ClusterConfig)
pkg/server/cluster_manager.go:257
↓ 2 callersMethodAddEndpoint
(endpoint *model.Endpoint)
pkg/cluster/cluster.go:55
↓ 2 callersMethodAddHeader
AddHeader add header
pkg/context/http/context.go:115
↓ 2 callersMethodAddRouterListener
(l RouterListener)
pkg/server/router_manager.go:45
↓ 2 callersMethodAllHeaders
AllHeaders get all headers
pkg/context/http/context.go:125
↓ 2 callersMethodAppendString
mock zapcore.PrimitiveArrayEncoder
pkg/logger/logger_test.go:180
↓ 2 callersMethodApply
Apply After the config is injected, check it or make it to default
pkg/common/extension/filter/filter.go:53
↓ 2 callersMethodApply
Apply initializes the validator and prebuilds resource metadata body
pkg/filter/auth/mcp/filter.go:78
← previousnext →401–500 of 3,410, ranked by callers