MCPcopy Create free account

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

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

↓ 1 callersMethodMapParams
MapParams params mapping to api.
pkg/client/dubbo/dubbo.go:248
↓ 1 callersMethodMarshalJSON
()
controllers/internal/controller/config/config.go:135
↓ 1 callersMethodMatchAPI
(url string, httpVerb string)
pkg/filter/http/apiconfig/api/discovery_service.go:77
↓ 1 callersMethodMatchHeader
MatchHeader used when there are only headers to match
pkg/model/router.go:101
↓ 1 callersMethodMatchValues
MatchValues match values in header, including regex type
pkg/model/router.go:122
↓ 1 callersMethodMcpMethod
McpMethod gets MCP method name
pkg/filter/mcp/mcpserver/context.go:72
↓ 1 callersMethodMethodAdd
MethodAdd handle add method below one resource event
pkg/config/api_config.go:67
↓ 1 callersFunctionMethodAllowed
(methods []string, m string)
pkg/model/router_snapshot.go:56
↓ 1 callersMethodMethodChange
MethodChange handle modify method event
pkg/config/api_config.go:65
↓ 1 callersMethodMethodDelete
MethodDelete handle delete method event
pkg/config/api_config.go:69
↓ 1 callersMethodMutate
(obj client.Object)
controllers/internal/controller/status/status.go:64
↓ 1 callersMethodName
Name returns the name of the codec.
pkg/common/codec/grpc/passthrough/codec.go:65
↓ 1 callersFunctionNewCluster
(clusterConfig *model.ClusterConfig)
pkg/cluster/cluster.go:30
↓ 1 callersFunctionNewConfigLoad
(bootConfig *model.Bootstrap)
pkg/configcenter/load.go:64
↓ 1 callersFunctionNewConfigManger
()
pkg/config/config_load.go:193
↓ 1 callersFunctionNewDubboFilterManager
NewDubboFilterManager create filter manager
pkg/filter/network/dubboproxy/dubbofiltermanager.go:34
↓ 1 callersFunctionNewDubboResponse
(data any, hump bool)
pkg/common/util/response.go:31
↓ 1 callersFunctionNewFilterManager
NewFilterManager create filter manager
pkg/common/extension/filter/filter_manager.go:47
↓ 1 callersFunctionNewGreeterClient
(cc *triple.TripleConn)
tools/benchmark/api/samples_api_triple.pb.go:78
↓ 1 callersFunctionNewGrpcFilterManager
NewGrpcFilterManager create gRPC filter manager
pkg/filter/network/grpcproxy/grpc_filter_manager.go:34
↓ 1 callersFunctionNewJaegerExporter
(cfg *model.TracerConfig)
pkg/tracing/jaeger/jaeger.go:38
↓ 1 callersFunctionNewKafkaConsumerFacade
(config KafkaConsumerConfig, consumerGroup string)
pkg/client/mq/kafka_facade.go:50
↓ 1 callersFunctionNewKafkaProviderFacade
(config KafkaProducerConfig)
pkg/client/mq/kafka_facade.go:206
↓ 1 callersFunctionNewMCPContextFromHttpContext
NewMCPContextFromHttpContext creates MCPContext from existing HttpContext and tries to load stored MCP data
pkg/filter/mcp/mcpserver/context.go:110
↓ 1 callersFunctionNewMQClient
(config Config)
pkg/client/mq/mq.go:57
↓ 1 callersFunctionNewMatcher
()
pkg/filter/sentinel/matcher.go:33
↓ 1 callersFunctionNewMcpController
NewMcpController creates a new MCP controller
pkg/adapter/mcpserver/registry/nacos/controller.go:50
↓ 1 callersFunctionNewMcpRegistryClient
==================== Constructors ==================== NewMcpRegistryClient creates a new Nacos MCP registry client
pkg/adapter/mcpserver/registry/nacos/client.go:157
↓ 1 callersFunctionNewMetric
NewMetric associates prometheus.Collector based on Metric.Type
pkg/prometheus/prometheus.go:150
↓ 1 callersFunctionNewNacosClient
(config *model.RemoteConfig)
pkg/remote/nacos/client.go:61
↓ 1 callersFunctionNewNacosServiceDiscovery
(targetService []string, config *model.RemoteConfig, l servicediscovery.ServiceEventListener)
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:220
↓ 1 callersFunctionNewOTLPExporter
(ctx context.Context, cfg *model.TracerConfig)
pkg/tracing/otlp/otlp.go:35
↓ 1 callersFunctionNewPackageHandler
(ls *TcpListenerService)
pkg/listener/tcp/pkg_handler.go:28
↓ 1 callersFunctionNewPolicyLoader
NewPolicyLoader creates a new PolicyLoader
controllers/internal/controller/policy_loader.go:42
↓ 1 callersFunctionNewProtoAny
(typeConfig *v3.TypedExtensionConfig)
pkg/config/xds/apiclient/apiclient.go:65
↓ 1 callersFunctionNewProxy
NewProxy creates a new client
pkg/client/proxy/proxy.go:47
↓ 1 callersFunctionNewReflector
NewReflector creates a new Reflector from the reflection client
pkg/client/proxy/reflection.go:38
↓ 1 callersFunctionNewRingHash
(config model.ConsistentHash, endpoints []*model.Endpoint)
pkg/cluster/loadbalancer/ringhash/ring_hash.go:39
↓ 1 callersFunctionNewServer
NewServer create server
pkg/server/pixiu_start.go:120
↓ 1 callersFunctionNewServerPackageHandler
NewServerPackageHandler create serverHandler
pkg/listener/tcp/server_handler.go:78
↓ 1 callersMethodNewStore
(version int32)
pkg/server/cluster_manager.go:139
↓ 1 callersFunctionNewStreamHTTPRecorder
()
pkg/common/http/manager_test.go:326
↓ 1 callersFunctionNewStreamRecorder
()
pkg/common/http/manager_test.go:265
↓ 1 callersFunctionNewStreamResponse
NewStreamResponse create response contains a stream
pkg/client/response.go:45
↓ 1 callersFunctionNewTrieWithDefault
NewTrieWithDefault
pkg/common/router/trie/trie.go:44
↓ 1 callersFunctionNewZKServiceDiscovery
(targetService []string, config *model.RemoteConfig, listener servicediscovery.ServiceEventListener)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:60
↓ 1 callersMethodOnAddAPI
(r router.API)
pkg/server/api_config_manager.go:36
↓ 1 callersMethodOnAddEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/common/common.go:25
↓ 1 callersMethodOnAddRouter
OnAddRouter add router
pkg/common/router/mock/router.go:140
↓ 1 callersMethodOnDeleteRouter
(r config.Resource)
pkg/server/api_config_manager.go:38
↓ 1 callersMethodOnError
OnError called when err
pkg/listener/tcp/server_handler.go:108
↓ 1 callersMethodOnRemoveAPI
(r router.API)
pkg/server/api_config_manager.go:37
↓ 1 callersMethodOnRemoveEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/common/common.go:26
↓ 1 callersFunctionOnRulesUpdate
OnRulesUpdate update rule
pkg/filter/sentinel/ratelimit/rate_limit.go:123
↓ 1 callersMethodOnUnaryRPC
OnUnaryRPC handles a unary RPC call.
pkg/common/extension/filter/filter.go:103
↓ 1 callersFunctionPaddedCallerEncoder
PaddedCallerEncoder aligns caller path to a fixed width for prettier console output.
pkg/logger/logger.go:54
↓ 1 callersMethodParseToken
ParseToken
admin/controller/auth/auth.go:114
↓ 1 callersMethodPickNextEndpoint
PickNextEndpoint picks the next endpoint in the cluster after the current endpoint ID.
pkg/server/cluster_manager.go:171
↓ 1 callersMethodProviderByTokenIssuer
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 callersMethodProviders
Providers returns the list of provider names
pkg/filter/auth/mcp/internal/validator/validator.go:341
↓ 1 callersMethodPutOrUpdate
Put put key and values into trie as map.
pkg/common/router/trie/trie.go:80
↓ 1 callersMethodPutOrUpdateAPI
PutOrUpdateAPI puts or updates an api into the resource
pkg/router/route.go:143
↓ 1 callersMethodQueryAllServices
QueryAllServices get all service from remote registry center
pkg/adapter/springcloud/servicediscovery/servicediscovery.go:53
↓ 1 callersMethodQueryServicesByName
(serviceNames []string)
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:157
↓ 1 callersMethodQueryServicesByName
(serviceNames []string)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:108
↓ 1 callersFunctionR
(a)
admin/web/src/utils/three.js:179
↓ 1 callersMethodRead
(ss getty.Session, data []byte)
pkg/listener/tcp/pkg_handler.go:32
↓ 1 callersMethodRecordDynamicMetric
RecordDynamicMetric records a dynamic metric based on type (counter, gauge, histogram)
pkg/prometheus/prometheus.go:456
↓ 1 callersMethodRefresh
Refresh config
pkg/listener/listener.go:44
↓ 1 callersFunctionRegister
(username, password string)
admin/logic/account/guest.go:45
↓ 1 callersFunctionRegisterConfigListener
RegisterConfigListener register APIConfigListener
pkg/config/api_config.go:612
↓ 1 callersFunctionRegisterConfigLoadFunc
RegisterConfigLoadFunc can replace a new config load function instead of default
pkg/config/config_load.go:75
↓ 1 callersFunctionRegisterGrpcFilterPlugin
RegisterGrpcFilterPlugin registers gRPC filter plugin.
pkg/common/extension/filter/filter.go:267
↓ 1 callersMethodRegisterHandler
(event <-chan zk.Event)
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:124
↓ 1 callersMethodRegisterPrompt
RegisterPrompt registers a prompt
pkg/filter/mcp/mcpserver/registry.go:295
↓ 1 callersFunctionRegisterProvider
RegisterProvider registers a provider-specific controller builder.
pkg/adapter/mcpserver/registry/factory.go:31
↓ 1 callersFunctionRegisterResolver
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 callersMethodRegisterResource
RegisterResource registers a resource (indexed by URI as per MCP specification)
pkg/filter/mcp/mcpserver/registry.go:79
↓ 1 callersMethodRegisterResourceTemplate
RegisterResourceTemplate registers a resource template
pkg/filter/mcp/mcpserver/registry.go:112
↓ 1 callersMethodRemoveAPIByIntance
(api router.API)
pkg/filter/http/apiconfig/api/discovery_service.go:42
↓ 1 callersMethodRemoveSvcListener
RemoveSvcListener remove the listener of the registry
pkg/adapter/llmregistry/registry/base/baseregistry.go:105
↓ 1 callersMethodRemoveSvcListener
RemoveSvcListener remove the listener of the registry
pkg/adapter/dubboregistry/registry/base/baseregistry.go:107
↓ 1 callersMethodResolve
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 callersMethodResolve
(ctx *contexthttp.HttpContext)
pkg/filter/http/remote/resolver/dubboresolver/dubbo_resolver.go:37
↓ 1 callersMethodResourceAdd
bool is return for interface implement is interesting ResourceAdd handle add resource event
pkg/config/api_config.go:61
↓ 1 callersMethodResourceChange
ResourceChange handle modify resource event
pkg/config/api_config.go:59
↓ 1 callersMethodResourceDelete
ResourceDelete handle delete resource event
pkg/config/api_config.go:63
↓ 1 callersMethodRestartCallBack
for registry destroy
pkg/remote/zookeeper/client.go:83
↓ 1 callersMethodRoundTrip
(*http.Request)
pkg/filter/opa/opa_test.go:546
↓ 1 callersMethodRoute
Route find routeAction for request
pkg/common/router/mock/router.go:65
↓ 1 callersFunctionRouters
Routers init router
admin/initialize/router.go:36
↓ 1 callersFunctionRunServer
RunServer start server
admin/core/server.go:51
↓ 1 callersMethodSayHello
Sends a greeting
tools/benchmark/api/samples_api_triple.pb.go:56
↓ 1 callersMethodSayHelloStream
Sends a greeting via stream
tools/benchmark/api/samples_api_triple.pb.go:58
↓ 1 callersMethodSearchConfig
(param vo.SearchConfigParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:169
↓ 1 callersMethodSelectInstances
(_ vo.SelectInstancesParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:252
↓ 1 callersMethodSendServerRequest
SendServerRequest sends a server request to the client via SSE stream
pkg/filter/mcp/mcpserver/filter.go:500
↓ 1 callersMethodServerNotification
ServerNotification creates a JSON-RPC notification from server
pkg/filter/mcp/mcpserver/response.go:156
↓ 1 callersMethodServerRequest
ServerRequest creates a JSON-RPC request from server
pkg/filter/mcp/mcpserver/response.go:171
↓ 1 callersMethodSetConfig
SetConfig set config
pkg/client/dubbo/dubbo.go:130
← previousnext →1,001–1,100 of 3,410, ranked by callers