Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[receiver/kubeletstats] refactor receiver to explicitly detail metrics emited. #9517

Merged
merged 11 commits into from
May 3, 2022
Merged

[receiver/kubeletstats] refactor receiver to explicitly detail metrics emited. #9517

Show file tree
Hide file tree
Changes from 6 commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
3b6631f
Update metadata.yaml to list all metrics
TylerHelmuth Apr 25, 2022
a0b2bac
Merge remote-tracking branch 'upstream/main' into issue-9413
TylerHelmuth Apr 25, 2022
fc70893
Updated accumulator to use new metrics
TylerHelmuth Apr 25, 2022
cd7ba20
Fix import
TylerHelmuth Apr 25, 2022
267959e
Fix lint
TylerHelmuth Apr 25, 2022
7ba1486
Moved init functions into Types
TylerHelmuth Apr 27, 2022
9e83fd6
Fix lint
TylerHelmuth Apr 27, 2022
7b65b18
Fix lint
TylerHelmuth Apr 27, 2022
4bc1d45
run goporto
TylerHelmuth Apr 27, 2022
e762fe4
re-enabled volume metrics
TylerHelmuth Apr 29, 2022
e234258
Merge remote-tracking branch 'upstream/main' into issue-9413
TylerHelmuth Apr 29, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
80 changes: 62 additions & 18 deletions receiver/kubeletstatsreceiver/documentation.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -8,27 +8,71 @@ These are the metrics available for this scraper.

