metadata

package
v0.60.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 15, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ContainerCPUMetrics = CPUMetrics{
	Time:        (*MetricsBuilder).RecordContainerCPUTimeDataPoint,
	Utilization: (*MetricsBuilder).RecordContainerCPUUtilizationDataPoint,
}
View Source 
var ContainerFilesystemMetrics = FilesystemMetrics{
	Available: (*MetricsBuilder).RecordContainerFilesystemAvailableDataPoint,
	Capacity:  (*MetricsBuilder).RecordContainerFilesystemCapacityDataPoint,
	Usage:     (*MetricsBuilder).RecordContainerFilesystemUsageDataPoint,
}
View Source 
var ContainerMemoryMetrics = MemoryMetrics{
	Available:       (*MetricsBuilder).RecordContainerMemoryAvailableDataPoint,
	Usage:           (*MetricsBuilder).RecordContainerMemoryUsageDataPoint,
	Rss:             (*MetricsBuilder).RecordContainerMemoryRssDataPoint,
	WorkingSet:      (*MetricsBuilder).RecordContainerMemoryWorkingSetDataPoint,
	PageFaults:      (*MetricsBuilder).RecordContainerMemoryPageFaultsDataPoint,
	MajorPageFaults: (*MetricsBuilder).RecordContainerMemoryMajorPageFaultsDataPoint,
}
View Source 
var K8sVolumeMetrics = VolumeMetrics{
	Available:  (*MetricsBuilder).RecordK8sVolumeAvailableDataPoint,
	Capacity:   (*MetricsBuilder).RecordK8sVolumeCapacityDataPoint,
	Inodes:     (*MetricsBuilder).RecordK8sVolumeInodesDataPoint,
	InodesFree: (*MetricsBuilder).RecordK8sVolumeInodesFreeDataPoint,
	InodesUsed: (*MetricsBuilder).RecordK8sVolumeInodesUsedDataPoint,
}
View Source 
var MapAttributeDirection = map[string]AttributeDirection{
	"receive":  AttributeDirectionReceive,
	"transmit": AttributeDirectionTransmit,
}

MapAttributeDirection is a helper map of string to AttributeDirection attribute value.

