MCPcopy Create free account
hub / github.com/0xUnixIO/pulse / Call

Method Call

internal/nodes/client.go:26–26  ·  view source on GitHub ↗
(ctx context.Context, nodeID, method string, body any)

Source from the content-addressed store, hash-verified

24// 生产环境由 *nodehub.Hub 实现。
25type HubCaller interface {
26 Call(ctx context.Context, nodeID, method string, body any) (json.RawMessage, error)
27}
28
29// HubStream 是 hub 流式调用返回的最小接口。生产实现由 nodehub 注册，

Callers 11

TestE2E_DispatchRPCFunction · 0.65
TestIntegration_HelloAndCallFunction · 0.65
TestSnapshot_BasicCountsFunction · 0.65
TestCall_SuccessFunction · 0.65
TestCall_NodeReturnsErrorFunction · 0.65
TestCall_ContextTimeoutSendsCancelFunction · 0.65
TestCall_OfflineNodeFunction · 0.65
TestCall_ConcurrentFunction · 0.65
TestLoad_ConcurrentNodesFunction · 0.65
callHubMethod · 0.65
CallMethod · 0.65

Implementers 8

recordingHubCallerinternal/integration/grpcpush_test.go
fakeHubinternal/jobs/fakehub_test.go
recordHubCallerinternal/jobs/selfsync_test.go
Hubinternal/nodehub/hub.go
mockHubinternal/nodes/client_hub_test.go
fakeHubCallerinternal/nodes/usagebuf_test.go
hubCallerAdapterinternal/server/server_selfsync.go
fakeHubinternal/serverapi/fakehub_test.go

Calls

no outgoing calls

Tested by 9

TestE2E_DispatchRPCFunction · 0.52
TestIntegration_HelloAndCallFunction · 0.52
TestSnapshot_BasicCountsFunction · 0.52
TestCall_SuccessFunction · 0.52
TestCall_NodeReturnsErrorFunction · 0.52
TestCall_ContextTimeoutSendsCancelFunction · 0.52
TestCall_OfflineNodeFunction · 0.52
TestCall_ConcurrentFunction · 0.52
TestLoad_ConcurrentNodesFunction · 0.52