Method sendNode

internal/nodehub/hub_test.go:165–169

(msg *nodev1.NodeMessage)

}

func (m *nodeMock) sendNode(msg *nodev1.NodeMessage) {
	m.sendMu.Lock()
	defer m.sendMu.Unlock()
	_ = m.stream.Send(msg)
}

func (m *nodeMock) pushUsage(seq uint64, body []byte) {
	m.sendNode(&nodev1.NodeMessage{Event: "usage_push", Seq: seq, Body: body})