MCPcopy Create free account

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

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

MethodMapParams
(req *client.Request)
pkg/client/mq/mq.go:157
MethodMarshalText
()
controllers/internal/types/namespacednamekind.go:46
MethodMarshalYAML
()
controllers/internal/controller/config/config.go:159
MethodMatch
Match node match
pkg/common/router/trie/trie.go:198
MethodMethodAdd
MethodAdd handle add method event
pkg/filter/http/apiconfig/api/discovery_service.go:148
MethodMethodChange
MethodChange handle modify method event
pkg/filter/http/apiconfig/api/discovery_service.go:137
MethodMethodDelete
MethodDelete handle delete method event
pkg/filter/http/apiconfig/api/discovery_service.go:159
MethodMethodMapper
()
tools/benchmark/protocol/dubbo/go-server/pkg/user_provider.go:115
FunctionModifyMethodInfo
@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
FunctionModifyResourceInfo
@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
MethodMutate
(obj client.Object)
controllers/internal/controller/status/status.go:69
MethodName
()
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:318
FunctionNamespacedName
(obj client.Object)
controllers/internal/utils/utils.go:28
FunctionNamespacedNameKind
(obj client.Object)
controllers/internal/utils/utils.go:35
MethodNeedsLeaderElection
()
controllers/internal/controller/status/status.go:134
FunctionNewBaseRegistry
(facade FacadeRegistry, adapterListener common.RegistryEventListener, registerType registry.RegisteredType)
pkg/adapter/dubboregistry/registry/base/baseregistry.go:80
FunctionNewConverter
()
controllers/internal/converter/converter.go:33
FunctionNewGuestDao
TODO
admin/dao/impl/guest.go:38
FunctionNewMaglevHash
(config model.ConsistentHash, endpoints []*model.Endpoint)
pkg/cluster/loadbalancer/maglev/maglev_hash.go:32
FunctionNewMockDynamicResourceManager
NewMockDynamicResourceManager creates a new mock instance.
pkg/server/controls/mocks/mocks.go:182
FunctionNewMockListenerManager
NewMockListenerManager creates a new mock instance.
pkg/server/controls/mocks/mocks.go:133
FunctionNewPrometheus
NewPrometheus generates a new set of metrics with a certain subsystem name
pkg/prometheus/prometheus.go:266
FunctionNewStatusUpdateHandler
(log logr.Logger, client client.Client)
controllers/internal/controller/status/status.go:101
FunctionNewTranslator
(client client.Client, logger logr.Logger)
controllers/internal/translator/translator.go:48
FunctionNewUserDao
()
admin/dao/impl/user.go:39
FunctionNewUserProviderClient
(cc grpc.ClientConnInterface)
tools/benchmark/protocol/grpc/proto/hello_grpc_grpc.pb.go:54
FunctionNewZooKeeperClient
(name string, zkAddrs []string, timeout time.Duration)
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:75
MethodNext
Deprecated: Next logic for lookup filter
pkg/context/http/context.go:86
MethodNotifyAll
TODO: this function is useless for service listener
pkg/adapter/dubboregistry/registry/nacos/service_listener.go:171
MethodNumber
()
pkg/config/xds/model/listener.pb.go:92
MethodNumber
()
pkg/config/xds/model/health_check.pb.go:105
MethodNumber
()
pkg/config/xds/model/health_check.pb.go:157
MethodNumber
()
pkg/config/xds/model/health_check.pb.go:215
MethodOnAddAPI
(r router.API)
pkg/adapter/dubboregistry/registrycenter.go:119
MethodOnAddAPI
(r router.API)
pkg/adapter/dubboregistry/registry/zookeeper/registry_test.go:37
MethodOnAddAPI
(r router.API)
pkg/filter/http/apiconfig/api_config.go:88
MethodOnAddEndpoint
OnAddEndpoint is the callback that gets triggered when a new LLM endpoint is discovered.
pkg/adapter/llmregistry/registrycenter.go:128
MethodOnAddEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/registry/base/baseregistry_test.go:67
MethodOnAddEndpoint
(endpoint *model.Endpoint)
pkg/adapter/llmregistry/registry/nacos/listener_test.go:94
MethodOnAddRouter
OnAddRouter add router, every call of OnAdd will ADD a new rule, instead of OVERWRITE the same rule
pkg/common/router/router.go:196
MethodOnAddServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:162
MethodOnCheck
()
pkg/cluster/healthcheck/healthcheck.go:301
MethodOnClose
OnError called when session close
pkg/listener/tcp/server_handler.go:116
MethodOnCron
OnCron cron
pkg/listener/tcp/server_handler.go:237
MethodOnData
OnData handle dubbo rpc invocation
pkg/filterchain/network_filter_chain.go:68
MethodOnData
OnData receive data from listener
pkg/common/extension/filter/filter.go:169
MethodOnData
OnData handle dubbo rpc invocation
pkg/filter/network/dubboproxy/manager.go:144
MethodOnDecode
OnDecode decode bytes received from getty listener
pkg/filterchain/network_filter_chain.go:50
MethodOnDecode
OnDecode empty implement
pkg/common/extension/filter/filter.go:159
MethodOnDecode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:29
MethodOnDecode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:61
MethodOnDecode
OnDecode decode bytes to DecodeResult
pkg/filter/network/dubboproxy/manager.go:67
MethodOnDecode
(ctx *contextHttp.HttpContext)
pkg/filter/metric/metric_test.go:111
MethodOnDecode
(ctx *contextHttp.HttpContext)
pkg/filter/opa/opa_test.go:534
MethodOnDeleteRouter
OnDeleteRouter delete router
pkg/common/router/router.go:217
MethodOnDeleteRouter
OnDeleteRouter delete router
pkg/common/router/mock/router.go:160
MethodOnDeleteRouter
(r config.Resource)
pkg/adapter/dubboregistry/registrycenter.go:155
MethodOnDeleteRouter
(r config.Resource)
pkg/adapter/dubboregistry/registry/zookeeper/registry_test.go:45
MethodOnDeleteRouter
(r config.Resource)
pkg/filter/http/apiconfig/api_config.go:95
MethodOnDeleteServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:182
MethodOnEncode
OnEncode encode struct to bytes sent to getty listener
pkg/filterchain/network_filter_chain.go:59
MethodOnEncode
OnEncode empty implement
pkg/common/extension/filter/filter.go:164
MethodOnEncode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:30
MethodOnEncode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter_chain.go:74
MethodOnEncode
OnEncode encode Response to bytes
pkg/filter/network/dubboproxy/manager.go:82
MethodOnEncode
(ctx *contextHttp.HttpContext)
pkg/filter/metric/metric_test.go:115
MethodOnEncode
(ctx *contextHttp.HttpContext)
pkg/filter/opa/opa_test.go:538
MethodOnMessage
OnMessage called when session receive new pkg
pkg/listener/tcp/server_handler.go:124
MethodOnOpen
OnOpen called when session opens
pkg/listener/tcp/server_handler.go:89
MethodOnRemoveAPI
(r router.API)
pkg/adapter/dubboregistry/registrycenter.go:149
MethodOnRemoveAPI
(r router.API)
pkg/adapter/dubboregistry/registry/zookeeper/registry_test.go:41
MethodOnRemoveAPI
(r router.API)
pkg/filter/http/apiconfig/api_config.go:91
MethodOnRemoveEndpoint
OnRemoveEndpoint is the callback that gets triggered when an LLM endpoint is removed.
pkg/adapter/llmregistry/registrycenter.go:141
MethodOnRemoveEndpoint
(r *model.Endpoint)
pkg/adapter/llmregistry/registry/base/baseregistry_test.go:71
MethodOnRemoveEndpoint
(endpoint *model.Endpoint)
pkg/adapter/llmregistry/registry/nacos/listener_test.go:101
MethodOnStreamRPC
OnStreamRPC handles a streaming RPC call.
pkg/filterchain/network_filter_chain.go:95
MethodOnStreamRPC
OnStreamRPC empty implement
pkg/common/extension/filter/filter.go:184
MethodOnStreamRPC
OnStreamRPC handles a streaming RPC call.
pkg/filter/network/grpcproxy/grpc_manager.go:73
MethodOnTimeout
()
pkg/cluster/healthcheck/http.go:34
MethodOnTimeout
()
pkg/cluster/healthcheck/healthcheck.go:80
MethodOnTimeout
()
pkg/cluster/healthcheck/healthcheck.go:313
MethodOnTimeout
()
pkg/cluster/healthcheck/https.go:35
MethodOnTimeout
()
pkg/cluster/healthcheck/tcp.go:33
MethodOnTripleData
OnTripleData handle triple rpc invocation
pkg/filterchain/network_filter_chain.go:77
MethodOnTripleData
OnTripleData empty implement
pkg/common/extension/filter/filter.go:174
MethodOnTripleData
OnTripleData handle triple rpc invocation
pkg/filter/network/dubboproxy/manager.go:108
MethodOnUnaryRPC
OnUnaryRPC handles a unary RPC call.
pkg/filterchain/network_filter_chain.go:86
MethodOnUnaryRPC
OnUnaryRPC empty implement
pkg/common/extension/filter/filter.go:179
MethodOnUpdateServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:190
FunctionPageReset
* page generator * @param {String} name page name * @param {String} title page title
admin/web/vue.config.js:86
FunctionParseYamlBytes
(content []byte, v any)
pkg/configcenter/load.go:136
MethodPrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/common/http/manager_test.go:101
MethodPrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/common/mock/routerfilter.go:89
MethodPrepareFilterChain
(ctx *contexthttp.HttpContext, chain FilterChain)
pkg/common/extension/filter/filter_manager_test.go:88
MethodPrepareFilterChain
(ctx *http.HttpContext, chain filter.FilterChain)
pkg/filter/csrf/csrf.go:76
MethodPrepareFilterChain
(ctx *contextHttp.HttpContext, chain filter.FilterChain)
pkg/filter/failinject/filter.go:59
MethodPrepareFilterChain
PrepareFilterChain creates a new Filter instance for a request chain.
pkg/filter/llm/proxy/filter.go:137
MethodPrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/filter/llm/tokenizer/tokenizer.go:132
MethodPrepareFilterChain
(ctx *contexthttp.HttpContext, chain filter.FilterChain)
pkg/filter/http/remote/call.go:116
MethodPrepareFilterChain
(ctx *http.HttpContext, chain filter.FilterChain)
pkg/filter/http/grpcproxy/grpc.go:154
← previousnext →2,401–2,500 of 3,410, ranked by callers