View Source 
var NodeCPUMetrics = CPUMetrics{
	Time:        (*MetricsBuilder).RecordK8sNodeCPUTimeDataPoint,
	Utilization: (*MetricsBuilder).RecordK8sNodeCPUUtilizationDataPoint,
}
View Source 
var NodeFilesystemMetrics = FilesystemMetrics{
	Available: (*MetricsBuilder).RecordK8sNodeFilesystemAvailableDataPoint,
	Capacity:  (*MetricsBuilder).RecordK8sNodeFilesystemCapacityDataPoint,
	Usage:     (*MetricsBuilder).RecordK8sNodeFilesystemUsageDataPoint,
}
View Source 
var NodeMemoryMetrics = MemoryMetrics{
	Available:       (*MetricsBuilder).RecordK8sNodeMemoryAvailableDataPoint,
	Usage:           (*MetricsBuilder).RecordK8sNodeMemoryUsageDataPoint,
	Rss:             (*MetricsBuilder).RecordK8sNodeMemoryRssDataPoint,
	WorkingSet:      (*MetricsBuilder).RecordK8sNodeMemoryWorkingSetDataPoint,
	PageFaults:      (*MetricsBuilder).RecordK8sNodeMemoryPageFaultsDataPoint,
	MajorPageFaults: (*MetricsBuilder).RecordK8sNodeMemoryMajorPageFaultsDataPoint,
}
View Source 
var NodeNetworkMetrics = NetworkMetrics{
	IO: NetworkMetricsRecorder{
		RecordReceiveDataPoint:  (*MetricsBuilder).RecordK8sNodeNetworkIoReceiveDataPoint,
		RecordTransmitDataPoint: (*MetricsBuilder).RecordK8sNodeNetworkIoTransmitDataPoint,
	},
	Errors: NetworkMetricsRecorder{
		RecordReceiveDataPoint:  (*MetricsBuilder).RecordK8sNodeNetworkErrorsReceiveDataPoint,
		RecordTransmitDataPoint: (*MetricsBuilder).RecordK8sNodeNetworkErrorsTransmitDataPoint,
	},
}
View Source 
var NodeNetworkMetricsWithDirection = NetworkMetricsWithDirection{
	IO:     (*MetricsBuilder).RecordK8sNodeNetworkIoDataPoint,
	Errors: (*MetricsBuilder).RecordK8sNodeNetworkErrorsDataPoint,
}
View Source 
var PodCPUMetrics = CPUMetrics{
	Time:        (*MetricsBuilder).RecordK8sPodCPUTimeDataPoint,
	Utilization: (*MetricsBuilder).RecordK8sPodCPUUtilizationDataPoint,
}
View Source 
var PodFilesystemMetrics = FilesystemMetrics{
	Available: (*MetricsBuilder).RecordK8sPodFilesystemAvailableDataPoint,
	Capacity:  (*MetricsBuilder).RecordK8sPodFilesystemCapacityDataPoint,
	Usage:     (*MetricsBuilder).RecordK8sPodFilesystemUsageDataPoint,
}
View Source 
var PodMemoryMetrics = MemoryMetrics{
	Available:       (*MetricsBuilder).RecordK8sPodMemoryAvailableDataPoint,
	Usage:           (*MetricsBuilder).RecordK8sPodMemoryUsageDataPoint,
	Rss:             (*MetricsBuilder).RecordK8sPodMemoryRssDataPoint,
	WorkingSet:      (*MetricsBuilder).RecordK8sPodMemoryWorkingSetDataPoint,
	PageFaults:      (*MetricsBuilder).RecordK8sPodMemoryPageFaultsDataPoint,
	MajorPageFaults: (*MetricsBuilder).RecordK8sPodMemoryMajorPageFaultsDataPoint,
}
View Source 
var PodNetworkMetrics = NetworkMetrics{
	IO: NetworkMetricsRecorder{
		RecordReceiveDataPoint:  (*MetricsBuilder).RecordK8sPodNetworkIoReceiveDataPoint,
		RecordTransmitDataPoint: (*MetricsBuilder).RecordK8sPodNetworkIoTransmitDataPoint,
	},
	Errors: NetworkMetricsRecorder{
		RecordReceiveDataPoint:  (*MetricsBuilder).RecordK8sPodNetworkErrorsReceiveDataPoint,
		RecordTransmitDataPoint: (*MetricsBuilder).RecordK8sPodNetworkErrorsTransmitDataPoint,
	},
}
View Source 
var PodNetworkMetricsWithDirection = NetworkMetricsWithDirection{
	IO:     (*MetricsBuilder).RecordK8sPodNetworkIoDataPoint,
	Errors: (*MetricsBuilder).RecordK8sPodNetworkErrorsDataPoint,
}

Functions

func WithStartTime added in v0.52.0 

func WithStartTime(startTime pcommon.Timestamp) metricBuilderOption

WithStartTime sets startTime on the metrics builder.

Types

type AttributeDirection added in v0.39.0 

type AttributeDirection int

AttributeDirection specifies the a value direction attribute. 

const (
	AttributeDirectionReceive AttributeDirection
	AttributeDirectionTransmit
)

func (AttributeDirection) String added in v0.52.0 

func (av AttributeDirection) String() string

String returns the string representation of the AttributeDirection.

type CPUMetrics added in v0.51.0 

type CPUMetrics struct {
	Time        RecordDoubleDataPointFunc
	Utilization RecordDoubleDataPointFunc
}

type FilesystemMetrics added in v0.51.0 

type FilesystemMetrics struct {
	Available RecordIntDataPointFunc
	Capacity  RecordIntDataPointFunc
	Usage     RecordIntDataPointFunc
}

type MemoryMetrics added in v0.51.0 

type MemoryMetrics struct {
	Available       RecordIntDataPointFunc
	Usage           RecordIntDataPointFunc
	Rss             RecordIntDataPointFunc
	WorkingSet      RecordIntDataPointFunc
	PageFaults      RecordIntDataPointFunc
	MajorPageFaults RecordIntDataPointFunc
}

