Function sendLogs

agent/boundarylogproxy/proxy_test.go:37–47

sendLogs writes a BoundaryMessage envelope containing logs to the connection using TagV2.

(t *testing.T, conn net.Conn, req *agentproto.ReportBoundaryLogsRequest)

// sendLogs writes a BoundaryMessage envelope containing logs to the
// connection using TagV2.
func sendLogs(t *testing.T, conn net.Conn, req *agentproto.ReportBoundaryLogsRequest) {
	t.Helper()

	msg := &codec.BoundaryMessage{
		Msg: &codec.BoundaryMessage_Logs{Logs: req},
	}
	err := codec.WriteMessage(conn, codec.TagV2, msg)
	if err != nil {
		t.Errorf("write logs: %s", err)
	}
}

// sendStatus writes a BoundaryMessage envelope containing a BoundaryStatus
// to the connection using TagV2.