MCPcopy Create free account

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

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

⨍ Functions 3,410◇ Types & classes 888
↓ 1 callersMethodmakeHealthChecks
(checks []*xdsmodel.HealthCheck)
pkg/config/xds/cds.go:186
↓ 1 callersFunctionmakeListeners
()
admin/core/xds.go:217
↓ 1 callersMethodmakeLoadBalancePolicy
(lb string)
pkg/config/xds/cds.go:152
↓ 1 callersMethodmakeNode
()
pkg/config/xds/apiclient/grpc_envoy.go:378
↓ 1 callersMethodmakeSocketAddress
(address *xdsmodel.SocketAddress)
pkg/config/xds/lds.go:88
↓ 1 callersFunctionmapConfigMapToServerConfig
==================== Configuration Conversion ==================== mapConfigMapToServerConfig converts configuration map to MCP server configuration I
pkg/adapter/mcpserver/registry/nacos/client.go:613
↓ 1 callersFunctionmapHeaderToMetadata
(header stdHttp.Header)
pkg/filter/http/grpcproxy/grpc.go:373
↓ 1 callersFunctionmapIItoMapSI
(in any)
pkg/common/util/response.go:81
↓ 1 callersMethodmatch
match determines whether a given request hits the error injection based on the rule's trigger type. - If the rule is nil, the request doesn't hit the
pkg/filter/failinject/filter.go:117
↓ 1 callersMethodmatchClient
(typ string)
pkg/filter/http/remote/call.go:175
↓ 1 callersFunctionmatchHeaders
(chs []model.CompiledHeader, r *stdHttp.Request)
pkg/common/router/router.go:235
↓ 1 callersMethodmatchNode
(fullPath string)
pkg/router/route.go:255
↓ 1 callersMethodmatchesGateway
matchesGateway checks if a policy matches a Gateway
controllers/internal/controller/policy_loader.go:137
↓ 1 callersMethodmatchesHTTPRoute
matchesHTTPRoute checks if a policy matches an HTTPRoute
controllers/internal/controller/policy_loader.go:155
↓ 1 callersFunctionmergeApiConfigMethod
(path string, val Method)
pkg/config/api_config.go:572
↓ 1 callersFunctionmergeApiConfigResource
(val Resource)
pkg/config/api_config.go:534
↓ 1 callersFunctionmergeBaseInfo
(val []byte)
pkg/config/api_config.go:550
↓ 1 callersFunctionmockConfig
()
pkg/filter/sentinel/circuitbreaker/circuit_breaker_test.go:55
↓ 1 callersFunctionmodifyAPIFromMethod
(fullPath string, new config.Method, old config.Method, headers map[string]string, localSrv APIDiscoveryServic
pkg/filter/http/apiconfig/api/discovery_service.go:256
↓ 1 callersFunctionmodifyAPIFromResource
(new config.Resource, old config.Resource, localSrv APIDiscoveryService)
pkg/filter/http/apiconfig/api/discovery_service.go:207
↓ 1 callersMethodmonitorConnection
monitorConnection periodically checks connection health and removes bad connections
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:395
↓ 1 callersFunctionnewApplicationServiceListener
(path string, serviceName string, ds *zookeeperDiscovery)
pkg/adapter/springcloud/servicediscovery/zookeeper/service_listener.go:46
↓ 1 callersFunctionnewApplicationServiceListener
newApplicationServiceListener creates a new zk service listener
pkg/adapter/dubboregistry/registry/zookeeper/application_service_listener.go:61
↓ 1 callersFunctionnewChecker
(endpoint *model.Endpoint, hc *HealthChecker)
pkg/cluster/healthcheck/healthcheck.go:172
↓ 1 callersFunctionnewClientPool
()
pkg/pool/pool.go:42
↓ 1 callersFunctionnewClusterStore
(bs *model.Bootstrap)
pkg/server/cluster_manager.go:79
↓ 1 callersFunctionnewExporter
(ctx context.Context, cfg *model.TracerConfig)
pkg/tracing/driver.go:91
↓ 1 callersFunctionnewHTTPLoader
(cache *jwk.Cache, uri string)
pkg/filter/auth/mcp/internal/validator/loader.go:64
↓ 1 callersMethodnewHttpForwarder
()
pkg/common/grpc/manager.go:150
↓ 1 callersFunctionnewMockAdapterListener
()
pkg/adapter/llmregistry/registry/nacos/listener_test.go:87
↓ 1 callersFunctionnewMockNacosClient
()
pkg/adapter/llmregistry/registry/nacos/listener_test.go:51
↓ 1 callersFunctionnewNacosAppListener
newNacosAppListener returns a new nacosAppListener with pre-defined path according to the registered type.
pkg/adapter/dubboregistry/registry/nacos/application_listener.go:53
↓ 1 callersFunctionnewNacosAppSrvListener
(client naming_client.INamingClient, adapterListener common2.RegistryEventListener)
pkg/adapter/dubboregistry/registry/nacos/application_service_listener.go:59
↓ 1 callersFunctionnewNacosIntfListener
newNacosIntfListener returns a new nacosIntfListener with pre-defined path according to the registered type.
pkg/adapter/dubboregistry/registry/nacos/interface_listener.go:63
↓ 1 callersFunctionnewNacosSrvListener
newNacosSrvListener creates a new zk service listener
pkg/adapter/dubboregistry/registry/nacos/service_listener.go:62
↓ 1 callersFunctionnewPixiuGatewayController
()
controllers/cmd/root.go:44
↓ 1 callersFunctionnewSampler
(sample model.Sampler)
pkg/tracing/driver.go:142
↓ 1 callersFunctionnewStaticLoaderFromBytes
(data []byte)
pkg/filter/auth/mcp/internal/validator/loader.go:40
↓ 1 callersFunctionnewStaticLoaderFromFile
(path string)
pkg/filter/auth/mcp/internal/validator/loader.go:48
↓ 1 callersFunctionnewTeeReadCloser
(r io.ReadCloser, w io.Writer)
pkg/filter/llm/tokenizer/tokenizer.go:480
↓ 1 callersFunctionnewTraceProvider
(exp sdktrace.SpanExporter, cfg *model.TracerConfig)
pkg/tracing/driver.go:103
↓ 1 callersFunctionnewZKIntfListener
newZKIntfListener returns a new zkIntfListener with pre-defined path according to the registered type.
pkg/adapter/dubboregistry/registry/zookeeper/interface_listener.go:56
↓ 1 callersFunctionnewZkAppListener
(ds *zookeeperDiscovery)
pkg/adapter/springcloud/servicediscovery/zookeeper/application_listener.go:48
↓ 1 callersFunctionnewZkAppListener
newZkAppListener returns a new newZkAppListener with pre-defined servicesPath according to the registered type.
pkg/adapter/dubboregistry/registry/zookeeper/application_listener.go:55
↓ 1 callersFunctionnewZkSrvListener
newZkSrvListener creates a new zk service listener
pkg/adapter/dubboregistry/registry/zookeeper/service_listener.go:55
↓ 1 callersFunctionnormalizeHTTPMethods
(cfg *converter.PixiuConfig)
controllers/internal/controller/gateway_controller.go:872
↓ 1 callersMethodnotifyToolsListChanged
notifyToolsListChanged sends notifications/tools/list_changed to all connected clients
pkg/filter/mcp/mcpserver/dynamic.go:236
↓ 1 callersFunctionnumCPU
numCPU returns the CPU quota
pkg/common/runtime/runtime.go:104
↓ 1 callersMethodonServerVersionChanged
onServerVersionChanged handles server version changes
pkg/adapter/mcpserver/registry/nacos/client.go:442
↓ 1 callersFunctionopenUriInNewWindowHack
(uri, failCb, successCb)
admin/web/public/static/js/protocolcheck.js:199
↓ 1 callersFunctionopenUriUsingFirefox
(uri, failCb, successCb)
admin/web/public/static/js/protocolcheck.js:136
↓ 1 callersFunctionopenUriUsingIE10InWindows7
(uri, failCb, successCb)
admin/web/public/static/js/protocolcheck.js:180
↓ 1 callersFunctionopenUriUsingIEInOlderWindows
(uri, failCb, successCb)
admin/web/public/static/js/protocolcheck.js:169
↓ 1 callersFunctionopenUriWithIE11UsingRegistry
(uri, failCb, successCb)
admin/web/public/static/js/protocolcheck.js:154
↓ 1 callersFunctionopenUriWithMsLaunchUri
(uri, failCb, successCb)
admin/web/public/static/js/protocolcheck.js:216
↓ 1 callersFunctionopenUriWithTimeoutHack
(uri, failCb, successCb)
admin/web/public/static/js/protocolcheck.js:112
↓ 1 callersFunctionparseServiceAddress
(address, defaultNamespace string)
controllers/internal/controller/gateway_controller.go:1128
↓ 1 callersFunctionparseTemplatePlaceholders
parseTemplatePlaceholders parses template placeholders and returns replaced content and required (dataId,group) list
pkg/adapter/mcpserver/registry/nacos/client.go:671
↓ 1 callersFunctionparseUint
copied from https://github.com/containerd/cgroups/blob/318312a373405e5e91134d8063d04d59768a1bff/utils.go#L251
pkg/common/runtime/runtime.go:85
↓ 1 callersFunctionpassCheck
(item string, rule AuthorityRule)
pkg/filter/authority/authority.go:87
↓ 1 callersMethodpathForInstance
(name, id string)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:277
↓ 1 callersMethodpathForName
(name string)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:281
↓ 1 callersFunctionpercentage
percentage checks if the current request matches based on a given odds percentage. The function returns true with a probability equal to the odds perc
pkg/filter/failinject/filter.go:147
↓ 1 callersMethodpickOneEndpoint
(c *model.ClusterConfig, policy model.LbPolicy)
pkg/server/cluster_manager.go:204
↓ 1 callersMethodpipeline
(output chan *DeltaResources)
pkg/config/xds/apiclient/grpc_envoy.go:140
↓ 1 callersFunctionprepareDubboClient
()
tools/benchmark/test/dubbo_suite/dubbo_test.go:263
↓ 1 callersFunctionprepareDubboServer
()
tools/benchmark/test/dubbo_suite/dubbo_test.go:250
↓ 1 callersFunctionprepareGRPCClient
()
tools/benchmark/test/grpc_suite/grpc_test.go:204
↓ 1 callersFunctionprepareGRPCServer
()
tools/benchmark/test/grpc_suite/grpc_test.go:192
↓ 1 callersMethodprepareRequestBody
prepareRequestBody ensures the request body can be read multiple times.
pkg/filter/llm/proxy/filter.go:201
↓ 1 callersFunctionprepareTripleClient
()
tools/benchmark/test/triple_suite/proto_suite/proto_test.go:160
↓ 1 callersFunctionprepareTripleServer
()
tools/benchmark/test/triple_suite/proto_suite/proto_test.go:145
↓ 1 callersMethodprocessListenerConfig
(gateway *gatewayv1.Gateway)
controllers/internal/controller/gateway_controller.go:415
↓ 1 callersMethodprocessStreamResponse
processStreamResponse handles streaming responses to calculate TTFT and count tokens.
pkg/filter/llm/tokenizer/tokenizer.go:215
↓ 1 callersMethodprocessToolCallResponse
processToolCallResponse processes the tool call response and sends the result
pkg/filter/mcp/mcpserver/handlers.go:572
↓ 1 callersMethodprocessUnaryResponse
processUnaryResponse handles non-streaming responses for token counting.
pkg/filter/llm/tokenizer/tokenizer.go:283
↓ 1 callersFunctionprotoMsgToJson
(msg proto.Message)
pkg/filter/http/grpcproxy/grpc.go:399
↓ 1 callersMethodputMatchAllNode
(matchStr string, isReal bool, bizInfo any)
pkg/common/router/trie/trie.go:342
↓ 1 callersMethodputNode
(matchStr string, isReal bool, bizInfo any)
pkg/common/router/trie/trie.go:320
↓ 1 callersMethodputPathVariable
(pathVariable string, isReal bool, bizInfo any)
pkg/common/router/trie/trie.go:299
↓ 1 callersMethodputWasmInstance
(instance common.WasmInstance)
pkg/wasm/service.go:103
↓ 1 callersMethodqueryForNames
()
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:267
↓ 1 callersFunctionrandom
random if the current request is matched
pkg/filter/failinject/filter.go:134
↓ 1 callersMethodreadDubboServiceFromListener
()
pkg/config/xds/xds.go:79
↓ 1 callersFunctionreadLinesFromFile
readLinesFromFile reads the lines from a file.
pkg/common/runtime/runtime.go:46
↓ 1 callersFunctionreconcileGatewaysMatchGatewayClass
(gatewayClass client.Object, gateways []gatewayv1.Gateway)
controllers/internal/controller/utils.go:418
↓ 1 callersMethodrecordDynamicCounter
recordDynamicCounter records a counter metric
pkg/prometheus/prometheus.go:478
↓ 1 callersMethodrecordDynamicGauge
recordDynamicGauge records a gauge metric
pkg/prometheus/prometheus.go:516
↓ 1 callersMethodrecordDynamicHistogram
recordDynamicHistogram records a histogram metric
pkg/prometheus/prometheus.go:554
↓ 1 callersFunctionreferenceGrantPredicates
(kind gatewayv1.Kind)
controllers/internal/controller/utils.go:282
↓ 1 callersMethodregisterExtension
(source DescriptorSource, mthDesc *desc.MethodDescriptor)
pkg/filter/http/grpcproxy/grpc.go:330
↓ 1 callersFunctionregisterLLMMetrics
registerLLMMetrics creates and registers all metrics for this plugin.
pkg/filter/llm/tokenizer/tokenizer.go:384
↓ 1 callersMethodregisterMetrics
()
pkg/prometheus/prometheus.go:283
↓ 1 callersFunctionregisterOtelMetricMeter
(conf model.Metric)
pkg/server/otel.go:39
↓ 1 callersFunctionregisterProxyServices
registerProxyServices registers services with the gRPC server
pkg/listener/grpc/grpc_listener.go:385
↓ 1 callersFunctionregisterServer
(grpcServer *grpc.Server, server envoyServer.Server)
admin/core/xds.go:74
↓ 1 callersMethodremoveCluster
(clusterNames []string)
pkg/config/xds/cds.go:85
↓ 1 callersMethodremoveClusters
(toRemoveList map[string]struct{})
pkg/config/xds/cds.go:129
↓ 1 callersMethodremoveListeners
(toRemoveHash map[string]struct{})
pkg/config/xds/lds.go:101
↓ 1 callersMethodremovePerm
(dst int)
pkg/cluster/loadbalancer/maglev/permutation.go:174
← previousnext →1,401–1,500 of 3,410, ranked by callers