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
MapParams
MapParams params mapping to api.
pkg/client/dubbo/dubbo.go:248
↓ 1 callers
Method
MarshalJSON
()
controllers/internal/controller/config/config.go:135
↓ 1 callers
Method
MatchAPI
(url string, httpVerb string)
pkg/filter/http/apiconfig/api/discovery_service.go:77
↓ 1 callers
Method
MatchHeader
MatchHeader used when there are only headers to match
pkg/model/router.go:101
↓ 1 callers
Method
MatchValues
MatchValues match values in header, including regex type
pkg/model/router.go:122
↓ 1 callers
Method
McpMethod
McpMethod gets MCP method name
pkg/filter/mcp/mcpserver/context.go:72
↓ 1 callers
Method
MethodAdd
MethodAdd handle add method below one resource event
pkg/config/api_config.go:67
↓ 1 callers
Function
MethodAllowed
(methods []string, m string)
pkg/model/router_snapshot.go:56
↓ 1 callers
Method
MethodChange
MethodChange handle modify method event
pkg/config/api_config.go:65
↓ 1 callers
Method
MethodDelete
MethodDelete handle delete method event
pkg/config/api_config.go:69
↓ 1 callers
Method
Mutate
(obj client.Object)
controllers/internal/controller/status/status.go:64
↓ 1 callers
Method
Name
Name returns the name of the codec.
pkg/common/codec/grpc/passthrough/codec.go:65
↓ 1 callers
Function
NewCluster
(clusterConfig *model.ClusterConfig)
pkg/cluster/cluster.go:30
↓ 1 callers
Function
NewConfigLoad
(bootConfig *model.Bootstrap)
pkg/configcenter/load.go:64
↓ 1 callers
Function
NewConfigManger
()
pkg/config/config_load.go:193
↓ 1 callers
Function
NewDubboFilterManager
NewDubboFilterManager create filter manager
pkg/filter/network/dubboproxy/dubbofiltermanager.go:34
↓ 1 callers
Function
NewDubboResponse
(data any, hump bool)
pkg/common/util/response.go:31
↓ 1 callers
Function
NewFilterManager
NewFilterManager create filter manager
pkg/common/extension/filter/filter_manager.go:47
↓ 1 callers
Function
NewGreeterClient
(cc *triple.TripleConn)
tools/benchmark/api/samples_api_triple.pb.go:78
↓ 1 callers
Function
NewGrpcFilterManager
NewGrpcFilterManager create gRPC filter manager
pkg/filter/network/grpcproxy/grpc_filter_manager.go:34
↓ 1 callers
Function
NewJaegerExporter
(cfg *model.TracerConfig)
pkg/tracing/jaeger/jaeger.go:38
↓ 1 callers
Function
NewKafkaConsumerFacade
(config KafkaConsumerConfig, consumerGroup string)
pkg/client/mq/kafka_facade.go:50
↓ 1 callers
Function
NewKafkaProviderFacade
(config KafkaProducerConfig)
pkg/client/mq/kafka_facade.go:206
↓ 1 callers
Function
NewMCPContextFromHttpContext
NewMCPContextFromHttpContext creates MCPContext from existing HttpContext and tries to load stored MCP data
pkg/filter/mcp/mcpserver/context.go:110
↓ 1 callers
Function
NewMQClient
(config Config)
pkg/client/mq/mq.go:57
↓ 1 callers
Function
NewMatcher
()
pkg/filter/sentinel/matcher.go:33
↓ 1 callers
Function
NewMcpController
NewMcpController creates a new MCP controller
pkg/adapter/mcpserver/registry/nacos/controller.go:50
↓ 1 callers
Function
NewMcpRegistryClient
==================== Constructors ==================== NewMcpRegistryClient creates a new Nacos MCP registry client
pkg/adapter/mcpserver/registry/nacos/client.go:157
↓ 1 callers
Function
NewMetric
NewMetric associates prometheus.Collector based on Metric.Type
pkg/prometheus/prometheus.go:150
↓ 1 callers
Function
NewNacosClient
(config *model.RemoteConfig)
pkg/remote/nacos/client.go:61
↓ 1 callers
Function
NewNacosServiceDiscovery
(targetService []string, config *model.RemoteConfig, l servicediscovery.ServiceEventListener)
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:220
↓ 1 callers
Function
NewOTLPExporter
(ctx context.Context, cfg *model.TracerConfig)
pkg/tracing/otlp/otlp.go:35
↓ 1 callers
Function
NewPackageHandler
(ls *TcpListenerService)
pkg/listener/tcp/pkg_handler.go:28
↓ 1 callers
Function
NewPolicyLoader
NewPolicyLoader creates a new PolicyLoader
controllers/internal/controller/policy_loader.go:42
↓ 1 callers
Function
NewProtoAny
(typeConfig *v3.TypedExtensionConfig)
pkg/config/xds/apiclient/apiclient.go:65
↓ 1 callers
Function
NewProxy
NewProxy creates a new client
pkg/client/proxy/proxy.go:47
↓ 1 callers
Function
NewReflector
NewReflector creates a new Reflector from the reflection client
pkg/client/proxy/reflection.go:38
↓ 1 callers
Function
NewRingHash
(config model.ConsistentHash, endpoints []*model.Endpoint)
pkg/cluster/loadbalancer/ringhash/ring_hash.go:39
↓ 1 callers
Function
NewServer
NewServer create server
pkg/server/pixiu_start.go:120
↓ 1 callers
Function
NewServerPackageHandler
NewServerPackageHandler create serverHandler
pkg/listener/tcp/server_handler.go:78
↓ 1 callers
Method
NewStore
(version int32)
pkg/server/cluster_manager.go:139
↓ 1 callers
Function
NewStreamHTTPRecorder
()
pkg/common/http/manager_test.go:326
↓ 1 callers
Function
NewStreamRecorder
()
pkg/common/http/manager_test.go:265
↓ 1 callers
Function
NewStreamResponse
NewStreamResponse create response contains a stream
pkg/client/response.go:45
↓ 1 callers
Function
NewTrieWithDefault
NewTrieWithDefault
pkg/common/router/trie/trie.go:44
↓ 1 callers
Function
NewZKServiceDiscovery
(targetService []string, config *model.RemoteConfig, listener servicediscovery.ServiceEventListener)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:60
↓ 1 callers
Method
OnAddAPI
(r router.API)
pkg/server/api_config_manager.go:36
↓ 1 callers
Method
OnAddEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/common/common.go:25
↓ 1 callers
Method
OnAddRouter
OnAddRouter add router
pkg/common/router/mock/router.go:140
↓ 1 callers
Method
OnDeleteRouter
(r config.Resource)
pkg/server/api_config_manager.go:38
↓ 1 callers
Method
OnError
OnError called when err
pkg/listener/tcp/server_handler.go:108
↓ 1 callers
Method
OnRemoveAPI
(r router.API)
pkg/server/api_config_manager.go:37
↓ 1 callers
Method
OnRemoveEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/common/common.go:26
↓ 1 callers
Function
OnRulesUpdate
OnRulesUpdate update rule
pkg/filter/sentinel/ratelimit/rate_limit.go:123
↓ 1 callers
Method
OnUnaryRPC
OnUnaryRPC handles a unary RPC call.
pkg/common/extension/filter/filter.go:103
↓ 1 callers
Function
PaddedCallerEncoder
PaddedCallerEncoder aligns caller path to a fixed width for prettier console output.
pkg/logger/logger.go:54
↓ 1 callers
Method
ParseToken
ParseToken
admin/controller/auth/auth.go:114
↓ 1 callers
Method
PickNextEndpoint
PickNextEndpoint picks the next endpoint in the cluster after the current endpoint ID.
pkg/server/cluster_manager.go:171
↓ 1 callers
Method
ProviderByTokenIssuer
ProviderByTokenIssuer parses token without validation to extract the issuer and returns the provider name configured for that issuer.
pkg/filter/auth/mcp/internal/validator/validator.go:212
↓ 1 callers
Method
Providers
Providers returns the list of provider names
pkg/filter/auth/mcp/internal/validator/validator.go:341
↓ 1 callers
Method
PutOrUpdate
Put put key and values into trie as map.
pkg/common/router/trie/trie.go:80
↓ 1 callers
Method
PutOrUpdateAPI
PutOrUpdateAPI puts or updates an api into the resource
pkg/router/route.go:143
↓ 1 callers
Method
QueryAllServices
QueryAllServices get all service from remote registry center
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:53
↓ 1 callers
Method
QueryServicesByName
(serviceNames []string)
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:157
↓ 1 callers
Method
QueryServicesByName
(serviceNames []string)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:108
↓ 1 callers
Function
R
(a)
admin/web/src/utils/three.js:179
↓ 1 callers
Method
Read
(ss getty.Session, data []byte)
pkg/listener/tcp/pkg_handler.go:32
↓ 1 callers
Method
RecordDynamicMetric
RecordDynamicMetric records a dynamic metric based on type (counter, gauge, histogram)
pkg/prometheus/prometheus.go:456
↓ 1 callers
Method
Refresh
Refresh config
pkg/listener/listener.go:44
↓ 1 callers
Function
Register
(username, password string)
admin/logic/account/guest.go:45
↓ 1 callers
Function
RegisterConfigListener
RegisterConfigListener register APIConfigListener
pkg/config/api_config.go:612
↓ 1 callers
Function
RegisterConfigLoadFunc
RegisterConfigLoadFunc can replace a new config load function instead of default
pkg/config/config_load.go:75
↓ 1 callers
Function
RegisterGrpcFilterPlugin
RegisterGrpcFilterPlugin registers gRPC filter plugin.
pkg/common/extension/filter/filter.go:267
↓ 1 callers
Method
RegisterHandler
(event <-chan zk.Event)
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:124
↓ 1 callers
Method
RegisterPrompt
RegisterPrompt registers a prompt
pkg/filter/mcp/mcpserver/registry.go:295
↓ 1 callers
Function
RegisterProvider
RegisterProvider registers a provider-specific controller builder.
pkg/adapter/mcpserver/registry/factory.go:31
↓ 1 callers
Function
RegisterResolver
RegisterResolver register resolver factory to registry. This function is called from init() functions in files that define a resolver.
pkg/filter/http/remote/resolver/resolver.go:110
↓ 1 callers
Method
RegisterResource
RegisterResource registers a resource (indexed by URI as per MCP specification)
pkg/filter/mcp/mcpserver/registry.go:79
↓ 1 callers
Method
RegisterResourceTemplate
RegisterResourceTemplate registers a resource template
pkg/filter/mcp/mcpserver/registry.go:112
↓ 1 callers
Method
RemoveAPIByIntance
(api router.API)
pkg/filter/http/apiconfig/api/discovery_service.go:42
↓ 1 callers
Method
RemoveSvcListener
RemoveSvcListener remove the listener of the registry
pkg/adapter/llmregistry/registry/base/baseregistry.go:105
↓ 1 callers
Method
RemoveSvcListener
RemoveSvcListener remove the listener of the registry
pkg/adapter/dubboregistry/registry/base/baseregistry.go:107
↓ 1 callers
Method
Resolve
Resolve attempts to create an API configuration from the given HTTP context. If the resolver can handle the request, it returns a configured *router.A
pkg/filter/http/remote/resolver/resolver.go:42
↓ 1 callers
Method
Resolve
(ctx *contexthttp.HttpContext)
pkg/filter/http/remote/resolver/dubboresolver/dubbo_resolver.go:37
↓ 1 callers
Method
ResourceAdd
bool is return for interface implement is interesting ResourceAdd handle add resource event
pkg/config/api_config.go:61
↓ 1 callers
Method
ResourceChange
ResourceChange handle modify resource event
pkg/config/api_config.go:59
↓ 1 callers
Method
ResourceDelete
ResourceDelete handle delete resource event
pkg/config/api_config.go:63
↓ 1 callers
Method
RestartCallBack
for registry destroy
pkg/remote/zookeeper/client.go:83
↓ 1 callers
Method
RoundTrip
(*http.Request)
pkg/filter/opa/opa_test.go:546
↓ 1 callers
Method
Route
Route find routeAction for request
pkg/common/router/mock/router.go:65
↓ 1 callers
Function
Routers
Routers init router
admin/initialize/router.go:36
↓ 1 callers
Function
RunServer
RunServer start server
admin/core/server.go:51
↓ 1 callers
Method
SayHello
Sends a greeting
tools/benchmark/api/samples_api_triple.pb.go:56
↓ 1 callers
Method
SayHelloStream
Sends a greeting via stream
tools/benchmark/api/samples_api_triple.pb.go:58
↓ 1 callers
Method
SearchConfig
(param vo.SearchConfigParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:169
↓ 1 callers
Method
SelectInstances
(_ vo.SelectInstancesParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:252
↓ 1 callers
Method
SendServerRequest
SendServerRequest sends a server request to the client via SSE stream
pkg/filter/mcp/mcpserver/filter.go:500
↓ 1 callers
Method
ServerNotification
ServerNotification creates a JSON-RPC notification from server
pkg/filter/mcp/mcpserver/response.go:156
↓ 1 callers
Method
ServerRequest
ServerRequest creates a JSON-RPC request from server
pkg/filter/mcp/mcpserver/response.go:171
↓ 1 callers
Method
SetConfig
SetConfig set config
pkg/client/dubbo/dubbo.go:130
← previous
next →
1,001–1,100 of 3,410, ranked by callers