Function Views

src/environmentd/src/http/static/js/memory.jsx:110–241

(props)

}

function Views(props) {
  const [currentDataflow, setCurrentDataflow] = useState(null);
  const [includeSystemCatalog, setIncludeSystemCatalog] = useState(false);
  const [records, setRecords] = useState(null);
  const [loading, setLoading] = useState(true);
  const [error, setError] = useState(false);

  useEffect(() => {
    const search = new URLSearchParams(location.search);
    const dataflow = search.get('dataflow');
    if (dataflow) {
      setCurrentDataflow(dataflow);
    }
    setIncludeSystemCatalog(search.get('system_catalog') === 'true');
  }, []);

  useEffect(() => {
    setCurrentDataflow(null);
  }, [props]);

  useEffect(() => {
    const params = new URLSearchParams(location.search);
    if (currentDataflow) {
      params.set('dataflow', currentDataflow);
    } else {
      params.delete('dataflow');
    }
    window.history.replaceState({}, '', `${location.pathname}?${params}`);
  }, [currentDataflow]);

  const whereFragment = includeSystemCatalog ? `` : `WHERE name NOT LIKE 'Dataflow: mz_catalog.%'`;

  useEffect(() => {
    setLoading(true);
    setError(false);

    const load = async () => {
      const {
        results: [_set_cluster, _set_replica, records_table],
      } = await query(`
        SET cluster = ${formatNameForQuery(props.clusterName)};
        SET cluster_replica = ${formatNameForQuery(props.replicaName)};
        SELECT
          id, name, batches, records, size, capacity, allocations
        FROM
          mz_introspection.mz_records_per_dataflow
        ${whereFragment}
        ORDER BY
          records DESC
      `);

      setRecords(records_table.rows);
      setLoading(false);
    };
    load().catch((error) => {
      setError(error);
      setLoading(false);
    });