type MetricSettings added in v0.52.0 

type MetricSettings struct {
	Enabled bool `mapstructure:"enabled"`
}

MetricSettings provides common settings for a particular metric.

type MetricsBuilder added in v0.52.0 

type MetricsBuilder struct {
	// contains filtered or unexported fields
}

MetricsBuilder provides an interface for scrapers to report metrics while taking care of all the transformations required to produce metric representation defined in metadata and user settings.

func NewMetricsBuilder added in v0.52.0 

func NewMetricsBuilder(settings MetricsSettings, buildInfo component.BuildInfo, options ...metricBuilderOption) *MetricsBuilder

func (*MetricsBuilder) Emit added in v0.52.0 

func (mb *MetricsBuilder) Emit(rmo ...ResourceMetricsOption) pmetric.Metrics

Emit returns all the metrics accumulated by the metrics builder and updates the internal state to be ready for recording another set of metrics. This function will be responsible for applying all the transformations required to produce metric representation defined in metadata and user settings, e.g. delta or cumulative.

func (*MetricsBuilder) EmitForResource added in v0.52.0 

func (mb *MetricsBuilder) EmitForResource(rmo ...ResourceMetricsOption)

EmitForResource saves all the generated metrics under a new resource and updates the internal state to be ready for recording another set of data points as part of another resource. This function can be helpful when one scraper needs to emit metrics from several resources. Otherwise calling this function is not required, just `Emit` function can be called instead. Resource attributes should be provided as ResourceMetricsOption arguments.

func (*MetricsBuilder) RecordContainerCPUTimeDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerCPUTimeDataPoint(ts pcommon.Timestamp, val float64)

RecordContainerCPUTimeDataPoint adds a data point to container.cpu.time metric.

func (*MetricsBuilder) RecordContainerCPUUtilizationDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerCPUUtilizationDataPoint(ts pcommon.Timestamp, val float64)

RecordContainerCPUUtilizationDataPoint adds a data point to container.cpu.utilization metric.

func (*MetricsBuilder) RecordContainerFilesystemAvailableDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerFilesystemAvailableDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerFilesystemAvailableDataPoint adds a data point to container.filesystem.available metric.

func (*MetricsBuilder) RecordContainerFilesystemCapacityDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerFilesystemCapacityDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerFilesystemCapacityDataPoint adds a data point to container.filesystem.capacity metric.

func (*MetricsBuilder) RecordContainerFilesystemUsageDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerFilesystemUsageDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerFilesystemUsageDataPoint adds a data point to container.filesystem.usage metric.

func (*MetricsBuilder) RecordContainerMemoryAvailableDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerMemoryAvailableDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerMemoryAvailableDataPoint adds a data point to container.memory.available metric.

func (*MetricsBuilder) RecordContainerMemoryMajorPageFaultsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerMemoryMajorPageFaultsDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerMemoryMajorPageFaultsDataPoint adds a data point to container.memory.major_page_faults metric.

func (*MetricsBuilder) RecordContainerMemoryPageFaultsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerMemoryPageFaultsDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerMemoryPageFaultsDataPoint adds a data point to container.memory.page_faults metric.

func (*MetricsBuilder) RecordContainerMemoryRssDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerMemoryRssDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerMemoryRssDataPoint adds a data point to container.memory.rss metric.

func (*MetricsBuilder) RecordContainerMemoryUsageDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerMemoryUsageDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerMemoryUsageDataPoint adds a data point to container.memory.usage metric.

func (*MetricsBuilder) RecordContainerMemoryWorkingSetDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordContainerMemoryWorkingSetDataPoint(ts pcommon.Timestamp, val int64)

RecordContainerMemoryWorkingSetDataPoint adds a data point to container.memory.working_set metric.

func (*MetricsBuilder) RecordK8sNodeCPUTimeDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeCPUTimeDataPoint(ts pcommon.Timestamp, val float64)