| Name | Description | Unit | Type | Attributes |
| ---- | ----------- | ---- | ---- | ---------- |
| **cpu.time** | CPU time | s | Sum(Double) | <ul> </ul> |
| **cpu.utilization** | CPU utilization | 1 | Gauge(Double) | <ul> </ul> |
| **filesystem.available** | Filesystem available | By | Gauge(Int) | <ul> </ul> |
| **filesystem.capacity** | Filesystem capacity | By | Gauge(Int) | <ul> </ul> |
| **filesystem.usage** | Filesystem usage | By | Gauge(Int) | <ul> </ul> |
| **memory.available** | Memory available | By | Gauge(Int) | <ul> </ul> |
| **memory.major_page_faults** | Memory major_page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **memory.page_faults** | Memory page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **memory.rss** | Memory rss | By | Gauge(Int) | <ul> </ul> |
| **memory.usage** | Memory usage | By | Gauge(Int) | <ul> </ul> |
| **memory.working_set** | Memory working_set | By | Gauge(Int) | <ul> </ul> |
| **network.errors** | Network errors | 1 | Sum(Int) | <ul> <li>interface</li> <li>direction</li> </ul> |
| **network.io** | Network IO | By | Sum(Int) | <ul> <li>interface</li> <li>direction</li> </ul> |
| **volume.available** | The number of available bytes in the volume. | By | Gauge(Int) | <ul> </ul> |
| **volume.capacity** | The total capacity in bytes of the volume. | By | Gauge(Int) | <ul> </ul> |
| **volume.inodes** | The total inodes in the filesystem. | 1 | Gauge(Int) | <ul> </ul> |
| **volume.inodes.free** | The free inodes in the filesystem. | 1 | Gauge(Int) | <ul> </ul> |
| **volume.inodes.used** | The inodes used by the filesystem. This may not equal inodes - free because filesystem may share inodes with other filesystems. | 1 | Gauge(Int) | <ul> </ul> |
| **container.cpu.time** | Container CPU time | s | Sum(Double) | <ul> </ul> |
| **container.cpu.utilization** | Container CPU utilization | 1 | Gauge(Double) | <ul> </ul> |
| **container.filesystem.available** | Container filesystem available | By | Gauge(Int) | <ul> </ul> |
| **container.filesystem.capacity** | Container filesystem capacity | By | Gauge(Int) | <ul> </ul> |
| **container.filesystem.usage** | Container filesystem usage | By | Gauge(Int) | <ul> </ul> |
| **container.memory.available** | Container memory available | By | Gauge(Int) | <ul> </ul> |
| **container.memory.major_page_faults** | Container memory major_page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **container.memory.page_faults** | Container memory page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **container.memory.rss** | Container memory rss | By | Gauge(Int) | <ul> </ul> |
| **container.memory.usage** | Container memory usage | By | Gauge(Int) | <ul> </ul> |
| **container.memory.working_set** | Container memory working_set | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.cpu.time** | Node CPU time | s | Sum(Double) | <ul> </ul> |
| **k8s.node.cpu.utilization** | Node CPU utilization | 1 | Gauge(Double) | <ul> </ul> |
| **k8s.node.filesystem.available** | Node filesystem available | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.filesystem.capacity** | Node filesystem capacity | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.filesystem.usage** | Node filesystem usage | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.memory.available** | Node memory available | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.memory.major_page_faults** | Node memory major_page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **k8s.node.memory.page_faults** | Node memory page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **k8s.node.memory.rss** | Node memory rss | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.memory.usage** | Node memory usage | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.memory.working_set** | Node memory working_set | By | Gauge(Int) | <ul> </ul> |
| **k8s.node.network.errors** | Node network errors | 1 | Sum(Int) | <ul> <li>interface</li> <li>direction</li> </ul> |
| **k8s.node.network.io** | Node network IO | By | Sum(Int) | <ul> <li>interface</li> <li>direction</li> </ul> |
| **k8s.pod.cpu.time** | Pod CPU time | s | Sum(Double) | <ul> </ul> |
| **k8s.pod.cpu.utilization** | Pod CPU utilization | 1 | Gauge(Double) | <ul> </ul> |
| **k8s.pod.filesystem.available** | Pod filesystem available | By | Gauge(Int) | <ul> </ul> |
| **k8s.pod.filesystem.capacity** | Pod filesystem capacity | By | Gauge(Int) | <ul> </ul> |
| **k8s.pod.filesystem.usage** | Pod filesystem usage | By | Gauge(Int) | <ul> </ul> |
| **k8s.pod.memory.available** | Pod memory available | By | Gauge(Int) | <ul> </ul> |
| **k8s.pod.memory.major_page_faults** | Pod memory major_page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **k8s.pod.memory.page_faults** | Pod memory page_faults | 1 | Gauge(Int) | <ul> </ul> |
| **k8s.pod.memory.rss** | Pod memory rss | By | Gauge(Int) | <ul> </ul> |
| **k8s.pod.memory.usage** | Pod memory usage | By | Gauge(Int) | <ul> </ul> |
| **k8s.pod.memory.working_set** | Pod memory working_set | By | Gauge(Int) | <ul> </ul> |
| **k8s.pod.network.errors** | Pod network errors | 1 | Sum(Int) | <ul> <li>interface</li> <li>direction</li> </ul> |
| **k8s.pod.network.io** | Pod network IO | By | Sum(Int) | <ul> <li>interface</li> <li>direction</li> </ul> |
| k8s.volume.available | The number of available bytes in the volume. | By | Gauge(Int) | <ul> </ul> |
| k8s.volume.capacity | The total capacity in bytes of the volume. | By | Gauge(Int) | <ul> </ul> |
| k8s.volume.inodes | The total inodes in the filesystem. | 1 | Gauge(Int) | <ul> </ul> |
| k8s.volume.inodes.free | The free inodes in the filesystem. | 1 | Gauge(Int) | <ul> </ul> |
| k8s.volume.inodes.used | The inodes used by the filesystem. This may not equal inodes - free because filesystem may share inodes with other filesystems. | 1 | Gauge(Int) | <ul> </ul> |

**Highlighted metrics** are emitted by default.

## Resource attributes

