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
Function
categorizeJWTError
categorizeJWTError categorizes JWT validation errors into standard error codes
pkg/filter/auth/mcp/internal/validator/validator.go:155
↓ 1 callers
Method
check
(key string)
pkg/client/dubbo/dubbo.go:283
↓ 1 callers
Method
check
()
pkg/config/config_load.go:275
↓ 1 callers
Function
checkBrowser
()
admin/web/public/static/js/protocolcheck.js:223
↓ 1 callers
Method
checkConsumerIsAlive
checkConsumerIsAlive make sure consumer is alive or would be removed from consumer list
pkg/client/mq/kafka_facade.go:155
↓ 1 callers
Method
checkEncoderConfig
checkEncoderConfig compares the old and new encoder configurations.
pkg/hotreload/logger.go:91
↓ 1 callers
Function
checkEndpointNotIn
(t *testing.T, table *LookUpTable, endpoint string)
pkg/cluster/loadbalancer/maglev/permutation_test.go:257
↓ 1 callers
Method
checkHasExistService
(name string)
pkg/adapter/springcloud/cloud.go:275
↓ 1 callers
Function
checkRouteAcceptedByListener
(ctx context.Context, mgrc client.Client, route client.Object, gateway gatewayv1.Gateway, listener gatewayv1.L
controllers/internal/controller/utils.go:302
↓ 1 callers
Method
checkSampling
checkSampling compares the old and new sampling configurations.
pkg/hotreload/logger.go:86
↓ 1 callers
Method
clearAndSetCurrentService
(instances []servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:264
↓ 1 callers
Function
computeApproximateRequestSize
(r *http.Request)
pkg/prometheus/prometheus.go:422
↓ 1 callers
Function
computeApproximateRequestSize
computeApproximateRequestSize computes the approximate size of an HTTP request.
pkg/filter/metric/metric.go:345
↓ 1 callers
Function
computeApproximateResponseSize
(res any)
pkg/prometheus/prometheus.go:445
↓ 1 callers
Function
computeApproximateResponseSize
computeApproximateResponseSize computes the approximate size of an HTTP response.
pkg/filter/metric/metric.go:369
↓ 1 callers
Function
configCheck
(cfg *Config)
pkg/filter/http/grpcproxy/grpc.go:429
↓ 1 callers
Function
configureKeepalive
configureKeepalive sets up keepalive parameters for the gRPC server
pkg/listener/grpc/grpc_listener.go:320
↓ 1 callers
Function
configureTLS
configureTLS sets up TLS credentials for the gRPC server if enabled
pkg/listener/grpc/grpc_listener.go:355
↓ 1 callers
Method
consumeLoop
(ctx context.Context, topics []string, handler sarama.ConsumerGroupHandler)
pkg/client/mq/kafka_facade.go:91
↓ 1 callers
Function
contains
(key string)
pkg/wasm/key.go:27
↓ 1 callers
Function
contains
(elems []string, v string)
pkg/adapter/springcloud/servicediscovery/zookeeper/application_listener.go:207
↓ 1 callers
Function
containsSubstring
containsSubstring is a helper function for media type checking
pkg/filter/mcp/mcpserver/context.go:210
↓ 1 callers
Method
convertCluster
(irCluster *ir.Cluster, isGRPC bool)
controllers/internal/converter/converter.go:443
↓ 1 callers
Method
convertHTTPListener
(httpListener *ir.HTTPListener, clusters []*ir.Cluster)
controllers/internal/converter/converter.go:110
↓ 1 callers
Method
convertHTTPRoute
(irRoute *ir.HTTPRoute)
controllers/internal/converter/converter.go:221
↓ 1 callers
Function
convertHeaders
(headers []map[string]string)
pkg/adapter/mcpserver/registry/nacos/converter.go:95
↓ 1 callers
Function
convertInputSchemaToArgs
(inputSchema map[string]any, requestTemplate RequestTemplate)
pkg/adapter/mcpserver/registry/nacos/converter.go:107
↓ 1 callers
Function
convertSingleTool
(nacosTool NacosTool, templateData any)
pkg/adapter/mcpserver/registry/nacos/converter.go:60
↓ 1 callers
Method
convertTCPListener
(tcpListener *ir.TCPListener, clusters []*ir.Cluster)
controllers/internal/converter/converter.go:328
↓ 1 callers
Method
convertToInputSchema
convertToInputSchema converts tool parameters to MCP inputSchema format
pkg/filter/mcp/mcpserver/registry.go:188
↓ 1 callers
Method
convertTripleListener
(tcpListener *ir.TCPListener, clusters []*ir.Cluster)
controllers/internal/converter/converter.go:279
↓ 1 callers
Method
convertUDPListener
(udpListener *ir.UDPListener)
controllers/internal/converter/converter.go:426
↓ 1 callers
Function
copyHeader
(dst, src stdHttp.Header)
pkg/common/grpc/manager.go:160
↓ 1 callers
Method
createABIContextWrapper
(ctx *http.HttpContext)
pkg/wasm/service.go:108
↓ 1 callers
Function
createBrokenJSON
createBrokenJSON creates intentionally broken JSON for testing error handling
pkg/adapter/mcpserver/registry/nacos/client_test.go:113
↓ 1 callers
Method
createConnection
createConnection creates a new gRPC connection with optimized settings
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:419
↓ 1 callers
Function
createDubboFilter
(fs []*model.DubboFilter)
pkg/filter/network/dubboproxy/dubbofiltermanager.go:40
↓ 1 callers
Function
createGrpcFilter
(fs []*model.GrpcFilter)
pkg/filter/network/grpcproxy/grpc_filter_manager.go:40
↓ 1 callers
Method
createTLSCredentials
createTLSCredentials loads TLS certs for mTLS
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:481
↓ 1 callers
Function
createWasmService
(service model.WasmService)
pkg/wasm/service.go:67
↓ 1 callers
Function
createWeightedClusterConfig
Helper function to create a ClusterConfig with specific endpoints and weights for probabilistic testing
pkg/cluster/loadbalancer/weightrandom/weight_random_test.go:141
↓ 1 callers
Function
decompress
decompress reads all data from a reader and returns the decompressed byte slice.
pkg/filter/llm/tokenizer/tokenizer.go:367
↓ 1 callers
Function
deleteAPIFromMethod
(fullPath string, deleted config.Method, localSrv APIDiscoveryService)
pkg/filter/http/apiconfig/api/discovery_service.go:268
↓ 1 callers
Function
deleteApiConfigMethod
(resourceId, methodId int)
pkg/config/api_config.go:554
↓ 1 callers
Function
deleteApiConfigResource
(resourceId int)
pkg/config/api_config.go:523
↓ 1 callers
Function
determineArgLocation
(argName string, requestTemplate RequestTemplate)
pkg/adapter/mcpserver/registry/nacos/converter.go:146
↓ 1 callers
Function
determineStreamType
determineStreamType determines the StreamType based on client and server streaming flags
pkg/filter/network/grpcproxy/grpc_manager.go:59
↓ 1 callers
Function
doInitOTelInstruments
()
pkg/filter/metric/metric.go:108
↓ 1 callers
Method
ensureDataPlane
(ctx context.Context, gateway *gatewayv1.Gateway, configHash string)
controllers/internal/controller/gateway_controller.go:627
↓ 1 callers
Method
ensureGatewayConfigMap
(ctx context.Context, gateway *gatewayv1.Gateway)
controllers/internal/controller/gateway_controller.go:442
↓ 1 callers
Function
equal
equal checks if two string slices are equal.
pkg/hotreload/hotreload.go:104
↓ 1 callers
Method
evaluateEmbedded
evaluateEmbedded evaluates the policy using embedded OPA engine
pkg/filter/opa/opa.go:206
↓ 1 callers
Method
evaluateServer
evaluateServer evaluates the policy by calling OPA server REST API
pkg/filter/opa/opa.go:235
↓ 1 callers
Method
extractAndSetMetadata
extractAndSetMetadata extracts and sets gRPC metadata
pkg/filter/network/grpcproxy/grpc_manager.go:120
↓ 1 callers
Method
extractBackendResponse
extractBackendResponse extracts response data from the context
pkg/filter/mcp/mcpserver/handlers.go:550
↓ 1 callers
Function
extractBearer
extractBearer pulls the token from Authorization header value
pkg/filter/auth/mcp/filter.go:210
↓ 1 callers
Method
extractMethodName
extractMethodName extracts the method name from the full gRPC method string. For example, from "/package.Service/Method", it returns "Method".
pkg/filter/network/grpcproxy/grpc_manager.go:184
↓ 1 callers
Method
extractServiceName
extractServiceName extract service name from context or method name
pkg/filter/network/grpcproxy/grpc_manager.go:193
↓ 1 callers
Method
fetchCompareAndSet
()
pkg/adapter/springcloud/cloud.go:284
↓ 1 callers
Function
file_adapter_proto_rawDescGZIP
()
pkg/config/xds/model/adapter.pb.go:112
↓ 1 callers
Function
file_bootstrap_proto_init
()
pkg/config/xds/model/bootstrap.pb.go:443
↓ 1 callers
Function
file_extension_proto_init
()
pkg/config/xds/model/extension.pb.go:186
↓ 1 callers
Function
file_hello_grpc_proto_init
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:364
↓ 1 callers
Function
file_route_proto_init
()
pkg/config/xds/model/route.pb.go:345
↓ 1 callers
Function
file_samples_api_proto_init
()
tools/benchmark/api/samples_api.pb.go:274
↓ 1 callers
Method
fillMissingSlots
()
pkg/cluster/loadbalancer/maglev/permutation.go:129
↓ 1 callers
Function
fillTrieFromRoutes
(cfg *model.RouteConfiguration)
pkg/common/router/router.go:203
↓ 1 callers
Function
filterKeySetByAllowedAlgorithms
filterKeySetByAllowedAlgorithms filters a JWK set to only include keys
pkg/filter/auth/mcp/internal/validator/validator.go:85
↓ 1 callers
Method
firstFetch
()
pkg/adapter/springcloud/cloud.go:241
↓ 1 callers
Method
forwardClientToServer
forwardClientToServer forwards messages from the incoming client stream to the backend server stream.
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:249
↓ 1 callers
Method
forwardHeaders
forwardHeaders specific what headers should be forwarded
pkg/client/triple/triple.go:111
↓ 1 callers
Method
forwardServerToClient
forwardServerToClient forwards messages from the backend server stream to the incoming client stream.
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:291
↓ 1 callers
Function
fromInstanceToServiceInstance
(serviceName string, instance xdsmodel.Instance)
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:235
↓ 1 callers
Function
fromServiceFullKey
(fullKey string)
pkg/adapter/dubboregistry/registry/nacos/interface_listener.go:134
↓ 1 callers
Function
fromServiceKey
(serviceKey string)
pkg/adapter/dubboregistry/registry/nacos/application_listener.go:122
↓ 1 callers
Function
fromSubscribeServiceToServiceInstance
(instance xdsmodel.SubscribeService)
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:253
↓ 1 callers
Function
genRandomRequests
(n int, seed int64)
pkg/common/router/router_test.go:711
↓ 1 callers
Function
genRandomSpecsWithVars
(s varSyntax, n int, prefixRatio, headerOnlyRatio float64, seed int64)
pkg/common/router/router_test.go:637
↓ 1 callers
Function
generateInstance
(ss nacosModel.SubscribeService)
pkg/adapter/llmregistry/registry/nacos/listener.go:323
↓ 1 callers
Method
generatePerms
()
pkg/cluster/loadbalancer/maglev/permutation.go:146
↓ 1 callers
Function
generateToken
(c *gin.Context, username string)
admin/controller/account/guest.go:101
↓ 1 callers
Method
genericArgs
(req *client.Request)
pkg/client/dubbo/dubbo.go:238
↓ 1 callers
Function
getAttachedRoutesForListener
(ctx context.Context, mgrc client.Client, gateway gatewayv1.Gateway, listener gatewayv1.Listener)
controllers/internal/controller/utils.go:204
↓ 1 callers
Function
getCdsConfig
()
pkg/config/xds/cds_test.go:64
↓ 1 callers
Function
getCheckClusterRegexp
()
admin/logic/logic.go:632
↓ 1 callers
Function
getCheckListenerRegexp
()
admin/logic/logic.go:636
↓ 1 callers
Function
getCheckResourceRegexp
()
admin/logic/logic.go:628
↓ 1 callers
Function
getClusterId
()
admin/logic/logic.go:563
↓ 1 callers
Method
getClusterResourceReference
getClusterResourceReference get resources of cluster
pkg/config/xds/apiclient/grpc_envoy.go:417
↓ 1 callers
Method
getDescriptorCompose
(ctx context.Context, cfg *Config)
pkg/filter/http/grpcproxy/descriptor.go:87
↓ 1 callers
Method
getDescriptorSource
(ctx context.Context, cfg *Config)
pkg/filter/http/grpcproxy/descriptor.go:62
↓ 1 callers
Function
getEncoder
()
admin/core/zap.go:104
↓ 1 callers
Function
getExitCode
(e error)
controllers/cmd/pgctl/main.go:31
↓ 1 callers
Function
getFallbackPort
(scheme string)
pkg/adapter/mcpserver/common/util/url.go:121
↓ 1 callers
Method
getFileDescriptorCompose
(ctx context.Context, cfg *Config)
pkg/filter/http/grpcproxy/descriptor.go:128
↓ 1 callers
Function
getFilterPrefixKey
(unpublished bool)
admin/logic/logic.go:543
↓ 1 callers
Function
getListenerStatus
(ctx context.Context, mrgc client.Client, gateway *gatewayv1.Gateway)
controllers/internal/controller/utils.go:118
↓ 1 callers
Method
getMethods
getMethods return the methods of a service
pkg/adapter/dubboregistry/registry/zookeeper/application_service_listener.go:251
↓ 1 callers
Method
getMetrics
()
pkg/prometheus/prometheus.go:341
↓ 1 callers
Function
getMockMethod
(verb string)
pkg/filter/header/header_test.go:64
← previous
next →
1,201–1,300 of 3,410, ranked by callers