Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 0 additions & 20 deletions internal/xds/resolver/helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -191,26 +191,6 @@ func verifyNoUpdateFromResolver(ctx context.Context, t *testing.T, stateCh chan
}
}

// waitForErrorFromResolver waits for the resolver to push an error and verifies
// that it matches the expected error and contains the expected node ID.
func waitForErrorFromResolver(ctx context.Context, errCh chan error, wantErr, wantNodeID string) error {
select {
case <-ctx.Done():
return fmt.Errorf("timeout when waiting for error to be propagated to the ClientConn")
case gotErr := <-errCh:
if gotErr == nil {
return fmt.Errorf("got nil error from resolver, want %q", wantErr)
}
if !strings.Contains(gotErr.Error(), wantErr) {
return fmt.Errorf("got error from resolver %q, want %q", gotErr, wantErr)
}
if !strings.Contains(gotErr.Error(), wantNodeID) {
return fmt.Errorf("got error from resolver %q, want nodeID %q", gotErr, wantNodeID)
}
}
return nil
}

func verifyResolverError(gotErr error, wantCode codes.Code, wantErr, wantNodeID string) error {
if gotErr == nil {
return fmt.Errorf("got nil error from resolver, want error with code %v", wantCode)
Expand Down
92 changes: 0 additions & 92 deletions internal/xds/resolver/watch_service.go

This file was deleted.

Loading
Loading