sour-is/xt
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add-otel #3

Merged
xuu merged 13 commits from add-otel into main 2025-03-26 20:49:42 -06:00
Conversation 0 Commits 13 Files Changed 16 +6 -4
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 8ae61d4a27 - Show all commits

4
http.go
View File

@ -153,10 +153,10 @@ func httpServer(c *console, app *appState) error {
http.HandleFunc("/queue", func(w http.ResponseWriter, r *http.Request) { http.HandleFunc("/queue", func(w http.ResponseWriter, r *http.Request) {
lis := slices.Collect(app.queue.Iter()) lis := slices.Collect(app.queue.Iter())
sort.Slice(lis, func(i, j int) bool { sort.Slice(lis, func(i, j int) bool {
return lis[i].LastScanOn.Time.Before(lis[j].LastScanOn.Time) return lis[i].NextScanOn.Time.Before(lis[j].LastScanOn.Time)
}) })
for _, feed := range lis { for _, feed := range lis {
fmt.Fprintln(w, feed.State, feed.LastScanOn.Time.Format(time.RFC3339), feed.Nick, feed.URI) fmt.Fprintln(w, feed.State, feed.NextScanOn.Time.Format(time.RFC3339), feed.Nick, feed.URI)
} }
}) })

6
refresh-loop.go
View File

@ -91,12 +91,14 @@ func feedRefreshProcessor(c *console, app *appState) error {
continue continue
} }
span.AddEvent(
"till next",
trace.WithAttributes(attribute.String("time", until.String())))
sleeping_time.Add(ctx, until.Milliseconds()) sleeping_time.Add(ctx, until.Milliseconds())
select { select {
case <-ctx.Done(): case <-ctx.Done():
return nil return nil
case t := <-time.After(time.Until(f.NextScanOn.Time)): case t := <-time.After(until):
span.AddEvent("fetch", trace.WithAttributes( span.AddEvent("fetch", trace.WithAttributes(
attribute.Int("size", int(queue.count)), attribute.Int("size", int(queue.count)),
attribute.String("uri", f.URI), attribute.String("uri", f.URI),