metriccache

package

Go to main page

Versions in this module

v1

v1.5.0

Jun 3, 2024

Changes in this version

type Querier

+ Close func()

+ QueryAndClose func(meta MetricMeta, hints *QueryHints, result MetricResult) error

v1.4.1

Feb 26, 2024

v1.4.0

Jan 9, 2024

Changes in this version

+ var ContainerMemoryColdPageSizeMetric = defaultMetricFactory.New(ContainerMemoryColdPageSize).withPropertySchema(MetricPropertyContainerID)

+ var ContainerMemoryUsageWithPageCacheMetric = defaultMetricFactory.New(ContainerMemoryWithPageCacheUsage).withPropertySchema(MetricPropertyContainerID)

+ var ContainerMemoryWithHotPageUsageMetric = defaultMetricFactory.New(ContainerMemoryWithHotPageUsage).withPropertySchema(MetricPropertyContainerID)

+ var HostAppCPUUsageMetric = defaultMetricFactory.New(HostAppCPUUsage).withPropertySchema(MetricPropertyHostAppName)

+ var HostAppMemoryColdPageSizeMetric = defaultMetricFactory.New(HostAppMemoryColdPageSize).withPropertySchema(MetricPropertyHostAppName)

+ var HostAppMemoryUsageMetric = defaultMetricFactory.New(HostAppMemoryUsage).withPropertySchema(MetricPropertyHostAppName)

+ var HostAppMemoryUsageWithPageCacheMetric = defaultMetricFactory.New(HostAppMemoryWithPageCacheUsage).withPropertySchema(MetricPropertyHostAppName)

+ var HostAppMemoryWithHotPageUsageMetric = defaultMetricFactory.New(HostAppMemoryWithHotPageUsage).withPropertySchema(MetricPropertyHostAppName)

+ var NodeMemoryColdPageSizeMetric = defaultMetricFactory.New(NodeMemoryColdPageSize)

+ var NodeMemoryUsageWithPageCacheMetric = defaultMetricFactory.New(NodeMemoryWithPageCacheUsage)

+ var NodeMemoryWithHotPageUsageMetric = defaultMetricFactory.New(NodeMemoryWithHotPageUsage)

+ var PodMemoryColdPageSizeMetric = defaultMetricFactory.New(PodMemoryColdPageSize).withPropertySchema(MetricPropertyPodUID)

+ var PodMemoryUsageWithPageCacheMetric = defaultMetricFactory.New(PodMemoryWithPageCacheUsage).withPropertySchema(MetricPropertyPodUID)

+ var PodMemoryWithHotPageUsageMetric = defaultMetricFactory.New(PodMemoryWithHotPageUsage).withPropertySchema(MetricPropertyPodUID)

type MetricKind

+ const ContainerMemoryColdPageSize

+ const ContainerMemoryWithHotPageUsage

+ const ContainerMemoryWithPageCacheUsage

+ const HostAppCPUUsage

+ const HostAppMemoryColdPageSize

+ const HostAppMemoryUsage

+ const HostAppMemoryWithHotPageUsage

+ const HostAppMemoryWithPageCacheUsage

+ const NodeMemoryColdPageSize

+ const NodeMemoryWithHotPageUsage

+ const NodeMemoryWithPageCacheUsage

+ const PodMemoryColdPageSize

+ const PodMemoryWithHotPageUsage

+ const PodMemoryWithPageCacheUsage

type MetricProperty

+ const MetricPropertyHostAppName

type MetricPropertyValue

+ const BEResourceAllocationRealLimit

+ const BEResourceAllocationRequest

+ const BEResourceAllocationUsage

v1.3.0

Aug 14, 2023

Changes in this version

+ const NodeCPUInfoKey

+ const NodeLocalStorageInfoKey

+ const NodeNUMAInfoKey

+ var ContainerCPI = defaultMetricFactory.New(ContainerMetricCPI).withPropertySchema(MetricPropertyPodUID, MetricPropertyContainerID, MetricPropertyCPIResource)

