foreign/node/src/wire/system/get-stats.command.ts

/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */


import type { CommandResponse } from '../../client/client.type.js';
import { wrapCommand } from '../command.utils.js';

export type Stats = {
  processId: number,
  cpuUsage: number,
  totalCpuUsage: number,
  memoryUsage: bigint,
  totalMemory: bigint,
  availableMemory: bigint,
  runTime: bigint,
  startTime: bigint,
  readBytes: bigint,
  writtenBytes: bigint,
  messagesSizeBytes: bigint,
  streamsCount: number,
  topicsCount: number,
  partitionsCount: number,
  segmentsCount: number,
  messagesCount: bigint,
  clientsCount: number,
  consumersGroupsCount: number,
  hostname: string,
  osName: string,
  osVersion: string,
  kernelVersion: string
}


export const GET_STATS = {
  code: 10,
  serialize: () => Buffer.alloc(0),
  deserialize: (r: CommandResponse): Stats => {

    const processId = r.data.readUInt32LE(0);
    const cpuUsage = r.data.readFloatLE(4);
    const totalCpuUsage = r.data.readFloatLE(8);
    const memoryUsage = r.data.readBigUInt64LE(12);
    const totalMemory = r.data.readBigUInt64LE(20);
    const availableMemory = r.data.readBigUInt64LE(28);
    const runTime = r.data.readBigUInt64LE(36);
    const startTime = r.data.readBigUInt64LE(44);
    const readBytes = r.data.readBigUInt64LE(52);
    const writtenBytes = r.data.readBigUInt64LE(60);
    const messagesSizeBytes = r.data.readBigUInt64LE(68);
    const streamsCount = r.data.readUInt32LE(76);
    const topicsCount = r.data.readUInt32LE(80);
    const partitionsCount = r.data.readUInt32LE(84);
    const segmentsCount = r.data.readUInt32LE(88);
    const messagesCount = r.data.readBigUInt64LE(92);
    const clientsCount = r.data.readUInt32LE(100);
    const consumersGroupsCount = r.data.readUInt32LE(104);

    let position = 104 + 4;
    const hostnameLength = r.data.readUInt32LE(position);
    const hostname = r.data.subarray(
      position + 4,
      position + 4 + hostnameLength
    ).toString();
    position += 4 + hostnameLength;

    const osNameLength = r.data.readUInt32LE(position);
    const osName = r.data.subarray(
      position + 4,
      position + 4 + osNameLength
    ).toString();
    position += 4 + osNameLength;

    const osVersionLength = r.data.readUInt32LE(position);
    const osVersion = r.data.subarray(
      position + 4,
      position + 4 + osVersionLength
    ).toString();
    position += 4 + osVersionLength;

    const kernelVersionLength = r.data.readUInt32LE(position);
    const kernelVersion = r.data.subarray(
      position + 4,
      position + 4 + kernelVersionLength
    ).toString();

    return {
      processId,
      cpuUsage,
      totalCpuUsage,
      memoryUsage,
      totalMemory,
      availableMemory,
      runTime,
      startTime,
      readBytes,
      writtenBytes,
      messagesSizeBytes,
      streamsCount,
      topicsCount,
      partitionsCount,
      segmentsCount,
      messagesCount,
      clientsCount,
      consumersGroupsCount,
      hostname,
      osName,
      osVersion,
      kernelVersion
    };
  }
};

export const getStats = wrapCommand<void, Stats>(GET_STATS);