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
Method
GetAllSvcListener
GetAllSvcListener get all the listener of the registry
pkg/adapter/dubboregistry/registry/base/baseregistry.go:97
↓ 1 callers
Method
GetApiConfigManager
()
pkg/server/pixiu_start.go:72
↓ 1 callers
Function
GetApiStatsResponse
()
pkg/filter/prometheus/metric_test.go:74
↓ 1 callers
Method
GetApplicationName
()
pkg/context/base_context.go:49
↓ 1 callers
Method
GetConfigType
()
pkg/config/xds/model/health_check.pb.go:1588
↓ 1 callers
Function
GetConsumerManagerKey
(topic []string, consumerGroup string)
pkg/client/mq/facade.go:32
↓ 1 callers
Function
GetDiscoveryType
(cfg *model.Bootstrap)
pkg/config/config_load.go:163
↓ 1 callers
Method
GetDriver
()
pkg/tracing/trace_manager.go:38
↓ 1 callers
Function
GetDubboFilterPlugin
GetDubboFilterPlugin get plugin by kind
pkg/common/extension/filter/filter.go:258
↓ 1 callers
Method
GetDynamicResourceManager
()
pkg/server/pixiu_start.go:76
↓ 1 callers
Function
GetEnableReferenceGrant
()
controllers/internal/controller/utils.go:63
↓ 1 callers
Method
GetEngineType
()
pkg/config/xds/model/health_check.pb.go:917
↓ 1 callers
Method
GetErr
(ctx context.Context, req *User)
tools/benchmark/protocol/dubbo/go-server/pkg/user_provider.go:86
↓ 1 callers
Method
GetGender
(i int32)
tools/benchmark/protocol/dubbo/go-server/pkg/user_provider.go:108
↓ 1 callers
Function
GetGrpcFilterPlugin
(kind string)
pkg/common/extension/filter/filter.go:280
↓ 1 callers
Method
GetHash
(key uint32)
pkg/model/lb.go:48
↓ 1 callers
Function
GetHttpConfig
(cfg *model.Bootstrap)
pkg/config/config_load.go:131
↓ 1 callers
Function
GetHttpFilterPlugin
GetHttpFilterPlugin get plugin by kind
pkg/common/extension/filter/filter.go:212
↓ 1 callers
Method
GetListener
(id string)
pkg/adapter/springcloud/servicediscovery/zookeeper/application_listener.go:179
↓ 1 callers
Method
GetListener
GetListener returns existing listener or nil
pkg/adapter/dubboregistry/registry/base/baseregistry.go:43
↓ 1 callers
Method
GetListenerService
(name string)
pkg/server/listener_manager.go:225
↓ 1 callers
Function
GetLoadBalance
(cfg *model.Bootstrap)
pkg/config/config_load.go:155
↓ 1 callers
Method
GetLocalReplyBody
()
pkg/context/http/context.go:192
↓ 1 callers
Function
GetNetworkFilterPlugin
GetNetworkFilterPlugin get plugin by kind
pkg/common/extension/filter/filter.go:235
↓ 1 callers
Function
GetPathParameterNames
GetPathParameterNames gets all parameter names in the path template
pkg/model/mcpserver.go:213
↓ 1 callers
Method
GetPreferredContentType
GetPreferredContentType returns the Content-Type header value for the given format
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:97
↓ 1 callers
Method
GetPrompt
GetPrompt gets a prompt
pkg/filter/mcp/mcpserver/registry.go:308
↓ 1 callers
Function
GetProtocol
(cfg *model.Bootstrap)
pkg/config/config_load.go:117
↓ 1 callers
Function
GetRegistry
GetRegistry creates and returns a new registry client based on the configuration. It panics if the registry client cannot be initialized.
pkg/adapter/llmregistry/registry/registry.go:47
↓ 1 callers
Function
GetRegistry
GetRegistry will return the registry if not found, it will panic
pkg/adapter/dubboregistry/registry/registry.go:84
↓ 1 callers
Function
GetResolver
GetResolver dynamically creates a resolver.
pkg/filter/http/remote/resolver/resolver.go:119
↓ 1 callers
Method
GetResourceByURI
GetResourceByURI gets resource configuration (by URI, O(1) lookup)
pkg/filter/mcp/mcpserver/registry.go:102
↓ 1 callers
Method
GetRouterManager
()
pkg/server/pixiu_start.go:68
↓ 1 callers
Function
GetServer
()
pkg/server/pixiu_start.go:135
↓ 1 callers
Method
GetService
(param vo.GetServiceParam)
pkg/adapter/mcpserver/registry/nacos/client_test.go:234
↓ 1 callers
Function
GetServiceRootID
(name string)
pkg/wasm/manager.go:74
↓ 1 callers
Function
GetSignKey
get signKey
admin/controller/auth/auth.go:101
↓ 1 callers
Method
GetSocketAddress
()
pkg/config/xds/model/address.pb.go:82
↓ 1 callers
Method
GetStaticListeners
()
pkg/model/bootstrap.go:53
↓ 1 callers
Method
GetTool
GetTool gets tool configuration
pkg/filter/mcp/mcpserver/registry.go:93
↓ 1 callers
Function
GetTraceDriverManager
()
pkg/server/pixiu_start.go:155
↓ 1 callers
Function
GetTripleLogger
()
pkg/logger/triple.go:25
↓ 1 callers
Method
GetURL
GetURL new url
pkg/client/request.go:49
↓ 1 callers
Method
GetUser0
(id string, name string)
tools/benchmark/protocol/dubbo/go-server/pkg/user_provider.go:59
↓ 1 callers
Method
GetUser2
(ctx context.Context, req int32)
tools/benchmark/protocol/dubbo/go-server/pkg/user_provider.go:73
↓ 1 callers
Function
GetUserInfo
(username string)
admin/logic/account/user.go:24
↓ 1 callers
Method
GetUserInfo
GetUserInfo get user info
admin/dao/daos.go:35
↓ 1 callers
Function
GetUserRole
(username string)
admin/logic/account/user.go:28
↓ 1 callers
Method
GetUserRole
GetUserRole get user role
admin/dao/daos.go:37
↓ 1 callers
Function
GetWriteSyncer
()
admin/utils/rotatelogs_unix.go:38
↓ 1 callers
Method
Handle
(hc *pch.HttpContext)
pkg/common/http/manager.go:81
↓ 1 callers
Function
HandleClientRestart
HandleClientRestart keeps the connection between client and server This method should be used only once. You can use handleClientRestart() in package
pkg/remote/zookeeper/client.go:89
↓ 1 callers
Method
HandleSuccess
()
pkg/cluster/healthcheck/healthcheck.go:265
↓ 1 callers
Method
HandleTimeout
()
pkg/cluster/healthcheck/healthcheck.go:281
↓ 1 callers
Method
HandleZkEvent
HandleZkEvent handles zookeeper events
pkg/adapter/dubboregistry/remoting/zookeeper/client.go:146
↓ 1 callers
Method
HasListener
(name string)
pkg/server/controls/controls.go:37
↓ 1 callers
Method
Hash
(key string)
pkg/model/lb.go:45
↓ 1 callers
Method
Hash
Hash the input key.
pkg/cluster/loadbalancer/maglev/permutation.go:189
↓ 1 callers
Method
Header
()
pkg/context/http/context_test.go:34
↓ 1 callers
Method
Header
()
pkg/context/mock/context.go:48
↓ 1 callers
Function
HostnamesIntersect
(a, b string)
controllers/internal/controller/utils.go:534
↓ 1 callers
Function
Init
(mysqlConf config.MysqlConfig)
admin/dao/database/initDB.go:40
↓ 1 callers
Method
InitAPIsFromConfig
(apiConfig config.APIConfig)
pkg/filter/http/apiconfig/api/discovery_service.go:35
↓ 1 callers
Method
InitAPIsFromConfig
InitAPIsFromConfig inits the router from API config and to local cache
pkg/filter/http/apiconfig/api/discovery_service.go:169
↓ 1 callers
Function
InitDefaultDubboClient
InitDefaultDubboClient init default dubbo client
pkg/client/dubbo/dubbo.go:113
↓ 1 callers
Function
InitDefaultTripleClient
InitDefaultTripleClient init default dubbo client
pkg/client/triple/triple.go:41
↓ 1 callers
Function
InitDriver
InitDriver loading BootStrap configuration about trace
pkg/tracing/driver.go:73
↓ 1 callers
Function
InitEtcdClient
InitEtcdClient init etcd client
admin/config/config.go:117
↓ 1 callers
Function
InitGuestDao
()
admin/logic/account/guest.go:29
↓ 1 callers
Function
InitLog
InitLog loads from YAML file; falls back to development defaults when file is absent/invalid.
pkg/logger/logger.go:83
↓ 1 callers
Function
InitProtosetSource
(protoset []string)
pkg/client/proxy/descriptor_source.go:49
↓ 1 callers
Function
InitUserDao
()
admin/logic/account/guest.go:35
↓ 1 callers
Function
InitWasmManager
InitWasmManager loads config in conf.yaml
pkg/wasm/manager.go:40
↓ 1 callers
Method
Inject
(ctx context.Context, carrier propagation.TextMapCarrier)
pkg/tracing/driver.go:125
↓ 1 callers
Function
Invoke
(ctx context.Context, stub grpcdynamic.Stub, mthDesc *desc.MethodDescriptor, grpcReq proto.Message, opts ...gr
pkg/filter/http/grpcproxy/invoke.go:35
↓ 1 callers
Function
IsHTTPRespSuccessful
IsHTTPRespSuccessful checks if the HTTP response status code indicates success (2xx).
pkg/common/util/response.go:185
↓ 1 callers
Method
IsMCPRequest
IsMCPRequest checks if it's an MCP request (by method name)
pkg/filter/mcp/mcpserver/context.go:62
↓ 1 callers
Method
IsMCPToolCall
IsMCPToolCall checks if it's a tool call request (by method name)
pkg/filter/mcp/mcpserver/context.go:87
↓ 1 callers
Function
IsSSEStream
IsSSEStream check if the response is a SSE stream
pkg/client/http/http.go:206
↓ 1 callers
Function
IsValidImagePullPolicy
IsValidImagePullPolicy checks if the given policy is valid
controllers/internal/controller/config/config.go:112
↓ 1 callers
Function
IsWildcard
IsWildcard return if is *
pkg/common/util/stringutil/stringutil.go:61
↓ 1 callers
Function
JWTAuth
@Tags Auth @Summary JWT check midware @Description Validate the token field in the request header, parse and verify the JWT. If verification fails, th
admin/controller/auth/auth.go:44
↓ 1 callers
Method
Kind
Kind returns the filter kind.
pkg/filter/metric/metric.go:73
↓ 1 callers
Function
ListMatchingRequests
(ctx context.Context, c client.Client, logger logr.Logger, listObj client.ObjectList, matchFunc func(obj clien
controllers/internal/controller/utils.go:90
↓ 1 callers
Method
ListPrompts
ListPrompts lists all prompts
pkg/filter/mcp/mcpserver/registry.go:317
↓ 1 callers
Method
ListResourceTemplates
ListResourceTemplates lists all resource templates
pkg/filter/mcp/mcpserver/registry.go:134
↓ 1 callers
Method
ListResources
ListResources lists all resources
pkg/filter/mcp/mcpserver/registry.go:158
↓ 1 callers
Method
Load
Load load api resource for matchers
pkg/filter/sentinel/matcher.go:43
↓ 1 callers
Function
LoadAPIConfig
LoadAPIConfig load the api config from config center
pkg/config/api_config.go:234
↓ 1 callers
Method
LoadAllClusterPolicies
LoadAllClusterPolicies loads all PixiuClusterPolicy in a namespace
controllers/internal/controller/policy_loader.go:128
↓ 1 callers
Method
LoadBootConfig
(path string)
pkg/config/config_load.go:197
↓ 1 callers
Method
LoadConfig
(properties map[string]any)
pkg/configcenter/configclient.go:26
↓ 1 callers
Method
LoadConfigs
(boot *model.Bootstrap, opts ...Option)
pkg/configcenter/load.go:44
↓ 1 callers
Method
LoadConfigs
(boot *model.Bootstrap, opts ...Option)
pkg/configcenter/load.go:86
↓ 1 callers
Method
LoadGatewayPolicy
LoadGatewayPolicy loads PixiuGatewayPolicy for a Gateway
controllers/internal/controller/policy_loader.go:50
↓ 1 callers
Method
LoadMCPDataFromParams
LoadMCPDataFromParams loads MCP data from HttpContext.Params
pkg/filter/mcp/mcpserver/context.go:100
↓ 1 callers
Function
Login
(username string, password string)
admin/logic/account/guest.go:41
↓ 1 callers
Method
Login
Login login
admin/dao/daos.go:23
↓ 1 callers
Function
MapInGrpcStruct
MapInGrpcStruct maps any config to GrpcConfig struct
pkg/model/listener.go:104
↓ 1 callers
Method
MapParams
MapParams param mapping to api.
pkg/client/http/http.go:139
← previous
next →
901–1,000 of 3,410, ranked by callers