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
↓ 1 callers
Method
getOrCreateConnection
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 callers
Function
getPluginGroupKey
(name string, unpublished bool)
admin/logic/logic.go:532
↓ 1 callers
Function
getPluginRatelimitKey
(unpublished bool)
admin/logic/logic.go:528
↓ 1 callers
Method
getPushGatewayURL
()
pkg/prometheus/prometheus.go:368
↓ 1 callers
Function
getRegexpWithCache
map[string]*regexp.Regexp
pkg/model/router_snapshot.go:70
↓ 1 callers
Function
getResourceId
create method, No need to judge whether to publish or not
admin/logic/logic.go:559
↓ 1 callers
Function
getRootCmd
()
cmd/pixiu/pixiu.go:44
↓ 1 callers
Function
getRootCmd
()
cmd/admin/admin.go:85
↓ 1 callers
Function
getServiceAndMethod
getServiceAndMethod first return value is package.service, second one is method name
pkg/filter/http/grpcproxy/grpc.go:162
↓ 1 callers
Function
getSubscribeName
(url *dubboCommon.URL)
pkg/adapter/dubboregistry/registry/nacos/interface_listener.go:193
↓ 1 callers
Method
getUrls
getUrls return exported urls from instance
pkg/adapter/dubboregistry/registry/zookeeper/application_service_listener.go:192
↓ 1 callers
Method
getWasmInstance
()
pkg/wasm/service.go:99
↓ 1 callers
Method
gracefulShutdownInit
()
pkg/server/listener_manager.go:88
↓ 1 callers
Method
gracefulStopServer
gracefulStopServer attempts to gracefully stop the gRPC server with timeout
pkg/listener/grpc/grpc_listener.go:265
↓ 1 callers
Function
handleDeleteEvent
(key, val []byte)
pkg/config/api_config.go:439
↓ 1 callers
Method
handleDeltaResponse
(resp *discoverypb.DeltaDiscoveryResponse, xState *xdsState, output chan<- *DeltaResources)
pkg/config/xds/apiclient/grpc.go:207
↓ 1 callers
Method
handleDeltaResponse
(resp *discoverypb.DiscoveryResponse, xdsState *xdsState, handler discoveryResponseHandler)
pkg/config/xds/apiclient/grpc_envoy.go:340
↓ 1 callers
Method
handleGrpcInvocation
handleGrpcInvocation handle gRPC request through filter chain
pkg/filter/network/grpcproxy/grpc_manager.go:144
↓ 1 callers
Method
handleHTTPRequest
handleHTTPRequest handle http request
pkg/common/http/manager.go:106
↓ 1 callers
Method
handleHealth
()
pkg/cluster/healthcheck/healthcheck.go:289
↓ 1 callers
Method
handleInitialize
handleInitialize handles the initialize method
pkg/filter/mcp/mcpserver/handlers.go:53
↓ 1 callers
Method
handlePing
handlePing handles the ping method
pkg/filter/mcp/mcpserver/handlers.go:223
↓ 1 callers
Method
handlePostRequest
handlePostRequest handles HTTP POST requests with JSON-RPC messages
pkg/filter/mcp/mcpserver/filter.go:266
↓ 1 callers
Method
handlePromptsGet
handlePromptsGet handles the prompts/get method
pkg/filter/mcp/mcpserver/handlers.go:326
↓ 1 callers
Method
handlePromptsList
handlePromptsList handles the prompts/list method
pkg/filter/mcp/mcpserver/handlers.go:306
↓ 1 callers
Function
handlePutEvent
(key, val []byte)
pkg/config/api_config.go:487
↓ 1 callers
Method
handleResourceRead
handleResourceRead handles the resources/read method
pkg/filter/mcp/mcpserver/handlers.go:244
↓ 1 callers
Method
handleResourceTemplatesList
handleResourceTemplatesList handles the resources/templates/list method
pkg/filter/mcp/mcpserver/handlers.go:288
↓ 1 callers
Method
handleResourcesList
handleResourcesList handles the resources/list method
pkg/filter/mcp/mcpserver/handlers.go:204
↓ 1 callers
Function
handleServiceName
group@@serviceName convert to serviceName
pkg/adapter/dubboregistry/registry/nacos/application_service_listener.go:208
↓ 1 callers
Method
handleStream
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 callers
Method
handleTerminalMethodWithNegotiation
handleTerminalMethodWithNegotiation handles terminal methods with response format negotiation
pkg/filter/mcp/mcpserver/filter.go:311
↓ 1 callers
Method
handleToolCall
handleToolCall handles tool call requests by forwarding to backend
pkg/filter/mcp/mcpserver/handlers.go:404
↓ 1 callers
Method
handleToolCallResponse
handleToolCallResponse handles tool call responses, wrapping backend responses in MCP format
pkg/filter/mcp/mcpserver/handlers.go:528
↓ 1 callers
Method
handleToolCallWithNegotiation
handleToolCallWithNegotiation handles tool calls with response format negotiation
pkg/filter/mcp/mcpserver/filter.go:347
↓ 1 callers
Method
handleToolsList
handleToolsList handles the tools/list method using mcp-go APIs
pkg/filter/mcp/mcpserver/handlers.go:124
↓ 1 callers
Function
hashString
(input string)
controllers/internal/controller/gateway_controller.go:867
↓ 1 callers
Function
headerFromReq
(r *stdHttp.Request)
pkg/common/router/router_test.go:618
↓ 1 callers
Method
hotReload
hotReload checks for configuration changes and triggers hot reload for registered reloaders.
pkg/hotreload/hotreload.go:80
↓ 1 callers
Method
httpListener
()
pkg/listener/http/http_listener.go:138
↓ 1 callers
Method
httpsListener
()
pkg/listener/http/http_listener.go:109
↓ 1 callers
Function
humpToUnderline
(s string)
pkg/common/util/response.go:156
↓ 1 callers
Function
inMethod
(methods []string, method string)
pkg/filter/csrf/csrf.go:121
↓ 1 callers
Method
init
()
pkg/config/xds/apiclient/grpc.go:265
↓ 1 callers
Method
init
()
pkg/config/xds/apiclient/grpc_envoy.go:102
↓ 1 callers
Function
initAPIConfigFromKVList
(kList, vList []string)
pkg/config/api_config.go:258
↓ 1 callers
Function
initAPIConfigMethodFromKvList
(config *APIConfig, kList, vList []string)
pkg/config/api_config.go:323
↓ 1 callers
Function
initAPIConfigServiceFromKvList
(config *APIConfig, kList, vList []string)
pkg/config/api_config.go:364
↓ 1 callers
Method
initAdapters
()
pkg/server/adapter_manager.go:54
↓ 1 callers
Function
initApiConfig
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 callers
Function
initDefaultValue
initDefaultValue If not set both in args and env, set default values
pkg/cmd/gateway.go:133
↓ 1 callers
Function
initDefaultValue
()
cmd/admin/admin.go:89
↓ 1 callers
Method
initDescriptorSource
(cfg *Config)
pkg/filter/http/grpcproxy/descriptor.go:98
↓ 1 callers
Function
initLimitCpus
()
pkg/cmd/gateway.go:187
↓ 1 callers
Function
initLog
initLog initializes logger according to log config file and log level
pkg/cmd/gateway.go:160
↓ 1 callers
Function
initLogWithConfig
(boot *model.Bootstrap)
pkg/cmd/gateway.go:174
↓ 1 callers
Function
initOTelInstruments
initOTelInstruments initializes OpenTelemetry instruments (singleton).
pkg/filter/metric/metric.go:101
↓ 1 callers
Function
initRegex
(cfg *model.RouteConfiguration)
pkg/common/router/router.go:182
↓ 1 callers
Method
initRegex
()
pkg/common/router/mock/router.go:123
↓ 1 callers
Function
initServer
(address string, router *gin.Engine)
admin/core/server_init.go:29
↓ 1 callers
Function
initSignal
()
tools/benchmark/protocol/grpc/go-server/cmd/server.go:127
↓ 1 callers
Function
initSignal
()
tools/benchmark/protocol/triple/pb/go-server/cmd/server.go:58
↓ 1 callers
Function
initSignal
()
tools/benchmark/protocol/dubbo/go-server/cmd/server.go:59
↓ 1 callers
Method
initTrie
()
pkg/common/router/mock/router.go:114
↓ 1 callers
Function
initUsers
(s *server)
tools/benchmark/protocol/grpc/go-server/cmd/server.go:90
↓ 1 callers
Method
interfaceSubscribe
To subscribe service level service discovery
pkg/adapter/dubboregistry/registry/zookeeper/registry.go:103
↓ 1 callers
Function
invokeUnary
(ctx context.Context, stub grpcdynamic.Stub, mthDesc *desc.MethodDescriptor, grpcReq proto.Message, opts ...gr
pkg/filter/http/grpcproxy/invoke.go:52
↓ 1 callers
Function
isIPAddress
(s string)
controllers/internal/controller/gateway_controller.go:1110
↓ 1 callers
Function
isIPAddress
isIPAddress checks if a string is an IP address
controllers/internal/converter/policy_applier.go:722
↓ 1 callers
Method
isMCPRequest
isMCPRequest checks if it's an MCP request
pkg/filter/mcp/mcpserver/filter.go:190
↓ 1 callers
Function
isMcpServerShouldBeDiscoveryForGateway
==================== Utility Functions ==================== isMcpServerShouldBeDiscoveryForGateway checks if MCP server should be discovered by gatewa
pkg/adapter/mcpserver/registry/nacos/client.go:865
↓ 1 callers
Function
isNacosRunning
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 callers
Function
isNumeric
(s string)
controllers/internal/controller/gateway_controller.go:1154
↓ 1 callers
Function
isRouteKindAllowed
(route client.Object, kinds []gatewayv1.RouteGroupKind)
controllers/internal/controller/utils.go:345
↓ 1 callers
Function
isRouteNamespaceAllowed
(ctx context.Context, route client.Object, mgrc client.Client, gatewayNamespace string, parentRefNamespace *ga
controllers/internal/controller/utils.go:356
↓ 1 callers
Function
isServerTimeout
(st *status.Status)
pkg/filter/http/grpcproxy/grpc.go:409
↓ 1 callers
Function
isSystemConfigKey
isSystemConfigKey determines if it is a system configuration key
pkg/adapter/mcpserver/registry/nacos/client.go:853
↓ 1 callers
Method
isTerminalMethod
isTerminalMethod checks if it's a terminal method (methods that don't need forwarding to backend)
pkg/filter/mcp/mcpserver/filter.go:159
↓ 1 callers
Function
javaClassNameElem
(values []hessian.Object)
pkg/client/dubbo/dubbo.go:58
↓ 1 callers
Function
jsonToProtoMsg
(reader io.Reader, msg proto.Message)
pkg/filter/http/grpcproxy/grpc.go:391
↓ 1 callers
Method
listMcpServerConfigs
==================== Internal Helper Methods ==================== listMcpServerConfigs paginates to get all MCP server configurations
pkg/adapter/mcpserver/registry/nacos/client.go:405
↓ 1 callers
Function
listenResourceAndMethodEvent
(key string)
pkg/config/api_config.go:397
↓ 1 callers
Function
listenerHostnameIntersectWithRouteHostnames
(listener gatewayv1.Listener, hostnames []gatewayv1.Hostname)
controllers/internal/controller/utils.go:432
↓ 1 callers
Function
loadFileSource
(gc *Config)
pkg/filter/http/grpcproxy/descriptor.go:153
↓ 1 callers
Method
loadLocalBootConfigs
(path string)
pkg/config/config_load.go:222
↓ 1 callers
Method
loadRemoteBootConfigs
()
pkg/config/config_load.go:227
↓ 1 callers
Function
loadRules
(rules []*circuitbreaker.Rule)
pkg/filter/sentinel/circuitbreaker/circuit_breaker.go:154
↓ 1 callers
Function
loadTLSCredentials
loadTLSCredentials loads TLS credentials from certificate and key files
pkg/listener/grpc/grpc_listener.go:371
↓ 1 callers
Method
logConfiguration
logConfiguration logs the current gRPC server configuration
pkg/listener/grpc/grpc_listener.go:185
↓ 1 callers
Method
logUsage
logUsage prints usage details to the log.
pkg/filter/llm/tokenizer/tokenizer.go:337
↓ 1 callers
Method
makeAddress
(addr *xdsmodel.Address)
pkg/config/xds/lds.go:209
↓ 1 callers
Method
makeAddress
(endpoint *xdsmodel.Endpoint)
pkg/config/xds/cds.go:173
↓ 1 callers
Method
makeApiConfigSource
(apiConfig *xdsmodel.ApiConfigSource)
pkg/config/xds/cds.go:231
↓ 1 callers
Method
makeClusterType
(cluster *xdsmodel.Cluster)
pkg/config/xds/cds.go:156
↓ 1 callers
Function
makeClusters
()
admin/core/xds.go:245
↓ 1 callers
Method
makeEdsClusterConfig
(edsConfig *xdsmodel.EdsClusterConfig)
pkg/config/xds/cds.go:218
↓ 1 callers
Method
makeEndpoints
(endpoints []*xdsmodel.Endpoint)
pkg/config/xds/cds.go:160
↓ 1 callers
Method
makeFilterChain
(fChain *xdsmodel.FilterChain)
pkg/config/xds/lds.go:173
↓ 1 callers
Method
makeFilters
(filters []*xdsmodel.NetworkFilter)
pkg/config/xds/lds.go:179
↓ 1 callers
Function
makeHTTPFilter
makeHTTPFilter returns a handler for the given resource.
admin/core/xds.go:172
← previous
next →
1,301–1,400 of 3,410, ranked by callers