MCPcopy Create free account

hub / github.com/NuyoahCh/mcpchainx / functions

Functions459 in github.com/NuyoahCh/mcpchainx

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