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
Reset
()
pkg/config/xds/model/health_check.pb.go:1549
Method
Reset
()
pkg/config/xds/model/health_check.pb.go:1628
Method
Reset
()
pkg/config/xds/model/health_check.pb.go:1697
Method
Reset
()
pkg/cluster/retry/retry_test.go:36
Method
Reset
()
pkg/cluster/retry/retry_test.go:51
Method
Reset
()
pkg/cluster/retry/exponentialbackoff/exponential_backoff.go:80
Method
Reset
()
pkg/cluster/retry/noretry/no_retry.go:41
Method
Reset
()
pkg/cluster/retry/countbased/count_based.go:52
Method
ResourceAdd
ResourceAdd handle add resource event
pkg/filter/http/apiconfig/api/discovery_service.go:118
Method
ResourceChange
ResourceChange handle modify resource event
pkg/filter/http/apiconfig/api/discovery_service.go:110
Method
ResourceDelete
ResourceDelete handle delete resource event
pkg/filter/http/apiconfig/api/discovery_service.go:129
Method
Response
()
pkg/context/base_context.go:56
Method
RestartCallBack
()
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:342
Method
Route
(req *stdHttp.Request)
pkg/model/router.go:96
Method
RouteByPathAndName
(path, method string)
pkg/common/router/mock/router.go:72
Function
Run
(ctx context.Context, logger logr.Logger)
controllers/internal/manager/run.go:72
Method
Run
Run starts the controller, periodically discovering and watching MCP services
pkg/adapter/mcpserver/registry/nacos/controller.go:60
Method
SayHello
(ctx context.Context, in *pb.HelloRequest)
tools/benchmark/protocol/triple/pb/go-server/pkg/greeter.go:34
Method
SayHello
(ctx context.Context, in *HelloRequest, opts ...grpc_go.CallOption)
tools/benchmark/api/samples_api_triple.pb.go:82
Method
SayHello
Sends a greeting
tools/benchmark/api/samples_api_triple.pb.go:125
Method
SayHello
(context.Context, *HelloRequest)
tools/benchmark/api/samples_api_triple.pb.go:136
Method
SayHelloStream
(ctx context.Context, opts ...grpc_go.CallOption)
tools/benchmark/api/samples_api_triple.pb.go:88
Method
SayHelloStream
Sends a greeting via stream
tools/benchmark/api/samples_api_triple.pb.go:127
Method
SayHelloStream
(Greeter_SayHelloStreamServer)
tools/benchmark/api/samples_api_triple.pb.go:139
Method
SelectAllInstances
(_ vo.SelectAllInstancesParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:247
Method
SelectInstances
(param vo.SelectInstancesParam)
pkg/remote/nacos/client.go:49
Method
SelectOneHealthyInstance
(_ vo.SelectOneHealthInstanceParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:257
Method
Send
(*HelloRequest)
tools/benchmark/api/samples_api_triple.pb.go:99
Method
Send
(m *HelloRequest)
tools/benchmark/api/samples_api_triple.pb.go:108
Method
Send
(*User)
tools/benchmark/api/samples_api_triple.pb.go:217
Method
Send
(m *User)
tools/benchmark/api/samples_api_triple.pb.go:226
Method
Send
(msgs []string, opts ...Option)
pkg/client/mq/kafka_facade.go:234
Method
SendMsg
SendMsg implements model.RPCStream interface
pkg/listener/grpc/grpc_listener.go:405
Method
ServeHTTP
ServeHTTP handle http request
pkg/filterchain/network_filter_chain.go:42
Method
ServeHTTP
(w stdHttp.ResponseWriter, r *stdHttp.Request)
pkg/common/http/manager.go:91
Method
ServeHTTP
ServeHTTP handle request and response
pkg/common/grpc/manager.go:63
Method
ServeHTTP
ServeHTTP empty implement
pkg/common/extension/filter/filter.go:189
Method
ServeHTTP
ServeHTTP http request entrance.
pkg/listener/http/http_listener.go:177
Method
ServeHTTP
ServeHTTP call Handler to handle http request and response.
pkg/listener/http2/http2_listener.go:66
Method
ServeHTTP
ServeHTTP call FilterChain to handle http request and response.
pkg/listener/http2/http2_listener.go:71
Method
ServerHealthy
()
pkg/adapter/mcpserver/registry/nacos/client_test.go:279
Method
SetAcceptJSON
SetAcceptJSON sets if client accepts application/json
pkg/filter/mcp/mcpserver/context.go:151
Method
SetAcceptSSE
Accept header management methods SetAcceptSSE sets if client accepts text/event-stream
pkg/filter/mcp/mcpserver/context.go:141
Method
SetAttachment
SetAttachment set attachment
pkg/context/grpc/context.go:72
Function
SetBaseInfo
@Tags Config @Summary modify pixiu base info such as name,desc @Description Pass YAML content through the form's content field to set basic informatio
admin/controller/configInfo/configInfo.go:69
Function
SetEnableReferenceGrant
(enable bool)
controllers/internal/controller/utils.go:59
Method
SetEndpoint
(clusterName string, endpoint *model.Endpoint)
pkg/server/cluster_manager.go:105
Method
SetError
SetError set error in RpcResult
pkg/context/dubbo/context.go:42
Method
SetProtocolVersion
Protocol version management methods SetProtocolVersion sets MCP protocol version
pkg/filter/mcp/mcpserver/context.go:163
Method
SetResult
SetResult set successful result in RpcResult
pkg/context/dubbo/context.go:50
Method
SetRoute
SetRoute set route
pkg/context/grpc/context.go:80
Method
SetRouteEntry
(ra *model.RouteAction)
pkg/context/base_context.go:47
Method
SetStream
SetStream sets the RPCStream for streaming operations
pkg/context/grpc/context.go:125
Method
SetZkClient
(client *gxzookeeper.ZookeeperClient)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:326
Method
Setup
(session sarama.ConsumerGroupSession)
pkg/client/mq/kafka_facade.go:113
Function
SetupIndexer
(mgr ctrl.Manager)
controllers/internal/controller/indexer/indexer.go:39
Method
SetupWithManager
SetupWithManager sets up the controller with the Manager.
controllers/internal/controller/gateway_controller.go:78
Method
SetupWithManager
SetupWithManager sets up the controller with the Manager.
controllers/internal/controller/gatewayclass_controller.go:63
Method
ShutDown
(wg any)
pkg/listener/http/http_listener.go:89
Method
ShutDown
ShutDown gracefully shuts down the gRPC listener
pkg/listener/grpc/grpc_listener.go:217
Method
ShutDown
(wg any)
pkg/listener/triple/triple_listener.go:102
Method
ShutDown
(wg any)
pkg/listener/http2/http2_listener.go:137
Method
ShutDown
(wg any)
pkg/listener/tcp/tcp_listener.go:80
Function
SingletonHTTPClient
SingletonHTTPClient singleton HTTP Client
pkg/client/http/http.go:70
Function
SingletonPool
SingletonPool singleton pool
pkg/pool/pool.go:61
Method
Start
(ctx context.Context)
controllers/internal/controller/status/status.go:113
Method
Start
()
pkg/server/adapter_manager_test.go:53
Method
Start
Start server start
pkg/server/pixiu_start.go:85
Method
Start
()
pkg/server/adapter_manager.go:42
Method
Start
()
pkg/common/extension/adapter/adapter_test.go:60
Method
Start
Start start the adapter
pkg/adapter/springcloud/cloud.go:108
Method
Start
Start starts the adapter
pkg/adapter/mcpserver/registrycenter.go:92
Method
Start
Start starts the adapter by subscribing to all configured registries.
pkg/adapter/llmregistry/registrycenter.go:83
Method
Start
Start starts the adaptor
pkg/adapter/dubboregistry/registrycenter.go:79
Method
Start
Start start the listener
pkg/listener/http/http_listener.go:73
Method
Start
Start initializes and starts the gRPC server
pkg/listener/grpc/grpc_listener.go:101
Method
Start
Start start triple server
pkg/listener/triple/triple_listener.go:92
Method
Start
Start start listen
pkg/listener/http2/http2_listener.go:95
Method
Start
Start start tcp server
pkg/listener/tcp/tcp_listener.go:70
Method
Start
()
pkg/cluster/healthcheck/healthcheck.go:132
Method
Start
()
pkg/cluster/healthcheck/healthcheck.go:214
Method
StartPeriodicalRefresh
()
pkg/adapter/springcloud/servicediscovery/nacos/nacos.go:216
Method
StatusCode
(code int)
pkg/context/http/context.go:200
Method
Stop
()
pkg/server/adapter_manager_test.go:67
Method
Stop
()
pkg/server/adapter_manager.go:48
Method
Stop
()
pkg/common/extension/adapter/adapter_test.go:64
Method
Stop
Stop stop the adapter
pkg/adapter/springcloud/cloud.go:131
Method
Stop
Stop stops the adapter
pkg/adapter/mcpserver/registrycenter.go:117
Method
Stop
Stop stops the adapter by unsubscribing from all registries.
pkg/adapter/llmregistry/registrycenter.go:93
Method
Stop
Stop stops the adaptor
pkg/adapter/dubboregistry/registrycenter.go:88
Method
Stop
()
pkg/config/xds/xds.go:140
Method
Stop
()
pkg/cluster/cluster.go:43
Method
Stop
()
pkg/cluster/healthcheck/healthcheck.go:139
Method
Stop
()
pkg/cluster/healthcheck/healthcheck.go:259
Method
String
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:61
Method
String
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:108
Method
String
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:155
Method
String
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:202
Method
String
()
tools/benchmark/protocol/dubbo/go-server/pkg/user.go:51
Method
String
()
tools/benchmark/protocol/dubbo/go-client/pkg/user.go:52
← previous
next →
2,701–2,800 of 3,410, ranked by callers