···

       
49
       
49
       
 
       
# This uses time.ParseDuration semantics

     

       
50
       
50
       
 
       
retention_period = "720h"

     

       
51
       
51
       
 
       


     

       
52
       
52
       
-
       
[cache]

     

       
53
       
53
       
-
       
# The maximum number of items to store in the cache.

     

       
54
       
54
       
-
       
max_items = 5000

     

       
55
       
55
       
-
       


     

       
56
       
56
       
-
       
# How often the cache will evict items.

     

       
57
       
57
       
-
       
cleanup_interval = "5m"

     

       
58
       
58
       
-
       


     

       
59
       
52
       
 
       
[advanced]

     

       
60
       
53
       
 
       
# Timeout (in milliseconds) for outgoing queries before being cancelled.

     

       
61
       
54
       
 
       
query_timeout = 100

     

···

       
4
       
4
       
 
       
	"fmt"

     

       
5
       
5
       
 
       
	"os"

     

       
6
       
6
       
 
       
	"slices"

     

       
7
       
7
       
-
       
	"strings"

     

       
8
       
7
       
 
       
	"time"

     

       
9
       
8
       
 
       


     

       
10
       
9
       
 
       
	"github.com/BurntSushi/toml"

     

···

       
5
       
5
       
 
       
	"fmt"

     

       
6
       
6
       
 
       
	"log/slog"

     

       
7
       
7
       
 
       
	"net"

     

       
8
       
8
       
-
       
	"strings"

     

       
9
       
8
       
 
       
	"time"

     

       
10
       
9
       
 
       


     

       
11
       
10
       
 
       
	"tangled.sh/seiso.moe/magna"

     
···

       
61
       
60
       
 
       
func (h *QueryHandler) resolveQuestion(ctx context.Context, question magna.Question, servers []string) ([]magna.ResourceRecord, error) {

     

       
62
       
61
       
 
       
	ch := make(chan queryResponse, len(servers))

     

       
63
       
62
       
 
       


     

       
64
       
64
       
-
       
	labels = strings.Split(question.QName, ".")

     

       
65
       
65
       
-
       


     

       
66
       
66
       
-
       
	for label in 		

     

       
67
       
63
       
 
       
	for _, s := range servers {

     

       
68
       
64
       
 
       
		go queryServer(ctx, question, s, ch, h.Timeout)

     

       
69
       
65
       
 
       
	}

     

···

       
55
       
55
       
 
       


     

       
56
       
56
       
 
       
			if r.Message != nil && len(r.Message.Question) > 0 {

     

       
57
       
57
       
 
       
				question := r.Message.Question[0]

     

       
58
       
58
       
-
       
				cacheHit := dns.GetCacheHit(r.Context)

     

       
59
       
58
       
 
       


     

       
60
       
59
       
 
       
				metrics.RecordQuery(QueryMetric{

     

       
61
       
60
       
 
       
					Timestamp:    start,

     
···

       
66
       
65
       
 
       
					RemoteAddr:   r.RemoteAddr.String(),

     

       
67
       
66
       
 
       
					ResponseCode: r.Message.Header.RCode.String(),

     

       
68
       
67
       
 
       
					Duration:     duration.Nanoseconds(),

     

       
69
       
69
       
-
       
					CacheHit:     cacheHit,

     

       
70
       
68
       
 
       
				})

     

       
71
       
69
       
 
       
			} else {

     

       
72
       
70
       
 
       
				slog := slog.Default()