+ var ContainerCPUThrottledMetric = defaultMetricFactory.New(ContainerMetricCPUThrottled).withPropertySchema(MetricPropertyContainerID)

+ var ContainerCPUUsageMetric = defaultMetricFactory.New(ContainerMetricCPUUsage).withPropertySchema(MetricPropertyContainerID)

+ var ContainerGPUCoreUsageMetric = defaultMetricFactory.New(ContainerMetricGPUCoreUsage).withPropertySchema(MetricPropertyContainerID, MetricPropertyGPUMinor, MetricPropertyGPUDeviceUUID)

+ var ContainerGPUMemUsageMetric = defaultMetricFactory.New(ContainerMetricGPUMemUsage).withPropertySchema(MetricPropertyContainerID, MetricPropertyGPUMinor, MetricPropertyGPUDeviceUUID)

+ var ContainerMemUsageMetric = defaultMetricFactory.New(ContainerMetricMemoryUsage).withPropertySchema(MetricPropertyContainerID)

+ var ContainerPSICPUFullSupportedMetric = defaultMetricFactory.New(ContainerMetricPSICPUFullSupported).withPropertySchema(MetricPropertyPodUID, MetricPropertyContainerID)

+ var ContainerPSIMetric = defaultMetricFactory.New(ContainerMetricPSI).withPropertySchema(MetricPropertyPodUID, MetricPropertyContainerID, MetricPropertyPSIResource, ...)

+ var MetricPropertiesFunc = struct{ ... }

+ var NodeBEMetric = defaultMetricFactory.New(NodeMetricBE).withPropertySchema(MetricPropertyBEResource, MetricPropertyBEAllocation)

+ var NodeCPUUsageMetric = defaultMetricFactory.New(NodeMetricCPUUsage)

+ var NodeGPUCoreUsageMetric = defaultMetricFactory.New(NodeMetricGPUCoreUsage).withPropertySchema(MetricPropertyGPUMinor, MetricPropertyGPUDeviceUUID)

+ var NodeGPUMemTotalMetric = defaultMetricFactory.New(NodeMetricGPUMemTotal).withPropertySchema(MetricPropertyGPUMinor, MetricPropertyGPUDeviceUUID)

+ var NodeGPUMemUsageMetric = defaultMetricFactory.New(NodeMetricGPUMemUsage).withPropertySchema(MetricPropertyGPUMinor, MetricPropertyGPUDeviceUUID)

+ var NodeMemoryUsageMetric = defaultMetricFactory.New(NodeMetricMemoryUsage)

+ var PodCPUThrottledMetric = defaultMetricFactory.New(PodMetricCPUThrottled).withPropertySchema(MetricPropertyPodUID)

+ var PodCPUUsageMetric = defaultMetricFactory.New(PodMetricCPUUsage).withPropertySchema(MetricPropertyPodUID)

+ var PodGPUCoreUsageMetric = defaultMetricFactory.New(PodMetricGPUCoreUsage).withPropertySchema(MetricPropertyPodUID, MetricPropertyGPUMinor, MetricPropertyGPUDeviceUUID)

+ var PodGPUMemUsageMetric = defaultMetricFactory.New(PodMetricGPUMemUsage).withPropertySchema(MetricPropertyPodUID, MetricPropertyGPUMinor, MetricPropertyGPUDeviceUUID)

+ var PodMemUsageMetric = defaultMetricFactory.New(PodMetricMemoryUsage).withPropertySchema(MetricPropertyPodUID)

+ var PodPSICPUFullSupportedMetric = defaultMetricFactory.New(PodMetricPSICPUFullSupported).withPropertySchema(MetricPropertyPodUID)

+ var PodPSIMetric = defaultMetricFactory.New(PodMetricPSI).withPropertySchema(MetricPropertyPodUID, MetricPropertyPSIResource, MetricPropertyPSIPrecision, ...)

