Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/NuyoahCh/mcpchainx
/ functions
Functions
459 in github.com/NuyoahCh/mcpchainx
⨍
Functions
459
◇
Types & classes
188
Method
Close
Close terminates the subscription.
internal/web3/types.go:52
Method
Close
Close releases network connections held by the client.
internal/web3/ethereum/client.go:103
Method
Close
Close 关闭 Redis 连接。
internal/task/redis_queue.go:108
Method
Close
Close 释放资源。
internal/task/service.go:118
Method
Close
Close 对内存存储无需操作。
internal/task/memory_store.go:171
Method
Close
Close 关闭 RabbitMQ 连接。
internal/task/rabbitmq_queue.go:115
Method
Close
Close 关闭底层数据库连接。
internal/task/mysql_store.go:347
Method
Close
()
internal/task/queue.go:13
Method
Close
()
internal/task/queue.go:19
Method
Close
Close 关闭内存队列。
internal/task/memory_queue.go:69
Method
Close
Close releases the underlying database connection pool.
internal/storage/mysql/auth_store.go:34
Method
Close
Close 关闭底层数据库连接。
internal/storage/mysql/task_repository.go:560
Method
Close
()
internal/api/server_test.go:164
Function
CodeOf
CodeOf 返回错误对应的错误码。
internal/errors/errors.go:310
Method
Configure
Configure 配置内存数据源插件。
examples/plugins/datasource/memory/memory.go:36
Method
Configure
Configure 配置日志处理器插件。
examples/plugins/processor/logger/logger.go:31
Function
ConnectionSettings
({ baseUrl, defaultBaseUrl, onUpdate, onReset, onTest, testing, status, lastSynced, refreshi
web/src/components/ConnectionSettings.tsx:27
Method
Consume
Consume 通过 BRPOP 从 Redis 获取任务。
internal/task/redis_queue.go:61
Method
Consume
Consume 使用手动确认模式消费 RabbitMQ 队列。
internal/task/rabbitmq_queue.go:74
Method
Consume
Consume 启动指定数量的工作协程消费队列中的任务。
internal/task/memory_queue.go:41
Method
Create
Create 插入新的任务记录。
internal/task/mysql_store.go:90
Method
Create
(ctx context.Context, record *TaskRecord)
internal/storage/mysql/task_repository.go:34
Method
Create
Create 以追加写的方式记录任务结果。
internal/storage/mysql/task_repository.go:67
Method
Create
(_ context.Context, record *TaskRecord)
internal/storage/mysql/task_repository.go:269
Method
Create
(ctx context.Context, record *TaskRecord)
internal/storage/mysql/task_repository.go:383
Method
Create
(ctx context.Context, record *TaskRecord)
internal/storage/mysql/task_repository.go:571
Method
Delete
(ctx context.Context, id int64)
internal/storage/mysql/task_repository.go:37
Method
Delete
(_ context.Context, id int64)
internal/storage/mysql/task_repository.go:124
Method
Delete
(_ context.Context, id int64)
internal/storage/mysql/task_repository.go:323
Method
Delete
(ctx context.Context, id int64)
internal/storage/mysql/task_repository.go:479
Method
Delete
(ctx context.Context, id int64)
internal/storage/mysql/task_repository.go:667
Method
DeployContract
DeployContract sends the contract creation transaction using the provided transact opts and bytecode.
internal/web3/ethereum/client.go:223
Method
Error
()
sdk/go/openmcp/client.go:79
Method
Execute
Execute 根据任务目标调用大模型,并尝试从链上获取实时信息。
internal/agent/agent.go:104
Method
ExecuteAction
ExecuteAction runs small helper RPC calls for the agent layer.
internal/web3/ethereum/client.go:178
Method
FetchChainSnapshot
FetchChainSnapshot gathers lightweight metadata from the chain.
internal/web3/ethereum/client.go:128
Method
FindUserByUsername
FindUserByUsername 根据用户名查找用户记录。
internal/auth/memory_store.go:103
Method
FindUserByUsername
FindUserByUsername implements auth.Store.
internal/storage/mysql/auth_store.go:42
Method
Generate
Generate 调用外部脚本,并解析输出。
internal/llm/pythonbridge/bridge.go:39
Method
Generate
Generate 生成访问令牌和刷新令牌对。
internal/auth/service.go:304
Method
Generate
Generate 生成一个响应。
internal/agent/agent_test.go:20
Method
Get
Get 返回任务。
internal/task/memory_store.go:54
Method
GetByID
(ctx context.Context, id int64)
internal/storage/mysql/task_repository.go:35
Method
GetByID
(_ context.Context, id int64)
internal/storage/mysql/task_repository.go:86
Method
GetByID
(_ context.Context, id int64)
internal/storage/mysql/task_repository.go:291
Method
GetByID
(ctx context.Context, id int64)
internal/storage/mysql/task_repository.go:418
Method
GetByID
(ctx context.Context, id int64)
internal/storage/mysql/task_repository.go:606
Method
Info
Info 返回插件的元信息。
examples/plugins/datasource/memory/memory.go:23
Method
Info
Info 返回插件的元信息。
examples/plugins/processor/logger/logger.go:18
Method
Init
Init 初始化内存数据源插件。
examples/plugins/datasource/memory/memory.go:72
Method
Init
Init 初始化日志处理器插件。
examples/plugins/processor/logger/logger.go:34
Method
List
List 返回符合过滤条件的任务列表。
internal/task/service.go:100
Method
List
List 返回最近的任务。
internal/task/mysql_store.go:277
Method
ListHistory
ListHistory 获取最近的任务执行记录。
internal/agent/agent.go:212
Method
ListLatest
ListLatest 返回最近的任务记录,按时间倒序排列。
internal/storage/mysql/task_repository.go:146
Method
ListLatest
(_ context.Context, limit int)
internal/storage/mysql/task_repository.go:338
Method
ListLatest
ListLatest 查询最近的若干条任务记录。
internal/storage/mysql/task_repository.go:496
Method
ListLatest
(ctx context.Context, limit int)
internal/storage/mysql/task_repository.go:683
Method
Load
Load opens the shared object and searches for a `Plugin` symbol implementing the Plugin interface.
pkg/plugin/loader.go:17
Function
LoadManagerConfig
LoadManagerConfig reads a YAML file into a ManagerConfig.
pkg/plugin/config.go:44
Method
LoadSubject
LoadSubject 根据用户 ID 加载主体信息。
internal/auth/memory_store.go:114
Method
LoadSubject
LoadSubject loads the subject details including roles and permissions.
internal/storage/mysql/auth_store.go:58
Method
MarkFailed
MarkFailed 将任务标记为失败,并在必要时终止重试。
internal/task/mysql_store.go:252
Method
MarkSucceeded
MarkSucceeded 将任务标记为成功。
internal/task/mysql_store.go:227
Method
Message
Message 返回错误信息。
internal/errors/errors.go:242
Method
Metadata
Metadata 返回附加信息。
internal/errors/errors.go:250
Function
NewFanout
NewFanout 创建一个新的 FanoutDispatcher。
internal/observability/alerting/alert.go:54
Function
NewManager
NewManager constructs a manager using the supplied configuration and options.
pkg/plugin/manager.go:32
Method
Notify
(ctx context.Context, event Event)
internal/observability/alerting/alert.go:45
Method
Notify
Notify 将事件广播至所有注册渠道。
internal/observability/alerting/alert.go:66
Method
Notify
Notify 发送邮件。
internal/observability/alerting/alert.go:98
Method
Notify
Notify 发送钉钉消息。
internal/observability/alerting/alert.go:129
Method
Notify
Notify 发送 Slack 消息。
internal/observability/alerting/alert.go:154
Method
Prepare
Prepare implements IsolationStrategy.
pkg/plugin/isolation.go:42
Method
Publish
Publish 将任务投递到 Redis。
internal/task/redis_queue.go:53
Method
Publish
Publish 将任务投递到 RabbitMQ。
internal/task/rabbitmq_queue.go:63
Method
Publish
Publish 将任务投递到队列。
internal/task/memory_queue.go:25
Method
Publish
(_ context.Context, taskID string)
internal/api/server_test.go:159
Method
Query
Query 根据目标和链上操作进行简单匹配。
internal/knowledge/static.go:67
Function
Register
Register 允许业务模块在初始化阶段注册新的错误码描述。
internal/errors/errors.go:116
Function
RetryableError
Retryable 判断任意 error 是否可重试。
internal/errors/errors.go:318
Method
Send
(ctx context.Context, content string)
internal/observability/alerting/alert.go:117
Method
Send
(ctx context.Context, channel, content string)
internal/observability/alerting/alert.go:141
Method
SendBatchTransactions
SendBatchTransactions broadcasts multiple signed transactions in a single RPC batch call when possible.
internal/web3/ethereum/client.go:276
Method
SetAccessToken
SetAccessToken overrides the stored access token.
sdk/go/openmcp/client.go:142
Function
SeverityOf
SeverityOf 返回错误严重程度。
internal/errors/errors.go:334
Function
ShouldAlert
ShouldAlert 判断是否需要触发告警。
internal/errors/errors.go:326
Method
Start
Start 启动内存数据源插件,向下游发送配置的记录。
examples/plugins/datasource/memory/memory.go:75
Method
Start
Start 启动日志处理器插件,开始记录传入的负载。
examples/plugins/processor/logger/logger.go:37
Method
StartAll
StartAll starts all registered plugins.
pkg/plugin/manager.go:151
Method
State
State returns the lifecycle state of a plugin.
pkg/plugin/manager.go:183
Method
Stats
Stats 返回符合过滤条件的任务统计信息。
internal/task/service.go:109
Method
Stats
Stats 返回符合过滤条件的任务聚合信息。
internal/task/mysql_store.go:355
Function
StatusSummary
({ tasks, stats, loading }: StatusSummaryProps)
web/src/components/StatusSummary.tsx:24
Method
Stop
Stop 停止内存数据源插件。
examples/plugins/datasource/memory/memory.go:93
Method
Stop
Stop 停止日志处理器插件。
examples/plugins/processor/logger/logger.go:53
Method
StopAll
StopAll stops all active plugins.
pkg/plugin/manager.go:167
Method
SubscribeEvents
SubscribeEvents attaches a log subscription to the chain.
internal/web3/ethereum/client.go:257
Function
TaskDetails
({ task, isPolling }: TaskDetailsProps)
web/src/components/TaskDetails.tsx:10
Function
TaskForm
({ onSubmit, submitting, disabled, disabledReason, loading }: TaskFormProps)
web/src/components/TaskForm.tsx:24
← previous
next →
301–400 of 459, ranked by callers