| Name | Description | Type |
| ---- | ----------- | ---- |
| aws.volume.id | The id of the AWS Volume | String |
| container.id | Container id used to identify container | String |
| container.name | Container name used by container runtime | String |
| fs.type | The filesystem type of the Volume | String |
| gce.pd.name | The name of the persistent disk in GCE | String |
| glusterfs.endpoints.name | The endpoint name that details Glusterfs topology | String |
| glusterfs.path | Glusterfs volume path | String |
| k8s.namespace.name | The name of the namespace that the pod is running in | String |
| k8s.node.name | The name of the Node | String |
| k8s.persistentvolumeclaim.name | The name of the Persistent Volume Claim | String |
| k8s.pod.name | The name of the Pod | String |
| k8s.pod.uid | The UID of the Pod | String |
| k8s.volume.name | The name of the Volume | String |
| k8s.volume.type | The type of the Volume | String |
| partition | The partition in the Volume | String |

## Metric attributes

| Name | Description | Values |
Expand Down
32 changes: 15 additions & 17 deletions receiver/kubeletstatsreceiver/internal/kubelet/accumulator.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,8 @@ import (
"go.opentelemetry.io/collector/pdata/pmetric"
"go.uber.org/zap"
stats "k8s.io/kubelet/pkg/apis/stats/v1alpha1"

"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
)

type MetricGroup string
Expand Down Expand Up @@ -50,11 +52,7 @@ type metricDataAccumulator struct {
}

const (
k8sPrefix = "k8s."
nodePrefix = k8sPrefix + "node."
podPrefix = k8sPrefix + "pod."
containerPrefix = "container."
scopeName = "otelcol/kubeletstatsreceiver"
scopeName = "otelcol/kubeletstatsreceiver"
)

