chore(updater): rename presolver to parallelResolver

This commit is contained in:
Quentin McGaw
2022-06-11 20:12:35 +00:00
parent 33b8f5f596
commit 45c9e780c0
30 changed files with 108 additions and 108 deletions

View File

@@ -39,7 +39,7 @@ func (u *Updater) FetchServers(ctx context.Context, minServers int) (
}
resolveSettings := parallelResolverSettings(hosts)
hostToIPs, warnings, err := u.presolver.Resolve(ctx, resolveSettings)
hostToIPs, warnings, err := u.parallelResolver.Resolve(ctx, resolveSettings)
for _, warning := range warnings {
u.warner.Warn(warning)
}

View File

@@ -150,18 +150,18 @@ func Test_Updater_GetServers(t *testing.T) {
}),
}
presolver := common.NewMockParallelResolver(ctrl)
parallelResolver := common.NewMockParallelResolver(ctrl)
if testCase.expectResolve {
presolver.EXPECT().Resolve(ctx, testCase.resolveSettings).
parallelResolver.EXPECT().Resolve(ctx, testCase.resolveSettings).
Return(testCase.hostToIPs, testCase.resolveWarnings, testCase.resolveErr)
}
warner := testCase.warnerBuilder(ctrl)
updater := &Updater{
client: client,
presolver: presolver,
warner: warner,
client: client,
parallelResolver: parallelResolver,
warner: warner,
}
servers, err := updater.FetchServers(ctx, testCase.minServers)

View File

@@ -7,16 +7,16 @@ import (
)
type Updater struct {
client *http.Client
presolver common.ParallelResolver
warner common.Warner
client *http.Client
parallelResolver common.ParallelResolver
warner common.Warner
}
func New(client *http.Client, warner common.Warner,
parallelResolver common.ParallelResolver) *Updater {
return &Updater{
client: client,
presolver: parallelResolver,
warner: warner,
client: client,
parallelResolver: parallelResolver,
warner: warner,
}
}