+ var SystemCPUUsageMetric = defaultMetricFactory.New(SysMetricCPUUsage)

+ var SystemMemoryUsageMetric = defaultMetricFactory.New(SysMetricMemoryUsage)

+ type AggregateResult interface

+ Count func() int

+ TimeRangeDuration func() time.Duration

+ Value func(t AggregationType) (float64, error)

+ type AggregateResultFactory interface

+ New func(meta MetricMeta) AggregateResult

+ var DefaultAggregateResultFactory AggregateResultFactory = &aggregateResultFactory{}

+ type Appendable interface

+ Appender func() Appender

+ type Appender interface

+ Append func(s []MetricSample) error

+ Commit func() error

type Config

+ TSDBEnablePromMetrics bool

+ TSDBHeadChunksWriteBufferSize int

+ TSDBMaxBlockChunkSegmentSize int64

+ TSDBMaxBlockDuration time.Duration

+ TSDBMaxBytes int64

+ TSDBMinBlockDuration time.Duration

+ TSDBPath string

+ TSDBRetentionDuration time.Duration

+ TSDBStripeSize int

+ TSDBWALSegmentSize int

+ type Devices util.Devices

+ type KVStorage interface

+ Get func(key interface{}) (interface{}, bool)

+ Set func(key, value interface{})

+ func NewMemoryStorage() KVStorage

+ type MetricFactory interface

+ New func(metricKind MetricKind) MetricResource

+ func NewMetricFactory() MetricFactory

+ type MetricKind string

+ const ContainerMetricCPI

+ const ContainerMetricCPUThrottled

+ const ContainerMetricCPUUsage

+ const ContainerMetricGPUCoreUsage

+ const ContainerMetricGPUMemUsage

+ const ContainerMetricMemoryUsage

+ const ContainerMetricPSI

+ const ContainerMetricPSICPUFullSupported

+ const NodeMetricBE

+ const NodeMetricCPUUsage

+ const NodeMetricGPUCoreUsage

+ const NodeMetricGPUMemTotal

+ const NodeMetricGPUMemUsage

+ const NodeMetricMemoryUsage

+ const PodMetricCPUThrottled

+ const PodMetricCPUUsage

+ const PodMetricGPUCoreUsage

+ const PodMetricGPUMemUsage

+ const PodMetricMemoryUsage

+ const PodMetricPSI

+ const PodMetricPSICPUFullSupported

+ const PriorityMetricCPURealLimit

+ const PriorityMetricCPURequest

+ const PriorityMetricCPUUsage

+ const SysMetricCPUUsage

+ const SysMetricMemoryUsage

+ type MetricMeta interface

+ GetKind func() string

+ GetProperties func() map[string]string

+ type MetricProperty string

+ const MetricPropertyBEAllocation

+ const MetricPropertyBEResource

+ const MetricPropertyCPIResource

+ const MetricPropertyContainerID

+ const MetricPropertyGPUDeviceUUID

+ const MetricPropertyGPUMinor

+ const MetricPropertyPSIDegree

+ const MetricPropertyPSIPrecision

+ const MetricPropertyPSIResource

+ const MetricPropertyPodUID

+ const MetricPropertyPriorityClass

+ type MetricPropertyValue string

+ const BEResouceAllocationRealLimit

+ const BEResouceAllocationRequest

+ const BEResouceAllocationUsage

+ const BEResourceCPU

+ const CPIResourceCycle

+ const CPIResourceInstruction

+ const PSIDegreeFull

+ const PSIDegreeSome

+ const PSIPrecision10

+ const PSIPrecision300

+ const PSIPrecision60

+ const PSIResourceCPU

+ const PSIResourceIO

+ const PSIResourceMem

+ type MetricResource interface

+ BuildQueryMeta func(properties map[MetricProperty]string) (MetricMeta, error)

+ GenerateSample func(properties map[MetricProperty]string, t time.Time, val float64) (MetricSample, error)

+ type MetricResult interface

+ AddSeries func(promstorage.Series) error

