Function assertAuthority

tests/integration/grpc_test.go:162–181

(t *testing.T, expectedAuthorityPattern string, clus *integration.Cluster, filterMethod string)

}

func assertAuthority(t *testing.T, expectedAuthorityPattern string, clus *integration.Cluster, filterMethod string) {
	t.Helper()
	for _, m := range clus.Members {
		requestsFound := 0
		expectedAuthority := templateAuthority(t, expectedAuthorityPattern, m)
		for _, r := range m.RecordedRequests() {
			if filterMethod != "" && r.FullMethod != filterMethod {
				continue
			}
			if r.Authority == expectedAuthority {
				requestsFound++
			} else {
				t.Errorf("Got unexpected authority header, member: %q, request: %q, got authority: %q, expected %q", m.Name, r.FullMethod, r.Authority, expectedAuthority)
			}
		}
		if requestsFound == 0 {
			t.Errorf("Expect at least one request with matched authority header value was recorded by the server intercepter on member %s but got 0", m.Name)
		}
	}
}