weave-scope/client/app/scripts/utils/data-utils.js

import _ from 'lodash';
import d3 from 'd3';
import { formatMetric } from './string-utils';
import AppStore from '../stores/app-store';


// Inspired by Lee Byron's test data generator.
/*eslint-disable */
function bumpLayer(n, maxValue) {
  function bump(a) {
    const x = 1 / (0.1 + Math.random());
    const y = 2 * Math.random() - 0.5;
    const z = 10 / (0.1 + Math.random());
    for (let i = 0; i < n; i++) {
      const w = (i / n - y) * z;
      a[i] += x * Math.exp(-w * w);
    }
  }

  const a = [];
  let i;
  for (i = 0; i < n; ++i) a[i] = 0;
  for (i = 0; i < 5; ++i) bump(a);
  const values = a.map(function(d) { return Math.max(0, d * maxValue); });
  const s = d3.scale.linear().domain(d3.extent(values)).range([0, maxValue]);
  return values.map(s);
}
/*eslint-enable */


const nodeData = {};


function getNextValue(keyValues, maxValue) {
  const key = keyValues.join('-');
  let series = nodeData[key];
  if (!series || !series.length) {
    series = nodeData[key] = bumpLayer(100, maxValue);
  }
  const v = series.shift();
  return v;
}

export const METRIC_LABELS = {
  docker_cpu_total_usage: 'Container CPU',
  docker_memory_usage: 'Container Memory',
  host_cpu_usage_percent: 'Host CPU',
  host_mem_usage_bytes: 'Host Memory',
  load1: 'Host Load 1',
  load15: 'Host Load 15',
  load5: 'Host Load 5',
  open_files_count: 'Process Open files',
  process_cpu_usage_percent: 'Process CPU',
  process_memory_usage_bytes: 'Process Memory'
};


export function label(m) {
  return METRIC_LABELS[m.id];
}


const METRIC_FORMATS = {
  docker_cpu_total_usage: 'percent',
  docker_memory_usage: 'filesize',
  host_cpu_usage_percent: 'percent',
  host_mem_usage_bytes: 'filesize',
  load1: 'number',
  load15: 'number',
  load5: 'number',
  open_files_count: 'integer',
  process_cpu_usage_percent: 'percent',
  process_memory_usage_bytes: 'filesize'
};


const memoryMetric = (node, name, max = 1024 * 1024 * 1024) => ({
  samples: [{value: getNextValue([node.id, name], max)}],
  max
});

const cpuMetric = (node, name, max = 100) => ({
  samples: [{value: getNextValue([node.id, name], max)}],
  max
});

const fileMetric = (node, name, max = 10000) => ({
  samples: [{value: getNextValue([node.id, name], max)}],
  max
});

const loadMetric = (node, name, max = 10) => ({
  samples: [{value: getNextValue([node.id, name], max)}],
  max
});

function mergeMetrics(node) {
  if (node.pseudo) {
    return node;
  }
  return Object.assign({}, node, {
    metrics: {
      process_cpu_usage_percent: cpuMetric(node, 'process_cpu_usage_percent'),
      process_memory_usage_bytes: memoryMetric(node, 'process_memory_usage_bytes'),
      open_files_count: fileMetric(node, 'open_files_count'),
      load1: loadMetric(node, 'load1'),
      load5: loadMetric(node, 'load5'),
      load15: loadMetric(node, 'load15'),
      docker_cpu_total_usage: cpuMetric(node, 'docker_cpu_total_usage'),
      docker_memory_usage: memoryMetric(node, 'docker_memory_usage'),
      host_cpu_usage_percent: cpuMetric(node, 'host_cpu_usage_percent'),
      host_mem_usage_bytes: memoryMetric(node, 'host_mem_usage_bytes')
    }
  });
}


function handleAdd(nodes) {
  if (!nodes) {
    return nodes;
  }
  return nodes.map(mergeMetrics);
}


function handleUpdated(updatedNodes, prevNodes) {
  const modifiedNodesIndex = _.zipObject((updatedNodes || []).map(n => [n.id, n]));
  return prevNodes.toIndexedSeq().toJS().map(n => (
    Object.assign({}, mergeMetrics(n), modifiedNodesIndex[n.id])
  ));
}


export function addMetrics(delta, prevNodes) {
  return Object.assign({}, delta, {
    add: handleAdd(delta.add),
    update: handleUpdated(delta.update, prevNodes)
  });
}

const openFilesScale = d3.scale.log().domain([1, 100000]).range([0, 1]);
//
// loadScale(1) == 0.5; E.g. a nicely balanced system :).
const loadScale = d3.scale.log().domain([0.01, 100]).range([0, 1]);

export function getMetricValue(metric, size) {
  if (!metric) {
    return {height: 0, value: null, formattedValue: 'n/a'};
  }

  const max = metric.getIn(['max']);
  const value = metric.getIn(['samples', 0, 'value']);
  const selectedMetric = AppStore.getSelectedMetric();

  let valuePercentage = value === 0 ? 0 : value / max;
  if (selectedMetric === 'open_files_count') {
    valuePercentage = openFilesScale(value);
  } else if (_.includes(['load1', 'load5', 'load15'], selectedMetric)) {
    valuePercentage = loadScale(value);
  }

  let displayedValue = value;
  if (displayedValue > 0) {
    const baseline = 0.1;
    displayedValue = valuePercentage * (1 - baseline) + baseline;
  }
  const height = size * displayedValue;
  const metricWithFormat = Object.assign(
    {}, {format: METRIC_FORMATS[selectedMetric]}, metric.toJS());

  return {
    height,
    value,
    formattedValue: formatMetric(value, metricWithFormat, true)
  };
}

export function getMetricColor() {
  const selectedMetric = AppStore.getSelectedMetric();
  if (/memory/.test(selectedMetric)) {
    return '#1f77b4';
  } else if (/cpu/.test(selectedMetric)) {
    return '#2ca02c';
  } else if (/files/.test(selectedMetric)) {
    return '#9467bd';
  } else if (/load/.test(selectedMetric)) {
    return '#e6550d';
  }
  return 'steelBlue';
}