MCPcopy Index your code

hub / github.com/NuyoahCh/mcpchainx / functions

Functions459 in github.com/NuyoahCh/mcpchainx

↓ 44 callersMethodClose
()
internal/task/store.go:18
↓ 42 callersMethodError
Error 实现 error 接口。
internal/errors/errors.go:203
↓ 31 callersFunctionL
L returns the structured logger instance.
pkg/logger/logger.go:156
↓ 29 callersFunctionwriteJSONError
(w http.ResponseWriter, status int, code, message string)
internal/api/server.go:502
↓ 28 callersMethodIs
Is 允许通过 errors.Is 判断是否相同错误码。
internal/errors/errors.go:222
↓ 19 callersMethodErr
Err forwards the subscription error channel.
internal/web3/types.go:44
↓ 15 callersFunctionshowToast
({ title: error instanceof UnauthorizedError ? "需要登录" : "同步失败", message, m
web/src/App.tsx:288
↓ 14 callersFunctionbuildListOptions
buildListOptions applies option functions on top of defaults.
internal/task/list_options.go:128
↓ 14 callersMethodget
(ctx context.Context, endpoint string, out any, withAuth bool)
sdk/go/openmcp/client.go:161
↓ 13 callersFunctionescape
escape 转义字符串中的特殊字符,确保符合 Prometheus 格式要求。
internal/observability/metrics/http.go:217
↓ 12 callersMethodInfo
Info returns the static metadata for the plugin.
pkg/plugin/plugin.go:8
↓ 12 callersFunctionrequest
( path: string, options: RequestOptions = {}, )
web/src/api.ts:236
↓ 11 callersMethodGet
(ctx context.Context, id string)
internal/task/store.go:12
↓ 10 callersMethodnormalise
normalise 初始化 Subject 的内部缓存。
internal/auth/types.go:52
↓ 10 callersFunctiontoRFC3339
(input: string | Date | undefined)
web/src/api.ts:390
↓ 9 callersMethodRegister
Register registers a plugin instance directly with the manager.
pkg/plugin/manager.go:54
↓ 8 callersMethodList
List 返回最近任务。
internal/task/memory_store.go:127
↓ 8 callersFunctionbuildTaskQueryParams
( query: TaskListQuery = {}, options: { includeLimit?: boolean; includeOrder?: boolean; includ
web/src/api.ts:400
↓ 8 callersFunctioncloneMetadata
(metadata map[string]any)
internal/task/task.go:138
↓ 8 callersMethodget
(id string)
pkg/plugin/manager.go:193
↓ 8 callersFunctionlistTasks
( query: TaskListQuery = {}, )
web/src/api.ts:445
↓ 7 callersFunctionNewMemoryStore
NewMemoryStore 创建 MemoryStore。
internal/task/memory_store.go:21
↓ 7 callersFunctionuseCallback
( async (taskId: string) => { setIsPolling(true); try { for (let attempt = 0; attempt
web/src/App.tsx:407
↓ 6 callersFunctionAudit
Audit returns the audit logger.
pkg/logger/logger.go:164
↓ 6 callersMethodClient
Client returns the chain client identified by name.
internal/web3/provider/registry.go:96
↓ 6 callersMethodClose
()
internal/web3/types.go:67
↓ 6 callersMethodStats
Stats 统计符合过滤条件的任务数量与更新时间范围。
internal/task/memory_store.go:265
↓ 6 callersMethodWriteHeader
Write 捕获响应状态码。
internal/api/server.go:448
↓ 6 callersFunctionfirstValue
(values map[string][]string, key string)
internal/api/server.go:597
↓ 6 callersMethodhandleTaskDetail
handleTaskDetail 处理单个任务查询请求。
internal/api/server.go:129
↓ 6 callersFunctionsetAuthState
(next: AuthState | null)
web/src/api.ts:105
↓ 5 callersFunctionAttributesOf
AttributesOf 返回错误码对应的属性。若未注册则返回 UNKNOWN 的属性。
internal/errors/errors.go:123
↓ 5 callersFunctionNewServer
NewServer 构造 API 服务实例。
internal/api/server.go:31
↓ 5 callersFunctionNewService
NewService 构造任务服务。
internal/task/service.go:25
↓ 5 callersFunctionWithQuery
WithQuery filters tasks by fuzzy matching across goal, address and result fields.
internal/task/list_options.go:121
↓ 5 callersFunctionappendObservation
appendObservation 将新的观察结果追加到现有的观察字符串中。
internal/agent/agent.go:242
↓ 5 callersMethodapplyDefaults
applyDefaults sanitizes the options and fills in default values.
internal/task/list_options.go:38
↓ 5 callersFunctioncloneTask
(task *Task)
internal/task/memory_store.go:175
↓ 5 callersFunctionstatusFromError
statusFromError 将错误映射为 HTTP 状态码。
internal/api/server.go:476
↓ 4 callersMethodAuthenticate
Authenticate exchanges workspace credentials for an access token and stores it for subsequent calls.
sdk/go/openmcp/client.go:104
↓ 4 callersMethodCreate
Create 实现 Store 接口。
internal/task/memory_store.go:26
↓ 4 callersFunctionFrom
From 尝试从 error 中解析统一错误类型。
internal/errors/errors.go:298
↓ 4 callersMethodMarkFailed
(ctx context.Context, id string, code xerrors.Code, lastError string, terminal bool)
internal/task/store.go:15
↓ 4 callersMethodMode
Mode 返回当前身份认证服务的工作模式。
internal/auth/service.go:102
↓ 4 callersFunctionNewClient
NewClient 根据配置创建 OpenAI 客户端。
internal/llm/openai/client.go:40
↓ 4 callersFunctionNewClient
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 callersMethodPublish
(ctx context.Context, taskID string)
internal/task/queue.go:12
↓ 4 callersMethodQuery
(goal, chainAction string)
internal/knowledge/static.go:13
↓ 4 callersFunctionWithResultPresence
WithResultPresence filters tasks by whether they already contain execution results.
internal/task/list_options.go:106
↓ 4 callersFunctiondedupeStrings
dedupeStrings 去重并规范化字符串切片。
internal/auth/memory_store.go:125
↓ 4 callersMethodemitAlert
(ctx context.Context, task *Task, code xerrors.Code, cause error, stage string)
internal/task/processor.go:235
↓ 4 callersFunctionformatTimestamp
(timestamp: number | null | undefined)
web/src/api.ts:710
↓ 4 callersMethodinstrument
instrument 包装 HTTP 处理器以收集请求指标。
internal/api/server.go:184
↓ 4 callersFunctionnormalizeBaseUrl
(input: string)
web/src/api.ts:45
↓ 4 callersMethodpersistToDisk
()
internal/storage/mysql/task_repository.go:230
↓ 4 callersFunctionrenderToolbar
(options?: { disableExport?: boolean })
web/src/components/TaskList.tsx:52
↓ 4 callersFunctionsortTaskRecords
(records []TaskRecord)
internal/storage/mysql/task_repository.go:255
↓ 4 callersFunctionstatusLabel
(status: TaskStatus)
web/src/api.ts:691
↓ 3 callersMethodChannel
()
internal/observability/alerting/alert.go:39
↓ 3 callersMethodCleanup
(info Info)
pkg/plugin/isolation.go:13
↓ 3 callersMethodClone
Clone returns a shallow copy of the execution context so plugins can safely mutate maps.
pkg/plugin/plugin.go:31
↓ 3 callersMethodExecute
(ctx context.Context, req agent.TaskRequest)
internal/task/processor.go:18
↓ 3 callersFunctionHashPassword
HashPassword 对给定的密码进行哈希处理并返回哈希值。
internal/auth/service.go:582
↓ 3 callersMethodLoadSubject
(ctx context.Context, userID int64)
internal/auth/types.go:24
↓ 3 callersFunctionNew
New 创建一个 Agent。
internal/agent/agent.go:81
↓ 3 callersMethodSend
(ctx context.Context, subject, content string, to []string)
internal/observability/alerting/alert.go:84
↓ 3 callersMethodStats
(ctx context.Context, opts ListOptions)
internal/task/store.go:17
↓ 3 callersMethodStop
Stop gracefully halts the plugin and releases any resources.
pkg/plugin/plugin.go:17
↓ 3 callersFunctionWithOffset
WithOffset skips the first n matching tasks before returning results.
internal/task/list_options.go:70
↓ 3 callersFunctionWithStatuses
WithStatuses filters tasks by the provided statuses.
internal/task/list_options.go:77
↓ 3 callersMethodWrite
(p []byte)
pkg/logger/rotate.go:47
↓ 3 callersFunctionclearAuth
()
web/src/api.ts:725
↓ 3 callersFunctionfetch_history
(endpoint: str, limit: int, query: str | None = None, offset: int = 0)
examples/task_quickstart.py:42
↓ 3 callersFunctionformatRemaining
(expiresAt?: number)
web/src/components/AuthPanel.tsx:13
↓ 3 callersFunctionmergeTasks
(prev: TaskItem[], incoming: TaskItem)
web/src/App.tsx:49
↓ 3 callersMethodpost
(ctx context.Context, endpoint string, payload any, out any, withAuth bool)
sdk/go/openmcp/client.go:148
↓ 3 callersMethodsortRecords
()
internal/storage/mysql/task_repository.go:246
↓ 3 callersFunctiontoHexBig
(n *big.Int)
internal/web3/ethereum/client.go:371
↓ 3 callersFunctiontruncate
(text string)
internal/llm/openai/client.go:215
↓ 2 callersMethodAccessToken
AccessToken returns the currently stored token string.
sdk/go/openmcp/client.go:135
↓ 2 callersMethodClone
Clone 创建并返回主体的深拷贝,包括角色和权限切片的副本,以防止外部修改
internal/auth/types.go:99
↓ 2 callersMethodConsume
(ctx context.Context, workerCount int, handler Handler)
internal/task/queue.go:18
↓ 2 callersMethodCreate
(ctx context.Context, task *Task)
internal/task/store.go:11
↓ 2 callersMethodDeployContract
(ctx context.Context, auth *bind.TransactOpts, abiJSON string, bytecode []byte, params ...any)
internal/web3/types.go:64
↓ 2 callersMethodExecuteAction
(ctx context.Context, action, address string)
internal/web3/types.go:63
↓ 2 callersMethodFetchChainSnapshot
(ctx context.Context)
internal/web3/types.go:62
↓ 2 callersMethodFindUserByUsername
(ctx context.Context, username string)
internal/auth/types.go:23
↓ 2 callersMethodGenerate
(ctx context.Context, req Request)
internal/llm/llm.go:28
↓ 2 callersMethodGenerate
Generate 调用 OpenAI 生成结构化回复。
internal/llm/openai/client.go:73
↓ 2 callersMethodGet
Get 查询指定任务。
internal/task/mysql_store.go:134
↓ 2 callersMethodGetTask
GetTask fetches task details by identifier.
sdk/go/openmcp/client.go:125
↓ 2 callersFunctionHandler
Handler 返回一个 HTTP 处理器,用于暴露 Prometheus 格式的指标数据。
internal/observability/metrics/http.go:112
↓ 2 callersFunctionInit
Init configures the global logger instances.
pkg/logger/logger.go:40
↓ 2 callersFunctionIsTaskError
IsTaskError 判断错误是否为统一任务错误。
internal/task/task.go:119
↓ 2 callersFunctionIsValidStatus
IsValidStatus 检查给定的任务状态是否为支持的枚举值。
internal/task/task.go:150
↓ 2 callersMethodList
(ctx context.Context, opts ListOptions)
internal/task/store.go:16
↓ 2 callersMethodListLatest
(ctx context.Context, limit int)
internal/storage/mysql/task_repository.go:38
↓ 2 callersMethodMarkFailed
MarkFailed 标记任务失败。
internal/task/memory_store.go:112
↓ 2 callersMethodMarkSucceeded
(ctx context.Context, id string, result ExecutionResult)
internal/task/store.go:14
↓ 2 callersMethodMarkSucceeded
MarkSucceeded 记录成功结果。
internal/task/memory_store.go:96
next →1–100 of 459, ranked by callers