Documentation
¶
Index ¶
- func ClearCache()
- func DisableEnableCache(isEnable bool) error
- func DisableEnableMetrics(isEnable bool) error
- func Get(db, rp string, seriesKey []byte, fieldKeys []string) (int64, map[string]any, bool)
- func GetCacheMetrics() *ristretto.Metrics
- func InitCache() error
- func IsLastRowCacheEnabled() bool
- func RestartCache() error
- func Set(db, rp string, seriesKey []byte, nCacheValue *CacheValue) bool
- func SetLastRowCacheEnabled(isEnable bool)
- func SetRow(db, rp string, seriesKey []byte, row *influx.Row) bool
- func SetRows(db, rp string, rows *[]influx.Row) bool
- func UpdateCacheMaxCost(maxCost int64)
- type CacheValue
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClearCache ¶
func ClearCache()
func DisableEnableCache ¶
func DisableEnableMetrics ¶
func GetCacheMetrics ¶
func IsLastRowCacheEnabled ¶
func IsLastRowCacheEnabled() bool
func RestartCache ¶
func RestartCache() error
func SetLastRowCacheEnabled ¶
func SetLastRowCacheEnabled(isEnable bool)
func UpdateCacheMaxCost ¶
func UpdateCacheMaxCost(maxCost int64)
Types ¶
type CacheValue ¶
type CacheValue struct {
// contains filtered or unexported fields
}
func (*CacheValue) SetFields ¶
func (c *CacheValue) SetFields(fields *sync.Map)
func (*CacheValue) SetTimestamp ¶
func (c *CacheValue) SetTimestamp(timestamp int64)
Source Files
Click to show internal directories.
Click to hide internal directories.