MCPcopy Index your code

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

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

↓ 426 callersMethodErrorf
(fmt string, args ...any)
pkg/logger/triple.go:53
↓ 279 callersFunctionErrorf
(fmt string, args ...any)
pkg/logger/output.go:44
↓ 231 callersMethodNew
New creates a standard error response without details
pkg/context/http/erroresponse.go:86
↓ 212 callersFunctionWarnf
(fmt string, args ...any)
pkg/logger/output.go:40
↓ 148 callersFunctionInfof
(fmt string, args ...any)
pkg/logger/output.go:36
↓ 124 callersMethodGet
(key string)
pkg/model/lb.go:47
↓ 118 callersMethodRun
(ctx context.Context, interval time.Duration)
pkg/adapter/mcpserver/registry/controller.go:32
↓ 112 callersMethodadd
(host string)
pkg/cluster/loadbalancer/maglev/permutation.go:237
↓ 104 callersMethodWithError
(err error)
pkg/context/http/erroresponse.go:93
↓ 100 callersFunctionDebugf
(fmt string, args ...any)
pkg/logger/output.go:48
↓ 98 callersMethodSet
(key, value string)
pkg/wasm/utils.go:55
↓ 91 callersMethodcreate
(key string, irequest config.IntegrationRequest)
pkg/client/dubbo/dubbo.go:307
↓ 81 callersMethodSendLocalReply
SendLocalReply Means that the request was interrupted and UnaryResponse will be sent directly Even if it’s currently in to Decode stage
pkg/context/http/context.go:174
↓ 75 callersMethodAdd
(host string)
pkg/model/lb.go:46
↓ 74 callersMethodUnmarshal
Unmarshal stores the raw data into the target, which must be a *[]byte or proto.Message.
pkg/common/codec/grpc/passthrough/codec.go:53
↓ 70 callersMethodToJSON
()
pkg/context/http/erroresponse.go:105
↓ 66 callersMethodContains
Contains return if key exists in trie
pkg/common/router/trie/trie.go:139
↓ 61 callersMethodMarshal
Marshal checks if the value is already bytes or a proto.Message and marshals accordingly.
pkg/common/codec/grpc/passthrough/codec.go:42
↓ 59 callersMethodClose
Close close the client
pkg/client/client.go:26
↓ 59 callersMethodError
()
pkg/adapter/mcpserver/common/util/url.go:48
↓ 53 callersMethodwarn
(args ...any)
pkg/logger/controller.go:64
↓ 50 callersFunctiond
(a,b,c)
admin/web/src/utils/three.js:25
↓ 48 callersMethodPut
Put put key and values into trie as map.
pkg/common/router/trie/trie.go:71
↓ 47 callersFunctionb
(a,b,c,d,e,f,h)
admin/web/src/utils/three.js:145
↓ 44 callersFunctionError
(args ...any)
pkg/logger/output.go:28
↓ 43 callersMethodLen
()
pkg/logger/logger_test.go:214
↓ 41 callersFunctionh
(a)
admin/web/src/utils/three.js:260
↓ 38 callersMethodDone
for wait group control, zk client listener & zk client container
pkg/remote/zookeeper/client.go:82
↓ 38 callersFunctionInfo
(args ...any)
pkg/logger/output.go:20
↓ 37 callersMethodError
()
controllers/internal/utils/error.go:25
↓ 37 callersMethodStop
()
pkg/config/xds/xds.go:152
↓ 36 callersMethodGetName
()
tools/benchmark/api/samples_api.pb.go:193
↓ 36 callersFunctionc
(a)
admin/web/src/utils/three.js:75
↓ 35 callersMethodInfo
(args ...any)
pkg/logger/triple.go:29
↓ 34 callersMethodString
()
pkg/filter/http/grpcproxy/grpc.go:128
↓ 33 callersMethodError
(err error, msg string, keysAndValues ...any)
pkg/filter/sentinel/logger_warpper.go:45
↓ 32 callersMethodError
Error implements the error interface
pkg/context/http/erroresponse.go:123
↓ 32 callersFunctionRegisterHttpFilter
Register registers filter plugin.
pkg/common/extension/filter/filter.go:198
↓ 31 callersMethodAppendDecodeFilters
(f ...HttpDecodeFilter)
pkg/common/extension/filter/filter_chain.go:26
↓ 31 callersMethodToLower
()
pkg/model/retry.go:45
↓ 30 callersMethodDeepCopyInto
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
controllers/api/v1alpha1/zz_generated.deepcopy.go:166
↓ 30 callersMethodError
()
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:141
↓ 29 callersMethodLoad
(ctx context.Context)
pkg/filter/auth/mcp/internal/validator/loader.go:34
↓ 27 callersMethodAttempt
Attempt checks if a retry should be performed and potentially waits. It returns true if the request should be attempted, false otherwise.
pkg/cluster/retry/retry.go:34
↓ 27 callersMethodDecode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter.go:71
↓ 27 callersFunctionNewSessionManager
NewSessionManager creates a new session manager
pkg/filter/mcp/mcpserver/transport/session_manager.go:57
↓ 26 callersMethodMatch
Match get values according url , pathVariable supported. returns: *Node this node in path, if not exists return nil []string reversed array of pathV
pkg/common/router/trie/trie.go:113
↓ 26 callersFunctionUnmarshalYML
UnmarshalYML unmarshals decodes the first document found within the in byte slice and assigns decoded values into the out value.
pkg/common/yaml/yaml.go:54
↓ 26 callersFunctionresolve
(dir)
admin/web/vue.config.js:22
↓ 25 callersMethodGetAddress
()
pkg/model/base.go:177
↓ 25 callersMethodSetError
SetError set error to context
pkg/context/grpc/context.go:53
↓ 25 callersMethodStop
Stop stops the session manager
pkg/filter/mcp/mcpserver/transport/session_manager.go:130
↓ 25 callersMethodWrite
([]byte)
pkg/context/base_context.go:38
↓ 24 callersFunctionGetMockAPI
GetMockAPI a mock util to create router.API
pkg/common/mock/router.go:27
↓ 23 callersMethodGetBizInfo
GetBizInfo get info
pkg/common/router/trie/trie.go:192
↓ 23 callersMethodRoute
(hc *http.HttpContext)
pkg/common/router/router.go:68
↓ 23 callersFunctionf
(a,b)
admin/web/src/utils/three.js:157
↓ 22 callersMethodEnsureSession
EnsureSession gets existing session or creates new one
pkg/filter/mcp/mcpserver/transport/session_manager.go:67
↓ 22 callersFunctione
(a,e,f,g,i,k,n)
admin/web/src/utils/three.js:224
↓ 21 callersMethodApplyMcpServerConfigByServer
ApplyMcpServerConfigByServer applies configuration by server ID
pkg/filter/mcp/mcpserver/dynamic.go:74
↓ 21 callersMethodError
Error creates an error JSON-RPC response
pkg/filter/mcp/mcpserver/response.go:63
↓ 21 callersMethodRecordMetric
RecordMetric records a metric to the context.
pkg/context/http/context.go:247
↓ 21 callersMethoderror
(args ...any)
pkg/logger/controller.go:70
↓ 20 callersMethodError
()
pkg/client/mq/kafka_facade.go:46
↓ 20 callersFunctionGetLogger
GetLogger exposes the current sugared logger.
pkg/logger/logger.go:163
↓ 20 callersFunctioncreateTestToolConfig
============================================================================= Test Utilities =========================================================
pkg/filter/mcp/mcpserver/dynamic_test.go:40
↓ 19 callersFunctionGetClusterManager
()
pkg/server/pixiu_start.go:139
↓ 19 callersFunctionNewReq
NewReq create a request
pkg/client/request.go:40
↓ 19 callersFunctionNewSSEHandler
NewSSEHandler creates a new SSE handler
pkg/filter/mcp/mcpserver/transport/sse_handler.go:36
↓ 19 callersFunctionfile_health_check_proto_rawDescGZIP
()
pkg/config/xds/model/health_check.pb.go:2013
↓ 18 callersMethodBuild
()
pkg/model/log.go:42
↓ 18 callersMethodError
(args ...any)
pkg/logger/triple.go:37
↓ 18 callersMethodSession
Session retrieves a session by ID
pkg/filter/mcp/mcpserver/transport/session_manager.go:97
↓ 18 callersMethodTo
(configModel PixiuDynamicConfigModel)
pkg/config/xds/apiclient/apiclient.go:53
↓ 18 callersFunctioncreateTestMcpServerConfig
createTestMcpServerConfig creates a test MCP server configuration
pkg/filter/mcp/mcpserver/dynamic_test.go:63
↓ 17 callersMethodEncode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter.go:77
↓ 17 callersFunctionGetTrieKey
(method string, path string)
pkg/common/util/stringutil/stringutil.go:70
↓ 17 callersMethodListTools
ListTools lists all tools
pkg/filter/mcp/mcpserver/registry.go:146
↓ 17 callersFunctionMarshalYML
MarshalYML serializes the value provided into a YAML document.
pkg/common/yaml/yaml.go:59
↓ 16 callersFunctionGetMockHTTPContext
GetMockHTTPContext mock context for test.
pkg/context/mock/context.go:31
↓ 16 callersMethodHeader
()
pkg/filter/metric/metric_test.go:55
↓ 16 callersMethodKind
Kind returns the unique kind name to represent itself.
pkg/common/extension/filter/filter.go:41
↓ 16 callersMethodPutAPI
PutAPI puts an api into the resource
pkg/router/route.go:121
↓ 15 callersMethodGetAllMetrics
GetAllMetrics returns all recorded metrics.
pkg/context/http/context.go:268
↓ 15 callersMethodGetStatusCode
()
pkg/context/http/context.go:196
↓ 15 callersFunctionInitLogger
InitLogger initializes logger. Default is development-style (console, debug), but we force stacktrace to Error+ only, and enable caller with our custo
pkg/logger/logger.go:113
↓ 15 callersMethodReset
Reset re-initializes the policy's state.
pkg/cluster/retry/retry.go:36
↓ 15 callersMethodapply
(ctx context.Context, update Update)
controllers/internal/controller/status/status.go:138
↓ 15 callersFunctiongetRootPath
(key string)
admin/logic/logic.go:620
↓ 15 callersFunctionnewRequestParams
()
pkg/client/http/mapper.go:55
↓ 14 callersMethodCall
Call invoke the downstream service.
pkg/client/client.go:29
↓ 14 callersMethodClose
Close the filter and release resources
pkg/common/extension/filter/filter.go:137
↓ 14 callersMethodHandlerFunc
HandlerFunc defines handler function for middleware
pkg/prometheus/prometheus.go:379
↓ 14 callersMethodOnAddRouter
(r *model.Router)
pkg/server/router_manager.go:31
↓ 14 callersMethodString
()
pkg/context/base_context.go:60
↓ 14 callersFunctiongenRoutes
(sh benchShape)
pkg/common/router/router_bench_test.go:58
↓ 14 callersFunctionnewErrorBuilder
(status int, message string)
pkg/context/http/erroresponse.go:78
↓ 14 callersFunctionsetTarget
(target *requestParams, to string, key string, val any)
pkg/client/http/mapper.go:154
↓ 13 callersMethodApply
Apply is called after the configuration is loaded and is used to prepare the OPA query.
pkg/filter/opa/opa.go:91
↓ 13 callersFunctionI
(a)
admin/web/src/utils/three.js:426
next →1–100 of 3,410, ranked by callers