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

Function NewClientWithHub

internal/nodes/client.go:146–148  ·  view source on GitHub ↗

NewClientWithHub 构造一个绑定到 gRPC long-connection hub 的 Client。 nodeID 是节点逻辑 ID（与 hub 注册时一致）。hub 必须非 nil；否则后续方法 都会返回 ErrHubNotConfigured。

(nodeID string, hub HubCaller)

Source from the content-addressed store, hash-verified

144// nodeID 是节点逻辑 ID（与 hub 注册时一致）。hub 必须非 nil；否则后续方法
145// 都会返回 ErrHubNotConfigured。
146func NewClientWithHub(nodeID string, hub HubCaller) *Client {
147 return &Client{nodeID: nodeID, hub: hub}
148}
149
150func (c *Client) Runtime(ctx context.Context) (RuntimeInfo, error) {
151 var out RuntimeInfo

Callers 15

TestE2E_DispatchRPCFunction · 0.92
TestE2E_StreamLogsCancelFunction · 0.92
TestE2E_UsagePushAckFunction · 0.92
TestE2E_MultiNodeFunction · 0.92
TestIntegration_NodesClient_HubPathFunction · 0.92
hubDialFunction · 0.92
RunFunction · 0.92
NewFunction · 0.92
SetNodeHubMethod · 0.92
fakeHubClientFactoryFunction · 0.92
TestClient_Status_HubSuccessFunction · 0.85
TestClient_HubOffline_UsesSentinelFunction · 0.85

Calls

no outgoing calls

Tested by 15

TestE2E_DispatchRPCFunction · 0.74
TestE2E_StreamLogsCancelFunction · 0.74
TestE2E_UsagePushAckFunction · 0.74
TestE2E_MultiNodeFunction · 0.74
TestIntegration_NodesClient_HubPathFunction · 0.74
hubDialFunction · 0.74
fakeHubClientFactoryFunction · 0.74
TestClient_Status_HubSuccessFunction · 0.68
TestClient_HubOffline_UsesSentinelFunction · 0.68
TestClient_HubOffline_RegisteredSentinelFunction · 0.68
TestClient_HubBadJSON_ReturnsDecodeErrorFunction · 0.68
TestClient_HubGenericError_PassThroughFunction · 0.68