RecordK8sNodeCPUTimeDataPoint adds a data point to k8s.node.cpu.time metric.

func (*MetricsBuilder) RecordK8sNodeCPUUtilizationDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeCPUUtilizationDataPoint(ts pcommon.Timestamp, val float64)

RecordK8sNodeCPUUtilizationDataPoint adds a data point to k8s.node.cpu.utilization metric.

func (*MetricsBuilder) RecordK8sNodeFilesystemAvailableDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeFilesystemAvailableDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeFilesystemAvailableDataPoint adds a data point to k8s.node.filesystem.available metric.

func (*MetricsBuilder) RecordK8sNodeFilesystemCapacityDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeFilesystemCapacityDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeFilesystemCapacityDataPoint adds a data point to k8s.node.filesystem.capacity metric.

func (*MetricsBuilder) RecordK8sNodeFilesystemUsageDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeFilesystemUsageDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeFilesystemUsageDataPoint adds a data point to k8s.node.filesystem.usage metric.

func (*MetricsBuilder) RecordK8sNodeMemoryAvailableDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeMemoryAvailableDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeMemoryAvailableDataPoint adds a data point to k8s.node.memory.available metric.

func (*MetricsBuilder) RecordK8sNodeMemoryMajorPageFaultsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeMemoryMajorPageFaultsDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeMemoryMajorPageFaultsDataPoint adds a data point to k8s.node.memory.major_page_faults metric.

func (*MetricsBuilder) RecordK8sNodeMemoryPageFaultsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeMemoryPageFaultsDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeMemoryPageFaultsDataPoint adds a data point to k8s.node.memory.page_faults metric.

func (*MetricsBuilder) RecordK8sNodeMemoryRssDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeMemoryRssDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeMemoryRssDataPoint adds a data point to k8s.node.memory.rss metric.

func (*MetricsBuilder) RecordK8sNodeMemoryUsageDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeMemoryUsageDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeMemoryUsageDataPoint adds a data point to k8s.node.memory.usage metric.

func (*MetricsBuilder) RecordK8sNodeMemoryWorkingSetDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeMemoryWorkingSetDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sNodeMemoryWorkingSetDataPoint adds a data point to k8s.node.memory.working_set metric.

func (*MetricsBuilder) RecordK8sNodeNetworkErrorsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeNetworkErrorsDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string, directionAttributeValue AttributeDirection)

RecordK8sNodeNetworkErrorsDataPoint adds a data point to k8s.node.network.errors metric.

func (*MetricsBuilder) RecordK8sNodeNetworkErrorsReceiveDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sNodeNetworkErrorsReceiveDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sNodeNetworkErrorsReceiveDataPoint adds a data point to k8s.node.network.errors.receive metric.

func (*MetricsBuilder) RecordK8sNodeNetworkErrorsTransmitDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sNodeNetworkErrorsTransmitDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sNodeNetworkErrorsTransmitDataPoint adds a data point to k8s.node.network.errors.transmit metric.

func (*MetricsBuilder) RecordK8sNodeNetworkIoDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sNodeNetworkIoDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string, directionAttributeValue AttributeDirection)

RecordK8sNodeNetworkIoDataPoint adds a data point to k8s.node.network.io metric.

func (*MetricsBuilder) RecordK8sNodeNetworkIoReceiveDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sNodeNetworkIoReceiveDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sNodeNetworkIoReceiveDataPoint adds a data point to k8s.node.network.io.receive metric.

func (*MetricsBuilder) RecordK8sNodeNetworkIoTransmitDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sNodeNetworkIoTransmitDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sNodeNetworkIoTransmitDataPoint adds a data point to k8s.node.network.io.transmit metric.

func (*MetricsBuilder) RecordK8sPodCPUTimeDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodCPUTimeDataPoint(ts pcommon.Timestamp, val float64)

RecordK8sPodCPUTimeDataPoint adds a data point to k8s.pod.cpu.time metric.

func (*MetricsBuilder) RecordK8sPodCPUUtilizationDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodCPUUtilizationDataPoint(ts pcommon.Timestamp, val float64)

