MCPcopy Create free account

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

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

↓ 1 callersMethodSetContext
SetContext set golang context
pkg/context/grpc/context.go:90
↓ 1 callersFunctionSetGatewayConditionAccepted
(gw *gatewayv1.Gateway, status bool, message string)
controllers/internal/controller/utils.go:250
↓ 1 callersFunctionSetGatewayConditionProgrammed
(gw *gatewayv1.Gateway, status bool, message string)
controllers/internal/controller/utils.go:460
↓ 1 callersFunctionSetGatewayListenerConditionProgrammed
(gw *gatewayv1.Gateway, listenerName string, status bool, message string)
controllers/internal/controller/utils.go:477
↓ 1 callersFunctionSetGatewayListenerConditionResolvedRefs
(gw *gatewayv1.Gateway, listenerName string, status bool, message string)
controllers/internal/controller/utils.go:494
↓ 1 callersMethodSetListener
(id string, listener zookeeper.Listener)
pkg/adapter/springcloud/servicediscovery/zookeeper/application_listener.go:189
↓ 1 callersMethodSetListener
SetListener set the listener to the registry
pkg/adapter/dubboregistry/registry/base/baseregistry.go:54
↓ 1 callersMethodSetMCPMethod
SetMCPMethod sets MCP method name
pkg/filter/mcp/mcpserver/context.go:67
↓ 1 callersMethodSetMCPRequestID
SetMCPRequestID sets JSON-RPC request ID
pkg/filter/mcp/mcpserver/context.go:77
↓ 1 callersMethodSetPushGateway
()
pkg/prometheus/prometheus.go:335
↓ 1 callersFunctionSetRegistry
SetRegistry registers a factory function for creating a new registry client.
pkg/adapter/llmregistry/registry/registry.go:41
↓ 1 callersMethodSetSessionID
SessionID management methods SetSessionID sets MCP session ID
pkg/filter/mcp/mcpserver/context.go:124
↓ 1 callersMethodSetSvcListener
SetSvcListener set the listener to the registry
pkg/adapter/llmregistry/registry/base/baseregistry.go:100
↓ 1 callersMethodSetUrl
(url string)
pkg/context/http/context.go:134
↓ 1 callersMethodSetZkClient
(*gxzookeeper.ZookeeperClient)
pkg/remote/zookeeper/client.go:79
↓ 1 callersMethodSetupWithManager
(mgr manager.Manager)
controllers/internal/manager/controllers.go:54
↓ 1 callersMethodShutDown
ShutDown gracefully shuts down the listener.
pkg/listener/listener.go:42
↓ 1 callersFunctionSingletonTripleClient
SingletonTripleClient singleton dubbo clent
pkg/client/triple/triple.go:77
↓ 1 callersFunctionStart
(bs *model.Bootstrap)
pkg/server/pixiu_start.go:126
↓ 1 callersFunctionStart
Start start init etcd client and start admin http server
cmd/admin/admin.go:70
↓ 1 callersFunctionStartHotReload
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 callersMethodStartListen
()
pkg/server/listener_manager.go:191
↓ 1 callersMethodStartOne
(endpoint *model.Endpoint)
pkg/cluster/healthcheck/healthcheck.go:149
↓ 1 callersFunctionStartXdsClient
StartXdsClient create XdsClient and run. only one xds client create at first(singleton)
pkg/config/xds/xds.go:156
↓ 1 callersFunctionStartxDsServer
StartxDsServer RunXDSServerWithCache starts an xDS server at the gi.ven port.
admin/core/xds.go:87
↓ 1 callersMethodStatus
(code int)
pkg/context/base_context.go:35
↓ 1 callersFunctionStop
()
pkg/config/xds/apiclient/grpc.go:80
↓ 1 callersFunctionStop
()
cmd/admin/admin.go:74
↓ 1 callersMethodStop
()
pkg/client/mq/kafka_facade.go:201
↓ 1 callersMethodStop
Stop stop adapter lifetime
pkg/common/extension/adapter/adapter.go:47
↓ 1 callersMethodStopOne
(endpoint *model.Endpoint)
pkg/cluster/healthcheck/healthcheck.go:145
↓ 1 callersMethodString
()
tools/benchmark/protocol/grpc/proto/hello_grpc.pb.go:250
↓ 1 callersMethodString
()
tools/benchmark/protocol/dubbo/go-server/pkg/user.go:100
↓ 1 callersMethodString
()
pkg/adapter/dubboregistry/registry/registry.go:54
↓ 1 callersMethodString
()
pkg/adapter/dubboregistry/registry/nacos/application_listener.go:118
↓ 1 callersMethodSupportsJSON
SupportsJSON checks if the Accept header includes application/json
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:65
↓ 1 callersFunctionTestEmbeddedAllowedRule
TestEmbeddedAllowedRule tests embedded mode with allowed request
pkg/filter/opa/opa_test.go:73
↓ 1 callersFunctionTestEmbeddedDeniedRule
TestEmbeddedDeniedRule tests embedded mode with denied request
pkg/filter/opa/opa_test.go:90
↓ 1 callersMethodToMCPPrompts
ToMCPPrompts converts prompt configurations to MCP prompt list
pkg/filter/mcp/mcpserver/registry.go:330
↓ 1 callersMethodToMCPResourceTemplates
ToMCPResourceTemplates converts resource template configurations to MCP resource template list
pkg/filter/mcp/mcpserver/registry.go:254
↓ 1 callersMethodToMCPResources
ToMCPResources converts resource configurations to MCP resource list using mcp-go structures
pkg/filter/mcp/mcpserver/registry.go:235
↓ 1 callersMethodToolCallError
ToolCallError creates an error tool call response
pkg/filter/mcp/mcpserver/response.go:82
↓ 1 callersMethodToolCallSuccess
ToolCallSuccess creates a successful tool call response
pkg/filter/mcp/mcpserver/response.go:68
↓ 1 callersMethodTranslateBackendToCluster
(ctx context.Context, httpRoute *gatewayv1.HTTPRoute)
controllers/internal/translator/translator.go:296
↓ 1 callersMethodTranslateGateway
(ctx context.Context, gateway *gatewayv1.Gateway)
controllers/internal/translator/translator.go:55
↓ 1 callersMethodType
()
pkg/config/xds/model/health_check.pb.go:101
↓ 1 callersFunctionTypePredicate
()
controllers/internal/controller/utils.go:67
↓ 1 callersMethodUnmarshalJSON
(data []byte)
controllers/internal/controller/config/config.go:139
↓ 1 callersMethodUpdateListener
(m *model.Listener)
pkg/server/controls/controls.go:35
↓ 1 callersMethodUpdateRoutes
UpdateRoutes updates the routes in RouterManager with the provided new routes.
pkg/server/router_manager.go:64
↓ 1 callersMethodVal
()
pkg/filter/http/grpcproxy/grpc.go:132
↓ 1 callersMethodValidate
Validate validates the configuration based on mode.
pkg/filter/metric/config.go:67
↓ 1 callersFunctionValidateImagePullPolicy
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 callersFunctionValidateZookeeperClient
(container ZkClientFacade, zkName string)
pkg/remote/zookeeper/client.go:37
↓ 1 callersMethodViewConfig
ViewConfig returns the current remote configuration.
pkg/configcenter/configclient.go:31
↓ 1 callersFunctionViper
(path ...string)
admin/core/viper.go:38
↓ 1 callersMethodWaitGroup
()
pkg/remote/zookeeper/client.go:81
↓ 1 callersFunctionWithCheckUrl
(ck string)
pkg/client/mq/facade.go:75
↓ 1 callersFunctionWithConsumeUrl
(ch string)
pkg/client/mq/facade.go:69
↓ 1 callersFunctionWithConsumerGroup
(cp string)
pkg/client/mq/facade.go:81
↓ 1 callersFunctionWithIstioService
(serviceNames ...string)
pkg/config/xds/apiclient/grpc_envoy.go:52
↓ 1 callersFunctionWithTopic
(t string)
pkg/client/mq/facade.go:63
↓ 1 callersFunctionWithTopics
(t []string)
pkg/client/mq/facade.go:57
↓ 1 callersMethodWriteHeader
(statusCode int)
pkg/context/http/context_test.go:45
↓ 1 callersFunctionWriteToFile
WriteToFile write message to access log file
pkg/filter/accesslog/log.go:80
↓ 1 callersMethodWriter
()
controllers/internal/controller/status/status.go:84
↓ 1 callersFunctionZap
()
admin/core/zap.go:38
↓ 1 callersMethodZkClientLock
()
pkg/remote/zookeeper/client.go:80
↓ 1 callersFunction_hash1
(key string)
pkg/cluster/loadbalancer/maglev/permutation.go:281
↓ 1 callersFunction_hash2
(key string)
pkg/cluster/loadbalancer/maglev/permutation.go:286
↓ 1 callersFunctionabs
(f float64)
pkg/cluster/loadbalancer/weightrandom/weight_random_test.go:223
↓ 1 callersFunctionacceptedMessage
(kind string)
controllers/internal/controller/utils.go:278
↓ 1 callersFunctionaddFile
(fd *desc.FileDescriptor, fds map[string]*desc.FileDescriptor)
pkg/filter/http/grpcproxy/descriptor_operation.go:38
↓ 1 callersMethodaddListenerService
(ls listener.ListenerService, lsConf *model.Listener)
pkg/server/listener_manager.go:216
↓ 1 callersMethodaddNewService
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/cloud.go:280
↓ 1 callersMethodaddProvider
addProvider adds a provider to the validator
pkg/filter/auth/mcp/internal/validator/validator.go:194
↓ 1 callersMethodaddServiceInstance
(instance *servicediscovery.ServiceInstance)
pkg/adapter/springcloud/servicediscovery/zookeeper/zk_discovery.go:252
↓ 1 callersFunctionafterResourcePathChange
(resourceId, path string, unpublished bool)
admin/controller/configInfo/configInfo.go:221
↓ 1 callersMethodallocateContext
()
pkg/common/http/manager.go:75
↓ 1 callersFunctionapiKey
(ir *config.IntegrationRequest)
pkg/client/dubbo/dubbo.go:302
↓ 1 callersMethodassembleClusterEndpoints
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 callersMethodassembleRequest
assembleRequest creates a new http.Request for a specific endpoint.
pkg/filter/llm/proxy/filter.go:221
↓ 1 callersFunctionassertRouteByPathAndNameSame
helper: assert RouteByPathAndName behavior is the same
pkg/common/router/router_bench_test.go:189
↓ 1 callersMethodasyncHandler
(read chan *apiclient.DeltaResources)
pkg/config/xds/lds.go:71
↓ 1 callersMethodasyncHandler
(read chan *apiclient.DeltaResources)
pkg/config/xds/cds.go:66
↓ 1 callersMethodawaitAndPublish
wait for timer and publish
pkg/common/router/router.go:151
↓ 1 callersMethodbackgroundSyncPeriod
()
pkg/adapter/springcloud/cloud.go:338
↓ 1 callersFunctionbuildAccessLogMsg
(c *http.HttpContext, cost time.Duration)
pkg/filter/accesslog/access_log.go:118
↓ 1 callersMethodbuildBackendRequest
buildBackendRequest builds the complete backend request including path, body, and headers
pkg/filter/mcp/mcpserver/handlers.go:455
↓ 1 callersFunctionbuildCredentialConfigKey
buildCredentialConfigKey constructs credential configuration key name Format: cred::<group>::<dataId>
pkg/adapter/mcpserver/registry/nacos/client.go:827
↓ 1 callersFunctionbuildGrpcServerOptions
buildGrpcServerOptions creates gRPC server options from config
pkg/listener/grpc/grpc_listener.go:295
↓ 1 callersMethodbuildLoaderFromJWKS
buildLoaderFromJWKS parses provider.JWKS and constructs an appropriate loader.
pkg/filter/auth/mcp/internal/validator/validator.go:241
↓ 1 callersMethodbuildPingResponseObject
buildPingResponseObject builds the ping response object (for SSE)
pkg/filter/mcp/mcpserver/handlers.go:229
↓ 1 callersMethodbuildPromptMessages
buildPromptMessages builds prompt messages with parameter replacement support
pkg/filter/mcp/mcpserver/handlers.go:370
↓ 1 callersMethodbuildResourcesListResponseObject
buildResourcesListResponseObject builds the resources/list response object (for SSE)
pkg/filter/mcp/mcpserver/handlers.go:216
↓ 1 callersMethodbuildTargetResponse
(c *pch.HttpContext)
pkg/common/http/manager.go:213
↓ 1 callersMethodbuildToolParameterOptions
buildToolParameterOptions builds the mcp.PropertyOption slice for a given tool argument
pkg/filter/mcp/mcpserver/handlers.go:167
↓ 1 callersMethodbuildToolsListResponseObject
buildToolsListResponseObject builds the tools/list response object (for SSE)
pkg/filter/mcp/mcpserver/handlers.go:130
↓ 1 callersFunctionbuildWithPixiuOptions
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 callersFunctioncategorizeJWKSLoadError
categorizeJWKSLoadError maps loader errors to standardized error code/message
pkg/filter/auth/mcp/internal/validator/validator.go:147
← previousnext →1,101–1,200 of 3,410, ranked by callers