mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2024-11-21 14:44:00 +00:00
381 lines
11 KiB
Go
381 lines
11 KiB
Go
// Copyright 2022 The Prometheus Authors
|
|
// Licensed 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.
|
|
|
|
package procfs
|
|
|
|
import (
|
|
"bufio"
|
|
"bytes"
|
|
"errors"
|
|
"io"
|
|
"os"
|
|
"strconv"
|
|
"strings"
|
|
|
|
"github.com/prometheus/procfs/internal/util"
|
|
)
|
|
|
|
// ProcSnmp6 models the content of /proc/<pid>/net/snmp6.
|
|
type ProcSnmp6 struct {
|
|
// The process ID.
|
|
PID int
|
|
Ip6
|
|
Icmp6
|
|
Udp6
|
|
UdpLite6
|
|
}
|
|
|
|
type Ip6 struct { // nolint:revive
|
|
InReceives *float64
|
|
InHdrErrors *float64
|
|
InTooBigErrors *float64
|
|
InNoRoutes *float64
|
|
InAddrErrors *float64
|
|
InUnknownProtos *float64
|
|
InTruncatedPkts *float64
|
|
InDiscards *float64
|
|
InDelivers *float64
|
|
OutForwDatagrams *float64
|
|
OutRequests *float64
|
|
OutDiscards *float64
|
|
OutNoRoutes *float64
|
|
ReasmTimeout *float64
|
|
ReasmReqds *float64
|
|
ReasmOKs *float64
|
|
ReasmFails *float64
|
|
FragOKs *float64
|
|
FragFails *float64
|
|
FragCreates *float64
|
|
InMcastPkts *float64
|
|
OutMcastPkts *float64
|
|
InOctets *float64
|
|
OutOctets *float64
|
|
InMcastOctets *float64
|
|
OutMcastOctets *float64
|
|
InBcastOctets *float64
|
|
OutBcastOctets *float64
|
|
InNoECTPkts *float64
|
|
InECT1Pkts *float64
|
|
InECT0Pkts *float64
|
|
InCEPkts *float64
|
|
}
|
|
|
|
type Icmp6 struct {
|
|
InMsgs *float64
|
|
InErrors *float64
|
|
OutMsgs *float64
|
|
OutErrors *float64
|
|
InCsumErrors *float64
|
|
InDestUnreachs *float64
|
|
InPktTooBigs *float64
|
|
InTimeExcds *float64
|
|
InParmProblems *float64
|
|
InEchos *float64
|
|
InEchoReplies *float64
|
|
InGroupMembQueries *float64
|
|
InGroupMembResponses *float64
|
|
InGroupMembReductions *float64
|
|
InRouterSolicits *float64
|
|
InRouterAdvertisements *float64
|
|
InNeighborSolicits *float64
|
|
InNeighborAdvertisements *float64
|
|
InRedirects *float64
|
|
InMLDv2Reports *float64
|
|
OutDestUnreachs *float64
|
|
OutPktTooBigs *float64
|
|
OutTimeExcds *float64
|
|
OutParmProblems *float64
|
|
OutEchos *float64
|
|
OutEchoReplies *float64
|
|
OutGroupMembQueries *float64
|
|
OutGroupMembResponses *float64
|
|
OutGroupMembReductions *float64
|
|
OutRouterSolicits *float64
|
|
OutRouterAdvertisements *float64
|
|
OutNeighborSolicits *float64
|
|
OutNeighborAdvertisements *float64
|
|
OutRedirects *float64
|
|
OutMLDv2Reports *float64
|
|
InType1 *float64
|
|
InType134 *float64
|
|
InType135 *float64
|
|
InType136 *float64
|
|
InType143 *float64
|
|
OutType133 *float64
|
|
OutType135 *float64
|
|
OutType136 *float64
|
|
OutType143 *float64
|
|
}
|
|
|
|
type Udp6 struct { // nolint:revive
|
|
InDatagrams *float64
|
|
NoPorts *float64
|
|
InErrors *float64
|
|
OutDatagrams *float64
|
|
RcvbufErrors *float64
|
|
SndbufErrors *float64
|
|
InCsumErrors *float64
|
|
IgnoredMulti *float64
|
|
}
|
|
|
|
type UdpLite6 struct { // nolint:revive
|
|
InDatagrams *float64
|
|
NoPorts *float64
|
|
InErrors *float64
|
|
OutDatagrams *float64
|
|
RcvbufErrors *float64
|
|
SndbufErrors *float64
|
|
InCsumErrors *float64
|
|
}
|
|
|
|
func (p Proc) Snmp6() (ProcSnmp6, error) {
|
|
filename := p.path("net/snmp6")
|
|
data, err := util.ReadFileNoStat(filename)
|
|
if err != nil {
|
|
// On systems with IPv6 disabled, this file won't exist.
|
|
// Do nothing.
|
|
if errors.Is(err, os.ErrNotExist) {
|
|
return ProcSnmp6{PID: p.PID}, nil
|
|
}
|
|
|
|
return ProcSnmp6{PID: p.PID}, err
|
|
}
|
|
|
|
procSnmp6, err := parseSNMP6Stats(bytes.NewReader(data))
|
|
procSnmp6.PID = p.PID
|
|
return procSnmp6, err
|
|
}
|
|
|
|
// parseSnmp6 parses the metrics from proc/<pid>/net/snmp6 file
|
|
// and returns a map contains those metrics.
|
|
func parseSNMP6Stats(r io.Reader) (ProcSnmp6, error) {
|
|
var (
|
|
scanner = bufio.NewScanner(r)
|
|
procSnmp6 = ProcSnmp6{}
|
|
)
|
|
|
|
for scanner.Scan() {
|
|
stat := strings.Fields(scanner.Text())
|
|
if len(stat) < 2 {
|
|
continue
|
|
}
|
|
// Expect to have "6" in metric name, skip line otherwise
|
|
if sixIndex := strings.Index(stat[0], "6"); sixIndex != -1 {
|
|
protocol := stat[0][:sixIndex+1]
|
|
key := stat[0][sixIndex+1:]
|
|
value, err := strconv.ParseFloat(stat[1], 64)
|
|
if err != nil {
|
|
return procSnmp6, err
|
|
}
|
|
|
|
switch protocol {
|
|
case "Ip6":
|
|
switch key {
|
|
case "InReceives":
|
|
procSnmp6.Ip6.InReceives = &value
|
|
case "InHdrErrors":
|
|
procSnmp6.Ip6.InHdrErrors = &value
|
|
case "InTooBigErrors":
|
|
procSnmp6.Ip6.InTooBigErrors = &value
|
|
case "InNoRoutes":
|
|
procSnmp6.Ip6.InNoRoutes = &value
|
|
case "InAddrErrors":
|
|
procSnmp6.Ip6.InAddrErrors = &value
|
|
case "InUnknownProtos":
|
|
procSnmp6.Ip6.InUnknownProtos = &value
|
|
case "InTruncatedPkts":
|
|
procSnmp6.Ip6.InTruncatedPkts = &value
|
|
case "InDiscards":
|
|
procSnmp6.Ip6.InDiscards = &value
|
|
case "InDelivers":
|
|
procSnmp6.Ip6.InDelivers = &value
|
|
case "OutForwDatagrams":
|
|
procSnmp6.Ip6.OutForwDatagrams = &value
|
|
case "OutRequests":
|
|
procSnmp6.Ip6.OutRequests = &value
|
|
case "OutDiscards":
|
|
procSnmp6.Ip6.OutDiscards = &value
|
|
case "OutNoRoutes":
|
|
procSnmp6.Ip6.OutNoRoutes = &value
|
|
case "ReasmTimeout":
|
|
procSnmp6.Ip6.ReasmTimeout = &value
|
|
case "ReasmReqds":
|
|
procSnmp6.Ip6.ReasmReqds = &value
|
|
case "ReasmOKs":
|
|
procSnmp6.Ip6.ReasmOKs = &value
|
|
case "ReasmFails":
|
|
procSnmp6.Ip6.ReasmFails = &value
|
|
case "FragOKs":
|
|
procSnmp6.Ip6.FragOKs = &value
|
|
case "FragFails":
|
|
procSnmp6.Ip6.FragFails = &value
|
|
case "FragCreates":
|
|
procSnmp6.Ip6.FragCreates = &value
|
|
case "InMcastPkts":
|
|
procSnmp6.Ip6.InMcastPkts = &value
|
|
case "OutMcastPkts":
|
|
procSnmp6.Ip6.OutMcastPkts = &value
|
|
case "InOctets":
|
|
procSnmp6.Ip6.InOctets = &value
|
|
case "OutOctets":
|
|
procSnmp6.Ip6.OutOctets = &value
|
|
case "InMcastOctets":
|
|
procSnmp6.Ip6.InMcastOctets = &value
|
|
case "OutMcastOctets":
|
|
procSnmp6.Ip6.OutMcastOctets = &value
|
|
case "InBcastOctets":
|
|
procSnmp6.Ip6.InBcastOctets = &value
|
|
case "OutBcastOctets":
|
|
procSnmp6.Ip6.OutBcastOctets = &value
|
|
case "InNoECTPkts":
|
|
procSnmp6.Ip6.InNoECTPkts = &value
|
|
case "InECT1Pkts":
|
|
procSnmp6.Ip6.InECT1Pkts = &value
|
|
case "InECT0Pkts":
|
|
procSnmp6.Ip6.InECT0Pkts = &value
|
|
case "InCEPkts":
|
|
procSnmp6.Ip6.InCEPkts = &value
|
|
|
|
}
|
|
case "Icmp6":
|
|
switch key {
|
|
case "InMsgs":
|
|
procSnmp6.Icmp6.InMsgs = &value
|
|
case "InErrors":
|
|
procSnmp6.Icmp6.InErrors = &value
|
|
case "OutMsgs":
|
|
procSnmp6.Icmp6.OutMsgs = &value
|
|
case "OutErrors":
|
|
procSnmp6.Icmp6.OutErrors = &value
|
|
case "InCsumErrors":
|
|
procSnmp6.Icmp6.InCsumErrors = &value
|
|
case "InDestUnreachs":
|
|
procSnmp6.Icmp6.InDestUnreachs = &value
|
|
case "InPktTooBigs":
|
|
procSnmp6.Icmp6.InPktTooBigs = &value
|
|
case "InTimeExcds":
|
|
procSnmp6.Icmp6.InTimeExcds = &value
|
|
case "InParmProblems":
|
|
procSnmp6.Icmp6.InParmProblems = &value
|
|
case "InEchos":
|
|
procSnmp6.Icmp6.InEchos = &value
|
|
case "InEchoReplies":
|
|
procSnmp6.Icmp6.InEchoReplies = &value
|
|
case "InGroupMembQueries":
|
|
procSnmp6.Icmp6.InGroupMembQueries = &value
|
|
case "InGroupMembResponses":
|
|
procSnmp6.Icmp6.InGroupMembResponses = &value
|
|
case "InGroupMembReductions":
|
|
procSnmp6.Icmp6.InGroupMembReductions = &value
|
|
case "InRouterSolicits":
|
|
procSnmp6.Icmp6.InRouterSolicits = &value
|
|
case "InRouterAdvertisements":
|
|
procSnmp6.Icmp6.InRouterAdvertisements = &value
|
|
case "InNeighborSolicits":
|
|
procSnmp6.Icmp6.InNeighborSolicits = &value
|
|
case "InNeighborAdvertisements":
|
|
procSnmp6.Icmp6.InNeighborAdvertisements = &value
|
|
case "InRedirects":
|
|
procSnmp6.Icmp6.InRedirects = &value
|
|
case "InMLDv2Reports":
|
|
procSnmp6.Icmp6.InMLDv2Reports = &value
|
|
case "OutDestUnreachs":
|
|
procSnmp6.Icmp6.OutDestUnreachs = &value
|
|
case "OutPktTooBigs":
|
|
procSnmp6.Icmp6.OutPktTooBigs = &value
|
|
case "OutTimeExcds":
|
|
procSnmp6.Icmp6.OutTimeExcds = &value
|
|
case "OutParmProblems":
|
|
procSnmp6.Icmp6.OutParmProblems = &value
|
|
case "OutEchos":
|
|
procSnmp6.Icmp6.OutEchos = &value
|
|
case "OutEchoReplies":
|
|
procSnmp6.Icmp6.OutEchoReplies = &value
|
|
case "OutGroupMembQueries":
|
|
procSnmp6.Icmp6.OutGroupMembQueries = &value
|
|
case "OutGroupMembResponses":
|
|
procSnmp6.Icmp6.OutGroupMembResponses = &value
|
|
case "OutGroupMembReductions":
|
|
procSnmp6.Icmp6.OutGroupMembReductions = &value
|
|
case "OutRouterSolicits":
|
|
procSnmp6.Icmp6.OutRouterSolicits = &value
|
|
case "OutRouterAdvertisements":
|
|
procSnmp6.Icmp6.OutRouterAdvertisements = &value
|
|
case "OutNeighborSolicits":
|
|
procSnmp6.Icmp6.OutNeighborSolicits = &value
|
|
case "OutNeighborAdvertisements":
|
|
procSnmp6.Icmp6.OutNeighborAdvertisements = &value
|
|
case "OutRedirects":
|
|
procSnmp6.Icmp6.OutRedirects = &value
|
|
case "OutMLDv2Reports":
|
|
procSnmp6.Icmp6.OutMLDv2Reports = &value
|
|
case "InType1":
|
|
procSnmp6.Icmp6.InType1 = &value
|
|
case "InType134":
|
|
procSnmp6.Icmp6.InType134 = &value
|
|
case "InType135":
|
|
procSnmp6.Icmp6.InType135 = &value
|
|
case "InType136":
|
|
procSnmp6.Icmp6.InType136 = &value
|
|
case "InType143":
|
|
procSnmp6.Icmp6.InType143 = &value
|
|
case "OutType133":
|
|
procSnmp6.Icmp6.OutType133 = &value
|
|
case "OutType135":
|
|
procSnmp6.Icmp6.OutType135 = &value
|
|
case "OutType136":
|
|
procSnmp6.Icmp6.OutType136 = &value
|
|
case "OutType143":
|
|
procSnmp6.Icmp6.OutType143 = &value
|
|
}
|
|
case "Udp6":
|
|
switch key {
|
|
case "InDatagrams":
|
|
procSnmp6.Udp6.InDatagrams = &value
|
|
case "NoPorts":
|
|
procSnmp6.Udp6.NoPorts = &value
|
|
case "InErrors":
|
|
procSnmp6.Udp6.InErrors = &value
|
|
case "OutDatagrams":
|
|
procSnmp6.Udp6.OutDatagrams = &value
|
|
case "RcvbufErrors":
|
|
procSnmp6.Udp6.RcvbufErrors = &value
|
|
case "SndbufErrors":
|
|
procSnmp6.Udp6.SndbufErrors = &value
|
|
case "InCsumErrors":
|
|
procSnmp6.Udp6.InCsumErrors = &value
|
|
case "IgnoredMulti":
|
|
procSnmp6.Udp6.IgnoredMulti = &value
|
|
}
|
|
case "UdpLite6":
|
|
switch key {
|
|
case "InDatagrams":
|
|
procSnmp6.UdpLite6.InDatagrams = &value
|
|
case "NoPorts":
|
|
procSnmp6.UdpLite6.NoPorts = &value
|
|
case "InErrors":
|
|
procSnmp6.UdpLite6.InErrors = &value
|
|
case "OutDatagrams":
|
|
procSnmp6.UdpLite6.OutDatagrams = &value
|
|
case "RcvbufErrors":
|
|
procSnmp6.UdpLite6.RcvbufErrors = &value
|
|
case "SndbufErrors":
|
|
procSnmp6.UdpLite6.SndbufErrors = &value
|
|
case "InCsumErrors":
|
|
procSnmp6.UdpLite6.InCsumErrors = &value
|
|
}
|
|
}
|
|
}
|
|
}
|
|
return procSnmp6, scanner.Err()
|
|
}
|