Function writePGMessage

server/conn_test.go:3947–3951

writePGMessage writes a PostgreSQL wire protocol message (type byte + int32 length + body) into w, matching the format wire.ReadMessage() expects.

(w io.Writer, msgType byte, body []byte)

// An org's full-power principal (nil QueryAccessPolicy) sees its own org's
// connections in pg_stat_activity, never another org's. On the multitenant
// control plane every org shares one process-wide connection registry.
func TestPgStatActivityOrgRootSeesOnlyOwnOrg(t *testing.T) {
	srv := &Server{conns: make(map[int32]*clientConn)}
	root := &clientConn{server: srv, username: "root", orgID: "org-a", pid: 100}
	sameOrg := &clientConn{username: "svc-reporting", orgID: "org-a", pid: 101}
	otherOrg := &clientConn{username: "root", orgID: "org-b", pid: 102}
	for _, conn := range []*clientConn{root, sameOrg, otherOrg} {
		srv.registerConn(conn)