internal

Documentation

Index

• Constants
• type AwsNeuronMemoryMetricsAggregator
  • func NewMemoryMemoryAggregator() *AwsNeuronMemoryMetricsAggregator
  • func (d *AwsNeuronMemoryMetricsAggregator) AggregateMemoryMetric(originalMetric pmetric.Metric)
  • func (d *AwsNeuronMemoryMetricsAggregator) FlushAggregatedMemoryMetric() pmetric.Metric
• type AwsNeuronMetricChecker
  • func NewAwsNeuronMetricChecker() *AwsNeuronMetricChecker
  • func (md *AwsNeuronMetricChecker) IsProcessedNeuronMetric(name string) bool
• type AwsNeuronMetricModifier
  • func NewMetricModifier(logger *zap.Logger) *AwsNeuronMetricModifier
  • func (md *AwsNeuronMetricModifier) ModifyMetric(originalMetric pmetric.Metric, metrics pmetric.MetricSlice)
• type MetricDatapointAggregationKey
• type MetricModifications
• type NeuronCoreInfo

Constants

const (
	ErrorType  = "error_type"
	StatusType = "status_type"
	EventType  = "event_type"

	MemoryLocation = "memory_location"

	Core                                          = "Core"
	Device                                        = "Device"
	Percentile                                    = "percentile"
	PodName                                       = "PodName"
	Count                                         = "Count"
	Bytes                                         = "Bytes"
	Seconds                                       = "Seconds"
	Percent                                       = "Percent"
	NeuronCoreAttributeKey                        = "NeuronCore"
	NeuronDeviceAttributeKey                      = "NeuronDevice"
	RuntimeTag                                    = "runtime_tag"
	ClusterName                                   = "ClusterName"
	ContainerName                                 = "ContainerName"
	FullPodName                                   = "FullPodName"
	InstanceId                                    = "InstanceId"
	InstanceType                                  = "InstanceType"
	K8sPodName                                    = "K8sPodName"
	Namespace                                     = "Namespace"
	NeuronCore                                    = "NeuronCore"
	NeuronDevice                                  = "NeuronDevice"
	NodeName                                      = "NodeName"
	Service                                       = "Service"
	AvailabilityZone                              = "availability_zone"
	Kubernetes                                    = "kubernetes"
	Region                                        = "region"
	SubnetId                                      = "subnet_id"
	RuntimeTagOverride                            = "DEFAULT"
	NeuronExecutionErrorsAggregatedMetric         = containerinsightscommon.NeuronExecutionErrors + "_total"
	NeuronDeviceHardwareEccEventsAggregatedMetric = containerinsightscommon.NeuronDeviceHardwareEccEvents + "_total"
)

const (
	PROCESSED_NEURON_METRIC_PATTERN = "^(container|node|pod)_(neuroncore_|neurondevice_).*|^node_neuron_.*"
)

Types

type AwsNeuronMemoryMetricsAggregator

type AwsNeuronMemoryMetricsAggregator struct {
	MemoryMetricsFound bool
	// contains filtered or unexported fields
}

func NewMemoryMemoryAggregator

func NewMemoryMemoryAggregator() *AwsNeuronMemoryMetricsAggregator

func (*AwsNeuronMemoryMetricsAggregator) AggregateMemoryMetric

func (d *AwsNeuronMemoryMetricsAggregator) AggregateMemoryMetric(originalMetric pmetric.Metric)

func (*AwsNeuronMemoryMetricsAggregator) FlushAggregatedMemoryMetric

func (d *AwsNeuronMemoryMetricsAggregator) FlushAggregatedMemoryMetric() pmetric.Metric

type AwsNeuronMetricChecker

type AwsNeuronMetricChecker struct {
}

func NewAwsNeuronMetricChecker

func NewAwsNeuronMetricChecker() *AwsNeuronMetricChecker

func (*AwsNeuronMetricChecker) IsProcessedNeuronMetric

func (md *AwsNeuronMetricChecker) IsProcessedNeuronMetric(name string) bool

type AwsNeuronMetricModifier

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

func NewMetricModifier

func NewMetricModifier(logger *zap.Logger) *AwsNeuronMetricModifier

func (*AwsNeuronMetricModifier) ModifyMetric

func (md *AwsNeuronMetricModifier) ModifyMetric(originalMetric pmetric.Metric, metrics pmetric.MetricSlice)

type MetricDatapointAggregationKey

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

type MetricModifications

type MetricModifications struct {
	DuplicationTypes []string
	UniqueAttribute  string
	LogTypeSuffix    string
	Unit             string
}

type NeuronCoreInfo

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