collection

Documentation

Index

• type DataCollector
  • func NewDataCollector(logger *zap.Logger, nodeConditionsToReport, allocatableTypesToReport []string) *DataCollector
  • func (dc *DataCollector) CollectMetricData(currentTime time.Time) pmetric.Metrics
  • func (dc *DataCollector) RemoveFromMetricsStore(obj interface{})
  • func (dc *DataCollector) SetupMetadataStore(gvk schema.GroupVersionKind, store cache.Store)
  • func (dc *DataCollector) SyncMetadata(obj interface{}) map[experimentalmetricmetadata.ResourceID]*metadata.KubernetesMetadata
  • func (dc *DataCollector) SyncMetrics(obj interface{})
  • func (dc *DataCollector) UpdateMetricsStore(obj interface{}, md pmetric.Metrics)

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, allocatableTypesToReport []string) *DataCollector

NewDataCollector returns a DataCollector.

func (*DataCollector) CollectMetricData

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

func (*DataCollector) RemoveFromMetricsStore

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

func (*DataCollector) SetupMetadataStore

func (dc *DataCollector) SetupMetadataStore(gvk schema.GroupVersionKind, store cache.Store)

SetupMetadataStore initializes a metadata store for the kubernetes kind.

func (*DataCollector) SyncMetadata

func (dc *DataCollector) SyncMetadata(obj interface{}) map[experimentalmetricmetadata.ResourceID]*metadata.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{}, md pmetric.Metrics)