MCPcopy Create free account

hub / github.com/NuyoahCh/mcpchainx / functions

Functions459 in github.com/NuyoahCh/mcpchainx

⨍ Functions 459◇ Types & classes 188
↓ 2 callersFunctionMergePolicies
MergePolicies combines the default and plugin specific isolation policies.
pkg/plugin/isolation.go:56
↓ 2 callersMethodMiddleware
Middleware 返回一个 HTTP 中间件，用于处理身份认证和授权。
internal/auth/middleware.go:19
↓ 2 callersFunctionNewClient
NewClient dials the configured RPC endpoints and returns a ready-to-use client.
internal/web3/ethereum/client.go:52
↓ 2 callersFunctionNewIsolationStrategy
NewIsolationStrategy returns a default isolation strategy if none is supplied.
pkg/plugin/isolation.go:48
↓ 2 callersMethodNotify
(ctx context.Context, event Event)
internal/observability/alerting/alert.go:40
↓ 2 callersMethodSubmitTask
SubmitTask creates a new task using the stored access token.
sdk/go/openmcp/client.go:116
↓ 2 callersMethodTimeout
Timeout 返回配置的超时时间，默认 60 秒。
internal/config/config.go:179
↓ 2 callersMethodValidate
(info Info, policy IsolationPolicy)
pkg/plugin/isolation.go:11
↓ 2 callersFunctionWithLLMTimeout
WithLLMTimeout 设置调用大模型的超时时间。
internal/agent/agent.go:70
↓ 2 callersFunctionWithLimit
WithLimit limits the number of tasks returned.
internal/task/list_options.go:63
↓ 2 callersFunctionWithSortOrder
WithSortOrder changes the returned order of tasks.
internal/task/list_options.go:114
↓ 2 callersFunctionWithUpdatedSince
WithUpdatedSince filters tasks updated after the provided instant (inclusive).
internal/task/list_options.go:84
↓ 2 callersFunctionbuildFilterClause
(opts ListOptions)
internal/task/mysql_store.go:419
↓ 2 callersFunctionbuildUrl
(path: string)
web/src/api.ts:142
↓ 2 callersMethodcollectStrings
(ctx context.Context, query string, args ...any)
internal/storage/mysql/auth_store.go:97
↓ 2 callersFunctiondedupeValues
(values []string)
internal/storage/mysql/auth_store.go:207
↓ 2 callersMethoddo
(req *http.Request, out any)
sdk/go/openmcp/client.go:186
↓ 2 callersMethodensureFile
()
pkg/logger/rotate.go:79
↓ 2 callersFunctionfetchTaskStats
( query: TaskStatsQuery = {}, )
web/src/api.ts:361
↓ 2 callersFunctionfetchWithTimeout
( input: string, options: RequestOptions = {}, )
web/src/api.ts:147
↓ 2 callersFunctionfetch_stats
( endpoint: str, statuses: list[str], since: str | None, until: str | None, has_result: st
examples/task_quickstart.py:67
↓ 2 callersFunctionformatFloat
formatFloat 将浮点数格式化为字符串。
internal/observability/metrics/http.go:225
↓ 2 callersFunctiongetAuthState
()
web/src/api.ts:721
↓ 2 callersFunctiongetConnectionType
()
web/src/hooks/useNetworkStatus.ts:19
↓ 2 callersFunctiongetIsOnline
()
web/src/hooks/useNetworkStatus.ts:9
↓ 2 callersMethodhandleListTasks
handleListTasks 处理列出智能体任务的请求。
internal/api/server.go:298
↓ 2 callersFunctionisAuthExpired
(state: AuthState | null | undefined)
web/src/api.ts:736
↓ 2 callersMethodlogDebug
(msg string, attrs ...slog.Attr)
internal/task/processor.go:224
↓ 2 callersFunctionmatchesListFilters
(task *Task, opts ListOptions)
internal/task/memory_store.go:185
↓ 2 callersMethodnewRequest
(ctx context.Context, method, endpoint string, body io.Reader, withAuth bool)
sdk/go/openmcp/client.go:169
↓ 2 callersFunctionopenDatabase
Config 定义 MySQL 连接的配置参数。
internal/storage/mysql/connection.go:12
↓ 2 callersFunctionparseFilterOptions
(query map[string][]string)
internal/api/server.go:534
↓ 2 callersMethodrender
render 生成 Prometheus 格式的指标数据字符串。
internal/observability/metrics/http.go:120
↓ 2 callersFunctionrequest_json
(method: str, url: str, data: dict[str, Any] | None = None)
scripts/task_client.py:18
↓ 2 callersFunctionrunMigrations
Migrate 执行数据库迁移。
internal/storage/mysql/migrations.go:26
↓ 2 callersMethodsign
sign 使用 HMAC-SHA256 签名 JWT 令牌。
internal/auth/service.go:352
↓ 2 callersMethodsignature
signature 计算 JWT 令牌的签名部分。
internal/auth/service.go:364
↓ 2 callersFunctiontoCandidate
(value: unknown)
web/src/App.tsx:107
↓ 2 callersFunctionunmarshalMetadata
(raw sql.NullString)
internal/task/mysql_store.go:408
↓ 1 callersMethodApplySeed
(ctx context.Context, seed Seed)
internal/auth/types.go:29
↓ 1 callersMethodAuthenticate
Authenticate 根据提供的令牌请求进行身份验证，并返回相应的令牌对。 current mode.
internal/auth/service.go:111
↓ 1 callersMethodAuthenticateRequest
AuthenticateRequest 验证传入请求的授权头，并返回相应的主体信息。 associated subject.
internal/auth/service.go:176
↓ 1 callersMethodAuthorize
Authorize 验证主体是否具有所有指定的权限。
internal/auth/types.go:80
↓ 1 callersMethodClaim
(ctx context.Context, id string)
internal/task/store.go:13
↓ 1 callersMethodClose
Close releases all clients managed by the registry.
internal/web3/provider/registry.go:105
↓ 1 callersMethodCode
Code 返回错误码。
internal/errors/errors.go:234
↓ 1 callersMethodConfigure
Configure allows the plugin to inspect its configuration block prior to initialisation. Implementations may mutate the configuration map to inject def
pkg/plugin/plugin.go:11
↓ 1 callersMethodDefaultClient
DefaultClient returns the client configured as default chain.
internal/web3/provider/registry.go:84
↓ 1 callersFunctionEnsurePolicy
EnsurePolicy returns an error when the isolation policy is empty and the plugin requests capabilities.
pkg/plugin/isolation.go:68
↓ 1 callersMethodGet
Get 返回指定任务的状态。
internal/task/service.go:92
↓ 1 callersMethodHasPermission
HasPermission 检查主体是否具有指定的权限。
internal/auth/types.go:70
↓ 1 callersMethodInit
Init prepares the plugin for use.
pkg/plugin/plugin.go:13
↓ 1 callersFunctionLoad
Load 负责解析指定路径的 JSON 配置文件。
internal/config/config.go:210
↓ 1 callersMethodLoad
(path string)
pkg/plugin/loader.go:10
↓ 1 callersMethodLoad
Load loads a plugin implementation from disk and registers it with the manager.
pkg/plugin/manager.go:88
↓ 1 callersFunctionLoadChainDefinitions
LoadChainDefinitions parses the YAML file containing chain metadata.
internal/web3/config.go:26
↓ 1 callersFunctionLoadStaticProvider
LoadStaticProvider 从 JSON 文件加载知识条目。
internal/knowledge/static.go:42
↓ 1 callersMethodLogs
Logs returns the channel that receives blockchain logs.
internal/web3/types.go:39
↓ 1 callersMethodMerge
Merge returns a new policy using values from other when not present.
pkg/plugin/config.go:33
↓ 1 callersFunctionNamed
Named returns a child logger with the provided component name.
pkg/logger/logger.go:182
↓ 1 callersFunctionNew
New 创建一个新的错误实例。
internal/errors/errors.go:182
↓ 1 callersFunctionNewClient
NewClient 创建 Python Bridge 客户端。
internal/llm/pythonbridge/bridge.go:24
↓ 1 callersFunctionNewEventSubscription
NewEventSubscription constructs a managed subscription wrapper.
internal/web3/types.go:34
↓ 1 callersFunctionNewMemoryQueue
NewMemoryQueue 创建一个内存队列。
internal/task/memory_queue.go:17
↓ 1 callersFunctionNewMemoryStore
NewMemoryStore 使用初始种子数据创建 MemoryStore 实例。
internal/auth/memory_store.go:20
↓ 1 callersFunctionNewMemoryTaskRepository
NewMemoryTaskRepository 创建一个内存任务仓库。
internal/storage/mysql/task_repository.go:51
↓ 1 callersFunctionNewMySQLStore
NewMySQLStore 创建一个新的 MySQLStore。
internal/task/mysql_store.go:22
↓ 1 callersFunctionNewProcessor
NewProcessor 构造 Processor。
internal/task/processor.go:67
↓ 1 callersFunctionNewRabbitMQQueue
NewRabbitMQQueue 创建 RabbitMQ 队列实例。
internal/task/rabbitmq_queue.go:29
↓ 1 callersFunctionNewRedisQueue
NewRedisQueue 创建 Redis 队列实例。
internal/task/redis_queue.go:29
↓ 1 callersFunctionNewRegistry
NewRegistry loads chain definitions and instantiates concrete clients.
internal/web3/provider/registry.go:22
↓ 1 callersFunctionNewSQLAuthStore
NewSQLAuthStore creates the store using the provided connection settings.
internal/storage/mysql/auth_store.go:21
↓ 1 callersFunctionNewSQLTaskRepository
NewSQLTaskRepository 创建连接池并初始化数据表。
internal/storage/mysql/task_repository.go:369
↓ 1 callersFunctionNewService
NewService 构造身份认证服务实例。
internal/auth/service.go:45
↓ 1 callersFunctionNewSimulatedClient
NewSimulatedClient wraps a go-ethereum simulated backend for testing purposes.
internal/web3/ethereum/client.go:92
↓ 1 callersFunctionNewStaticProvider
NewStaticProvider 创建静态知识库实例。
internal/knowledge/static.go:31
↓ 1 callersMethodNormalise
Normalise 对外暴露的规范化方法。
internal/auth/types.go:65
↓ 1 callersFunctionObserveHTTPRequest
ObserveHTTPRequest 记录一次 HTTP 请求的指标数据。
internal/observability/metrics/http.go:58
↓ 1 callersMethodPrepare
(info Info)
pkg/plugin/isolation.go:12
↓ 1 callersMethodRecover
Recover 尝试根据失败原因进行补偿或降级。 返回的 ExecutionResult 将作为降级结果写入任务；若返回 nil 则继续按照失败流程处理。
internal/task/recovery.go:9
↓ 1 callersFunctionResolveScriptPath
ResolveScriptPath 根据工作目录推导脚本绝对路径。
internal/llm/pythonbridge/bridge.go:107
↓ 1 callersMethodRetryable
Retryable 判断是否可重试。
internal/errors/errors.go:262
↓ 1 callersMethodSendBatchTransactions
(ctx context.Context, txs []*types.Transaction)
internal/web3/types.go:66
↓ 1 callersMethodSeverity
Severity 返回错误严重程度。
internal/errors/errors.go:286
↓ 1 callersMethodShouldAlert
ShouldAlert 判断是否需要告警。
internal/errors/errors.go:274
↓ 1 callersMethodStart
Start activates the plugin and should spawn long running routines if required.
pkg/plugin/plugin.go:15
↓ 1 callersMethodStart
Start initialises and starts a plugin by id.
pkg/plugin/manager.go:100
↓ 1 callersMethodStart
Start 启动任务处理循环。
internal/task/processor.go:87
↓ 1 callersMethodStart
Start 启动 HTTP 服务，直到上下文取消或出现错误。
internal/api/server.go:59
↓ 1 callersFunctionStartServer
StartServer 启动一个 HTTP 服务器以暴露指标数据，直到上下文取消或出现错误。
internal/observability/metrics/http.go:230
↓ 1 callersMethodStop
Stop halts a plugin if it is running.
pkg/plugin/manager.go:129
↓ 1 callersFunctionSubjectFromContext
SubjectFromContext 从上下文中提取经过身份验证的主体信息。
internal/auth/context.go:18
↓ 1 callersMethodSubmit
Submit 创建一个新的任务并推送到队列。
internal/task/service.go:33
↓ 1 callersMethodSubscribeEvents
(ctx context.Context, query gethcore.FilterQuery)
internal/web3/types.go:65
↓ 1 callersMethodSubscribeFilterLogs
(ctx context.Context, q gethcore.FilterQuery, ch chan<- coretypes.Log)
internal/web3/ethereum/client.go:48
↓ 1 callersFunctionSync
Sync flushes buffered log entries to their outputs.
pkg/logger/logger.go:172
↓ 1 callersMethodVerify
Verify 验证 JWT 令牌的有效性并返回其声明。
internal/auth/service.go:373
↓ 1 callersFunctionWithAuthService
WithAuthService 设置身份认证服务。
internal/api/server.go:52
↓ 1 callersFunctionWithKnowledgeProvider
WithKnowledgeProvider 配置知识库，用于在推理前补充上下文。
internal/agent/agent.go:63
↓ 1 callersFunctionWithMemoryDepth
WithMemoryDepth 设置大模型调用时可参考的历史任务数量。
internal/agent/agent.go:56
← previousnext →101–200 of 459, ranked by callers