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

Method SetSender

internal/nodeagent/usage.go:72–76  ·  view source on GitHub ↗

SetSender 注入当前 session 的 Sender。传 nil 时下一轮 push 会被跳过。 一般在 Config.OnConnected 回调里调用: cfg.OnConnected = func(ctx context.Context, s nodeagent.Sender) { pusher.SetSender(s) }

(s Sender)

Source from the content-addressed store, hash-verified

70// pusher.SetSender(s)
71// }
72func (p *UsagePusher) SetSender(s Sender) {
73 p.mu.Lock()
74 p.sender = s
75 p.mu.Unlock()
76}
77
78func (p *UsagePusher) currentSender() Sender {
79 p.mu.Lock()

Callers 8

TestE2E_UsagePushAckFunction · 0.95
TestE2E_MultiNodeFunction · 0.95
RunFunction · 0.95
runSessionFunction · 0.45

Calls

no outgoing calls