// Licensed to the LF AI & Data foundation under one // or more contributor license agreements. See the NOTICE file // distributed with this work for additional information // regarding copyright ownership. The ASF licenses this file // to you under the Apache License, Version 2.0 (the // "License"); you may not use this file except in compliance // with the License. You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package metricsinfo import ( "sync" "time" "github.com/milvus-io/milvus/internal/proto/milvuspb" ) // DefaultMetricsRetention defines the default retention of metrics cache. // TODO(dragondriver): load from config file const DefaultMetricsRetention = time.Second * 5 // MetricsCacheManager manage the cache of metrics information. // TODO(dragondriver): we can use a map to manage the metrics if there are too many kind metrics type MetricsCacheManager struct { systemInfoMetrics *milvuspb.GetMetricsResponse systemInfoMetricsInvalid bool systemInfoMetricsLastUpdatedTime time.Time systemInfoMetricsMtx sync.RWMutex retention time.Duration retentionMtx sync.RWMutex // necessary? } // NewMetricsCacheManager returns a cache manager of metrics information. func NewMetricsCacheManager() *MetricsCacheManager { manager := &MetricsCacheManager{ systemInfoMetrics: nil, systemInfoMetricsInvalid: false, systemInfoMetricsLastUpdatedTime: time.Now(), systemInfoMetricsMtx: sync.RWMutex{}, retention: DefaultMetricsRetention, } return manager } // GetRetention returns the retention func (manager *MetricsCacheManager) GetRetention() time.Duration { manager.retentionMtx.RLock() defer manager.retentionMtx.RUnlock() return manager.retention } // SetRetention updates the retention func (manager *MetricsCacheManager) SetRetention(retention time.Duration) { manager.retentionMtx.Lock() defer manager.retentionMtx.Unlock() manager.retention = retention } // ResetRetention reset retention to default func (manager *MetricsCacheManager) ResetRetention() { manager.retentionMtx.Lock() defer manager.retentionMtx.Unlock() manager.retention = DefaultMetricsRetention } // InvalidateSystemInfoMetrics invalidates the system information metrics. func (manager *MetricsCacheManager) InvalidateSystemInfoMetrics() { manager.systemInfoMetricsMtx.Lock() defer manager.systemInfoMetricsMtx.Unlock() manager.systemInfoMetricsInvalid = true } // IsSystemInfoMetricsValid checks if the manager's systemInfoMetrics is valid func (manager *MetricsCacheManager) IsSystemInfoMetricsValid() bool { retention := manager.GetRetention() manager.systemInfoMetricsMtx.RLock() defer manager.systemInfoMetricsMtx.RUnlock() return (!manager.systemInfoMetricsInvalid) && (manager.systemInfoMetrics != nil) && (time.Since(manager.systemInfoMetricsLastUpdatedTime) < retention) } // GetSystemInfoMetrics returns the cached system information metrics. func (manager *MetricsCacheManager) GetSystemInfoMetrics() (*milvuspb.GetMetricsResponse, error) { retention := manager.GetRetention() manager.systemInfoMetricsMtx.RLock() defer manager.systemInfoMetricsMtx.RUnlock() if manager.systemInfoMetricsInvalid || manager.systemInfoMetrics == nil || time.Since(manager.systemInfoMetricsLastUpdatedTime) >= retention { return nil, errInvalidSystemInfosMetricCache } return manager.systemInfoMetrics, nil } // UpdateSystemInfoMetrics updates systemInfoMetrics by given info func (manager *MetricsCacheManager) UpdateSystemInfoMetrics(infos *milvuspb.GetMetricsResponse) { manager.systemInfoMetricsMtx.Lock() defer manager.systemInfoMetricsMtx.Unlock() manager.systemInfoMetrics = infos manager.systemInfoMetricsInvalid = false manager.systemInfoMetricsLastUpdatedTime = time.Now() }