metadata

package
v0.70.0 Latest Latest
Warning

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

 Go to latest Published: Jan 24, 2023 License: Apache-2.0 Imports: 6 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:     (*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:     (*MetricsBuilder).RecordK8sPodNetworkIoDataPoint,
	Errors: (*MetricsBuilder).RecordK8sPodNetworkErrorsDataPoint,
}

Functions

func WithResourceAttributesSettings added in v0.70.0 

func WithResourceAttributesSettings(ras ResourceAttributesSettings) metricBuilderOption

WithResourceAttributesSettings sets ResourceAttributeSettings on the metrics builder.

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"`
	// contains filtered or unexported fields
}

MetricSettings provides common settings for a particular metric.

func (*MetricSettings) Unmarshal added in v0.63.0 

func (ms *MetricSettings) Unmarshal(parser *confmap.Conf) error

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(ms MetricsSettings, settings receiver.CreateSettings, 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) 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) 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) 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) 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"`
	K8sNodeNetworkIo               MetricSettings `mapstructure:"k8s.node.network.io"`
	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"`
	K8sPodNetworkIo                MetricSettings `mapstructure:"k8s.pod.network.io"`
	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     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 ResourceAttributeSettings added in v0.70.0 

type ResourceAttributeSettings struct {
	Enabled bool `mapstructure:"enabled"`
	// contains filtered or unexported fields
}

ResourceAttributeSettings provides common settings for a particular metric.

func (*ResourceAttributeSettings) Unmarshal added in v0.70.0 

func (ras *ResourceAttributeSettings) Unmarshal(parser *confmap.Conf) error

type ResourceAttributesSettings added in v0.70.0 

type ResourceAttributesSettings struct {
	AwsVolumeID                  ResourceAttributeSettings `mapstructure:"aws.volume.id"`
	ContainerID                  ResourceAttributeSettings `mapstructure:"container.id"`
	FsType                       ResourceAttributeSettings `mapstructure:"fs.type"`
	GcePdName                    ResourceAttributeSettings `mapstructure:"gce.pd.name"`
	GlusterfsEndpointsName       ResourceAttributeSettings `mapstructure:"glusterfs.endpoints.name"`
	GlusterfsPath                ResourceAttributeSettings `mapstructure:"glusterfs.path"`
	K8sContainerName             ResourceAttributeSettings `mapstructure:"k8s.container.name"`
	K8sNamespaceName             ResourceAttributeSettings `mapstructure:"k8s.namespace.name"`
	K8sNodeName                  ResourceAttributeSettings `mapstructure:"k8s.node.name"`
	K8sPersistentvolumeclaimName ResourceAttributeSettings `mapstructure:"k8s.persistentvolumeclaim.name"`
	K8sPodName                   ResourceAttributeSettings `mapstructure:"k8s.pod.name"`
	K8sPodUID                    ResourceAttributeSettings `mapstructure:"k8s.pod.uid"`
	K8sVolumeName                ResourceAttributeSettings `mapstructure:"k8s.volume.name"`
	K8sVolumeType                ResourceAttributeSettings `mapstructure:"k8s.volume.type"`
	Partition                    ResourceAttributeSettings `mapstructure:"partition"`
}

ResourceAttributesSettings provides settings for kubeletstatsreceiver metrics.

func DefaultResourceAttributesSettings added in v0.70.0 

func DefaultResourceAttributesSettings() ResourceAttributesSettings

type ResourceMetricsOption added in v0.52.0 

type ResourceMetricsOption func(ResourceAttributesSettings, 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.