Method replicateQuery

server/logrepl/replication.go:418–422

replicateQuery executes the query provided on the replica connection

(replicationConn *pgx.Conn, query string)

// replicateQuery executes the query provided on the replica connection
func (r *LogicalReplicator) replicateQuery(replicationConn *pgx.Conn, query string) error {
	log.Printf("replicating query: %s", query)
	_, err := replicationConn.Exec(context.Background(), query)
	return err
}

// beginReplication starts a new replication connection to the primary server and returns it. The LSN provided is the
// last one we have confirmed that we flushed to disk.