RecordK8sPodCPUUtilizationDataPoint adds a data point to k8s.pod.cpu.utilization metric.

func (*MetricsBuilder) RecordK8sPodFilesystemAvailableDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodFilesystemAvailableDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodFilesystemAvailableDataPoint adds a data point to k8s.pod.filesystem.available metric.

func (*MetricsBuilder) RecordK8sPodFilesystemCapacityDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodFilesystemCapacityDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodFilesystemCapacityDataPoint adds a data point to k8s.pod.filesystem.capacity metric.

func (*MetricsBuilder) RecordK8sPodFilesystemUsageDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodFilesystemUsageDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodFilesystemUsageDataPoint adds a data point to k8s.pod.filesystem.usage metric.

func (*MetricsBuilder) RecordK8sPodMemoryAvailableDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodMemoryAvailableDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodMemoryAvailableDataPoint adds a data point to k8s.pod.memory.available metric.

func (*MetricsBuilder) RecordK8sPodMemoryMajorPageFaultsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodMemoryMajorPageFaultsDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodMemoryMajorPageFaultsDataPoint adds a data point to k8s.pod.memory.major_page_faults metric.

func (*MetricsBuilder) RecordK8sPodMemoryPageFaultsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodMemoryPageFaultsDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodMemoryPageFaultsDataPoint adds a data point to k8s.pod.memory.page_faults metric.

func (*MetricsBuilder) RecordK8sPodMemoryRssDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodMemoryRssDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodMemoryRssDataPoint adds a data point to k8s.pod.memory.rss metric.

func (*MetricsBuilder) RecordK8sPodMemoryUsageDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodMemoryUsageDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodMemoryUsageDataPoint adds a data point to k8s.pod.memory.usage metric.

func (*MetricsBuilder) RecordK8sPodMemoryWorkingSetDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodMemoryWorkingSetDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sPodMemoryWorkingSetDataPoint adds a data point to k8s.pod.memory.working_set metric.

func (*MetricsBuilder) RecordK8sPodNetworkErrorsDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodNetworkErrorsDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string, directionAttributeValue AttributeDirection)

RecordK8sPodNetworkErrorsDataPoint adds a data point to k8s.pod.network.errors metric.

func (*MetricsBuilder) RecordK8sPodNetworkErrorsReceiveDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sPodNetworkErrorsReceiveDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sPodNetworkErrorsReceiveDataPoint adds a data point to k8s.pod.network.errors.receive metric.

func (*MetricsBuilder) RecordK8sPodNetworkErrorsTransmitDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sPodNetworkErrorsTransmitDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sPodNetworkErrorsTransmitDataPoint adds a data point to k8s.pod.network.errors.transmit metric.

func (*MetricsBuilder) RecordK8sPodNetworkIoDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sPodNetworkIoDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string, directionAttributeValue AttributeDirection)

RecordK8sPodNetworkIoDataPoint adds a data point to k8s.pod.network.io metric.

func (*MetricsBuilder) RecordK8sPodNetworkIoReceiveDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sPodNetworkIoReceiveDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sPodNetworkIoReceiveDataPoint adds a data point to k8s.pod.network.io.receive metric.

func (*MetricsBuilder) RecordK8sPodNetworkIoTransmitDataPoint added in v0.59.0 

func (mb *MetricsBuilder) RecordK8sPodNetworkIoTransmitDataPoint(ts pcommon.Timestamp, val int64, interfaceAttributeValue string)

RecordK8sPodNetworkIoTransmitDataPoint adds a data point to k8s.pod.network.io.transmit metric.

func (*MetricsBuilder) RecordK8sVolumeAvailableDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sVolumeAvailableDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sVolumeAvailableDataPoint adds a data point to k8s.volume.available metric.

func (*MetricsBuilder) RecordK8sVolumeCapacityDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sVolumeCapacityDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sVolumeCapacityDataPoint adds a data point to k8s.volume.capacity metric.

func (*MetricsBuilder) RecordK8sVolumeInodesDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sVolumeInodesDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sVolumeInodesDataPoint adds a data point to k8s.volume.inodes metric.

