Zabbix

/*

** Zabbix

** Copyright (C) 2001-2023 Zabbix SIA

**

** This program is free software; you can redistribute it and/or modify

** it under the terms of the GNU General Public License as published by

** the Free Software Foundation; either version 2 of the License, or

** (at your option) any later version.

**

** This program is distributed in the hope that it will be useful,

** but WITHOUT ANY WARRANTY; without even the implied warranty of

** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

** GNU General Public License for more details.

**

** You should have received a copy of the GNU General Public License

** along with this program; if not, write to the Free Software

** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

**/

​

package ceph

​

import (

    "encoding/json"

    "math"

    "sort"

​

    "git.zabbix.com/ap/plugin-support/zbxerr"

)

​

type aggDataInt struct {

    Min uint64  `json:"min"`

    Max uint64  `json:"max"`

    Avg float64 `json:"avg"`

}

​

// newAggDataInt calculates min, max and average values for a given slice of integers.

func newAggDataInt(v []uint64) aggDataInt {

    if len(v) == 0 {

        return aggDataInt{0, 0, 0}

    }

​

    var total uint64 = 0

​

    for _, value := range v {

        total += value

    }

​

    sort.Slice(v, func(i, j int) bool { return v[i] < v[j] })

​

    return aggDataInt{

        Min: v[0],

        Max: v[len(v)-1],

        Avg: float64(total) / float64(len(v)),

    }

}

​

type aggDataFloat struct {

    Min float64 `json:"min"`

    Max float64 `json:"max"`

    Avg float64 `json:"avg"`

}

​

// newAggDataFloat calculates min, max and average values for a given slice of floats.

func newAggDataFloat(v []float64) aggDataFloat {

    if len(v) == 0 {

        return aggDataFloat{0, 0, 0}

    }

​

    var total float64 = 0

​

    for _, value := range v {

        total += value

    }

​

    sort.Float64s(v)

​

    return aggDataFloat{

        Min: v[0],

        Max: v[len(v)-1],

        Avg: total / float64(len(v)),

    }

}

​

type cephPgDump struct {

    PgMap struct {

        OsdStats []struct {

            Name     json.Number `json:"osd"`

            PerfStat struct {

                LatencyApply  uint64 `json:"apply_latency_ms"`

                LatencyCommit uint64 `json:"commit_latency_ms"`

            } `json:"perf_stat"`