storage

Documentation

Index

• func CacheReadings(readings ...models.MetricReadings) (err error)
• func IterateOverCachedReadings(ctx context.Context, fn ReadingsCacheIteratorFunc, pop bool)
• type ReadingsCacheIteratorFunc

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.