func (*MetricsBuilder) RecordK8sVolumeInodesFreeDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sVolumeInodesFreeDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sVolumeInodesFreeDataPoint adds a data point to k8s.volume.inodes.free metric.

func (*MetricsBuilder) RecordK8sVolumeInodesUsedDataPoint added in v0.52.0 

func (mb *MetricsBuilder) RecordK8sVolumeInodesUsedDataPoint(ts pcommon.Timestamp, val int64)

RecordK8sVolumeInodesUsedDataPoint adds a data point to k8s.volume.inodes.used metric.

func (*MetricsBuilder) Reset added in v0.52.0 

func (mb *MetricsBuilder) Reset(options ...metricBuilderOption)

Reset resets metrics builder to its initial state. It should be used when external metrics source is restarted, and metrics builder should update its startTime and reset it's internal state accordingly.

type MetricsBuilders added in v0.52.0 

type MetricsBuilders struct {
	NodeMetricsBuilder      *MetricsBuilder
	PodMetricsBuilder       *MetricsBuilder
	ContainerMetricsBuilder *MetricsBuilder
	OtherMetricsBuilder     *MetricsBuilder
}

type MetricsSettings added in v0.52.0 

type MetricsSettings struct {
	ContainerCPUTime               MetricSettings `mapstructure:"container.cpu.time"`
	ContainerCPUUtilization        MetricSettings `mapstructure:"container.cpu.utilization"`
	ContainerFilesystemAvailable   MetricSettings `mapstructure:"container.filesystem.available"`
	ContainerFilesystemCapacity    MetricSettings `mapstructure:"container.filesystem.capacity"`
	ContainerFilesystemUsage       MetricSettings `mapstructure:"container.filesystem.usage"`
	ContainerMemoryAvailable       MetricSettings `mapstructure:"container.memory.available"`
	ContainerMemoryMajorPageFaults MetricSettings `mapstructure:"container.memory.major_page_faults"`
	ContainerMemoryPageFaults      MetricSettings `mapstructure:"container.memory.page_faults"`
	ContainerMemoryRss             MetricSettings `mapstructure:"container.memory.rss"`
	ContainerMemoryUsage           MetricSettings `mapstructure:"container.memory.usage"`
	ContainerMemoryWorkingSet      MetricSettings `mapstructure:"container.memory.working_set"`
	K8sNodeCPUTime                 MetricSettings `mapstructure:"k8s.node.cpu.time"`
	K8sNodeCPUUtilization          MetricSettings `mapstructure:"k8s.node.cpu.utilization"`
	K8sNodeFilesystemAvailable     MetricSettings `mapstructure:"k8s.node.filesystem.available"`
	K8sNodeFilesystemCapacity      MetricSettings `mapstructure:"k8s.node.filesystem.capacity"`
	K8sNodeFilesystemUsage         MetricSettings `mapstructure:"k8s.node.filesystem.usage"`
	K8sNodeMemoryAvailable         MetricSettings `mapstructure:"k8s.node.memory.available"`
	K8sNodeMemoryMajorPageFaults   MetricSettings `mapstructure:"k8s.node.memory.major_page_faults"`
	K8sNodeMemoryPageFaults        MetricSettings `mapstructure:"k8s.node.memory.page_faults"`
	K8sNodeMemoryRss               MetricSettings `mapstructure:"k8s.node.memory.rss"`
	K8sNodeMemoryUsage             MetricSettings `mapstructure:"k8s.node.memory.usage"`
	K8sNodeMemoryWorkingSet        MetricSettings `mapstructure:"k8s.node.memory.working_set"`
	K8sNodeNetworkErrors           MetricSettings `mapstructure:"k8s.node.network.errors"`
	K8sNodeNetworkErrorsReceive    MetricSettings `mapstructure:"k8s.node.network.errors.receive"`
	K8sNodeNetworkErrorsTransmit   MetricSettings `mapstructure:"k8s.node.network.errors.transmit"`
	K8sNodeNetworkIo               MetricSettings `mapstructure:"k8s.node.network.io"`
	K8sNodeNetworkIoReceive        MetricSettings `mapstructure:"k8s.node.network.io.receive"`
	K8sNodeNetworkIoTransmit       MetricSettings `mapstructure:"k8s.node.network.io.transmit"`
	K8sPodCPUTime                  MetricSettings `mapstructure:"k8s.pod.cpu.time"`
	K8sPodCPUUtilization           MetricSettings `mapstructure:"k8s.pod.cpu.utilization"`
	K8sPodFilesystemAvailable      MetricSettings `mapstructure:"k8s.pod.filesystem.available"`
	K8sPodFilesystemCapacity       MetricSettings `mapstructure:"k8s.pod.filesystem.capacity"`
	K8sPodFilesystemUsage          MetricSettings `mapstructure:"k8s.pod.filesystem.usage"`
	K8sPodMemoryAvailable          MetricSettings `mapstructure:"k8s.pod.memory.available"`
	K8sPodMemoryMajorPageFaults    MetricSettings `mapstructure:"k8s.pod.memory.major_page_faults"`
	K8sPodMemoryPageFaults         MetricSettings `mapstructure:"k8s.pod.memory.page_faults"`
	K8sPodMemoryRss                MetricSettings `mapstructure:"k8s.pod.memory.rss"`
	K8sPodMemoryUsage              MetricSettings `mapstructure:"k8s.pod.memory.usage"`
	K8sPodMemoryWorkingSet         MetricSettings `mapstructure:"k8s.pod.memory.working_set"`
	K8sPodNetworkErrors            MetricSettings `mapstructure:"k8s.pod.network.errors"`
	K8sPodNetworkErrorsReceive     MetricSettings `mapstructure:"k8s.pod.network.errors.receive"`
	K8sPodNetworkErrorsTransmit    MetricSettings `mapstructure:"k8s.pod.network.errors.transmit"`
	K8sPodNetworkIo                MetricSettings `mapstructure:"k8s.pod.network.io"`
	K8sPodNetworkIoReceive         MetricSettings `mapstructure:"k8s.pod.network.io.receive"`
	K8sPodNetworkIoTransmit        MetricSettings `mapstructure:"k8s.pod.network.io.transmit"`
	K8sVolumeAvailable             MetricSettings `mapstructure:"k8s.volume.available"`
	K8sVolumeCapacity              MetricSettings `mapstructure:"k8s.volume.capacity"`
	K8sVolumeInodes                MetricSettings `mapstructure:"k8s.volume.inodes"`
	K8sVolumeInodesFree            MetricSettings `mapstructure:"k8s.volume.inodes.free"`
	K8sVolumeInodesUsed            MetricSettings `mapstructure:"k8s.volume.inodes.used"`
}

