MCPcopy Create free account

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

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

↓ 2 callersMethodApplyOpts
(opts ...Option)
pkg/client/mq/facade.go:45
↓ 2 callersFunctionBRCreate
(key, value, configType string)
admin/logic/logic.go:500
↓ 2 callersFunctionBRGetPluginGroupList
BRGetPluginGroupList GetPluginGroupList
admin/logic/logic.go:315
↓ 2 callersFunctionBRGetResourceList
BRGetResourceList GetResourceList
admin/logic/logic.go:300
↓ 2 callersFunctionBRUpdate
BRUpdate
admin/logic/logic.go:496
↓ 2 callersFunctionBizGetClusters
BizGetClusters get clusters
admin/logic/logic.go:321
↓ 2 callersFunctionBizGetListeners
BizGetListeners get Listeners
admin/logic/logic.go:411
↓ 2 callersFunctionBizGetMethodDetail
BizGetMethodDetail get method detail
admin/logic/logic.go:219
↓ 2 callersFunctionBizGetMethodList
BizGetMethodList get method list
admin/logic/logic.go:196
↓ 2 callersFunctionBizGetResourceDetail
BizGetResourceDetail get resource detail
admin/logic/logic.go:132
↓ 2 callersMethodBuildAPI
(req *http.Request, mappingParams []config.MappingParam)
pkg/filter/http/remote/resolver/resolver.go:64
↓ 2 callersMethodClear
()
pkg/common/router/trie/trie.go:61
↓ 2 callersMethodClearContentLengthHeader
ClearContentLengthHeader removes the Content-Length header to prevent conflicts with chunked transfer encoding.
pkg/filter/mcp/mcpserver/context.go:117
↓ 2 callersMethodClone
()
pkg/wasm/utils.go:74
↓ 2 callersMethodCloneStore
()
pkg/server/cluster_manager.go:121
↓ 2 callersMethodCloneXdsControlListener
()
pkg/server/controls/controls.go:38
↓ 2 callersMethodConnect
Connect opens a connection to target.
pkg/client/proxy/proxy.go:52
↓ 2 callersFunctionCreateDefaultAdapterManager
(server *Server, bs *model.Bootstrap)
pkg/server/adapter_manager.go:36
↓ 2 callersFunctionCreateDefaultClusterManager
(bs *model.Bootstrap)
pkg/server/cluster_manager.go:75
↓ 2 callersMethodCreateFilterChain
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_manager.go:57
↓ 2 callersFunctionCreateListenerService
CreateListenerService create listener service
pkg/listener/listener.go:64
↓ 2 callersFunctionD
(a,b)
admin/web/src/utils/three.js:423
↓ 2 callersMethodDecode
Decode handles the decode phase - records start time for both modes.
pkg/filter/metric/metric.go:194
↓ 2 callersMethodDeepCopy
DeepCopy returns a new independent copy of Config Deep copy slices/maps to avoid sharing pointers with the factory
pkg/filter/csrf/csrf.go:144
↓ 2 callersMethodDeepCopy
DeepCopy returns a new independent copy of Config Deep copy slices/maps to avoid sharing pointers with the factory
pkg/filter/authority/config.go:79
↓ 2 callersFunctionDefaultOptions
()
pkg/client/mq/facade.go:51
↓ 2 callersMethodDel
(key string)
pkg/wasm/utils.go:63
↓ 2 callersMethodDeleteRouter
(r *model.Router)
pkg/server/router_manager.go:56
↓ 2 callersMethodDestroy
()
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:295
↓ 2 callersMethodDoSubscribe
DoSubscribe subscribes the registry cluster to monitor the changes.
pkg/adapter/dubboregistry/registry/base/baseregistry.go:31
↓ 2 callersMethodDoUnsubscribe
DoUnsubscribe unsubscribes the registry cluster.
pkg/adapter/dubboregistry/registry/base/baseregistry.go:33
↓ 2 callersFunctionExtractPathFromURL
ExtractPathFromURL extracts the path component from a URL string. Supports MCP template parameter conversion: {{.args.name}} -> {name}
pkg/adapter/mcpserver/common/util/url.go:137
↓ 2 callersMethodFetch
(localVersion string)
pkg/config/xds/xds.go:38
↓ 2 callersMethodFormatSSEKeepalive
FormatSSEKeepalive formats a SSE keepalive comment
pkg/filter/mcp/mcpserver/transport/sse_handler.go:91
↓ 2 callersFunctionFullTypeName
(a any)
controllers/internal/controller/utils.go:450
↓ 2 callersFunctionGb
(a)
admin/web/src/utils/three.js:447
↓ 2 callersMethodGenerateHash
()
pkg/model/lb.go:40
↓ 2 callersFunctionGenerateSnapshotPixiu
GenerateSnapshotPixiu returns a snapshot with a single cluster and endpoint.
admin/core/xds.go:278
↓ 2 callersFunctionGetAdapterPlugin
GetAdapterPlugin get plugin by kind
pkg/common/extension/adapter/adapter.go:74
↓ 2 callersMethodGetAllSvcListener
GetAllSvcListener get all the listener of the registry
pkg/adapter/llmregistry/registry/base/baseregistry.go:95
↓ 2 callersMethodGetClientIP
()
pkg/context/base_context.go:48
↓ 2 callersFunctionGetConnection
()
admin/dao/database/initDB.go:57
↓ 2 callersMethodGetHost
()
pkg/model/cluster.go:128
↓ 2 callersFunctionGetIPAndPort
(address string)
pkg/common/util/stringutil/stringutil.go:109
↓ 2 callersMethodGetListenerManager
()
pkg/server/pixiu_start.go:64
↓ 2 callersMethodGetMetadata
()
pkg/config/xds/model/cluster.pb.go:393
↓ 2 callersMethodGetPath
GetPath get etcd config root path
admin/config/config.go:65
↓ 2 callersMethodGetPayload
()
pkg/config/xds/model/health_check.pb.go:1162
↓ 2 callersMethodGetPprof
GetPprof
pkg/model/bootstrap.go:70
↓ 2 callersMethodGetReceivedBuf
()
pkg/common/http/manager_test.go:288
↓ 2 callersMethodGetServiceName
()
pkg/config/xds/model/cluster.pb.go:217
↓ 2 callersMethodGetServiceNames
()
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:47
↓ 2 callersMethodGetSvcListener
GetSvcListener returns existing listener or nil
pkg/adapter/dubboregistry/registry/base/baseregistry.go:92
↓ 2 callersFunctionGetTrieKeyWithPrefix
(method, path, prefix string, isPrefix bool)
pkg/common/util/stringutil/stringutil.go:98
↓ 2 callersMethodGetUserId
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:273
↓ 2 callersMethodHandleFailure
(timeout bool)
pkg/cluster/healthcheck/healthcheck.go:273
↓ 2 callersFunctionHb
(a)
admin/web/src/utils/three.js:445
↓ 2 callersFunctionHostnamesMatch
HostnamesMatch checks that the hostnameB matches the hostnameA. HostnameA is treated as mask to be checked against the hostnameB.
controllers/internal/controller/utils.go:540
↓ 2 callersMethodHotReload
HotReload performs the hot reload of the configuration.
pkg/hotreload/hotreload.go:38
↓ 2 callersFunctionInit
(clusterMg controls.ClusterManager)
pkg/config/xds/apiclient/grpc.go:73
↓ 2 callersMethodIsAlive
()
pkg/config/xds/apiclient/grpc.go:377
↓ 2 callersMethodIsClientStreaming
IsClientStreaming check if it's client streaming
pkg/context/grpc/context.go:110
↓ 2 callersMethodIsServerStreaming
IsServerStreaming check if it's server streaming
pkg/context/grpc/context.go:115
↓ 2 callersMethodListServices
ListServices returns a list of fully-qualified service names. It will be all services in a set of descriptor files or the set of all services exposed
pkg/filter/http/grpcproxy/descriptor_source.go:44
↓ 2 callersMethodListenToConfig
ListenToConfig listens to configuration changes
pkg/adapter/mcpserver/registry/nacos/client.go:520
↓ 2 callersMethodListenToMcpServer
ListenToMcpServer listens to MCP server configuration and backend services
pkg/adapter/mcpserver/registry/nacos/client.go:238
↓ 2 callersFunctionLoad
Load config file and parse
pkg/config/config_load.go:62
↓ 2 callersFunctionLoadYMLConfig
LoadYMLConfig Load yml config byte from file
pkg/common/yaml/yaml.go:33
↓ 2 callersMethodMap
Map implements how the request parameters map to the target parameters described by config.MappingParam
pkg/client/mapper.go:38
↓ 2 callersMethodMap
nolint
pkg/client/http/mapper.go:131
↓ 2 callersMethodMap
nolint
pkg/client/dubbo/mapper.go:110
↓ 2 callersMethodMap
nolint
pkg/client/dubbo/mapper.go:168
↓ 2 callersFunctionMapInStruct
(cfg any)
pkg/model/http.go:89
↓ 2 callersMethodMatchAPI
(string, string)
pkg/filter/http/apiconfig/api/discovery_service.go:40
↓ 2 callersMethodMcpRequestID
McpRequestID gets JSON-RPC request ID
pkg/filter/mcp/mcpserver/context.go:82
↓ 2 callersFunctionMergeCondition
(conditions []metav1.Condition, newCondition metav1.Condition)
controllers/internal/controller/utils.go:520
↓ 2 callersMethodNegotiateResponse
NegotiateResponse determines the appropriate response format based on Accept header and session state
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:46
↓ 2 callersFunctionNewDefaultGatewayConfig
NewDefaultGatewayConfig returns default gateway configuration
controllers/internal/controller/config/config.go:91
↓ 2 callersFunctionNewEmptyFilterManager
NewEmptyFilterManager create empty filter manager
pkg/common/extension/filter/filter_manager.go:53
↓ 2 callersFunctionNewErrorHandler
NewErrorHandler returns the singleton ErrorHandler instance
pkg/filter/mcp/mcpserver/response.go:106
↓ 2 callersFunctionNewLeaderElection
()
controllers/internal/controller/config/config.go:116
↓ 2 callersFunctionNewLookUpTable
(tableSize int, hosts []string)
pkg/cluster/loadbalancer/maglev/permutation.go:60
↓ 2 callersFunctionNewRoute
NewRoute returns an empty router tree
pkg/router/route.go:292
↓ 2 callersFunctionNewRouterMatchPrefix
(name string)
pkg/model/router.go:75
↓ 2 callersFunctionNewSingletonMQClient
(config Config)
pkg/client/mq/mq.go:44
↓ 2 callersFunctionNewTestServerWithURL
(URL string, handler http.Handler)
pkg/common/http/manager_test.go:299
↓ 2 callersFunctionNewTripleClient
NewTripleClient create dubbo client
pkg/client/triple/triple.go:51
↓ 2 callersFunctionNewZkClient
(zkName string, config *model.RemoteConfig)
pkg/remote/zookeeper/client.go:54
↓ 2 callersFunctionO
(a,b)
admin/web/src/utils/three.js:425
↓ 2 callersMethodOnAddServiceInstance
(r *ServiceInstance)
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:44
↓ 2 callersMethodOnData
OnData dubbo rpc invocation from getty server
pkg/common/extension/filter/filter.go:99
↓ 2 callersMethodOnDeleteRouter
(r config.Resource)
pkg/adapter/dubboregistry/common/common.go:28
↓ 2 callersMethodOnDeleteServiceInstance
(r *ServiceInstance)
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:45
↓ 2 callersMethodOnRemoveAPI
(r router.API)
pkg/adapter/dubboregistry/common/common.go:27
↓ 2 callersMethodOnStreamRPC
OnStreamRPC handles a streaming RPC call. In gRPC, a Unary call is fundamentally a special, short-lived case of a stream. By consolidating all handlin
pkg/common/extension/filter/filter.go:108
↓ 2 callersMethodOnTripleData
OnTripleData triple rpc invocation from triple-server
pkg/common/extension/filter/filter.go:101
↓ 2 callersMethodOnUpdateServiceInstance
(r *ServiceInstance)
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:46
↓ 2 callersMethodParseAndSetProtocolVersionHeader
ParseAndSetProtocolVersionHeader parses MCP-Protocol-Version header
pkg/filter/mcp/mcpserver/context.go:192
↓ 2 callersFunctionParseLogLevel
ParseLogLevel parses textual level to zapcore.Level.
pkg/logger/logger.go:168
↓ 2 callersFunctionPathExists
(path string)
admin/utils/directory.go:32
← previousnext →501–600 of 3,410, ranked by callers