cache/updater_test.go

Rama main · réplica de lectura del repositorio original.

package cache

import (
	"fmt"
	"testing"
	"time"

	"github.com/coroot/coroot/timeseries"
	"github.com/stretchr/testify/assert"
)

func TestCacheUpdater_calcIntervals(t *testing.T) {
	scrapeInterval := 30 * timeseries.Second
	jitter := 12 * timeseries.Minute

	ts := func(s string) timeseries.Time {
		if s == "" {
			return 0
		}
		res, err := time.Parse("2006-01-02T15:04:05", s)
		assert.NoError(t, err)
		return timeseries.Time(res.Unix())
	}

	calc := func(lastSaved, now string) string {
		return fmt.Sprintf(`%s`, calcIntervals(ts(lastSaved), scrapeInterval, ts(now), jitter))
	}

	assert.Equal(t, // initial fetching
		"[(2020-11-13T09:42:00 2020-11-13T09:51:30) (2020-11-13T09:52:00 2020-11-13T10:01:30) (2020-11-13T10:02:00 2020-11-13T10:11:30) (2020-11-13T10:12:00 2020-11-13T10:21:30) (2020-11-13T10:22:00 2020-11-13T10:31:30) (2020-11-13T10:32:00 2020-11-13T10:41:30) (2020-11-13T10:42:00 2020-11-13T10:51:30) (2020-11-13T10:52:00 2020-11-13T11:01:30) (2020-11-13T11:02:00 2020-11-13T11:11:30) (2020-11-13T11:12:00 2020-11-13T11:21:30) (2020-11-13T11:22:00 2020-11-13T11:31:30) (2020-11-13T11:32:00 2020-11-13T11:41:30) (2020-11-13T11:42:00 2020-11-13T11:48:30)]",
		calc("2020-11-13T09:49:11", "2020-11-13T11:49:11"),
	)
	assert.Equal(t, // two new points
		"[(2020-11-13T11:42:00 2020-11-13T11:49:30)]",
		calc("2020-11-13T11:48:30", "2020-11-13T11:50:11"),
	)
	assert.Equal(t, // skipped more than two chunk intervals
		"[(2020-11-13T11:42:00 2020-11-13T11:51:30) (2020-11-13T11:52:00 2020-11-13T12:01:30) (2020-11-13T12:02:00 2020-11-13T12:11:30) (2020-11-13T12:12:00 2020-11-13T12:21:30) (2020-11-13T12:22:00 2020-11-13T12:31:30) (2020-11-13T12:32:00 2020-11-13T12:41:30) (2020-11-13T12:42:00 2020-11-13T12:51:30) (2020-11-13T12:52:00 2020-11-13T13:01:30) (2020-11-13T13:02:00 2020-11-13T13:11:30) (2020-11-13T13:12:00 2020-11-13T13:21:30) (2020-11-13T13:22:00 2020-11-13T13:31:30) (2020-11-13T13:32:00 2020-11-13T13:41:30) (2020-11-13T13:42:00 2020-11-13T13:48:30)]",
		calc("2020-11-13T11:50:00", "2020-11-13T13:49:11"),
	)
	assert.Equal(t, // one new point
		"[(2020-11-13T12:12:00 2020-11-13T12:12:30)]",
		calc("2020-11-13T12:12:00", "2020-11-13T12:13:05"),
	)
	assert.Equal(t, // two new points
		"[(2020-11-13T12:12:00 2020-11-13T12:12:30)]",
		calc("2020-11-13T12:11:30", "2020-11-13T12:13:05"),
	)
	assert.Equal(t, // re-fetch finished chunk
		"[(2020-11-13T12:02:00 2020-11-13T12:11:30)]",
		calc("2020-11-13T12:11:00", "2020-11-13T12:12:05"),
	)
	assert.Equal(t, // re-fetch finished chunk and one new point
		"[(2020-11-13T12:02:00 2020-11-13T12:11:30) (2020-11-13T12:12:00 2020-11-13T12:12:00)]",
		calc("2020-11-13T12:11:00", "2020-11-13T12:12:35"),
	)
	assert.Equal(t, // re-fetch finished chunk and two new points
		"[(2020-11-13T12:02:00 2020-11-13T12:11:30) (2020-11-13T12:12:00 2020-11-13T12:12:30)]",
		calc("2020-11-13T12:11:00", "2020-11-13T12:13:05"),
	)
	assert.Equal(t, // too early - nothing to do
		"[]",
		calc("2020-11-13T12:11:30", "2020-11-13T12:12:25"),
	)

	scrapeInterval = 2 * timeseries.Minute
	jitter = 11 * timeseries.Minute
	assert.Equal(t,
		"[(2020-11-13T09:50:00 2020-11-13T09:58:00) (2020-11-13T10:00:00 2020-11-13T10:08:00) (2020-11-13T10:10:00 2020-11-13T10:18:00) (2020-11-13T10:20:00 2020-11-13T10:28:00) (2020-11-13T10:30:00 2020-11-13T10:38:00) (2020-11-13T10:40:00 2020-11-13T10:48:00) (2020-11-13T10:50:00 2020-11-13T10:58:00) (2020-11-13T11:00:00 2020-11-13T11:08:00) (2020-11-13T11:10:00 2020-11-13T11:18:00) (2020-11-13T11:20:00 2020-11-13T11:28:00) (2020-11-13T11:30:00 2020-11-13T11:38:00) (2020-11-13T11:40:00 2020-11-13T11:46:00)]",
		calc("2020-11-13T09:49:11", "2020-11-13T11:49:11"),
	)

	scrapeInterval = 5 * timeseries.Minute
	jitter = 11 * timeseries.Minute
	assert.Equal(t,
		"[(2020-11-13T09:50:00 2020-11-13T09:55:00) (2020-11-13T10:00:00 2020-11-13T10:05:00) (2020-11-13T10:10:00 2020-11-13T10:15:00) (2020-11-13T10:20:00 2020-11-13T10:25:00) (2020-11-13T10:30:00 2020-11-13T10:35:00) (2020-11-13T10:40:00 2020-11-13T10:45:00) (2020-11-13T10:50:00 2020-11-13T10:55:00) (2020-11-13T11:00:00 2020-11-13T11:05:00) (2020-11-13T11:10:00 2020-11-13T11:15:00) (2020-11-13T11:20:00 2020-11-13T11:25:00) (2020-11-13T11:30:00 2020-11-13T11:35:00) (2020-11-13T11:40:00 2020-11-13T11:40:00)]",
		calc("2020-11-13T09:49:11", "2020-11-13T11:49:11"),
	)
}