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
Method
Apply
()
pkg/filter/event/event.go:90
Function
ApplyClusterConfig
ApplyClusterConfig applies PixiuClusterPolicy cluster config to a Cluster
controllers/internal/converter/policy_applier.go:142
Function
ApplyClusterPolicy
ApplyClusterPolicy applies PixiuClusterPolicy service config to a Cluster
controllers/internal/converter/policy_applier.go:104
Function
ApplyFilterPolicy
ApplyFilterPolicy applies PixiuFilterPolicy config to ir.HTTPFilter
controllers/internal/converter/policy_applier.go:162
Function
ApplyFilterPolicyToListener
ApplyFilterPolicyToListener applies PixiuFilterPolicy config to a Listener's network filter This is used for TCP listeners with dubboconnectionmanager
controllers/internal/converter/policy_applier.go:211
Function
ApplyGatewayPolicy
ApplyGatewayPolicy applies PixiuGatewayPolicy to PixiuConfig
controllers/internal/converter/policy_applier.go:41
Function
ApplyListenersRefToConfig
ApplyListenersRefToConfig applies PixiuFilterPolicy listenersRef to PixiuConfig
controllers/internal/converter/policy_applier.go:259
Method
Attempt
()
pkg/cluster/retry/retry_test.go:35
Method
Attempt
()
pkg/cluster/retry/retry_test.go:50
Method
Attempt
()
pkg/cluster/retry/exponentialbackoff/exponential_backoff.go:62
Method
Attempt
()
pkg/cluster/retry/noretry/no_retry.go:33
Method
Attempt
()
pkg/cluster/retry/countbased/count_based.go:44
Function
BRGetMethodList
BRGetMethodList GetMethodList
admin/logic/logic.go:309
Method
BatchRegisterInstance
(_ vo.BatchRegisterInstanceParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:219
Function
BatchReleaseMethod
@Tags Config @Summary batch Release Method Config @Description TODO: unimplemented @Produce application/json @Success 200 {object} string @Router /con
admin/controller/configInfo/configInfo.go:525
Function
BatchReleasePluginGroup
@Tags Config @Summary batch Release PluginGroup Config @Description publish the PluginGroup from the unpublished space to the published space. @Produc
admin/controller/configInfo/configInfo.go:536
Function
BatchReleaseResource
@Tags Config @Summary publish all configuration information @Description publish resources from unpublished spaces to published spaces @Produce applic
admin/controller/configInfo/configInfo.go:477
Function
BenchmarkApplyMcpServerConfig
============================================================================= Benchmark Tests ========================================================
pkg/filter/mcp/mcpserver/dynamic_test.go:417
Function
BenchmarkGetAllMetrics
BenchmarkGetAllMetrics benchmarks getting all metrics
pkg/context/http/context_test.go:765
Function
BenchmarkRecordMetric
BenchmarkRecordMetric benchmarks recording metrics
pkg/context/http/context_test.go:748
Function
BenchmarkReload100kLatency1Percent
(b *testing.B)
pkg/common/router/router_bench_test.go:419
Function
BenchmarkReloadLatency
============= Bench 3：read and write（1% write） =============
pkg/common/router/router_bench_test.go:296
Function
BenchmarkRoute100kReadParallel
(b *testing.B)
pkg/common/router/router_bench_test.go:373
Function
BenchmarkRoute100kReadThroughput
(b *testing.B)
pkg/common/router/router_bench_test.go:337
Function
BenchmarkRouteByPathAndName
============= Bench 4：RouteByPathAndName（API behavior must same） =============
pkg/common/router/router_bench_test.go:467
Function
BenchmarkRouteReadParallel
============= Bench 2：read throughput (parallel) =============
pkg/common/router/router_bench_test.go:247
Function
BenchmarkRouteReadThroughput
============= Bench 1：read throughput (one goroutine) =============
pkg/common/router/router_bench_test.go:208
Function
BuildController
BuildController builds a Nacos MCP registry controller
pkg/adapter/mcpserver/registry/nacos/adapter.go:47
Method
BuildFilters
()
pkg/context/base_context.go:44
Method
ByteSize
()
pkg/wasm/utils.go:81
Method
Call
Call invoke service
pkg/client/http/http.go:95
Method
Call
Call invoke service
pkg/client/triple/triple.go:82
Method
Call
(req *client.Request)
pkg/client/mq/mq.go:93
Method
Call
Call invoke service
pkg/client/dubbo/dubbo.go:176
Method
Callback
(services []xdsmodel.SubscribeService, err error)
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:105
Method
Callback
(services []nacosModel.SubscribeService, err error)
pkg/adapter/dubboregistry/registry/nacos/application_service_listener.go:77
Method
Callback
(services []nacosModel.SubscribeService, err error)
pkg/adapter/dubboregistry/registry/nacos/service_listener.go:72
Method
Cap
()
pkg/logger/logger_test.go:213
Function
Cb
(a)
admin/web/src/utils/three.js:443
Method
CheckHealth
()
pkg/cluster/healthcheck/http.go:29
Method
CheckHealth
()
pkg/cluster/healthcheck/https.go:29
Method
CheckHealth
()
pkg/cluster/healthcheck/tcp.go:29
Method
CheckLogin
CheckLogin check login
admin/dao/daos.go:25
Method
CheckLogin
()
admin/dao/impl/guest.go:89
Method
CheckUpdate
CheckUpdate compares the old and new route configurations to determine if a reload is needed.
pkg/hotreload/route_reloader.go:39
Method
CheckUpdate
CheckUpdate compares the old and new logger configurations to determine if a reload is needed.
pkg/hotreload/logger.go:33
Function
CheckUserIsAdmin
@Tags Account @Summary determine whether you are an administrator @Description to determine whether the current user is an administrator, the header m
admin/controller/account/user.go:151
Method
CheckUserIsAdmin
(username string)
admin/dao/impl/user.go:112
Method
Cleanup
(session sarama.ConsumerGroupSession)
pkg/client/mq/kafka_facade.go:117
Method
Clear
()
pkg/common/router/trie/trie.go:178
Method
ClearAPI
ClearAPI clear the api
pkg/router/route.go:53
Method
ClearAPI
ClearAPI clear all api
pkg/filter/http/apiconfig/api/discovery_service.go:85
Method
CloneXdsControlListener
()
pkg/server/listener_manager.go:171
Method
CloneXdsControlListener
()
pkg/config/xds/lds_test.go:201
Method
CloneXdsControlStore
CloneXdsControlStore clone cluster store for xds
pkg/server/cluster_manager.go:70
Method
CloneXdsControlStore
CloneXdsControlStore mocks base method.
pkg/server/controls/mocks/mocks.go:69
Method
CloneXdsControlStore
CloneXdsControlStore indicates an expected call of CloneXdsControlStore.
pkg/server/controls/mocks/mocks.go:78
Method
Close
Close close
pkg/client/http/http.go:90
Method
Close
Close clear GenericServicePool.
pkg/client/triple/triple.go:72
Method
Close
()
pkg/client/mq/mq.go:89
Method
Close
Close clear GenericServicePool.
pkg/client/dubbo/dubbo.go:166
Method
Close
Close closes this listener
pkg/remote/zookeeper/client.go:71
Method
Close
Close closes the filter chain and all filters in it.
pkg/filterchain/network_filter_chain.go:104
Method
Close
Close the filter and release resources
pkg/common/extension/filter/filter.go:110
Method
Close
()
pkg/common/extension/filter/filter.go:193
Method
Close
()
pkg/adapter/springcloud/servicediscovery/zookeeper/application_listener.go:57
Method
Close
Close closes this listener
pkg/adapter/springcloud/servicediscovery/zookeeper/service_listener.go:156
Method
Close
Close closes the controller
pkg/adapter/mcpserver/registry/nacos/controller.go:169
Method
Close
Close closes this listener
pkg/adapter/llmregistry/registry/listener.go:23
Method
Close
Close is a mock method.
pkg/adapter/llmregistry/registry/base/baseregistry_test.go:62
Method
Close
Close gracefully stops the listener.
pkg/adapter/llmregistry/registry/nacos/listener.go:240
Method
Close
()
pkg/adapter/dubboregistry/registry/nacos/application_listener.go:65
Method
Close
()
pkg/adapter/dubboregistry/registry/nacos/application_service_listener.go:72
Method
Close
()
pkg/adapter/dubboregistry/registry/nacos/interface_listener.go:75
Method
Close
Close closes this listener
pkg/adapter/dubboregistry/registry/nacos/service_listener.go:175
Method
Close
()
pkg/adapter/dubboregistry/registry/zookeeper/application_listener.go:66
Method
Close
Close closes this listener
pkg/adapter/dubboregistry/registry/zookeeper/application_service_listener.go:279
Method
Close
()
pkg/adapter/dubboregistry/registry/zookeeper/interface_listener.go:67
Method
Close
Close closes this listener
pkg/adapter/dubboregistry/registry/zookeeper/service_listener.go:181
Method
Close
()
pkg/listener/http/http_listener.go:85
Method
Close
Close stops the gRPC server immediately. It is a hard stop.
pkg/listener/grpc/grpc_listener.go:207
Method
Close
()
pkg/listener/triple/triple_listener.go:97
Method
Close
()
pkg/listener/http2/http2_listener.go:133
Method
Close
()
pkg/listener/tcp/tcp_listener.go:75
Method
Close
()
pkg/filter/llm/tokenizer/tokenizer.go:503
Method
Close
Close shuts down background resources
pkg/filter/auth/mcp/internal/validator/validator.go:352
Method
Close
()
pkg/filter/network/grpcproxy/grpc_manager.go:104
Method
Close
Close gracefully closes all connections and cleans up resources
pkg/filter/network/grpcproxy/filter/proxy/grpc_proxy_filter.go:496
Method
Close
()
pkg/config/xds/apiclient/grpc.go:332
Method
CloseClient
()
pkg/adapter/mcpserver/registry/nacos/client_test.go:205
Method
CloseClient
()
pkg/adapter/mcpserver/registry/nacos/client_test.go:284
Method
CloseClient
CloseClient closes the client and cleans up all resources
pkg/adapter/mcpserver/registry/nacos/client.go:377
Function
CloseEtcdClient
CloseEtcdClient close etcd client
admin/config/config.go:133
Method
Config
Config get config for Adapter
pkg/server/adapter_manager_test.go:63
Method
Config
()
pkg/server/cluster_manager.go:65
Method
Config
Config mocks base method.
pkg/server/controls/mocks/mocks.go:259
Method
Config
Config indicates an expected call of Config.
pkg/server/controls/mocks/mocks.go:267
Method
Config
()
pkg/common/http/manager_test.go:110
Method
Config
()
pkg/common/mock/routerfilter.go:71
Method
Config
Config get config for Adapter
pkg/common/extension/adapter/adapter_test.go:56
← previous
next →
1,701–1,800 of 3,410, ranked by callers