timeseries

type Consumer struct {
	Log  *zap.Logger
	Repo TimeseriesRepo
}

type DataPoint struct {
	DeviceID  string
	MessageID uint64
	Property  string
	Timestamp time.Time
	Value     float64
	Length    float32
}

type TimeseriesRepo interface {
	CreateDataPoint(ctx context.Context, datapoint *DataPoint) error
	ReadExistingDatapoint(ctx context.Context, deviceID string) (float32, error)
}