Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CacheReadings ¶
func CacheReadings(readings ...models.MetricReadings) (err error)
CacheReadings stores models.MetricReadings into local cache DB.
func IterateOverCachedReadings ¶
func IterateOverCachedReadings(ctx context.Context, fn ReadingsCacheIteratorFunc, pop bool)
IterateOverCachedReadings performs iteration over all cached models.MetricReadings records. allowing to `pop` them on fly.
Types ¶
type ReadingsCacheIteratorFunc ¶
type ReadingsCacheIteratorFunc func(key string, record models.MetricReadings) (toBreak bool, err error)
ReadingsCacheIteratorFunc defines function called by sensor readings cache iterator.
Source Files
Click to show internal directories.
Click to hide internal directories.