mirror of
https://github.com/amir20/dozzle.git
synced 2025-12-24 14:31:44 +01:00
fix: fixes search while looking back history (#3256)
This commit is contained in:
@@ -107,7 +107,7 @@ func (h *handler) fetchLogsBetweenDates(w http.ResponseWriter, r *http.Request)
|
||||
}
|
||||
|
||||
buffer := utils.NewRingBuffer[*docker.LogEvent](500)
|
||||
delta := to.Sub(from)
|
||||
delta := max(to.Sub(from), time.Second*3)
|
||||
|
||||
var regex *regexp.Regexp
|
||||
if r.URL.Query().Has("filter") {
|
||||
@@ -156,14 +156,17 @@ func (h *handler) fetchLogsBetweenDates(w http.ResponseWriter, r *http.Request)
|
||||
}
|
||||
}
|
||||
|
||||
from = from.Add(-delta)
|
||||
delta = delta * 2
|
||||
|
||||
if from.Before(containerService.Container.Created) {
|
||||
log.Debug().Msg("reached beginning of logs")
|
||||
break
|
||||
}
|
||||
|
||||
from = from.Add(-delta)
|
||||
delta = delta * 2
|
||||
}
|
||||
|
||||
log.Debug().Int("buffer_size", buffer.Len()).Msg("sending logs to client")
|
||||
|
||||
encoder := json.NewEncoder(w)
|
||||
for _, event := range buffer.Data() {
|
||||
if err := encoder.Encode(event); err != nil {
|
||||
|
||||
Reference in New Issue
Block a user