MCPcopy Create free account

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

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

↓ 7 callersFunctionvalidateTarget
validateTarget verify if the incoming target for the Map function can be processed as expected.
pkg/client/dubbo/mapper.go:188
↓ 6 callersMethodAddActiveCount
(num int32)
pkg/listener/listener.go:75
↓ 6 callersMethodConfig
()
pkg/server/controls/controls.go:48
↓ 6 callersMethodContext
()
pkg/model/stream.go:26
↓ 6 callersFunctionCreateRouterCoordinator
CreateRouterCoordinator create coordinator for http connection manager
pkg/common/router/router.go:53
↓ 6 callersFunctionGetAPIPattern
GetAPIPattern generate the API path pattern. /application/interface/version
pkg/adapter/dubboregistry/registry/registry.go:154
↓ 6 callersMethodGetAttachment
GetAttachment get attachment by key
pkg/context/grpc/context.go:63
↓ 6 callersMethodGetChildrenW
GetChildrenW gets children watch by @path
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:242
↓ 6 callersMethodGetEndpoint
(mustHealth bool)
pkg/model/cluster.go:110
↓ 6 callersFunctionGetOrInitSessionManager
GetOrInitSessionManager returns the global session manager singleton
pkg/filter/mcp/mcpserver/globals.go:63
↓ 6 callersMethodGetShutdownConfig
GetShutdownConfig
pkg/model/bootstrap.go:58
↓ 6 callersMethodGetTimeout
GetTimeoutOfShutdown
pkg/model/bootstrap.go:116
↓ 6 callersMethodHandler
(c *model.ClusterConfig, policy model.LbPolicy)
pkg/cluster/loadbalancer/load_balancer.go:25
↓ 6 callersFunctionIsConditionPresentAndEqual
(conditions []metav1.Condition, condition metav1.Condition)
controllers/internal/controller/utils.go:74
↓ 6 callersMethodMapParams
MapParams mapping param, uri, query, body ...
pkg/client/client.go:32
↓ 6 callersFunctionNewMCPContext
NewMCPContext creates a new MCP context
pkg/filter/mcp/mcpserver/context.go:54
↓ 6 callersMethodOnEncode
OnEncode encode interface sent to getty server
pkg/common/extension/filter/filter.go:97
↓ 6 callersFunctionParseDubboString
ParseDubboString parse the dubbo urls dubbo://192.168.3.46:20002/org.apache.dubbo.UserProvider2?anyhost=true&app.version=0.0.1&application=UserInfoSer
pkg/adapter/dubboregistry/registry/registry.go:137
↓ 6 callersMethodPut
Put put client to pool.
pkg/pool/pool.go:80
↓ 6 callersMethodRegister
Register register to remote registry center
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:59
↓ 6 callersMethodRegister
Register register
admin/dao/daos.go:27
↓ 6 callersFunctionRegisterAdapterPlugin
RegisterAdapterPlugin registers adapter plugin
pkg/common/extension/adapter/adapter.go:60
↓ 6 callersMethodRemove
(host string)
pkg/model/lb.go:49
↓ 6 callersMethodRemoveListener
(names []string)
pkg/server/controls/controls.go:36
↓ 6 callersMethodSendMsg
(m any)
pkg/model/stream.go:27
↓ 6 callersFunctionSetListenerServiceFactory
SetListenerServiceFactory will store the listenerService factory by name
pkg/listener/listener.go:59
↓ 6 callersMethodSetResult
SetResult set result to context
pkg/context/grpc/context.go:58
↓ 6 callersFunctionassertRouteSame
helper: assert Route behavior of old/new is the same on a set of requests
pkg/common/router/router_bench_test.go:168
↓ 6 callersFunctionbuildDelta
(base []*model.Router, seed int64)
pkg/common/router/router_bench_test.go:121
↓ 6 callersFunctioncontainsMediaType
containsMediaType checks if the Accept header contains the specified media type
pkg/filter/mcp/mcpserver/context.go:198
↓ 6 callersFunctiongenRequests
(n int)
pkg/common/router/router_bench_test.go:145
↓ 6 callersMethodget
(key string)
pkg/client/dubbo/dubbo.go:277
↓ 6 callersFunctiongetDefaultPath
()
pkg/filter/http/apiconfig/api/discovery_service.go:203
↓ 6 callersFunctiongetOrDefault
getOrDefault returns the target value if it is not empty; otherwise, it returns the fallback value.
pkg/configcenter/nacos_load.go:122
↓ 6 callersFunctiongetResourceKey
(path string, unpublished bool)
admin/logic/logic.go:513
↓ 6 callersFunctioni
(a)
admin/web/src/utils/three.js:261
↓ 6 callersFunctionl
(a)
admin/web/src/utils/three.js:319
↓ 6 callersFunctionn
(a)
admin/web/src/utils/three.js:401
↓ 6 callersFunctionnewDevConfigToFile
(t *testing.T)
pkg/logger/logger_test.go:33
↓ 6 callersFunctionnewTestRouter
(id, method, path, cluster string)
pkg/common/router/router_test.go:743
↓ 6 callersFunctionp
(a)
admin/web/src/utils/three.js:319
↓ 6 callersFunctionresolveStr2Time
(currentV string, defaultV time.Duration)
pkg/listener/http/http_listener.go:189
↓ 6 callersMethodsendJSONResponse
sendJSONResponse sends a JSON response
pkg/filter/mcp/mcpserver/filter.go:195
↓ 6 callersFunctiontf
(i)
admin/web/src/utils/utils.js:37
↓ 6 callersFunctionwildcardMatch
(wildcardPath string, checkPath string)
pkg/router/route.go:272
↓ 5 callersMethodAPI
(router.API)
pkg/context/base_context.go:50
↓ 5 callersMethodAction
Action for paramTypesOpt override the other param types mapping/config. The val must be string(e.g. "int, object"), and will then assign to the target
pkg/client/dubbo/option.go:188
↓ 5 callersMethodCloneXdsControlStore
()
pkg/server/controls/controls.go:30
↓ 5 callersMethodConfig
Config get config for Adapter
pkg/common/extension/adapter/adapter.go:51
↓ 5 callersFunctionCreateAPIConfig
CreateAPIConfig returns router.API struct base on the input
pkg/adapter/dubboregistry/registry/registry.go:96
↓ 5 callersMethodDeleteEndpoint
(clusterName string, endpointID string)
pkg/server/cluster_manager.go:336
↓ 5 callersMethodExecute
Execute orchestrates the request lifecycle using dynamic policies from endpoints.
pkg/filter/llm/proxy/filter.go:258
↓ 5 callersMethodGetAPI
(string, string)
pkg/filter/http/apiconfig/api/discovery_service.go:39
↓ 5 callersMethodGetConfig
()
pkg/remote/zookeeper/client.go:84
↓ 5 callersMethodGetListener
GetListener returns existing listener or nil
pkg/adapter/llmregistry/registry/base/baseregistry.go:43
↓ 5 callersMethodGetMatchPattern
()
pkg/config/xds/model/health_check.pb.go:765
↓ 5 callersFunctionGetRetryPolicy
GetRetryPolicy dynamically creates a RetryPolicy based on endpoint metadata.
pkg/cluster/retry/retry.go:57
↓ 5 callersMethodIncreaseVersion
()
pkg/server/cluster_manager.go:369
↓ 5 callersFunctionIsWildCardBackendPath
IsWildCardBackendPath checks whether the configured path of the upstream restful service contains parameters
pkg/router/api.go:44
↓ 5 callersMethodListMcpServer
==================== Public API ==================== ListMcpServer lists all MCP servers from Nacos MCP registry
pkg/adapter/mcpserver/registry/nacos/client.go:190
↓ 5 callersMethodLocalReply
()
pkg/context/http/context.go:204
↓ 5 callersMethodMap
nolint
pkg/client/http/mapper.go:67
↓ 5 callersMethodMap
nolint
pkg/client/http/mapper.go:87
↓ 5 callersMethodMap
nolint
pkg/client/dubbo/mapper.go:82
↓ 5 callersMethodMatch
Match
pkg/model/match.go:54
↓ 5 callersFunctionNewDubboClient
NewDubboClient create dubbo client
pkg/client/dubbo/dubbo.go:122
↓ 5 callersFunctionNewNacosConfig
NewNacosConfig creates a new NacosConfig instance. It returns an error if no Nacos server is configured or if the client cannot be created.
pkg/configcenter/nacos_load.go:69
↓ 5 callersFunctionNewValidator
NewValidator creates a new JWT validator instance
pkg/filter/auth/mcp/internal/validator/validator.go:170
↓ 5 callersMethodOnAddAPI
(r router.API)
pkg/adapter/dubboregistry/common/common.go:26
↓ 5 callersFunctionParseConfig
ParseConfig get config struct from map[string]interface{}
pkg/common/yaml/yaml.go:64
↓ 5 callersMethodRange
(f func(key string, value string) bool)
pkg/wasm/utils.go:67
↓ 5 callersMethodRecvMsg
(m any)
pkg/model/stream.go:28
↓ 5 callersFunctionRegisterLoadBalancer
(name model.LbPolicyType, balancer LoadBalancer)
pkg/cluster/loadbalancer/load_balancer.go:31
↓ 5 callersFunctionReplaceGoTemplateArgsInPath
ReplaceGoTemplateArgsInPath converts Go template args {{.args.name}} to standard format {name}
pkg/adapter/mcpserver/common/util/url.go:180
↓ 5 callersMethodSendInvalidParams
SendInvalidParams sends an invalid parameters error response
pkg/filter/mcp/mcpserver/response.go:128
↓ 5 callersMethodSendSSEMessage
SendSSEMessage sends a message through the SSE pipe
pkg/filter/mcp/mcpserver/transport/sse_handler.go:43
↓ 5 callersMethodSessionID
SessionID gets MCP session ID
pkg/filter/mcp/mcpserver/context.go:129
↓ 5 callersFunctionSplit
Split url split to []string by "/"
pkg/common/util/stringutil/stringutil.go:35
↓ 5 callersMethodStart
Start start adapter lifetime
pkg/common/extension/adapter/adapter.go:45
↓ 5 callersFunctionStateToString
StateToString will transfer zk state to string
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:99
↓ 5 callersMethodStatusCode
()
pkg/context/base_context.go:36
↓ 5 callersMethodString
()
pkg/config/xds/model/route.pb.go:172
↓ 5 callersMethodToEndpoint
ToEndpoint
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:77
↓ 5 callersFunctionUnmarshalYMLConfig
UnmarshalYMLConfig Load yml config byte from file, then unmarshal to object
pkg/common/yaml/yaml.go:45
↓ 5 callersFunctioncolonSyntax
()
pkg/common/router/router_test.go:459
↓ 5 callersFunctioncreateMcpServerConfig
createMcpServerConfig creates MCP server configuration JSON
pkg/adapter/mcpserver/registry/nacos/client_test.go:96
↓ 5 callersFunctioncreateMcpToolsConfig
createMcpToolsConfig creates MCP tools configuration JSON
pkg/adapter/mcpserver/registry/nacos/client_test.go:101
↓ 5 callersMethoddiscoverAndSubscribe
()
pkg/adapter/llmregistry/registry/nacos/listener.go:106
↓ 5 callersFunctionfile_bootstrap_proto_rawDescGZIP
()
pkg/config/xds/model/bootstrap.pb.go:409
↓ 5 callersFunctionfile_cluster_proto_rawDescGZIP
()
pkg/config/xds/model/cluster.pb.go:474
↓ 5 callersFunctionfile_hello_grpc_proto_rawDescGZIP
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:333
↓ 5 callersFunctiongenerateEndpoint
(instance nacosModel.Instance)
pkg/adapter/llmregistry/registry/nacos/listener.go:261
↓ 5 callersMethodgetConn
getConn gets zookeeper connection safely
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:204
↓ 5 callersFunctiongetFullPath
(groupPath string, resourcePath string)
pkg/filter/http/apiconfig/api/discovery_service.go:272
↓ 5 callersFunctiongetGenericMapTo
getGenericMapTo will parse the mapTo field, if the mapTo value is opt.xxx, the "opt." prefix will identify the param mapTo generic field, supporting g
pkg/client/dubbo/mapper.go:271
↓ 5 callersFunctiongetMethodKey
(path string, method string, unpublished bool)
admin/logic/logic.go:554
↓ 5 callersFunctiongetUnpublishedRootPath
(key string)
admin/logic/logic.go:624
↓ 5 callersFunctionnewCountBasedRetry
(config map[string]any)
pkg/cluster/retry/countbased/count_based.go:56
↓ 5 callersFunctionnewExponentialBackoffRetry
(config map[string]any)
pkg/cluster/retry/exponentialbackoff/exponential_backoff.go:84
↓ 5 callersMethodparseAcceptHeader
parseAcceptHeader parses the Accept header and returns support for JSON and SSE
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:71
← previousnext →201–300 of 3,410, ranked by callers