Method sendRaw

internal/nodeagent/session.go:99–103

(msg *nodev1.NodeMessage)

}

func (s *session) sendRaw(msg *nodev1.NodeMessage) error {
	s.sendMu.Lock()
	defer s.sendMu.Unlock()
	return s.stream.Send(msg)
}

// PushEvent 实现 Sender。
func (s *session) PushEvent(reqID, event string, body []byte, seq uint64) error {