Function NewRequestTracker

pkg/util/request_tracker/request_tracker.go:126–158

(localStoragePath string, fileName string, maxConcurrent int, logger *slog.Logger)

}

func NewRequestTracker(localStoragePath string, fileName string, maxConcurrent int, logger *slog.Logger) *RequestTracker {
	if localStoragePath == "" {
		return nil
	}

	err := os.MkdirAll(localStoragePath, 0o777)
	if err != nil {
		logger.Error("Failed to create directory for logging active requests")
		return nil
	}

	filename, filesize := filepath.Join(localStoragePath, fileName), 1+maxConcurrent*maxEntrySize
	logUnfinishedRequests(filename, filesize, logger)

	fileAsBytes, closer, err := getRequestMMappedFile(filename, filesize, logger)
	if err != nil {
		logger.Error("Unable to create mmap-ed active request log", "err", err)
		return nil
	}

	copy(fileAsBytes, "[")
	requestTracker := &RequestTracker{
		mmappedFile:   fileAsBytes,
		closer:        closer,
		getNextIndex:  make(chan int, maxConcurrent),
		logger:        logger,
		maxConcurrent: maxConcurrent,
	}

	requestTracker.generateIndices(maxConcurrent)

	return requestTracker
}

func (tracker *RequestTracker) generateIndices(maxConcurrent int) {
	for i := range maxConcurrent {