+ type MetricSample interface

+ type NodeLocalStorageInfo util.LocalStorageInfo

+ type Point struct

+ Timestamp time.Time

+ Value float64

+ type Querier interface

+ Query func(meta MetricMeta, hints *QueryHints, result MetricResult) error

+ type QueryHints struct

+ type Queryable interface

+ Querier func(startTime, endTime time.Time) (Querier, error)

+ type TSDBStorage interface

+ Close func() error

+ func NewTSDBStorage(conf *Config) (TSDBStorage, error)

v1.2.0

Apr 7, 2023

v1.1.1

Jan 16, 2023

v1.1.0

Dec 26, 2022

Changes in this version

type AggregateInfo

+ MetricEnd *time.Time

+ MetricStart *time.Time

+ func (a *AggregateInfo) TimeRangeDuration() time.Duration

type AggregationType

+ const AggregationTypeP50

+ const AggregationTypeP95

+ const AggregationTypeP99

type InterferenceMetricName

+ const MetricNameContainerPSI

+ const MetricNamePodPSI

type MetricCache

+ InsertPodInterferenceMetrics func(t time.Time, metric *PodInterferenceMetric) error

+ type PSIMetric struct

+ CPUFullSupported bool

+ FullCPUAvg10 float64

+ FullIOAvg10 float64

+ FullMemAvg10 float64

+ SomeCPUAvg10 float64

+ SomeIOAvg10 float64

+ SomeMemAvg10 float64

v1.0.0

Nov 2, 2022

Changes in this version

+ type CPIMetric struct

+ Cycles uint64

+ Instructions uint64

+ type ContainerInterferenceMetric struct

+ ContainerID string

+ MetricName InterferenceMetricName

+ MetricValue interface{}

+ PodUID string

+ type ContainerInterferenceQueryResult struct

+ Metric *ContainerInterferenceMetric

+ type InterferenceMetricName string

+ const MetricNameContainerCPI

+ const MetricNamePodCPI

type MetricCache

+ GetContainerInterferenceMetric func(metricName InterferenceMetricName, podUID *string, containerID *string, ...) ContainerInterferenceQueryResult

+ GetPodInterferenceMetric func(metricName InterferenceMetricName, podUID *string, param *QueryParam) PodInterferenceQueryResult

+ InsertContainerInterferenceMetrics func(t time.Time, metric *ContainerInterferenceMetric) error

+ type PodInterferenceMetric struct

+ MetricName InterferenceMetricName

+ MetricValue interface{}

+ PodUID string

+ type PodInterferenceQueryResult struct

+ Metric *PodInterferenceMetric

v0

v0.7.0

Sep 21, 2022

v0.6.2

Aug 15, 2022

v0.6.1

Aug 5, 2022

v0.6.0

Aug 4, 2022

Changes in this version

+ type AggregationFunc func(interface{}, AggregateParam) (float64, error)

type ContainerResourceMetric

+ GPUs []GPUMetric

+ type GPUMetric struct

+ DeviceUUID string

+ MemoryTotal resource.Quantity

+ MemoryUsed resource.Quantity

+ Minor int32

+ SMUtil uint32

+ type GPUMetricsArray []gpuResourceMetric

+ func (array *GPUMetricsArray) Scan(value interface{}) error

+ func (array GPUMetricsArray) Value() (driver.Value, error)

type NodeResourceMetric

+ GPUs []GPUMetric

type PodResourceMetric

+ GPUs []GPUMetric

v0.5.0

Jun 30, 2022

v0.4.1

Jun 8, 2022

v0.4.0

May 31, 2022

v0.3.1

May 9, 2022

v0.3.0

May 7, 2022

v0.2.0

Apr 20, 2022

v0.1.0

Apr 1, 2022

Changes in this version

+ const NodeCPUInfoRecordType

+ func NewCacheNotShareStorage() (*storage, error)

+ func NewStorage() (*storage, error)

+ type AggregateInfo struct

