/ internal / memory / attached_querier_test.go
attached_querier_test.go
 1  package memory
 2  
 3  import (
 4  	"testing"
 5  	"time"
 6  )
 7  
 8  func TestAttachedQuerier_StatusAlwaysReady(t *testing.T) {
 9  	a := NewAttachedQuerier("/tmp/nonexistent.sock", 0)
10  	if a.Status() != StatusReady {
11  		t.Fatalf("status=%v want StatusReady", a.Status())
12  	}
13  }
14  
15  func TestAttachedQuerier_DefaultTimeout(t *testing.T) {
16  	a := NewAttachedQuerier("/tmp/x.sock", 0)
17  	if a.timeout != 5*time.Second {
18  		t.Fatalf("timeout=%v want 5s default", a.timeout)
19  	}
20  	a2 := NewAttachedQuerier("/tmp/y.sock", 2*time.Second)
21  	if a2.timeout != 2*time.Second {
22  		t.Fatalf("timeout=%v want 2s explicit", a2.timeout)
23  	}
24  }