MetricsSettings provides settings for kubeletstatsreceiver metrics.

func DefaultMetricsSettings added in v0.52.0 

func DefaultMetricsSettings() MetricsSettings

type NetworkMetrics added in v0.51.0 

type NetworkMetrics struct {
	IO     NetworkMetricsRecorder
	Errors NetworkMetricsRecorder
}

type NetworkMetricsRecorder added in v0.59.0 

type NetworkMetricsRecorder struct {
	RecordReceiveDataPoint  RecordIntDataPointWithStringAttributeFunc
	RecordTransmitDataPoint RecordIntDataPointWithStringAttributeFunc
}

type NetworkMetricsWithDirection added in v0.59.0 

type NetworkMetricsWithDirection struct {
	IO     RecordIntDataPointWithDirectionFunc
	Errors RecordIntDataPointWithDirectionFunc
}

type RecordDoubleDataPointFunc added in v0.52.0 

type RecordDoubleDataPointFunc func(*MetricsBuilder, pcommon.Timestamp, float64)

type RecordIntDataPointFunc added in v0.52.0 

type RecordIntDataPointFunc func(*MetricsBuilder, pcommon.Timestamp, int64)

type RecordIntDataPointWithDirectionFunc added in v0.52.0 

type RecordIntDataPointWithDirectionFunc func(*MetricsBuilder, pcommon.Timestamp, int64, string, AttributeDirection)