+ MetricsCount int64

+ type AggregateParam struct

+ TimeFieldName string

+ ValueFieldName string

+ type AggregationType string

+ const AggregationTypeAVG

+ const AggregationTypeCount

+ const AggregationTypeLast

+ const AggregationTypeP90

+ type BECPUResourceMetric struct

+ CPURealLimit resource.Quantity

+ CPURequest resource.Quantity

+ CPUUsed resource.Quantity

+ type BECPUResourceQueryResult struct

+ Metric *BECPUResourceMetric

+ type CPUMetric struct

+ CPUUsed resource.Quantity

+ type CPUThrottledMetric struct

+ ThrottledRatio float64

+ type Config struct

+ MetricExpireSeconds int

+ MetricGCIntervalSeconds int

+ func NewDefaultConfig() *Config

+ func (c *Config) InitFlags(fs *flag.FlagSet)

+ type ContainerResourceMetric struct

+ CPUUsed CPUMetric

+ ContainerID string

+ MemoryUsed MemoryMetric

+ type ContainerResourceQueryResult struct

+ Metric *ContainerResourceMetric

+ type ContainerThrottledMetric struct

+ CPUThrottledMetric *CPUThrottledMetric

+ ContainerID string

+ type ContainerThrottledQueryResult struct

+ Metric *ContainerThrottledMetric

+ type MemoryMetric struct

+ MemoryWithoutCache resource.Quantity

+ type MetricCache interface

+ GetBECPUResourceMetric func(param *QueryParam) BECPUResourceQueryResult

+ GetContainerResourceMetric func(containerID *string, param *QueryParam) ContainerResourceQueryResult

+ GetContainerThrottledMetric func(containerID *string, param *QueryParam) ContainerThrottledQueryResult

+ GetNodeCPUInfo func(param *QueryParam) (*NodeCPUInfo, error)

+ GetNodeResourceMetric func(param *QueryParam) NodeResourceQueryResult

+ GetPodResourceMetric func(podUID *string, param *QueryParam) PodResourceQueryResult

+ GetPodThrottledMetric func(podUID *string, param *QueryParam) PodThrottledQueryResult

+ InsertBECPUResourceMetric func(t time.Time, metric *BECPUResourceMetric) error

+ InsertContainerResourceMetric func(t time.Time, containerResUsed *ContainerResourceMetric) error

+ InsertContainerThrottledMetrics func(t time.Time, metric *ContainerThrottledMetric) error

+ InsertNodeCPUInfo func(info *NodeCPUInfo) error

+ InsertNodeResourceMetric func(t time.Time, nodeResUsed *NodeResourceMetric) error

+ InsertPodResourceMetric func(t time.Time, podResUsed *PodResourceMetric) error

+ InsertPodThrottledMetrics func(t time.Time, metric *PodThrottledMetric) error

+ Run func(stopCh <-chan struct{}) error

+ func NewCacheNotShareMetricCache(cfg *Config) (MetricCache, error)

+ func NewMetricCache(cfg *Config) (MetricCache, error)

+ type NodeCPUInfo util.LocalCPUInfo

+ type NodeResourceMetric struct

+ CPUUsed CPUMetric

+ MemoryUsed MemoryMetric

+ type NodeResourceQueryResult struct

+ Metric *NodeResourceMetric

+ type PodResourceMetric struct

+ CPUUsed CPUMetric

+ MemoryUsed MemoryMetric

+ PodUID string

+ type PodResourceQueryResult struct

+ Metric *PodResourceMetric

+ type PodThrottledMetric struct

+ CPUThrottledMetric *CPUThrottledMetric

+ PodUID string

+ type PodThrottledQueryResult struct

+ Metric *PodThrottledMetric

+ type QueryParam struct

+ Aggregate AggregationType

+ End *time.Time

+ Start *time.Time

+ func (q *QueryParam) FillDefaultValue()

+ type QueryResult struct

+ AggregateInfo *AggregateInfo

+ Error error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL