storage

package

v0.0.0-...-a6d84cd Latest Latest Go to latest Published: Feb 8, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func AddRows(mrs model.MetricRows) error

AddRows adds mrs to the storage.

func FlushVolatileDataPoints() error

FlushVolatileDataPoints runs a loop of flushing data points from MemStore to DiskStore.

func Init()

Init creates a storage client.

func RunMemWriter(num int)

func StreamVolatileDataPoints() error

StreamVolatileDataPoints streams volatile datapoints to reliable stream.

func SubmitMemWriter(mrs model.MetricRows) error

type Storage struct {
	Memstore *redis.Redis
}

var Store *Storage