Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/NuyoahCh/mcpchainx
/ functions
Functions
459 in github.com/NuyoahCh/mcpchainx
⨍
Functions
459
◇
Types & classes
188
↓ 44 callers
Method
Close
()
internal/task/store.go:18
↓ 42 callers
Method
Error
Error 实现 error 接口。
internal/errors/errors.go:203
↓ 31 callers
Function
L
L returns the structured logger instance.
pkg/logger/logger.go:156
↓ 29 callers
Function
writeJSONError
(w http.ResponseWriter, status int, code, message string)
internal/api/server.go:502
↓ 28 callers
Method
Is
Is 允许通过 errors.Is 判断是否相同错误码。
internal/errors/errors.go:222
↓ 19 callers
Method
Err
Err forwards the subscription error channel.
internal/web3/types.go:44
↓ 15 callers
Function
showToast
({ title: error instanceof UnauthorizedError ? "需要登录" : "同步失败", message, m
web/src/App.tsx:288
↓ 14 callers
Function
buildListOptions
buildListOptions applies option functions on top of defaults.
internal/task/list_options.go:128
↓ 14 callers
Method
get
(ctx context.Context, endpoint string, out any, withAuth bool)
sdk/go/openmcp/client.go:161
↓ 13 callers
Function
escape
escape 转义字符串中的特殊字符,确保符合 Prometheus 格式要求。
internal/observability/metrics/http.go:217
↓ 12 callers
Method
Info
Info returns the static metadata for the plugin.
pkg/plugin/plugin.go:8
↓ 12 callers
Function
request
( path: string, options: RequestOptions = {}, )
web/src/api.ts:236
↓ 11 callers
Method
Get
(ctx context.Context, id string)
internal/task/store.go:12
↓ 10 callers
Method
normalise
normalise 初始化 Subject 的内部缓存。
internal/auth/types.go:52
↓ 10 callers
Function
toRFC3339
(input: string | Date | undefined)
web/src/api.ts:390
↓ 9 callers
Method
Register
Register registers a plugin instance directly with the manager.
pkg/plugin/manager.go:54
↓ 8 callers
Method
List
List 返回最近任务。
internal/task/memory_store.go:127
↓ 8 callers
Function
buildTaskQueryParams
( query: TaskListQuery = {}, options: { includeLimit?: boolean; includeOrder?: boolean; includ
web/src/api.ts:400
↓ 8 callers
Function
cloneMetadata
(metadata map[string]any)
internal/task/task.go:138
↓ 8 callers
Method
get
(id string)
pkg/plugin/manager.go:193
↓ 8 callers
Function
listTasks
( query: TaskListQuery = {}, )
web/src/api.ts:445
↓ 7 callers
Function
NewMemoryStore
NewMemoryStore 创建 MemoryStore。
internal/task/memory_store.go:21
↓ 7 callers
Function
useCallback
( async (taskId: string) => { setIsPolling(true); try { for (let attempt = 0; attempt
web/src/App.tsx:407
↓ 6 callers
Function
Audit
Audit returns the audit logger.
pkg/logger/logger.go:164
↓ 6 callers
Method
Client
Client returns the chain client identified by name.
internal/web3/provider/registry.go:96
↓ 6 callers
Method
Close
()
internal/web3/types.go:67
↓ 6 callers
Method
Stats
Stats 统计符合过滤条件的任务数量与更新时间范围。
internal/task/memory_store.go:265
↓ 6 callers
Method
WriteHeader
Write 捕获响应状态码。
internal/api/server.go:448
↓ 6 callers
Function
firstValue
(values map[string][]string, key string)
internal/api/server.go:597
↓ 6 callers
Method
handleTaskDetail
handleTaskDetail 处理单个任务查询请求。
internal/api/server.go:129
↓ 6 callers
Function
setAuthState
(next: AuthState | null)
web/src/api.ts:105
↓ 5 callers
Function
AttributesOf
AttributesOf 返回错误码对应的属性。若未注册则返回 UNKNOWN 的属性。
internal/errors/errors.go:123
↓ 5 callers
Function
NewServer
NewServer 构造 API 服务实例。
internal/api/server.go:31
↓ 5 callers
Function
NewService
NewService 构造任务服务。
internal/task/service.go:25
↓ 5 callers
Function
WithQuery
WithQuery filters tasks by fuzzy matching across goal, address and result fields.
internal/task/list_options.go:121
↓ 5 callers
Function
appendObservation
appendObservation 将新的观察结果追加到现有的观察字符串中。
internal/agent/agent.go:242
↓ 5 callers
Method
applyDefaults
applyDefaults sanitizes the options and fills in default values.
internal/task/list_options.go:38
↓ 5 callers
Function
cloneTask
(task *Task)
internal/task/memory_store.go:175
↓ 5 callers
Function
statusFromError
statusFromError 将错误映射为 HTTP 状态码。
internal/api/server.go:476
↓ 4 callers
Method
Authenticate
Authenticate exchanges workspace credentials for an access token and stores it for subsequent calls.
sdk/go/openmcp/client.go:104
↓ 4 callers
Method
Create
Create 实现 Store 接口。
internal/task/memory_store.go:26
↓ 4 callers
Function
From
From 尝试从 error 中解析统一错误类型。
internal/errors/errors.go:298
↓ 4 callers
Method
MarkFailed
(ctx context.Context, id string, code xerrors.Code, lastError string, terminal bool)
internal/task/store.go:15
↓ 4 callers
Method
Mode
Mode 返回当前身份认证服务的工作模式。
internal/auth/service.go:102
↓ 4 callers
Function
NewClient
NewClient 根据配置创建 OpenAI 客户端。
internal/llm/openai/client.go:40
↓ 4 callers
Function
NewClient
NewClient instantiates a client for the OpenMCP Chain API. When httpClient is nil, a default client with a sensible timeout is used.
sdk/go/openmcp/client.go:91
↓ 4 callers
Method
Publish
(ctx context.Context, taskID string)
internal/task/queue.go:12
↓ 4 callers
Method
Query
(goal, chainAction string)
internal/knowledge/static.go:13
↓ 4 callers
Function
WithResultPresence
WithResultPresence filters tasks by whether they already contain execution results.
internal/task/list_options.go:106
↓ 4 callers
Function
dedupeStrings
dedupeStrings 去重并规范化字符串切片。
internal/auth/memory_store.go:125
↓ 4 callers
Method
emitAlert
(ctx context.Context, task *Task, code xerrors.Code, cause error, stage string)
internal/task/processor.go:235
↓ 4 callers
Function
formatTimestamp
(timestamp: number | null | undefined)
web/src/api.ts:710
↓ 4 callers
Method
instrument
instrument 包装 HTTP 处理器以收集请求指标。
internal/api/server.go:184
↓ 4 callers
Function
normalizeBaseUrl
(input: string)
web/src/api.ts:45
↓ 4 callers
Method
persistToDisk
()
internal/storage/mysql/task_repository.go:230
↓ 4 callers
Function
renderToolbar
(options?: { disableExport?: boolean })
web/src/components/TaskList.tsx:52
↓ 4 callers
Function
sortTaskRecords
(records []TaskRecord)
internal/storage/mysql/task_repository.go:255
↓ 4 callers
Function
statusLabel
(status: TaskStatus)
web/src/api.ts:691
↓ 3 callers
Method
Channel
()
internal/observability/alerting/alert.go:39
↓ 3 callers
Method
Cleanup
(info Info)
pkg/plugin/isolation.go:13
↓ 3 callers
Method
Clone
Clone returns a shallow copy of the execution context so plugins can safely mutate maps.
pkg/plugin/plugin.go:31
↓ 3 callers
Method
Execute
(ctx context.Context, req agent.TaskRequest)
internal/task/processor.go:18
↓ 3 callers
Function
HashPassword
HashPassword 对给定的密码进行哈希处理并返回哈希值。
internal/auth/service.go:582
↓ 3 callers
Method
LoadSubject
(ctx context.Context, userID int64)
internal/auth/types.go:24
↓ 3 callers
Function
New
New 创建一个 Agent。
internal/agent/agent.go:81
↓ 3 callers
Method
Send
(ctx context.Context, subject, content string, to []string)
internal/observability/alerting/alert.go:84
↓ 3 callers
Method
Stats
(ctx context.Context, opts ListOptions)
internal/task/store.go:17
↓ 3 callers
Method
Stop
Stop gracefully halts the plugin and releases any resources.
pkg/plugin/plugin.go:17
↓ 3 callers
Function
WithOffset
WithOffset skips the first n matching tasks before returning results.
internal/task/list_options.go:70
↓ 3 callers
Function
WithStatuses
WithStatuses filters tasks by the provided statuses.
internal/task/list_options.go:77
↓ 3 callers
Method
Write
(p []byte)
pkg/logger/rotate.go:47
↓ 3 callers
Function
clearAuth
()
web/src/api.ts:725
↓ 3 callers
Function
fetch_history
(endpoint: str, limit: int, query: str | None = None, offset: int = 0)
examples/task_quickstart.py:42
↓ 3 callers
Function
formatRemaining
(expiresAt?: number)
web/src/components/AuthPanel.tsx:13
↓ 3 callers
Function
mergeTasks
(prev: TaskItem[], incoming: TaskItem)
web/src/App.tsx:49
↓ 3 callers
Method
post
(ctx context.Context, endpoint string, payload any, out any, withAuth bool)
sdk/go/openmcp/client.go:148
↓ 3 callers
Method
sortRecords
()
internal/storage/mysql/task_repository.go:246
↓ 3 callers
Function
toHexBig
(n *big.Int)
internal/web3/ethereum/client.go:371
↓ 3 callers
Function
truncate
(text string)
internal/llm/openai/client.go:215
↓ 2 callers
Method
AccessToken
AccessToken returns the currently stored token string.
sdk/go/openmcp/client.go:135
↓ 2 callers
Method
Clone
Clone 创建并返回主体的深拷贝,包括角色和权限切片的副本,以防止外部修改
internal/auth/types.go:99
↓ 2 callers
Method
Consume
(ctx context.Context, workerCount int, handler Handler)
internal/task/queue.go:18
↓ 2 callers
Method
Create
(ctx context.Context, task *Task)
internal/task/store.go:11
↓ 2 callers
Method
DeployContract
(ctx context.Context, auth *bind.TransactOpts, abiJSON string, bytecode []byte, params ...any)
internal/web3/types.go:64
↓ 2 callers
Method
ExecuteAction
(ctx context.Context, action, address string)
internal/web3/types.go:63
↓ 2 callers
Method
FetchChainSnapshot
(ctx context.Context)
internal/web3/types.go:62
↓ 2 callers
Method
FindUserByUsername
(ctx context.Context, username string)
internal/auth/types.go:23
↓ 2 callers
Method
Generate
(ctx context.Context, req Request)
internal/llm/llm.go:28
↓ 2 callers
Method
Generate
Generate 调用 OpenAI 生成结构化回复。
internal/llm/openai/client.go:73
↓ 2 callers
Method
Get
Get 查询指定任务。
internal/task/mysql_store.go:134
↓ 2 callers
Method
GetTask
GetTask fetches task details by identifier.
sdk/go/openmcp/client.go:125
↓ 2 callers
Function
Handler
Handler 返回一个 HTTP 处理器,用于暴露 Prometheus 格式的指标数据。
internal/observability/metrics/http.go:112
↓ 2 callers
Function
Init
Init configures the global logger instances.
pkg/logger/logger.go:40
↓ 2 callers
Function
IsTaskError
IsTaskError 判断错误是否为统一任务错误。
internal/task/task.go:119
↓ 2 callers
Function
IsValidStatus
IsValidStatus 检查给定的任务状态是否为支持的枚举值。
internal/task/task.go:150
↓ 2 callers
Method
List
(ctx context.Context, opts ListOptions)
internal/task/store.go:16
↓ 2 callers
Method
ListLatest
(ctx context.Context, limit int)
internal/storage/mysql/task_repository.go:38
↓ 2 callers
Method
MarkFailed
MarkFailed 标记任务失败。
internal/task/memory_store.go:112
↓ 2 callers
Method
MarkSucceeded
(ctx context.Context, id string, result ExecutionResult)
internal/task/store.go:14
↓ 2 callers
Method
MarkSucceeded
MarkSucceeded 记录成功结果。
internal/task/memory_store.go:96
next →
1–100 of 459, ranked by callers