Skip to content

Commit

Permalink
Add util function for BackendConfig
Browse files Browse the repository at this point in the history
Signed-off-by: Dimitar Dimitrov <[email protected]>
  • Loading branch information
dimitarvdimitrov committed Dec 6, 2024
1 parent 9533198 commit 44c8d42
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 8 deletions.
6 changes: 5 additions & 1 deletion tools/querytee/proxy_backend_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,7 +84,7 @@ func Test_ProxyBackend_createBackendRequest_HTTPBasicAuthentication(t *testing.T
orig.Header.Set("X-Scope-OrgID", testData.clientTenant)
}

b := NewProxyBackend("test", u, time.Second, false, false, BackendConfig{})
b := NewProxyBackend("test", u, time.Second, false, false, defaultBackendConfig())
bp, ok := b.(*ProxyBackend)
if !ok {
t.Fatalf("Type assertion to *ProxyBackend failed")
Expand All @@ -98,3 +98,7 @@ func Test_ProxyBackend_createBackendRequest_HTTPBasicAuthentication(t *testing.T
})
}
}

func defaultBackendConfig() BackendConfig {
return BackendConfig{}
}
14 changes: 7 additions & 7 deletions tools/querytee/proxy_endpoint_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,9 @@ func Test_ProxyEndpoint_waitBackendResponseForDownstream(t *testing.T) {
backendURL3, err := url.Parse("http://backend-3/")
require.NoError(t, err)

backendPref := NewProxyBackend("backend-1", backendURL1, time.Second, true, false, BackendConfig{})
backendOther1 := NewProxyBackend("backend-2", backendURL2, time.Second, false, false, BackendConfig{})
backendOther2 := NewProxyBackend("backend-3", backendURL3, time.Second, false, false, BackendConfig{})
backendPref := NewProxyBackend("backend-1", backendURL1, time.Second, true, false, defaultBackendConfig())
backendOther1 := NewProxyBackend("backend-2", backendURL2, time.Second, false, false, defaultBackendConfig())
backendOther2 := NewProxyBackend("backend-3", backendURL3, time.Second, false, false, defaultBackendConfig())

tests := map[string]struct {
backends []ProxyBackendInterface
Expand Down Expand Up @@ -157,8 +157,8 @@ func Test_ProxyEndpoint_Requests(t *testing.T) {
require.NoError(t, err)

backends := []ProxyBackendInterface{
NewProxyBackend("backend-1", backendURL1, time.Second, true, false, BackendConfig{}),
NewProxyBackend("backend-2", backendURL2, time.Second, false, false, BackendConfig{}),
NewProxyBackend("backend-1", backendURL1, time.Second, true, false, defaultBackendConfig()),
NewProxyBackend("backend-2", backendURL2, time.Second, false, false, defaultBackendConfig()),
}
endpoint := NewProxyEndpoint(backends, testRoute, NewProxyMetrics(nil), log.NewNopLogger(), nil, 0, 1.0)

Expand Down Expand Up @@ -325,8 +325,8 @@ func Test_ProxyEndpoint_Comparison(t *testing.T) {
require.NoError(t, err)

backends := []ProxyBackendInterface{
NewProxyBackend("preferred-backend", preferredBackendURL, time.Second, true, false, BackendConfig{}),
NewProxyBackend("secondary-backend", secondaryBackendURL, time.Second, false, false, BackendConfig{}),
NewProxyBackend("preferred-backend", preferredBackendURL, time.Second, true, false, defaultBackendConfig()),
NewProxyBackend("secondary-backend", secondaryBackendURL, time.Second, false, false, defaultBackendConfig()),
}

logger := newMockLogger()
Expand Down

0 comments on commit 44c8d42

Please sign in to comment.