type RecordIntDataPointWithStringAttributeFunc added in v0.59.0 

type RecordIntDataPointWithStringAttributeFunc func(*MetricsBuilder, pcommon.Timestamp, int64, string)

type ResourceMetricsOption added in v0.52.0 

type ResourceMetricsOption func(pmetric.ResourceMetrics)

ResourceMetricsOption applies changes to provided resource metrics.

func WithAwsVolumeID added in v0.52.0 

func WithAwsVolumeID(val string) ResourceMetricsOption

WithAwsVolumeID sets provided value as "aws.volume.id" attribute for current resource.

func WithContainerID added in v0.52.0 

func WithContainerID(val string) ResourceMetricsOption

WithContainerID sets provided value as "container.id" attribute for current resource.

func WithFsType added in v0.52.0 

func WithFsType(val string) ResourceMetricsOption

WithFsType sets provided value as "fs.type" attribute for current resource.

func WithGcePdName added in v0.52.0 

func WithGcePdName(val string) ResourceMetricsOption

WithGcePdName sets provided value as "gce.pd.name" attribute for current resource.

func WithGlusterfsEndpointsName added in v0.52.0 

func WithGlusterfsEndpointsName(val string) ResourceMetricsOption

WithGlusterfsEndpointsName sets provided value as "glusterfs.endpoints.name" attribute for current resource.

func WithGlusterfsPath added in v0.52.0 

func WithGlusterfsPath(val string) ResourceMetricsOption

WithGlusterfsPath sets provided value as "glusterfs.path" attribute for current resource.

func WithK8sContainerName added in v0.54.0 

func WithK8sContainerName(val string) ResourceMetricsOption

WithK8sContainerName sets provided value as "k8s.container.name" attribute for current resource.

func WithK8sNamespaceName added in v0.52.0 

func WithK8sNamespaceName(val string) ResourceMetricsOption

WithK8sNamespaceName sets provided value as "k8s.namespace.name" attribute for current resource.

func WithK8sNodeName added in v0.52.0 

func WithK8sNodeName(val string) ResourceMetricsOption

WithK8sNodeName sets provided value as "k8s.node.name" attribute for current resource.

func WithK8sPersistentvolumeclaimName added in v0.52.0 

func WithK8sPersistentvolumeclaimName(val string) ResourceMetricsOption

WithK8sPersistentvolumeclaimName sets provided value as "k8s.persistentvolumeclaim.name" attribute for current resource.

func WithK8sPodName added in v0.52.0 

func WithK8sPodName(val string) ResourceMetricsOption

WithK8sPodName sets provided value as "k8s.pod.name" attribute for current resource.

func WithK8sPodUID added in v0.52.0 

func WithK8sPodUID(val string) ResourceMetricsOption

WithK8sPodUID sets provided value as "k8s.pod.uid" attribute for current resource.

func WithK8sVolumeName added in v0.52.0 

func WithK8sVolumeName(val string) ResourceMetricsOption

WithK8sVolumeName sets provided value as "k8s.volume.name" attribute for current resource.

func WithK8sVolumeType added in v0.52.0 

func WithK8sVolumeType(val string) ResourceMetricsOption

WithK8sVolumeType sets provided value as "k8s.volume.type" attribute for current resource.

func WithPartition added in v0.52.0 

func WithPartition(val string) ResourceMetricsOption

WithPartition sets provided value as "partition" attribute for current resource.

func WithStartTimeOverride added in v0.52.0 

func WithStartTimeOverride(start pcommon.Timestamp) ResourceMetricsOption

WithStartTimeOverride overrides start time for all the resource metrics data points. This option should be only used if different start time has to be set on metrics coming from different resources.

type VolumeMetrics added in v0.51.0 

type VolumeMetrics struct {
	Available  RecordIntDataPointFunc
	Capacity   RecordIntDataPointFunc
	Inodes     RecordIntDataPointFunc
	InodesFree RecordIntDataPointFunc
	InodesUsed RecordIntDataPointFunc
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.