collection

Documentation

Index

• func GetMetadataUpdate(old, new map[metadataPkg.ResourceID]*KubernetesMetadata) []*metadataPkg.MetadataUpdate
• type DataCollector
  • func NewDataCollector(logger *zap.Logger, nodeConditionsToReport []string) *DataCollector
  • func (dc *DataCollector) CollectMetricData(currentTime time.Time) pdata.Metrics
  • func (dc *DataCollector) RemoveFromMetricsStore(obj interface{})
  • func (dc *DataCollector) SetupMetadataStore(o runtime.Object, store cache.Store)
  • func (dc *DataCollector) SyncMetadata(obj interface{}) map[metadata.ResourceID]*KubernetesMetadata
  • func (dc *DataCollector) SyncMetrics(obj interface{})
  • func (dc *DataCollector) UpdateMetricsStore(obj interface{}, rm []*resourceMetrics)
• type KubernetesMetadata

Functions

func GetMetadataUpdate

func GetMetadataUpdate(old, new map[metadataPkg.ResourceID]*KubernetesMetadata) []*metadataPkg.MetadataUpdate

GetMetadataUpdate processes metadata updates and returns a map of a delta of metadata mapped to each resource.

Types

type DataCollector

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

DataCollector wraps around a metricsStore and a metadaStore exposing methods to perform on the underlying stores. DataCollector also provides an interface to interact with refactored code from SignalFx Agent which is confined to the collection package.

func NewDataCollector

func NewDataCollector(logger *zap.Logger, nodeConditionsToReport []string) *DataCollector

NewDataCollector returns a DataCollector.

func (*DataCollector) CollectMetricData

func (dc *DataCollector) CollectMetricData(currentTime time.Time) pdata.Metrics

func (*DataCollector) RemoveFromMetricsStore

func (dc *DataCollector) RemoveFromMetricsStore(obj interface{})

func (*DataCollector) SetupMetadataStore

func (dc *DataCollector) SetupMetadataStore(o runtime.Object, store cache.Store)

SetupMetadataStore initializes a metadata store for the kubernetes object.

func (*DataCollector) SyncMetadata

func (dc *DataCollector) SyncMetadata(obj interface{}) map[metadata.ResourceID]*KubernetesMetadata

SyncMetadata updates the metric store with latest metrics from the kubernetes object

func (*DataCollector) SyncMetrics

func (dc *DataCollector) SyncMetrics(obj interface{})

SyncMetrics updates the metric store with latest metrics from the kubernetes object.

func (*DataCollector) UpdateMetricsStore

func (dc *DataCollector) UpdateMetricsStore(obj interface{}, rm []*resourceMetrics)

type KubernetesMetadata

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

KubernetesMetadata associates a resource to a set of properties.