ClusterCockpit/cc-metric-store
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-store.git synced 2024-09-19 23:27:24 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add a firstWrite method

Browse Source
This commit is contained in:
Lou Knauer 2022-04-07 14:29:03 +02:00
parent 6c4c8bb3ea
commit db099605ec
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
memstore.go
View File

@ -98,7 +98,11 @@ func (b *buffer) write(ts int64, value Float) (*buffer, error) {
} }
func (b *buffer) end() int64 { func (b *buffer) end() int64 {
return b.start + int64(len(b.data))*b.frequency return b.firstWrite() + int64(len(b.data))*b.frequency
}
func (b *buffer) firstWrite() int64 {
return b.start + (b.frequency / 2)
} }
func (b *buffer) close() {} func (b *buffer) close() {}
@ -151,11 +155,11 @@ func (b *buffer) close() {
// The loaded values are added to `data` and `data` is returned, possibly with a shorter length. // The loaded values are added to `data` and `data` is returned, possibly with a shorter length.
// If `data` is not long enough to hold all values, this function will panic! // If `data` is not long enough to hold all values, this function will panic!
func (b *buffer) read(from, to int64, data []Float) ([]Float, int64, int64, error) { func (b *buffer) read(from, to int64, data []Float) ([]Float, int64, int64, error) {
if from < b.start { if from < b.firstWrite() {
if b.prev != nil { if b.prev != nil {
return b.prev.read(from, to, data) return b.prev.read(from, to, data)
} }
from = b.start from = b.firstWrite()
} }
var i int = 0 var i int = 0