Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/apache/dubbo-go-pixiu
/ functions
Functions
3,410 in github.com/apache/dubbo-go-pixiu
⨍
Functions
3,410
◇
Types & classes
888
↓ 426 callers
Method
Errorf
(fmt string, args ...any)
pkg/logger/triple.go:53
↓ 279 callers
Function
Errorf
(fmt string, args ...any)
pkg/logger/output.go:44
↓ 231 callers
Method
New
New creates a standard error response without details
pkg/context/http/erroresponse.go:86
↓ 212 callers
Function
Warnf
(fmt string, args ...any)
pkg/logger/output.go:40
↓ 148 callers
Function
Infof
(fmt string, args ...any)
pkg/logger/output.go:36
↓ 124 callers
Method
Get
(key string)
pkg/model/lb.go:47
↓ 118 callers
Method
Run
(ctx context.Context, interval time.Duration)
pkg/adapter/mcpserver/registry/controller.go:32
↓ 112 callers
Method
add
(host string)
pkg/cluster/loadbalancer/maglev/permutation.go:237
↓ 104 callers
Method
WithError
(err error)
pkg/context/http/erroresponse.go:93
↓ 100 callers
Function
Debugf
(fmt string, args ...any)
pkg/logger/output.go:48
↓ 98 callers
Method
Set
(key, value string)
pkg/wasm/utils.go:55
↓ 91 callers
Method
create
(key string, irequest config.IntegrationRequest)
pkg/client/dubbo/dubbo.go:307
↓ 81 callers
Method
SendLocalReply
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 callers
Method
Add
(host string)
pkg/model/lb.go:46
↓ 74 callers
Method
Unmarshal
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 callers
Method
ToJSON
()
pkg/context/http/erroresponse.go:105
↓ 66 callers
Method
Contains
Contains return if key exists in trie
pkg/common/router/trie/trie.go:139
↓ 61 callers
Method
Marshal
Marshal checks if the value is already bytes or a proto.Message and marshals accordingly.
pkg/common/codec/grpc/passthrough/codec.go:42
↓ 59 callers
Method
Close
Close close the client
pkg/client/client.go:26
↓ 59 callers
Method
Error
()
pkg/adapter/mcpserver/common/util/url.go:48
↓ 53 callers
Method
warn
(args ...any)
pkg/logger/controller.go:64
↓ 50 callers
Function
d
(a,b,c)
admin/web/src/utils/three.js:25
↓ 48 callers
Method
Put
Put put key and values into trie as map.
pkg/common/router/trie/trie.go:71
↓ 47 callers
Function
b
(a,b,c,d,e,f,h)
admin/web/src/utils/three.js:145
↓ 44 callers
Function
Error
(args ...any)
pkg/logger/output.go:28
↓ 43 callers
Method
Len
()
pkg/logger/logger_test.go:214
↓ 41 callers
Function
h
(a)
admin/web/src/utils/three.js:260
↓ 38 callers
Method
Done
for wait group control, zk client listener & zk client container
pkg/remote/zookeeper/client.go:82
↓ 38 callers
Function
Info
(args ...any)
pkg/logger/output.go:20
↓ 37 callers
Method
Error
()
controllers/internal/utils/error.go:25
↓ 37 callers
Method
Stop
()
pkg/config/xds/xds.go:152
↓ 36 callers
Method
GetName
()
tools/benchmark/api/samples_api.pb.go:193
↓ 36 callers
Function
c
(a)
admin/web/src/utils/three.js:75
↓ 35 callers
Method
Info
(args ...any)
pkg/logger/triple.go:29
↓ 34 callers
Method
String
()
pkg/filter/http/grpcproxy/grpc.go:128
↓ 33 callers
Method
Error
(err error, msg string, keysAndValues ...any)
pkg/filter/sentinel/logger_warpper.go:45
↓ 32 callers
Method
Error
Error implements the error interface
pkg/context/http/erroresponse.go:123
↓ 32 callers
Function
RegisterHttpFilter
Register registers filter plugin.
pkg/common/extension/filter/filter.go:198
↓ 31 callers
Method
AppendDecodeFilters
(f ...HttpDecodeFilter)
pkg/common/extension/filter/filter_chain.go:26
↓ 31 callers
Method
ToLower
()
pkg/model/retry.go:45
↓ 30 callers
Method
DeepCopyInto
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 callers
Method
Error
()
pkg/filter/mcp/mcpserver/transport/content_negotiator.go:141
↓ 29 callers
Method
Load
(ctx context.Context)
pkg/filter/auth/mcp/internal/validator/loader.go:34
↓ 27 callers
Method
Attempt
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 callers
Method
Decode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter.go:71
↓ 27 callers
Function
NewSessionManager
NewSessionManager creates a new session manager
pkg/filter/mcp/mcpserver/transport/session_manager.go:57
↓ 26 callers
Method
Match
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 callers
Function
UnmarshalYML
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 callers
Function
resolve
(dir)
admin/web/vue.config.js:22
↓ 25 callers
Method
GetAddress
()
pkg/model/base.go:177
↓ 25 callers
Method
SetError
SetError set error to context
pkg/context/grpc/context.go:53
↓ 25 callers
Method
Stop
Stop stops the session manager
pkg/filter/mcp/mcpserver/transport/session_manager.go:130
↓ 25 callers
Method
Write
([]byte)
pkg/context/base_context.go:38
↓ 24 callers
Function
GetMockAPI
GetMockAPI a mock util to create router.API
pkg/common/mock/router.go:27
↓ 23 callers
Method
GetBizInfo
GetBizInfo get info
pkg/common/router/trie/trie.go:192
↓ 23 callers
Method
Route
(hc *http.HttpContext)
pkg/common/router/router.go:68
↓ 23 callers
Function
f
(a,b)
admin/web/src/utils/three.js:157
↓ 22 callers
Method
EnsureSession
EnsureSession gets existing session or creates new one
pkg/filter/mcp/mcpserver/transport/session_manager.go:67
↓ 22 callers
Function
e
(a,e,f,g,i,k,n)
admin/web/src/utils/three.js:224
↓ 21 callers
Method
ApplyMcpServerConfigByServer
ApplyMcpServerConfigByServer applies configuration by server ID
pkg/filter/mcp/mcpserver/dynamic.go:74
↓ 21 callers
Method
Error
Error creates an error JSON-RPC response
pkg/filter/mcp/mcpserver/response.go:63
↓ 21 callers
Method
RecordMetric
RecordMetric records a metric to the context.
pkg/context/http/context.go:247
↓ 21 callers
Method
error
(args ...any)
pkg/logger/controller.go:70
↓ 20 callers
Method
Error
()
pkg/client/mq/kafka_facade.go:46
↓ 20 callers
Function
GetLogger
GetLogger exposes the current sugared logger.
pkg/logger/logger.go:163
↓ 20 callers
Function
createTestToolConfig
============================================================================= Test Utilities =========================================================
pkg/filter/mcp/mcpserver/dynamic_test.go:40
↓ 19 callers
Function
GetClusterManager
()
pkg/server/pixiu_start.go:139
↓ 19 callers
Function
NewReq
NewReq create a request
pkg/client/request.go:40
↓ 19 callers
Function
NewSSEHandler
NewSSEHandler creates a new SSE handler
pkg/filter/mcp/mcpserver/transport/sse_handler.go:36
↓ 19 callers
Function
file_health_check_proto_rawDescGZIP
()
pkg/config/xds/model/health_check.pb.go:2013
↓ 18 callers
Method
Build
()
pkg/model/log.go:42
↓ 18 callers
Method
Error
(args ...any)
pkg/logger/triple.go:37
↓ 18 callers
Method
Session
Session retrieves a session by ID
pkg/filter/mcp/mcpserver/transport/session_manager.go:97
↓ 18 callers
Method
To
(configModel PixiuDynamicConfigModel)
pkg/config/xds/apiclient/apiclient.go:53
↓ 18 callers
Function
createTestMcpServerConfig
createTestMcpServerConfig creates a test MCP server configuration
pkg/filter/mcp/mcpserver/dynamic_test.go:63
↓ 17 callers
Method
Encode
(ctx *http.HttpContext)
pkg/common/extension/filter/filter.go:77
↓ 17 callers
Function
GetTrieKey
(method string, path string)
pkg/common/util/stringutil/stringutil.go:70
↓ 17 callers
Method
ListTools
ListTools lists all tools
pkg/filter/mcp/mcpserver/registry.go:146
↓ 17 callers
Function
MarshalYML
MarshalYML serializes the value provided into a YAML document.
pkg/common/yaml/yaml.go:59
↓ 16 callers
Function
GetMockHTTPContext
GetMockHTTPContext mock context for test.
pkg/context/mock/context.go:31
↓ 16 callers
Method
Header
()
pkg/filter/metric/metric_test.go:55
↓ 16 callers
Method
Kind
Kind returns the unique kind name to represent itself.
pkg/common/extension/filter/filter.go:41
↓ 16 callers
Method
PutAPI
PutAPI puts an api into the resource
pkg/router/route.go:121
↓ 15 callers
Method
GetAllMetrics
GetAllMetrics returns all recorded metrics.
pkg/context/http/context.go:268
↓ 15 callers
Method
GetStatusCode
()
pkg/context/http/context.go:196
↓ 15 callers
Function
InitLogger
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 callers
Method
Reset
Reset re-initializes the policy's state.
pkg/cluster/retry/retry.go:36
↓ 15 callers
Method
apply
(ctx context.Context, update Update)
controllers/internal/controller/status/status.go:138
↓ 15 callers
Function
getRootPath
(key string)
admin/logic/logic.go:620
↓ 15 callers
Function
newRequestParams
()
pkg/client/http/mapper.go:55
↓ 14 callers
Method
Call
Call invoke the downstream service.
pkg/client/client.go:29
↓ 14 callers
Method
Close
Close the filter and release resources
pkg/common/extension/filter/filter.go:137
↓ 14 callers
Method
HandlerFunc
HandlerFunc defines handler function for middleware
pkg/prometheus/prometheus.go:379
↓ 14 callers
Method
OnAddRouter
(r *model.Router)
pkg/server/router_manager.go:31
↓ 14 callers
Method
String
()
pkg/context/base_context.go:60
↓ 14 callers
Function
genRoutes
(sh benchShape)
pkg/common/router/router_bench_test.go:58
↓ 14 callers
Function
newErrorBuilder
(status int, message string)
pkg/context/http/erroresponse.go:78
↓ 14 callers
Function
setTarget
(target *requestParams, to string, key string, val any)
pkg/client/http/mapper.go:154
↓ 13 callers
Method
Apply
Apply is called after the configuration is loaded and is used to prepare the OPA query.
pkg/filter/opa/opa.go:91
↓ 13 callers
Function
I
(a)
admin/web/src/utils/three.js:426
next →
1–100 of 3,410, ranked by callers