MCPcopy Create free account

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

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

↓ 1 callersMethodgetOrCreateConnection
getOrCreateConnection retrieves an existing connection or creates a new one for a given address.
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:343
↓ 1 callersFunctiongetPluginGroupKey
(name string, unpublished bool)
admin/logic/logic.go:532
↓ 1 callersFunctiongetPluginRatelimitKey
(unpublished bool)
admin/logic/logic.go:528
↓ 1 callersMethodgetPushGatewayURL
()
pkg/prometheus/prometheus.go:368
↓ 1 callersFunctiongetRegexpWithCache
map[string]*regexp.Regexp
pkg/model/router_snapshot.go:70
↓ 1 callersFunctiongetResourceId
create method, No need to judge whether to publish or not
admin/logic/logic.go:559
↓ 1 callersFunctiongetRootCmd
()
cmd/pixiu/pixiu.go:44
↓ 1 callersFunctiongetRootCmd
()
cmd/admin/admin.go:85
↓ 1 callersFunctiongetServiceAndMethod
getServiceAndMethod first return value is package.service, second one is method name
pkg/filter/http/grpcproxy/grpc.go:162
↓ 1 callersFunctiongetSubscribeName
(url *dubboCommon.URL)
pkg/adapter/dubboregistry/registry/nacos/interface_listener.go:193
↓ 1 callersMethodgetUrls
getUrls return exported urls from instance
pkg/adapter/dubboregistry/registry/zookeeper/application_service_listener.go:192
↓ 1 callersMethodgetWasmInstance
()
pkg/wasm/service.go:99
↓ 1 callersMethodgracefulShutdownInit
()
pkg/server/listener_manager.go:88
↓ 1 callersMethodgracefulStopServer
gracefulStopServer attempts to gracefully stop the gRPC server with timeout
pkg/listener/grpc/grpc_listener.go:265
↓ 1 callersFunctionhandleDeleteEvent
(key, val []byte)
pkg/config/api_config.go:439
↓ 1 callersMethodhandleDeltaResponse
(resp *discoverypb.DeltaDiscoveryResponse, xState *xdsState, output chan<- *DeltaResources)
pkg/config/xds/apiclient/grpc.go:207
↓ 1 callersMethodhandleDeltaResponse
(resp *discoverypb.DiscoveryResponse, xdsState *xdsState, handler discoveryResponseHandler)
pkg/config/xds/apiclient/grpc_envoy.go:340
↓ 1 callersMethodhandleGrpcInvocation
handleGrpcInvocation handle gRPC request through filter chain
pkg/filter/network/grpcproxy/grpc_manager.go:144
↓ 1 callersMethodhandleHTTPRequest
handleHTTPRequest handle http request
pkg/common/http/manager.go:106
↓ 1 callersMethodhandleHealth
()
pkg/cluster/healthcheck/healthcheck.go:289
↓ 1 callersMethodhandleInitialize
handleInitialize handles the initialize method
pkg/filter/mcp/mcpserver/handlers.go:53
↓ 1 callersMethodhandlePing
handlePing handles the ping method
pkg/filter/mcp/mcpserver/handlers.go:223
↓ 1 callersMethodhandlePostRequest
handlePostRequest handles HTTP POST requests with JSON-RPC messages
pkg/filter/mcp/mcpserver/filter.go:266
↓ 1 callersMethodhandlePromptsGet
handlePromptsGet handles the prompts/get method
pkg/filter/mcp/mcpserver/handlers.go:326
↓ 1 callersMethodhandlePromptsList
handlePromptsList handles the prompts/list method
pkg/filter/mcp/mcpserver/handlers.go:306
↓ 1 callersFunctionhandlePutEvent
(key, val []byte)
pkg/config/api_config.go:487
↓ 1 callersMethodhandleResourceRead
handleResourceRead handles the resources/read method
pkg/filter/mcp/mcpserver/handlers.go:244
↓ 1 callersMethodhandleResourceTemplatesList
handleResourceTemplatesList handles the resources/templates/list method
pkg/filter/mcp/mcpserver/handlers.go:288
↓ 1 callersMethodhandleResourcesList
handleResourcesList handles the resources/list method
pkg/filter/mcp/mcpserver/handlers.go:204
↓ 1 callersFunctionhandleServiceName
group@@serviceName convert to serviceName
pkg/adapter/dubboregistry/registry/nacos/application_service_listener.go:208
↓ 1 callersMethodhandleStream
handleStream handles all types of gRPC calls by creating a full-duplex stream pipe.
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:162
↓ 1 callersMethodhandleTerminalMethodWithNegotiation
handleTerminalMethodWithNegotiation handles terminal methods with response format negotiation
pkg/filter/mcp/mcpserver/filter.go:311
↓ 1 callersMethodhandleToolCall
handleToolCall handles tool call requests by forwarding to backend
pkg/filter/mcp/mcpserver/handlers.go:404
↓ 1 callersMethodhandleToolCallResponse
handleToolCallResponse handles tool call responses, wrapping backend responses in MCP format
pkg/filter/mcp/mcpserver/handlers.go:528
↓ 1 callersMethodhandleToolCallWithNegotiation
handleToolCallWithNegotiation handles tool calls with response format negotiation
pkg/filter/mcp/mcpserver/filter.go:347
↓ 1 callersMethodhandleToolsList
handleToolsList handles the tools/list method using mcp-go APIs
pkg/filter/mcp/mcpserver/handlers.go:124
↓ 1 callersFunctionhashString
(input string)
controllers/internal/controller/gateway_controller.go:867
↓ 1 callersFunctionheaderFromReq
(r *stdHttp.Request)
pkg/common/router/router_test.go:618
↓ 1 callersMethodhotReload
hotReload checks for configuration changes and triggers hot reload for registered reloaders.
pkg/hotreload/hotreload.go:80
↓ 1 callersMethodhttpListener
()
pkg/listener/http/http_listener.go:138
↓ 1 callersMethodhttpsListener
()
pkg/listener/http/http_listener.go:109
↓ 1 callersFunctionhumpToUnderline
(s string)
pkg/common/util/response.go:156
↓ 1 callersFunctioninMethod
(methods []string, method string)
pkg/filter/csrf/csrf.go:121
↓ 1 callersMethodinit
()
pkg/config/xds/apiclient/grpc.go:265
↓ 1 callersMethodinit
()
pkg/config/xds/apiclient/grpc_envoy.go:102
↓ 1 callersFunctioninitAPIConfigFromKVList
(kList, vList []string)
pkg/config/api_config.go:258
↓ 1 callersFunctioninitAPIConfigMethodFromKvList
(config *APIConfig, kList, vList []string)
pkg/config/api_config.go:323
↓ 1 callersFunctioninitAPIConfigServiceFromKvList
(config *APIConfig, kList, vList []string)
pkg/config/api_config.go:364
↓ 1 callersMethodinitAdapters
()
pkg/server/adapter_manager.go:54
↓ 1 callersFunctioninitApiConfig
initApiConfig return value of the bool is for the judgment of whether is a api meta data error, a kind of silly (?)
pkg/filter/http/apiconfig/api_config.go:136
↓ 1 callersFunctioninitDefaultValue
initDefaultValue If not set both in args and env, set default values
pkg/cmd/gateway.go:133
↓ 1 callersFunctioninitDefaultValue
()
cmd/admin/admin.go:89
↓ 1 callersMethodinitDescriptorSource
(cfg *Config)
pkg/filter/http/grpcproxy/descriptor.go:98
↓ 1 callersFunctioninitLimitCpus
()
pkg/cmd/gateway.go:187
↓ 1 callersFunctioninitLog
initLog initializes logger according to log config file and log level
pkg/cmd/gateway.go:160
↓ 1 callersFunctioninitLogWithConfig
(boot *model.Bootstrap)
pkg/cmd/gateway.go:174
↓ 1 callersFunctioninitOTelInstruments
initOTelInstruments initializes OpenTelemetry instruments (singleton).
pkg/filter/metric/metric.go:101
↓ 1 callersFunctioninitRegex
(cfg *model.RouteConfiguration)
pkg/common/router/router.go:182
↓ 1 callersMethodinitRegex
()
pkg/common/router/mock/router.go:123
↓ 1 callersFunctioninitServer
(address string, router *gin.Engine)
admin/core/server_init.go:29
↓ 1 callersFunctioninitSignal
()
tools/benchmark/protocol/grpc/go-server/cmd/server.go:127
↓ 1 callersFunctioninitSignal
()
tools/benchmark/protocol/triple/pb/go-server/cmd/server.go:58
↓ 1 callersFunctioninitSignal
()
tools/benchmark/protocol/dubbo/go-server/cmd/server.go:59
↓ 1 callersMethodinitTrie
()
pkg/common/router/mock/router.go:114
↓ 1 callersFunctioninitUsers
(s *server)
tools/benchmark/protocol/grpc/go-server/cmd/server.go:90
↓ 1 callersMethodinterfaceSubscribe
To subscribe service level service discovery
pkg/adapter/dubboregistry/registry/zookeeper/registry.go:103
↓ 1 callersFunctioninvokeUnary
(ctx context.Context, stub grpcdynamic.Stub, mthDesc *desc.MethodDescriptor, grpcReq proto.Message, opts ...gr
pkg/filter/http/grpcproxy/invoke.go:52
↓ 1 callersFunctionisIPAddress
(s string)
controllers/internal/controller/gateway_controller.go:1110
↓ 1 callersFunctionisIPAddress
isIPAddress checks if a string is an IP address
controllers/internal/converter/policy_applier.go:722
↓ 1 callersMethodisMCPRequest
isMCPRequest checks if it's an MCP request
pkg/filter/mcp/mcpserver/filter.go:190
↓ 1 callersFunctionisMcpServerShouldBeDiscoveryForGateway
==================== Utility Functions ==================== isMcpServerShouldBeDiscoveryForGateway checks if MCP server should be discovered by gatewa
pkg/adapter/mcpserver/registry/nacos/client.go:865
↓ 1 callersFunctionisNacosRunning
isNacosRunning checks whether the Nacos server is running. It returns true if Nacos is running, otherwise false.
pkg/configcenter/nacos_load_test.go:41
↓ 1 callersFunctionisNumeric
(s string)
controllers/internal/controller/gateway_controller.go:1154
↓ 1 callersFunctionisRouteKindAllowed
(route client.Object, kinds []gatewayv1.RouteGroupKind)
controllers/internal/controller/utils.go:345
↓ 1 callersFunctionisRouteNamespaceAllowed
(ctx context.Context, route client.Object, mgrc client.Client, gatewayNamespace string, parentRefNamespace *ga
controllers/internal/controller/utils.go:356
↓ 1 callersFunctionisServerTimeout
(st *status.Status)
pkg/filter/http/grpcproxy/grpc.go:409
↓ 1 callersFunctionisSystemConfigKey
isSystemConfigKey determines if it is a system configuration key
pkg/adapter/mcpserver/registry/nacos/client.go:853
↓ 1 callersMethodisTerminalMethod
isTerminalMethod checks if it's a terminal method (methods that don't need forwarding to backend)
pkg/filter/mcp/mcpserver/filter.go:159
↓ 1 callersFunctionjavaClassNameElem
(values []hessian.Object)
pkg/client/dubbo/dubbo.go:58
↓ 1 callersFunctionjsonToProtoMsg
(reader io.Reader, msg proto.Message)
pkg/filter/http/grpcproxy/grpc.go:391
↓ 1 callersMethodlistMcpServerConfigs
==================== Internal Helper Methods ==================== listMcpServerConfigs paginates to get all MCP server configurations
pkg/adapter/mcpserver/registry/nacos/client.go:405
↓ 1 callersFunctionlistenResourceAndMethodEvent
(key string)
pkg/config/api_config.go:397
↓ 1 callersFunctionlistenerHostnameIntersectWithRouteHostnames
(listener gatewayv1.Listener, hostnames []gatewayv1.Hostname)
controllers/internal/controller/utils.go:432
↓ 1 callersFunctionloadFileSource
(gc *Config)
pkg/filter/http/grpcproxy/descriptor.go:153
↓ 1 callersMethodloadLocalBootConfigs
(path string)
pkg/config/config_load.go:222
↓ 1 callersMethodloadRemoteBootConfigs
()
pkg/config/config_load.go:227
↓ 1 callersFunctionloadRules
(rules []*circuitbreaker.Rule)
pkg/filter/sentinel/circuitbreaker/circuit_breaker.go:154
↓ 1 callersFunctionloadTLSCredentials
loadTLSCredentials loads TLS credentials from certificate and key files
pkg/listener/grpc/grpc_listener.go:371
↓ 1 callersMethodlogConfiguration
logConfiguration logs the current gRPC server configuration
pkg/listener/grpc/grpc_listener.go:185
↓ 1 callersMethodlogUsage
logUsage prints usage details to the log.
pkg/filter/llm/tokenizer/tokenizer.go:337
↓ 1 callersMethodmakeAddress
(addr *xdsmodel.Address)
pkg/config/xds/lds.go:209
↓ 1 callersMethodmakeAddress
(endpoint *xdsmodel.Endpoint)
pkg/config/xds/cds.go:173
↓ 1 callersMethodmakeApiConfigSource
(apiConfig *xdsmodel.ApiConfigSource)
pkg/config/xds/cds.go:231
↓ 1 callersMethodmakeClusterType
(cluster *xdsmodel.Cluster)
pkg/config/xds/cds.go:156
↓ 1 callersFunctionmakeClusters
()
admin/core/xds.go:245
↓ 1 callersMethodmakeEdsClusterConfig
(edsConfig *xdsmodel.EdsClusterConfig)
pkg/config/xds/cds.go:218
↓ 1 callersMethodmakeEndpoints
(endpoints []*xdsmodel.Endpoint)
pkg/config/xds/cds.go:160
↓ 1 callersMethodmakeFilterChain
(fChain *xdsmodel.FilterChain)
pkg/config/xds/lds.go:173
↓ 1 callersMethodmakeFilters
(filters []*xdsmodel.NetworkFilter)
pkg/config/xds/lds.go:179
↓ 1 callersFunctionmakeHTTPFilter
makeHTTPFilter returns a handler for the given resource.
admin/core/xds.go:172
← previousnext →1,301–1,400 of 3,410, ranked by callers