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
MapParams
(req *client.Request)
pkg/client/mq/mq.go:157
Method
MarshalText
()
controllers/internal/types/namespacednamekind.go:46
Method
MarshalYAML
()
controllers/internal/controller/config/config.go:159
Method
Match
Match node match
pkg/common/router/trie/trie.go:198
Method
MethodAdd
MethodAdd handle add method event
pkg/filter/http/apiconfig/api/discovery_service.go:148
Method
MethodChange
MethodChange handle modify method event
pkg/filter/http/apiconfig/api/discovery_service.go:137
Method
MethodDelete
MethodDelete handle delete method event
pkg/filter/http/apiconfig/api/discovery_service.go:159
Method
MethodMapper
()
tools/benchmark/protocol/dubbo/go-server/pkg/user_provider.go:115
Function
ModifyMethodInfo
@Tags Config @Summary modify method @Description Modify the specified method, where content is the YAML for Method. @Accept application/x-www-form-url
admin/controller/configInfo/configInfo.go:416
Function
ModifyResourceInfo
@Tags Config @Summary modify resource @Description modify resource content, where content is the YAML of the Resource. Use resourceId to specify the r
admin/controller/configInfo/configInfo.go:182
Method
Mutate
(obj client.Object)
controllers/internal/controller/status/status.go:69
Method
Name
()
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:318
Function
NamespacedName
(obj client.Object)
controllers/internal/utils/utils.go:28
Function
NamespacedNameKind
(obj client.Object)
controllers/internal/utils/utils.go:35
Method
NeedsLeaderElection
()
controllers/internal/controller/status/status.go:134
Function
NewBaseRegistry
(facade FacadeRegistry, adapterListener common.RegistryEventListener, registerType registry.RegisteredType)
pkg/adapter/dubboregistry/registry/base/baseregistry.go:80
Function
NewConverter
()
controllers/internal/converter/converter.go:33
Function
NewGuestDao
TODO
admin/dao/impl/guest.go:38
Function
NewMaglevHash
(config model.ConsistentHash, endpoints []*model.Endpoint)
pkg/cluster/loadbalancer/maglev/maglev_hash.go:32
Function
NewMockDynamicResourceManager
NewMockDynamicResourceManager creates a new mock instance.
pkg/server/controls/mocks/mocks.go:182
Function
NewMockListenerManager
NewMockListenerManager creates a new mock instance.
pkg/server/controls/mocks/mocks.go:133
Function
NewPrometheus
NewPrometheus generates a new set of metrics with a certain subsystem name
pkg/prometheus/prometheus.go:266
Function
NewStatusUpdateHandler
(log logr.Logger, client client.Client)
controllers/internal/controller/status/status.go:101
Function
NewTranslator
(client client.Client, logger logr.Logger)
controllers/internal/translator/translator.go:48
Function
NewUserDao
()
admin/dao/impl/user.go:39
Function
NewUserProviderClient
(cc grpc.ClientConnInterface)
tools/benchmark/protocol/grpc/proto/hello_grpc_grpc.pb.go:54
Function
NewZooKeeperClient
(name string, zkAddrs []string, timeout time.Duration)
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:75
Method
Next
Deprecated: Next logic for lookup filter
pkg/context/http/context.go:86
Method
NotifyAll
TODO: this function is useless for service listener
pkg/adapter/dubboregistry/registry/nacos/service_listener.go:171
Method
Number
()
pkg/config/xds/model/listener.pb.go:92
Method
Number
()
pkg/config/xds/model/health_check.pb.go:105
Method
Number
()
pkg/config/xds/model/health_check.pb.go:157
Method
Number
()
pkg/config/xds/model/health_check.pb.go:215
Method
OnAddAPI
(r router.API)
pkg/adapter/dubboregistry/registrycenter.go:119
Method
OnAddAPI
(r router.API)
pkg/adapter/dubboregistry/registry/zookeeper/registry_test.go:37
Method
OnAddAPI
(r router.API)
pkg/filter/http/apiconfig/api_config.go:88
Method
OnAddEndpoint
OnAddEndpoint is the callback that gets triggered when a new LLM endpoint is discovered.
pkg/adapter/llmregistry/registrycenter.go:128
Method
OnAddEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/registry/base/baseregistry_test.go:67
Method
OnAddEndpoint
(endpoint *model.Endpoint)
pkg/adapter/llmregistry/registry/nacos/listener_test.go:94
Method
OnAddRouter
OnAddRouter add router, every call of OnAdd will ADD a new rule, instead of OVERWRITE the same rule
pkg/common/router/router.go:196
Method
OnAddServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:162
Method
OnCheck
()
pkg/cluster/healthcheck/healthcheck.go:301
Method
OnClose
OnError called when session close
pkg/listener/tcp/server_handler.go:116
Method
OnCron
OnCron cron
pkg/listener/tcp/server_handler.go:237
Method
OnData
OnData handle dubbo rpc invocation
pkg/filterchain/network_filter_chain.go:68
Method
OnData
OnData receive data from listener
pkg/common/extension/filter/filter.go:169
Method
OnData
OnData handle dubbo rpc invocation
pkg/filter/network/dubboproxy/manager.go:144
Method
OnDecode
OnDecode decode bytes received from getty listener
pkg/filterchain/network_filter_chain.go:50
Method
OnDecode
OnDecode empty implement
pkg/common/extension/filter/filter.go:159
Method
OnDecode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:29
Method
OnDecode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:61
Method
OnDecode
OnDecode decode bytes to DecodeResult
pkg/filter/network/dubboproxy/manager.go:67
Method
OnDecode
(ctx *contextHttp.HttpContext)
pkg/filter/metric/metric_test.go:111
Method
OnDecode
(ctx *contextHttp.HttpContext)
pkg/filter/opa/opa_test.go:534
Method
OnDeleteRouter
OnDeleteRouter delete router
pkg/common/router/router.go:217
Method
OnDeleteRouter
OnDeleteRouter delete router
pkg/common/router/mock/router.go:160
Method
OnDeleteRouter
(r config.Resource)
pkg/adapter/dubboregistry/registrycenter.go:155
Method
OnDeleteRouter
(r config.Resource)
pkg/adapter/dubboregistry/registry/zookeeper/registry_test.go:45
Method
OnDeleteRouter
(r config.Resource)
pkg/filter/http/apiconfig/api_config.go:95
Method
OnDeleteServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:182
Method
OnEncode
OnEncode encode struct to bytes sent to getty listener
pkg/filterchain/network_filter_chain.go:59
Method
OnEncode
OnEncode empty implement
pkg/common/extension/filter/filter.go:164
Method
OnEncode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:30
Method
OnEncode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:74
Method
OnEncode
OnEncode encode Response to bytes
pkg/filter/network/dubboproxy/manager.go:82
Method
OnEncode
(ctx *contextHttp.HttpContext)
pkg/filter/metric/metric_test.go:115
Method
OnEncode
(ctx *contextHttp.HttpContext)
pkg/filter/opa/opa_test.go:538
Method
OnMessage
OnMessage called when session receive new pkg
pkg/listener/tcp/server_handler.go:124
Method
OnOpen
OnOpen called when session opens
pkg/listener/tcp/server_handler.go:89
Method
OnRemoveAPI
(r router.API)
pkg/adapter/dubboregistry/registrycenter.go:149
Method
OnRemoveAPI
(r router.API)
pkg/adapter/dubboregistry/registry/zookeeper/registry_test.go:41
Method
OnRemoveAPI
(r router.API)
pkg/filter/http/apiconfig/api_config.go:91
Method
OnRemoveEndpoint
OnRemoveEndpoint is the callback that gets triggered when an LLM endpoint is removed.
pkg/adapter/llmregistry/registrycenter.go:141
Method
OnRemoveEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/registry/base/baseregistry_test.go:71
Method
OnRemoveEndpoint
(endpoint *model.Endpoint)
pkg/adapter/llmregistry/registry/nacos/listener_test.go:101
Method
OnStreamRPC
OnStreamRPC handles a streaming RPC call.
pkg/filterchain/network_filter_chain.go:95
Method
OnStreamRPC
OnStreamRPC empty implement
pkg/common/extension/filter/filter.go:184
Method
OnStreamRPC
OnStreamRPC handles a streaming RPC call.
pkg/filter/network/grpcproxy/grpc_manager.go:73
Method
OnTimeout
()
pkg/cluster/healthcheck/http.go:34
Method
OnTimeout
()
pkg/cluster/healthcheck/healthcheck.go:80
Method
OnTimeout
()
pkg/cluster/healthcheck/healthcheck.go:313
Method
OnTimeout
()
pkg/cluster/healthcheck/https.go:35
Method
OnTimeout
()
pkg/cluster/healthcheck/tcp.go:33
Method
OnTripleData
OnTripleData handle triple rpc invocation
pkg/filterchain/network_filter_chain.go:77
Method
OnTripleData
OnTripleData empty implement
pkg/common/extension/filter/filter.go:174
Method
OnTripleData
OnTripleData handle triple rpc invocation
pkg/filter/network/dubboproxy/manager.go:108
Method
OnUnaryRPC
OnUnaryRPC handles a unary RPC call.
pkg/filterchain/network_filter_chain.go:86
Method
OnUnaryRPC
OnUnaryRPC empty implement
pkg/common/extension/filter/filter.go:179
Method
OnUpdateServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:190
Function
PageReset
* page generator * @param {String} name page name * @param {String} title page title
admin/web/vue.config.js:86
Function
ParseYamlBytes
(content []byte, v any)
pkg/configcenter/load.go:136
Method
PrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/common/http/manager_test.go:101
Method
PrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/common/mock/routerfilter.go:89
Method
PrepareFilterChain
(ctx *contexthttp.HttpContext, chain FilterChain)
pkg/common/extension/filter/filter_manager_test.go:88
Method
PrepareFilterChain
(ctx *http.HttpContext, chain filter.FilterChain)
pkg/filter/csrf/csrf.go:76
Method
PrepareFilterChain
(ctx *contextHttp.HttpContext, chain filter.FilterChain)
pkg/filter/failinject/filter.go:59
Method
PrepareFilterChain
PrepareFilterChain creates a new Filter instance for a request chain.
pkg/filter/llm/proxy/filter.go:137
Method
PrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/filter/llm/tokenizer/tokenizer.go:132
Method
PrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/filter/http/remote/call.go:116
Method
PrepareFilterChain
(ctx *http.HttpContext, chain filter.FilterChain)
pkg/filter/http/grpcproxy/grpc.go:154
← previous
next →
2,401–2,500 of 3,410, ranked by callers