Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/dubbo-go-pixiu
/ functions
Functions
3,410 in github.com/apache/dubbo-go-pixiu
⨍
Functions
3,410
◇
Types & classes
888
↓ 7 callers
Function
validateTarget
validateTarget verify if the incoming target for the Map function can be processed as expected.
pkg/client/dubbo/mapper.go:188
↓ 6 callers
Method
AddActiveCount
(num int32)
pkg/listener/listener.go:75
↓ 6 callers
Method
Config
()
pkg/server/controls/controls.go:48
↓ 6 callers
Method
Context
()
pkg/model/stream.go:26
↓ 6 callers
Function
CreateRouterCoordinator
CreateRouterCoordinator create coordinator for http connection manager
pkg/common/router/router.go:53
↓ 6 callers
Function
GetAPIPattern
GetAPIPattern generate the API path pattern. /application/interface/version
pkg/adapter/dubboregistry/registry/registry.go:154
↓ 6 callers
Method
GetAttachment
GetAttachment get attachment by key
pkg/context/grpc/context.go:63
↓ 6 callers
Method
GetChildrenW
GetChildrenW gets children watch by @path
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:242
↓ 6 callers
Method
GetEndpoint
(mustHealth bool)
pkg/model/cluster.go:110
↓ 6 callers
Function
GetOrInitSessionManager
GetOrInitSessionManager returns the global session manager singleton
pkg/filter/mcp/mcpserver/globals.go:63
↓ 6 callers
Method
GetShutdownConfig
GetShutdownConfig
pkg/model/bootstrap.go:58
↓ 6 callers
Method
GetTimeout
GetTimeoutOfShutdown
pkg/model/bootstrap.go:116
↓ 6 callers
Method
Handler
(c *model.ClusterConfig, policy model.LbPolicy)
pkg/cluster/loadbalancer/load_balancer.go:25
↓ 6 callers
Function
IsConditionPresentAndEqual
(conditions []metav1.Condition, condition metav1.Condition)
controllers/internal/controller/utils.go:74
↓ 6 callers
Method
MapParams
MapParams mapping param, uri, query, body ...
pkg/client/client.go:32
↓ 6 callers
Function
NewMCPContext
NewMCPContext creates a new MCP context
pkg/filter/mcp/mcpserver/context.go:54
↓ 6 callers
Method
OnEncode
OnEncode encode interface sent to getty server
pkg/common/extension/filter/filter.go:97
↓ 6 callers
Function
ParseDubboString
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 callers
Method
Put
Put put client to pool.
pkg/pool/pool.go:80
↓ 6 callers
Method
Register
Register register to remote registry center
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:59
↓ 6 callers
Method
Register
Register register
admin/dao/daos.go:27
↓ 6 callers
Function
RegisterAdapterPlugin
RegisterAdapterPlugin registers adapter plugin
pkg/common/extension/adapter/adapter.go:60
↓ 6 callers
Method
Remove
(host string)
pkg/model/lb.go:49
↓ 6 callers
Method
RemoveListener
(names []string)
pkg/server/controls/controls.go:36
↓ 6 callers
Method
SendMsg
(m any)
pkg/model/stream.go:27
↓ 6 callers
Function
SetListenerServiceFactory
SetListenerServiceFactory will store the listenerService factory by name
pkg/listener/listener.go:59
↓ 6 callers
Method
SetResult
SetResult set result to context
pkg/context/grpc/context.go:58
↓ 6 callers
Function
assertRouteSame
helper: assert Route behavior of old/new is the same on a set of requests
pkg/common/router/router_bench_test.go:168
↓ 6 callers
Function
buildDelta
(base []*model.Router, seed int64)
pkg/common/router/router_bench_test.go:121
↓ 6 callers
Function
containsMediaType
containsMediaType checks if the Accept header contains the specified media type
pkg/filter/mcp/mcpserver/context.go:198
↓ 6 callers
Function
genRequests
(n int)
pkg/common/router/router_bench_test.go:145
↓ 6 callers
Method
get
(key string)
pkg/client/dubbo/dubbo.go:277
↓ 6 callers
Function
getDefaultPath
()
pkg/filter/http/apiconfig/api/discovery_service.go:203
↓ 6 callers
Function
getOrDefault
getOrDefault returns the target value if it is not empty; otherwise, it returns the fallback value.
pkg/configcenter/nacos_load.go:122
↓ 6 callers
Function
getResourceKey
(path string, unpublished bool)
admin/logic/logic.go:513
↓ 6 callers
Function
i
(a)
admin/web/src/utils/three.js:261
↓ 6 callers
Function
l
(a)
admin/web/src/utils/three.js:319
↓ 6 callers
Function
n
(a)
admin/web/src/utils/three.js:401
↓ 6 callers
Function
newDevConfigToFile
(t *testing.T)
pkg/logger/logger_test.go:33
↓ 6 callers
Function
newTestRouter
(id, method, path, cluster string)
pkg/common/router/router_test.go:743
↓ 6 callers
Function
p
(a)
admin/web/src/utils/three.js:319
↓ 6 callers
Function
resolveStr2Time
(currentV string, defaultV time.Duration)
pkg/listener/http/http_listener.go:189
↓ 6 callers
Method
sendJSONResponse
sendJSONResponse sends a JSON response
pkg/filter/mcp/mcpserver/filter.go:195
↓ 6 callers
Function
tf
(i)
admin/web/src/utils/utils.js:37
↓ 6 callers
Function
wildcardMatch
(wildcardPath string, checkPath string)
pkg/router/route.go:272
↓ 5 callers
Method
API
(router.API)
pkg/context/base_context.go:50
↓ 5 callers
Method
Action
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 callers
Method
CloneXdsControlStore
()
pkg/server/controls/controls.go:30
↓ 5 callers
Method
Config
Config get config for Adapter
pkg/common/extension/adapter/adapter.go:51
↓ 5 callers
Function
CreateAPIConfig
CreateAPIConfig returns router.API struct base on the input
pkg/adapter/dubboregistry/registry/registry.go:96
↓ 5 callers
Method
DeleteEndpoint
(clusterName string, endpointID string)
pkg/server/cluster_manager.go:336
↓ 5 callers
Method
Execute
Execute orchestrates the request lifecycle using dynamic policies from endpoints.
pkg/filter/llm/proxy/filter.go:258
↓ 5 callers
Method
GetAPI
(string, string)
pkg/filter/http/apiconfig/api/discovery_service.go:39
↓ 5 callers
Method
GetConfig
()
pkg/remote/zookeeper/client.go:84
↓ 5 callers
Method
GetListener
GetListener returns existing listener or nil
pkg/adapter/llmregistry/registry/base/baseregistry.go:43
↓ 5 callers
Method
GetMatchPattern
()
pkg/config/xds/model/health_check.pb.go:765
↓ 5 callers
Function
GetRetryPolicy
GetRetryPolicy dynamically creates a RetryPolicy based on endpoint metadata.
pkg/cluster/retry/retry.go:57
↓ 5 callers
Method
IncreaseVersion
()
pkg/server/cluster_manager.go:369
↓ 5 callers
Function
IsWildCardBackendPath
IsWildCardBackendPath checks whether the configured path of the upstream restful service contains parameters
pkg/router/api.go:44
↓ 5 callers
Method
ListMcpServer
==================== Public API ==================== ListMcpServer lists all MCP servers from Nacos MCP registry
pkg/adapter/mcpserver/registry/nacos/client.go:190
↓ 5 callers
Method
LocalReply
()
pkg/context/http/context.go:204
↓ 5 callers
Method
Map
nolint
pkg/client/http/mapper.go:67
↓ 5 callers
Method
Map
nolint
pkg/client/http/mapper.go:87
↓ 5 callers
Method
Map
nolint
pkg/client/dubbo/mapper.go:82
↓ 5 callers
Method
Match
Match
pkg/model/match.go:54
↓ 5 callers
Function
NewDubboClient
NewDubboClient create dubbo client
pkg/client/dubbo/dubbo.go:122
↓ 5 callers
Function
NewNacosConfig
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 callers
Function
NewValidator
NewValidator creates a new JWT validator instance
pkg/filter/auth/mcp/internal/validator/validator.go:170
↓ 5 callers
Method
OnAddAPI
(r router.API)
pkg/adapter/dubboregistry/common/common.go:26
↓ 5 callers
Function
ParseConfig
ParseConfig get config struct from map[string]interface{}
pkg/common/yaml/yaml.go:64
↓ 5 callers
Method
Range
(f func(key string, value string) bool)
pkg/wasm/utils.go:67
↓ 5 callers
Method
RecvMsg
(m any)
pkg/model/stream.go:28
↓ 5 callers
Function
RegisterLoadBalancer
(name model.LbPolicyType, balancer LoadBalancer)
pkg/cluster/loadbalancer/load_balancer.go:31
↓ 5 callers
Function
ReplaceGoTemplateArgsInPath
ReplaceGoTemplateArgsInPath converts Go template args {{.args.name}} to standard format {name}
pkg/adapter/mcpserver/common/util/url.go:180
↓ 5 callers
Method
SendInvalidParams
SendInvalidParams sends an invalid parameters error response
pkg/filter/mcp/mcpserver/response.go:128
↓ 5 callers
Method
SendSSEMessage
SendSSEMessage sends a message through the SSE pipe
pkg/filter/mcp/mcpserver/transport/sse_handler.go:43
↓ 5 callers
Method
SessionID
SessionID gets MCP session ID
pkg/filter/mcp/mcpserver/context.go:129
↓ 5 callers
Function
Split
Split url split to []string by "/"
pkg/common/util/stringutil/stringutil.go:35
↓ 5 callers
Method
Start
Start start adapter lifetime
pkg/common/extension/adapter/adapter.go:45
↓ 5 callers
Function
StateToString
StateToString will transfer zk state to string
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:99
↓ 5 callers
Method
StatusCode
()
pkg/context/base_context.go:36
↓ 5 callers
Method
String
()
pkg/config/xds/model/route.pb.go:172
↓ 5 callers
Method
ToEndpoint
ToEndpoint
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:77
↓ 5 callers
Function
UnmarshalYMLConfig
UnmarshalYMLConfig Load yml config byte from file, then unmarshal to object
pkg/common/yaml/yaml.go:45
↓ 5 callers
Function
colonSyntax
()
pkg/common/router/router_test.go:459
↓ 5 callers
Function
createMcpServerConfig
createMcpServerConfig creates MCP server configuration JSON
pkg/adapter/mcpserver/registry/nacos/client_test.go:96
↓ 5 callers
Function
createMcpToolsConfig
createMcpToolsConfig creates MCP tools configuration JSON
pkg/adapter/mcpserver/registry/nacos/client_test.go:101
↓ 5 callers
Method
discoverAndSubscribe
()
pkg/adapter/llmregistry/registry/nacos/listener.go:106
↓ 5 callers
Function
file_bootstrap_proto_rawDescGZIP
()
pkg/config/xds/model/bootstrap.pb.go:409
↓ 5 callers
Function
file_cluster_proto_rawDescGZIP
()
pkg/config/xds/model/cluster.pb.go:474
↓ 5 callers
Function
file_hello_grpc_proto_rawDescGZIP
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:333
↓ 5 callers
Function
generateEndpoint
(instance nacosModel.Instance)
pkg/adapter/llmregistry/registry/nacos/listener.go:261
↓ 5 callers
Method
getConn
getConn gets zookeeper connection safely
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:204
↓ 5 callers
Function
getFullPath
(groupPath string, resourcePath string)
pkg/filter/http/apiconfig/api/discovery_service.go:272
↓ 5 callers
Function
getGenericMapTo
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 callers
Function
getMethodKey
(path string, method string, unpublished bool)
admin/logic/logic.go:554
↓ 5 callers
Function
getUnpublishedRootPath
(key string)
admin/logic/logic.go:624
↓ 5 callers
Function
newCountBasedRetry
(config map[string]any)
pkg/cluster/retry/countbased/count_based.go:56
↓ 5 callers
Function
newExponentialBackoffRetry
(config map[string]any)
pkg/cluster/retry/exponentialbackoff/exponential_backoff.go:84
↓ 5 callers
Method
parseAcceptHeader
parseAcceptHeader parses the Accept header and returns support for JSON and SSE
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:71
← previous
next →
201–300 of 3,410, ranked by callers