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

Method PushEvent

internal/nodeagent/agent.go:46–46  ·  view source on GitHub ↗

PushEvent 推送一条非请求/响应的事件帧。reqID 通常留空(对 usage_push、 hello 而言),log/traceroute_hop 应携带触发它们的 server 请求 id。

(reqID, event string, body []byte, seq uint64)

Source from the content-addressed store, hash-verified

44 // PushEvent 推送一条非请求/响应的事件帧。reqID 通常留空(对 usage_push、
45 // hello 而言),log/traceroute_hop 应携带触发它们的 server 请求 id。
46 PushEvent(reqID, event string, body []byte, seq uint64) error
47 // WaitAck 阻塞等待对应 seq 的 ack(usage_push 用),ctx 控制超时。
48 // 在 WaitAck 之前调用 PushEvent;同一个 seq 仅会被 Wait 一次。
49 WaitAck(ctx context.Context, seq uint64) error

Callers 5

TestE2E_StreamLogsCancelFunction · 0.65
TestAgent_UsagePushAckFunction · 0.65
tickMethod · 0.65
handleLogsStreamMethod · 0.65

Implementers 3

fakeSenderinternal/nodeagent/dispatch_test.go
mockSenderinternal/nodeagent/usage_test.go
sessioninternal/nodeagent/session.go

Calls

no outgoing calls

Tested by 2

TestE2E_StreamLogsCancelFunction · 0.52
TestAgent_UsagePushAckFunction · 0.52