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
SetContext
SetContext set golang context
pkg/context/grpc/context.go:90
↓ 1 callers
Function
SetGatewayConditionAccepted
(gw *gatewayv1.Gateway, status bool, message string)
controllers/internal/controller/utils.go:250
↓ 1 callers
Function
SetGatewayConditionProgrammed
(gw *gatewayv1.Gateway, status bool, message string)
controllers/internal/controller/utils.go:460
↓ 1 callers
Function
SetGatewayListenerConditionProgrammed
(gw *gatewayv1.Gateway, listenerName string, status bool, message string)
controllers/internal/controller/utils.go:477
↓ 1 callers
Function
SetGatewayListenerConditionResolvedRefs
(gw *gatewayv1.Gateway, listenerName string, status bool, message string)
controllers/internal/controller/utils.go:494
↓ 1 callers
Method
SetListener
(id string, listener zookeeper.Listener)
pkg/adapter/springcloud/servicediscovery/zookeeper/application_listener.go:189
↓ 1 callers
Method
SetListener
SetListener set the listener to the registry
pkg/adapter/dubboregistry/registry/base/baseregistry.go:54
↓ 1 callers
Method
SetMCPMethod
SetMCPMethod sets MCP method name
pkg/filter/mcp/mcpserver/context.go:67
↓ 1 callers
Method
SetMCPRequestID
SetMCPRequestID sets JSON-RPC request ID
pkg/filter/mcp/mcpserver/context.go:77
↓ 1 callers
Method
SetPushGateway
()
pkg/prometheus/prometheus.go:335
↓ 1 callers
Function
SetRegistry
SetRegistry registers a factory function for creating a new registry client.
pkg/adapter/llmregistry/registry/registry.go:41
↓ 1 callers
Method
SetSessionID
SessionID management methods SetSessionID sets MCP session ID
pkg/filter/mcp/mcpserver/context.go:124
↓ 1 callers
Method
SetSvcListener
SetSvcListener set the listener to the registry
pkg/adapter/llmregistry/registry/base/baseregistry.go:100
↓ 1 callers
Method
SetUrl
(url string)
pkg/context/http/context.go:134
↓ 1 callers
Method
SetZkClient
(*gxzookeeper.ZookeeperClient)
pkg/remote/zookeeper/client.go:79
↓ 1 callers
Method
SetupWithManager
(mgr manager.Manager)
controllers/internal/manager/controllers.go:54
↓ 1 callers
Method
ShutDown
ShutDown gracefully shuts down the listener.
pkg/listener/listener.go:42
↓ 1 callers
Function
SingletonTripleClient
SingletonTripleClient singleton dubbo clent
pkg/client/triple/triple.go:77
↓ 1 callers
Function
Start
(bs *model.Bootstrap)
pkg/server/pixiu_start.go:126
↓ 1 callers
Function
Start
Start start init etcd client and start admin http server
cmd/admin/admin.go:70
↓ 1 callers
Function
StartHotReload
StartHotReload initializes the hot reload process. It should be called when the project starts, e.g., in cmd/gateway.go.
pkg/hotreload/hotreload.go:53
↓ 1 callers
Method
StartListen
()
pkg/server/listener_manager.go:191
↓ 1 callers
Method
StartOne
(endpoint *model.Endpoint)
pkg/cluster/healthcheck/healthcheck.go:149
↓ 1 callers
Function
StartXdsClient
StartXdsClient create XdsClient and run. only one xds client create at first(singleton)
pkg/config/xds/xds.go:156
↓ 1 callers
Function
StartxDsServer
StartxDsServer RunXDSServerWithCache starts an xDS server at the gi.ven port.
admin/core/xds.go:87
↓ 1 callers
Method
Status
(code int)
pkg/context/base_context.go:35
↓ 1 callers
Function
Stop
()
pkg/config/xds/apiclient/grpc.go:80
↓ 1 callers
Function
Stop
()
cmd/admin/admin.go:74
↓ 1 callers
Method
Stop
()
pkg/client/mq/kafka_facade.go:201
↓ 1 callers
Method
Stop
Stop stop adapter lifetime
pkg/common/extension/adapter/adapter.go:47
↓ 1 callers
Method
StopOne
(endpoint *model.Endpoint)
pkg/cluster/healthcheck/healthcheck.go:145
↓ 1 callers
Method
String
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:250
↓ 1 callers
Method
String
()
tools/benchmark/protocol/dubbo/go-server/pkg/user.go:100
↓ 1 callers
Method
String
()
pkg/adapter/dubboregistry/registry/registry.go:54
↓ 1 callers
Method
String
()
pkg/adapter/dubboregistry/registry/nacos/application_listener.go:118
↓ 1 callers
Method
SupportsJSON
SupportsJSON checks if the Accept header includes application/json
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:65
↓ 1 callers
Function
TestEmbeddedAllowedRule
TestEmbeddedAllowedRule tests embedded mode with allowed request
pkg/filter/opa/opa_test.go:73
↓ 1 callers
Function
TestEmbeddedDeniedRule
TestEmbeddedDeniedRule tests embedded mode with denied request
pkg/filter/opa/opa_test.go:90
↓ 1 callers
Method
ToMCPPrompts
ToMCPPrompts converts prompt configurations to MCP prompt list
pkg/filter/mcp/mcpserver/registry.go:330
↓ 1 callers
Method
ToMCPResourceTemplates
ToMCPResourceTemplates converts resource template configurations to MCP resource template list
pkg/filter/mcp/mcpserver/registry.go:254
↓ 1 callers
Method
ToMCPResources
ToMCPResources converts resource configurations to MCP resource list using mcp-go structures
pkg/filter/mcp/mcpserver/registry.go:235
↓ 1 callers
Method
ToolCallError
ToolCallError creates an error tool call response
pkg/filter/mcp/mcpserver/response.go:82
↓ 1 callers
Method
ToolCallSuccess
ToolCallSuccess creates a successful tool call response
pkg/filter/mcp/mcpserver/response.go:68
↓ 1 callers
Method
TranslateBackendToCluster
(ctx context.Context, httpRoute *gatewayv1.HTTPRoute)
controllers/internal/translator/translator.go:296
↓ 1 callers
Method
TranslateGateway
(ctx context.Context, gateway *gatewayv1.Gateway)
controllers/internal/translator/translator.go:55
↓ 1 callers
Method
Type
()
pkg/config/xds/model/health_check.pb.go:101
↓ 1 callers
Function
TypePredicate
()
controllers/internal/controller/utils.go:67
↓ 1 callers
Method
UnmarshalJSON
(data []byte)
controllers/internal/controller/config/config.go:139
↓ 1 callers
Method
UpdateListener
(m *model.Listener)
pkg/server/controls/controls.go:35
↓ 1 callers
Method
UpdateRoutes
UpdateRoutes updates the routes in RouterManager with the provided new routes.
pkg/server/router_manager.go:64
↓ 1 callers
Method
Val
()
pkg/filter/http/grpcproxy/grpc.go:132
↓ 1 callers
Method
Validate
Validate validates the configuration based on mode.
pkg/filter/metric/config.go:67
↓ 1 callers
Function
ValidateImagePullPolicy
ValidateImagePullPolicy checks if the given policy is a valid Kubernetes ImagePullPolicy. Returns the validated policy or the default if invalid.
controllers/internal/controller/config/config.go:100
↓ 1 callers
Function
ValidateZookeeperClient
(container ZkClientFacade, zkName string)
pkg/remote/zookeeper/client.go:37
↓ 1 callers
Method
ViewConfig
ViewConfig returns the current remote configuration.
pkg/configcenter/configclient.go:31
↓ 1 callers
Function
Viper
(path ...string)
admin/core/viper.go:38
↓ 1 callers
Method
WaitGroup
()
pkg/remote/zookeeper/client.go:81
↓ 1 callers
Function
WithCheckUrl
(ck string)
pkg/client/mq/facade.go:75
↓ 1 callers
Function
WithConsumeUrl
(ch string)
pkg/client/mq/facade.go:69
↓ 1 callers
Function
WithConsumerGroup
(cp string)
pkg/client/mq/facade.go:81
↓ 1 callers
Function
WithIstioService
(serviceNames ...string)
pkg/config/xds/apiclient/grpc_envoy.go:52
↓ 1 callers
Function
WithTopic
(t string)
pkg/client/mq/facade.go:63
↓ 1 callers
Function
WithTopics
(t []string)
pkg/client/mq/facade.go:57
↓ 1 callers
Method
WriteHeader
(statusCode int)
pkg/context/http/context_test.go:45
↓ 1 callers
Function
WriteToFile
WriteToFile write message to access log file
pkg/filter/accesslog/log.go:80
↓ 1 callers
Method
Writer
()
controllers/internal/controller/status/status.go:84
↓ 1 callers
Function
Zap
()
admin/core/zap.go:38
↓ 1 callers
Method
ZkClientLock
()
pkg/remote/zookeeper/client.go:80
↓ 1 callers
Function
_hash1
(key string)
pkg/cluster/loadbalancer/maglev/permutation.go:281
↓ 1 callers
Function
_hash2
(key string)
pkg/cluster/loadbalancer/maglev/permutation.go:286
↓ 1 callers
Function
abs
(f float64)
pkg/cluster/loadbalancer/weightrandom/weight_random_test.go:223
↓ 1 callers
Function
acceptedMessage
(kind string)
controllers/internal/controller/utils.go:278
↓ 1 callers
Function
addFile
(fd *desc.FileDescriptor, fds map[string]*desc.FileDescriptor)
pkg/filter/http/grpcproxy/descriptor_operation.go:38
↓ 1 callers
Method
addListenerService
(ls listener.ListenerService, lsConf *model.Listener)
pkg/server/listener_manager.go:216
↓ 1 callers
Method
addNewService
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:280
↓ 1 callers
Method
addProvider
addProvider adds a provider to the validator
pkg/filter/auth/mcp/internal/validator/validator.go:194
↓ 1 callers
Method
addServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:252
↓ 1 callers
Function
afterResourcePathChange
(resourceId, path string, unpublished bool)
admin/controller/configInfo/configInfo.go:221
↓ 1 callers
Method
allocateContext
()
pkg/common/http/manager.go:75
↓ 1 callers
Function
apiKey
(ir *config.IntegrationRequest)
pkg/client/dubbo/dubbo.go:302
↓ 1 callers
Method
assembleClusterEndpoints
assembleClusterEndpoints assembles the cluster endpoints by formatting the ID, name and domains for each endpoint If endpoint.LLMMeta is not nil, the
pkg/server/cluster_manager.go:274
↓ 1 callers
Method
assembleRequest
assembleRequest creates a new http.Request for a specific endpoint.
pkg/filter/llm/proxy/filter.go:221
↓ 1 callers
Function
assertRouteByPathAndNameSame
helper: assert RouteByPathAndName behavior is the same
pkg/common/router/router_bench_test.go:189
↓ 1 callers
Method
asyncHandler
(read chan *apiclient.DeltaResources)
pkg/config/xds/lds.go:71
↓ 1 callers
Method
asyncHandler
(read chan *apiclient.DeltaResources)
pkg/config/xds/cds.go:66
↓ 1 callers
Method
awaitAndPublish
wait for timer and publish
pkg/common/router/router.go:151
↓ 1 callers
Method
backgroundSyncPeriod
()
pkg/adapter/springcloud/cloud.go:338
↓ 1 callers
Function
buildAccessLogMsg
(c *http.HttpContext, cost time.Duration)
pkg/filter/accesslog/access_log.go:118
↓ 1 callers
Method
buildBackendRequest
buildBackendRequest builds the complete backend request including path, body, and headers
pkg/filter/mcp/mcpserver/handlers.go:455
↓ 1 callers
Function
buildCredentialConfigKey
buildCredentialConfigKey constructs credential configuration key name Format: cred::<group>::<dataId>
pkg/adapter/mcpserver/registry/nacos/client.go:827
↓ 1 callers
Function
buildGrpcServerOptions
buildGrpcServerOptions creates gRPC server options from config
pkg/listener/grpc/grpc_listener.go:295
↓ 1 callers
Method
buildLoaderFromJWKS
buildLoaderFromJWKS parses provider.JWKS and constructs an appropriate loader.
pkg/filter/auth/mcp/internal/validator/validator.go:241
↓ 1 callers
Method
buildPingResponseObject
buildPingResponseObject builds the ping response object (for SSE)
pkg/filter/mcp/mcpserver/handlers.go:229
↓ 1 callers
Method
buildPromptMessages
buildPromptMessages builds prompt messages with parameter replacement support
pkg/filter/mcp/mcpserver/handlers.go:370
↓ 1 callers
Method
buildResourcesListResponseObject
buildResourcesListResponseObject builds the resources/list response object (for SSE)
pkg/filter/mcp/mcpserver/handlers.go:216
↓ 1 callers
Method
buildTargetResponse
(c *pch.HttpContext)
pkg/common/http/manager.go:213
↓ 1 callers
Method
buildToolParameterOptions
buildToolParameterOptions builds the mcp.PropertyOption slice for a given tool argument
pkg/filter/mcp/mcpserver/handlers.go:167
↓ 1 callers
Method
buildToolsListResponseObject
buildToolsListResponseObject builds the tools/list response object (for SSE)
pkg/filter/mcp/mcpserver/handlers.go:130
↓ 1 callers
Function
buildWithPixiuOptions
helper: build with unified pixiu options. - always AddCaller + AddCallerSkip(2) - AddStacktrace(Error+) only when stacktrace is not disabled in cfg
pkg/logger/logger.go:71
↓ 1 callers
Function
categorizeJWKSLoadError
categorizeJWKSLoadError maps loader errors to standardized error code/message
pkg/filter/auth/mcp/internal/validator/validator.go:147
← previous
next →
1,101–1,200 of 3,410, ranked by callers