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
↓ 2 callers
Method
ApplyOpts
(opts ...Option)
pkg/client/mq/facade.go:45
↓ 2 callers
Function
BRCreate
(key, value, configType string)
admin/logic/logic.go:500
↓ 2 callers
Function
BRGetPluginGroupList
BRGetPluginGroupList GetPluginGroupList
admin/logic/logic.go:315
↓ 2 callers
Function
BRGetResourceList
BRGetResourceList GetResourceList
admin/logic/logic.go:300
↓ 2 callers
Function
BRUpdate
BRUpdate
admin/logic/logic.go:496
↓ 2 callers
Function
BizGetClusters
BizGetClusters get clusters
admin/logic/logic.go:321
↓ 2 callers
Function
BizGetListeners
BizGetListeners get Listeners
admin/logic/logic.go:411
↓ 2 callers
Function
BizGetMethodDetail
BizGetMethodDetail get method detail
admin/logic/logic.go:219
↓ 2 callers
Function
BizGetMethodList
BizGetMethodList get method list
admin/logic/logic.go:196
↓ 2 callers
Function
BizGetResourceDetail
BizGetResourceDetail get resource detail
admin/logic/logic.go:132
↓ 2 callers
Method
BuildAPI
(req *http.Request, mappingParams []config.MappingParam)
pkg/filter/http/remote/resolver/resolver.go:64
↓ 2 callers
Method
Clear
()
pkg/common/router/trie/trie.go:61
↓ 2 callers
Method
ClearContentLengthHeader
ClearContentLengthHeader removes the Content-Length header to prevent conflicts with chunked transfer encoding.
pkg/filter/mcp/mcpserver/context.go:117
↓ 2 callers
Method
Clone
()
pkg/wasm/utils.go:74
↓ 2 callers
Method
CloneStore
()
pkg/server/cluster_manager.go:121
↓ 2 callers
Method
CloneXdsControlListener
()
pkg/server/controls/controls.go:38
↓ 2 callers
Method
Connect
Connect opens a connection to target.
pkg/client/proxy/proxy.go:52
↓ 2 callers
Function
CreateDefaultAdapterManager
(server *Server, bs *model.Bootstrap)
pkg/server/adapter_manager.go:36
↓ 2 callers
Function
CreateDefaultClusterManager
(bs *model.Bootstrap)
pkg/server/cluster_manager.go:75
↓ 2 callers
Method
CreateFilterChain
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_manager.go:57
↓ 2 callers
Function
CreateListenerService
CreateListenerService create listener service
pkg/listener/listener.go:64
↓ 2 callers
Function
D
(a,b)
admin/web/src/utils/three.js:423
↓ 2 callers
Method
Decode
Decode handles the decode phase - records start time for both modes.
pkg/filter/metric/metric.go:194
↓ 2 callers
Method
DeepCopy
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 callers
Method
DeepCopy
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 callers
Function
DefaultOptions
()
pkg/client/mq/facade.go:51
↓ 2 callers
Method
Del
(key string)
pkg/wasm/utils.go:63
↓ 2 callers
Method
DeleteRouter
(r *model.Router)
pkg/server/router_manager.go:56
↓ 2 callers
Method
Destroy
()
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:295
↓ 2 callers
Method
DoSubscribe
DoSubscribe subscribes the registry cluster to monitor the changes.
pkg/adapter/dubboregistry/registry/base/baseregistry.go:31
↓ 2 callers
Method
DoUnsubscribe
DoUnsubscribe unsubscribes the registry cluster.
pkg/adapter/dubboregistry/registry/base/baseregistry.go:33
↓ 2 callers
Function
ExtractPathFromURL
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 callers
Method
Fetch
(localVersion string)
pkg/config/xds/xds.go:38
↓ 2 callers
Method
FormatSSEKeepalive
FormatSSEKeepalive formats a SSE keepalive comment
pkg/filter/mcp/mcpserver/transport/sse_handler.go:91
↓ 2 callers
Function
FullTypeName
(a any)
controllers/internal/controller/utils.go:450
↓ 2 callers
Function
Gb
(a)
admin/web/src/utils/three.js:447
↓ 2 callers
Method
GenerateHash
()
pkg/model/lb.go:40
↓ 2 callers
Function
GenerateSnapshotPixiu
GenerateSnapshotPixiu returns a snapshot with a single cluster and endpoint.
admin/core/xds.go:278
↓ 2 callers
Function
GetAdapterPlugin
GetAdapterPlugin get plugin by kind
pkg/common/extension/adapter/adapter.go:74
↓ 2 callers
Method
GetAllSvcListener
GetAllSvcListener get all the listener of the registry
pkg/adapter/llmregistry/registry/base/baseregistry.go:95
↓ 2 callers
Method
GetClientIP
()
pkg/context/base_context.go:48
↓ 2 callers
Function
GetConnection
()
admin/dao/database/initDB.go:57
↓ 2 callers
Method
GetHost
()
pkg/model/cluster.go:128
↓ 2 callers
Function
GetIPAndPort
(address string)
pkg/common/util/stringutil/stringutil.go:109
↓ 2 callers
Method
GetListenerManager
()
pkg/server/pixiu_start.go:64
↓ 2 callers
Method
GetMetadata
()
pkg/config/xds/model/cluster.pb.go:393
↓ 2 callers
Method
GetPath
GetPath get etcd config root path
admin/config/config.go:65
↓ 2 callers
Method
GetPayload
()
pkg/config/xds/model/health_check.pb.go:1162
↓ 2 callers
Method
GetPprof
GetPprof
pkg/model/bootstrap.go:70
↓ 2 callers
Method
GetReceivedBuf
()
pkg/common/http/manager_test.go:288
↓ 2 callers
Method
GetServiceName
()
pkg/config/xds/model/cluster.pb.go:217
↓ 2 callers
Method
GetServiceNames
()
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:47
↓ 2 callers
Method
GetSvcListener
GetSvcListener returns existing listener or nil
pkg/adapter/dubboregistry/registry/base/baseregistry.go:92
↓ 2 callers
Function
GetTrieKeyWithPrefix
(method, path, prefix string, isPrefix bool)
pkg/common/util/stringutil/stringutil.go:98
↓ 2 callers
Method
GetUserId
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:273
↓ 2 callers
Method
HandleFailure
(timeout bool)
pkg/cluster/healthcheck/healthcheck.go:273
↓ 2 callers
Function
Hb
(a)
admin/web/src/utils/three.js:445
↓ 2 callers
Function
HostnamesMatch
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 callers
Method
HotReload
HotReload performs the hot reload of the configuration.
pkg/hotreload/hotreload.go:38
↓ 2 callers
Function
Init
(clusterMg controls.ClusterManager)
pkg/config/xds/apiclient/grpc.go:73
↓ 2 callers
Method
IsAlive
()
pkg/config/xds/apiclient/grpc.go:377
↓ 2 callers
Method
IsClientStreaming
IsClientStreaming check if it's client streaming
pkg/context/grpc/context.go:110
↓ 2 callers
Method
IsServerStreaming
IsServerStreaming check if it's server streaming
pkg/context/grpc/context.go:115
↓ 2 callers
Method
ListServices
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 callers
Method
ListenToConfig
ListenToConfig listens to configuration changes
pkg/adapter/mcpserver/registry/nacos/client.go:520
↓ 2 callers
Method
ListenToMcpServer
ListenToMcpServer listens to MCP server configuration and backend services
pkg/adapter/mcpserver/registry/nacos/client.go:238
↓ 2 callers
Function
Load
Load config file and parse
pkg/config/config_load.go:62
↓ 2 callers
Function
LoadYMLConfig
LoadYMLConfig Load yml config byte from file
pkg/common/yaml/yaml.go:33
↓ 2 callers
Method
Map
Map implements how the request parameters map to the target parameters described by config.MappingParam
pkg/client/mapper.go:38
↓ 2 callers
Method
Map
nolint
pkg/client/http/mapper.go:131
↓ 2 callers
Method
Map
nolint
pkg/client/dubbo/mapper.go:110
↓ 2 callers
Method
Map
nolint
pkg/client/dubbo/mapper.go:168
↓ 2 callers
Function
MapInStruct
(cfg any)
pkg/model/http.go:89
↓ 2 callers
Method
MatchAPI
(string, string)
pkg/filter/http/apiconfig/api/discovery_service.go:40
↓ 2 callers
Method
McpRequestID
McpRequestID gets JSON-RPC request ID
pkg/filter/mcp/mcpserver/context.go:82
↓ 2 callers
Function
MergeCondition
(conditions []metav1.Condition, newCondition metav1.Condition)
controllers/internal/controller/utils.go:520
↓ 2 callers
Method
NegotiateResponse
NegotiateResponse determines the appropriate response format based on Accept header and session state
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:46
↓ 2 callers
Function
NewDefaultGatewayConfig
NewDefaultGatewayConfig returns default gateway configuration
controllers/internal/controller/config/config.go:91
↓ 2 callers
Function
NewEmptyFilterManager
NewEmptyFilterManager create empty filter manager
pkg/common/extension/filter/filter_manager.go:53
↓ 2 callers
Function
NewErrorHandler
NewErrorHandler returns the singleton ErrorHandler instance
pkg/filter/mcp/mcpserver/response.go:106
↓ 2 callers
Function
NewLeaderElection
()
controllers/internal/controller/config/config.go:116
↓ 2 callers
Function
NewLookUpTable
(tableSize int, hosts []string)
pkg/cluster/loadbalancer/maglev/permutation.go:60
↓ 2 callers
Function
NewRoute
NewRoute returns an empty router tree
pkg/router/route.go:292
↓ 2 callers
Function
NewRouterMatchPrefix
(name string)
pkg/model/router.go:75
↓ 2 callers
Function
NewSingletonMQClient
(config Config)
pkg/client/mq/mq.go:44
↓ 2 callers
Function
NewTestServerWithURL
(URL string, handler http.Handler)
pkg/common/http/manager_test.go:299
↓ 2 callers
Function
NewTripleClient
NewTripleClient create dubbo client
pkg/client/triple/triple.go:51
↓ 2 callers
Function
NewZkClient
(zkName string, config *model.RemoteConfig)
pkg/remote/zookeeper/client.go:54
↓ 2 callers
Function
O
(a,b)
admin/web/src/utils/three.js:425
↓ 2 callers
Method
OnAddServiceInstance
(r *ServiceInstance)
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:44
↓ 2 callers
Method
OnData
OnData dubbo rpc invocation from getty server
pkg/common/extension/filter/filter.go:99
↓ 2 callers
Method
OnDeleteRouter
(r config.Resource)
pkg/adapter/dubboregistry/common/common.go:28
↓ 2 callers
Method
OnDeleteServiceInstance
(r *ServiceInstance)
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:45
↓ 2 callers
Method
OnRemoveAPI
(r router.API)
pkg/adapter/dubboregistry/common/common.go:27
↓ 2 callers
Method
OnStreamRPC
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 callers
Method
OnTripleData
OnTripleData triple rpc invocation from triple-server
pkg/common/extension/filter/filter.go:101
↓ 2 callers
Method
OnUpdateServiceInstance
(r *ServiceInstance)
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:46
↓ 2 callers
Method
ParseAndSetProtocolVersionHeader
ParseAndSetProtocolVersionHeader parses MCP-Protocol-Version header
pkg/filter/mcp/mcpserver/context.go:192
↓ 2 callers
Function
ParseLogLevel
ParseLogLevel parses textual level to zapcore.Level.
pkg/logger/logger.go:168
↓ 2 callers
Function
PathExists
(path string)
admin/utils/directory.go:32
← previous
next →
501–600 of 3,410, ranked by callers