Function CallbackWithInterval

pkg/telemetry/exporter/task_queue.go:67–75

CallbackWithInterval is a wrapper that takes a task.Func and a time.Duration and returns a TaskCallback.

(_ context.Context, interval time.Duration, callback task.Func)

// CallbackWithInterval is a wrapper that takes a task.Func and a time.Duration and returns a TaskCallback.
func CallbackWithInterval(_ context.Context, interval time.Duration, callback task.Func) TaskCallback {
	return func(ctx context.Context) (time.Time, error) {
		t := time.Now().Add(interval)
		if err := callback(ctx); err != nil {
			return t, err
		}
		return t, nil
	}
}

// NewRedisTaskQueue returns new telemetry task queue.
func NewRedisTaskQueue(