func (a *metricDataAccumulator) nodeStats(s stats.NodeStats) {
Expand All @@ -71,10 +69,10 @@ func (a *metricDataAccumulator) nodeStats(s stats.NodeStats) {

startTime := pcommon.NewTimestampFromTime(s.StartTime.Time)
currentTime := pcommon.NewTimestampFromTime(a.time)
addCPUMetrics(ilm.Metrics(), nodePrefix, s.CPU, startTime, currentTime)
addMemoryMetrics(ilm.Metrics(), nodePrefix, s.Memory, currentTime)
addFilesystemMetrics(ilm.Metrics(), nodePrefix, s.Fs, currentTime)
addNetworkMetrics(ilm.Metrics(), nodePrefix, s.Network, startTime, currentTime)
addCPUMetrics(ilm.Metrics(), metadata.NodeCpuMetrics, s.CPU, startTime, currentTime)
addMemoryMetrics(ilm.Metrics(), metadata.NodeMemoryMetrics, s.Memory, currentTime)
addFilesystemMetrics(ilm.Metrics(), metadata.NodeFilesystemMetrics, s.Fs, currentTime)
addNetworkMetrics(ilm.Metrics(), metadata.NodeNetworkMetrics, s.Network, startTime, currentTime)
// todo s.Runtime.ImageFs

a.m = append(a.m, md)
Expand All @@ -94,10 +92,10 @@ func (a *metricDataAccumulator) podStats(s stats.PodStats) {

startTime := pcommon.NewTimestampFromTime(s.StartTime.Time)
currentTime := pcommon.NewTimestampFromTime(a.time)
addCPUMetrics(ilm.Metrics(), podPrefix, s.CPU, startTime, currentTime)
addMemoryMetrics(ilm.Metrics(), podPrefix, s.Memory, currentTime)
addFilesystemMetrics(ilm.Metrics(), podPrefix, s.EphemeralStorage, currentTime)
addNetworkMetrics(ilm.Metrics(), podPrefix, s.Network, startTime, currentTime)
addCPUMetrics(ilm.Metrics(), metadata.PodCpuMetrics, s.CPU, startTime, currentTime)
addMemoryMetrics(ilm.Metrics(), metadata.PodMemoryMetrics, s.Memory, currentTime)
addFilesystemMetrics(ilm.Metrics(), metadata.PodFilesystemMetrics, s.EphemeralStorage, currentTime)
addNetworkMetrics(ilm.Metrics(), metadata.PodNetworkMetrics, s.Network, startTime, currentTime)

a.m = append(a.m, md)
}
Expand All @@ -124,9 +122,9 @@ func (a *metricDataAccumulator) containerStats(sPod stats.PodStats, s stats.Cont

startTime := pcommon.NewTimestampFromTime(s.StartTime.Time)
currentTime := pcommon.NewTimestampFromTime(a.time)
addCPUMetrics(ilm.Metrics(), containerPrefix, s.CPU, startTime, currentTime)
addMemoryMetrics(ilm.Metrics(), containerPrefix, s.Memory, currentTime)
addFilesystemMetrics(ilm.Metrics(), containerPrefix, s.Rootfs, currentTime)
addCPUMetrics(ilm.Metrics(), metadata.ContainerCpuMetrics, s.CPU, startTime, currentTime)
addMemoryMetrics(ilm.Metrics(), metadata.ContainerMemoryMetrics, s.Memory, currentTime)
addFilesystemMetrics(ilm.Metrics(), metadata.ContainerFilesystemMetrics, s.Rootfs, currentTime)
a.m = append(a.m, md)
}

Expand All @@ -151,6 +149,6 @@ func (a *metricDataAccumulator) volumeStats(sPod stats.PodStats, s stats.VolumeS
ilm.Scope().SetName(scopeName)

currentTime := pcommon.NewTimestampFromTime(a.time)
addVolumeMetrics(ilm.Metrics(), k8sPrefix, s, currentTime)
addVolumeMetrics(ilm.Metrics(), metadata.K8sVolumeMetrics, s, currentTime)
a.m = append(a.m, md)
}
14 changes: 7 additions & 7 deletions receiver/kubeletstatsreceiver/internal/kubelet/cpu.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,26 +22,26 @@ import (
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
)

func addCPUMetrics(dest pmetric.MetricSlice, prefix string, s *stats.CPUStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
func addCPUMetrics(dest pmetric.MetricSlice, cpuMetrics metadata.CpuMetrics, s *stats.CPUStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
if s == nil {
return
}
addCPUUsageMetric(dest, prefix, s, currentTime)
addCPUTimeMetric(dest, prefix, s, startTime, currentTime)
addCPUUsageMetric(dest, cpuMetrics.Utilization, s, currentTime)
addCPUTimeMetric(dest, cpuMetrics.Time, s, startTime, currentTime)
}

func addCPUUsageMetric(dest pmetric.MetricSlice, prefix string, s *stats.CPUStats, currentTime pcommon.Timestamp) {
func addCPUUsageMetric(dest pmetric.MetricSlice, metricInt metadata.MetricIntf, s *stats.CPUStats, currentTime pcommon.Timestamp) {
if s.UsageNanoCores == nil {
return
}
value := float64(*s.UsageNanoCores) / 1_000_000_000
fillDoubleGauge(dest.AppendEmpty(), prefix, metadata.M.CPUUtilization, value, currentTime)
fillDoubleGauge(dest.AppendEmpty(), metricInt, value, currentTime)
}

func addCPUTimeMetric(dest pmetric.MetricSlice, prefix string, s *stats.CPUStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
func addCPUTimeMetric(dest pmetric.MetricSlice, metricInt metadata.MetricIntf, s *stats.CPUStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
if s.UsageCoreNanoSeconds == nil {
return
}
value := float64(*s.UsageCoreNanoSeconds) / 1_000_000_000
fillDoubleSum(dest.AppendEmpty(), prefix, metadata.M.CPUTime, value, startTime, currentTime)
fillDoubleSum(dest.AppendEmpty(), metricInt, value, startTime, currentTime)
}
11 changes: 5 additions & 6 deletions receiver/kubeletstatsreceiver/internal/kubelet/fs.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,19 +15,18 @@
package kubelet // import "github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/kubelet"

import (
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
"go.opentelemetry.io/collector/pdata/pcommon"
"go.opentelemetry.io/collector/pdata/pmetric"
stats "k8s.io/kubelet/pkg/apis/stats/v1alpha1"

"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
)

func addFilesystemMetrics(dest pmetric.MetricSlice, prefix string, s *stats.FsStats, currentTime pcommon.Timestamp) {
func addFilesystemMetrics(dest pmetric.MetricSlice, filesystemMetrics metadata.FilesystemMetrics, s *stats.FsStats, currentTime pcommon.Timestamp) {
if s == nil {
return
}

addIntGauge(dest, prefix, metadata.M.FilesystemAvailable, s.AvailableBytes, currentTime)
addIntGauge(dest, prefix, metadata.M.FilesystemCapacity, s.CapacityBytes, currentTime)
addIntGauge(dest, prefix, metadata.M.FilesystemUsage, s.UsedBytes, currentTime)
addIntGauge(dest, filesystemMetrics.Available, s.AvailableBytes, currentTime)
addIntGauge(dest, filesystemMetrics.Capacity, s.CapacityBytes, currentTime)
addIntGauge(dest, filesystemMetrics.Usage, s.UsedBytes, currentTime)
}
17 changes: 8 additions & 9 deletions receiver/kubeletstatsreceiver/internal/kubelet/mem.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,22 +15,21 @@
package kubelet // import "github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/kubelet"

import (
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
"go.opentelemetry.io/collector/pdata/pcommon"
"go.opentelemetry.io/collector/pdata/pmetric"
stats "k8s.io/kubelet/pkg/apis/stats/v1alpha1"

"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
)

func addMemoryMetrics(dest pmetric.MetricSlice, prefix string, s *stats.MemoryStats, currentTime pcommon.Timestamp) {
func addMemoryMetrics(dest pmetric.MetricSlice, memoryMetrics metadata.MemoryMetrics, s *stats.MemoryStats, currentTime pcommon.Timestamp) {
if s == nil {
return
}

addIntGauge(dest, prefix, metadata.M.MemoryAvailable, s.AvailableBytes, currentTime)
addIntGauge(dest, prefix, metadata.M.MemoryUsage, s.UsageBytes, currentTime)
addIntGauge(dest, prefix, metadata.M.MemoryRss, s.RSSBytes, currentTime)
addIntGauge(dest, prefix, metadata.M.MemoryWorkingSet, s.WorkingSetBytes, currentTime)
addIntGauge(dest, prefix, metadata.M.MemoryPageFaults, s.PageFaults, currentTime)
addIntGauge(dest, prefix, metadata.M.MemoryMajorPageFaults, s.MajorPageFaults, currentTime)
addIntGauge(dest, memoryMetrics.Available, s.AvailableBytes, currentTime)
addIntGauge(dest, memoryMetrics.Usage, s.UsageBytes, currentTime)
addIntGauge(dest, memoryMetrics.Rss, s.RSSBytes, currentTime)
addIntGauge(dest, memoryMetrics.WorkingSet, s.WorkingSetBytes, currentTime)
addIntGauge(dest, memoryMetrics.PageFaults, s.PageFaults, currentTime)
addIntGauge(dest, memoryMetrics.MajorPageFaults, s.MajorPageFaults, currentTime)
}
16 changes: 7 additions & 9 deletions receiver/kubeletstatsreceiver/internal/kubelet/network.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,35 +22,33 @@ import (
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
)

func addNetworkMetrics(dest pmetric.MetricSlice, prefix string, s *stats.NetworkStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
func addNetworkMetrics(dest pmetric.MetricSlice, networkMetrics metadata.NetworkMetrics, s *stats.NetworkStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
if s == nil {
return
}
addNetworkIOMetric(dest, prefix, s, startTime, currentTime)
addNetworkErrorsMetric(dest, prefix, s, startTime, currentTime)
addNetworkIOMetric(dest, networkMetrics.IO, s, startTime, currentTime)
addNetworkErrorsMetric(dest, networkMetrics.Errors, s, startTime, currentTime)
}

func addNetworkIOMetric(dest pmetric.MetricSlice, prefix string, s *stats.NetworkStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
func addNetworkIOMetric(dest pmetric.MetricSlice, metricInt metadata.MetricIntf, s *stats.NetworkStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
if s.RxBytes == nil && s.TxBytes == nil {
return
}

m := dest.AppendEmpty()
metadata.M.NetworkIo.Init(m)
m.SetName(prefix + m.Name())
metricInt.Init(m)

fillNetworkDataPoint(m.Sum().DataPoints(), s.Name, metadata.AttributeDirection.Receive, s.RxBytes, startTime, currentTime)
fillNetworkDataPoint(m.Sum().DataPoints(), s.Name, metadata.AttributeDirection.Transmit, s.TxBytes, startTime, currentTime)
}

func addNetworkErrorsMetric(dest pmetric.MetricSlice, prefix string, s *stats.NetworkStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
func addNetworkErrorsMetric(dest pmetric.MetricSlice, metricInt metadata.MetricIntf, s *stats.NetworkStats, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
if s.RxBytes == nil && s.TxBytes == nil {
return
}

m := dest.AppendEmpty()
metadata.M.NetworkErrors.Init(m)
m.SetName(prefix + m.Name())
metricInt.Init(m)

fillNetworkDataPoint(m.Sum().DataPoints(), s.Name, metadata.AttributeDirection.Receive, s.RxErrors, startTime, currentTime)
fillNetworkDataPoint(m.Sum().DataPoints(), s.Name, metadata.AttributeDirection.Transmit, s.TxErrors, startTime, currentTime)
Expand Down
13 changes: 5 additions & 8 deletions receiver/kubeletstatsreceiver/internal/kubelet/utils.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,32 +21,29 @@ import (
"github.com/open-telemetry/opentelemetry-collector-contrib/receiver/kubeletstatsreceiver/internal/metadata"
)

func fillDoubleGauge(dest pmetric.Metric, prefix string, metricInt metadata.MetricIntf, value float64, currentTime pcommon.Timestamp) {
func fillDoubleGauge(dest pmetric.Metric, metricInt metadata.MetricIntf, value float64, currentTime pcommon.Timestamp) {
metricInt.Init(dest)
dest.SetName(prefix + dest.Name())
dp := dest.Gauge().DataPoints().AppendEmpty()
dp.SetDoubleVal(value)
dp.SetTimestamp(currentTime)
}

func addIntGauge(dest pmetric.MetricSlice, prefix string, metricInt metadata.MetricIntf, value *uint64, currentTime pcommon.Timestamp) {
func addIntGauge(dest pmetric.MetricSlice, metricInt metadata.MetricIntf, value *uint64, currentTime pcommon.Timestamp) {
if value == nil {
return
}
fillIntGauge(dest.AppendEmpty(), prefix, metricInt, int64(*value), currentTime)
fillIntGauge(dest.AppendEmpty(), metricInt, int64(*value), currentTime)
}

func fillIntGauge(dest pmetric.Metric, prefix string, metricInt metadata.MetricIntf, value int64, currentTime pcommon.Timestamp) {
func fillIntGauge(dest pmetric.Metric, metricInt metadata.MetricIntf, value int64, currentTime pcommon.Timestamp) {
metricInt.Init(dest)
dest.SetName(prefix + dest.Name())
dp := dest.Gauge().DataPoints().AppendEmpty()
dp.SetIntVal(value)
dp.SetTimestamp(currentTime)
}

func fillDoubleSum(dest pmetric.Metric, prefix string, metricInt metadata.MetricIntf, value float64, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
func fillDoubleSum(dest pmetric.Metric, metricInt metadata.MetricIntf, value float64, startTime pcommon.Timestamp, currentTime pcommon.Timestamp) {
metricInt.Init(dest)
dest.SetName(prefix + dest.Name())
dp := dest.Sum().DataPoints().AppendEmpty()
dp.SetDoubleVal(value)
dp.SetStartTimestamp(startTime)
Expand Down
Loading