Skip to content

Commit

Permalink
Revert "grpc: Canonicalize string returned by ClientConn.Target() and…
Browse files Browse the repository at this point in the history
… resolver.Address.String() (grpc#6923)"

This reverts commit 3ae77e6.
  • Loading branch information
arvindbr8 committed Feb 28, 2024
1 parent eb08be4 commit 586a39d
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 41 deletions.
5 changes: 3 additions & 2 deletions clientconn.go
Expand Up @@ -883,14 +883,14 @@ func (cc *ClientConn) channelzMetric() *channelz.ChannelInternalMetric {
}
}

// Target returns the canonical target string of the ClientConn.
// Target returns the target string of the ClientConn.
//
// # Experimental
//
// Notice: This API is EXPERIMENTAL and may be changed or removed in a
// later release.
func (cc *ClientConn) Target() string {
return cc.parsedTarget.String()
return cc.target
}

func (cc *ClientConn) incrCallsStarted() {
Expand Down Expand Up @@ -1744,6 +1744,7 @@ func (cc *ClientConn) parseTargetAndFindResolver() error {
defScheme := resolver.GetDefaultScheme()
channelz.Infof(logger, cc.channelzID, "fallback to scheme %q", defScheme)
canonicalTarget := defScheme + ":///" + cc.target

parsedTarget, err = parseTarget(canonicalTarget)
if err != nil {
channelz.Infof(logger, cc.channelzID, "dial target %q parse failed: %v", canonicalTarget, err)
Expand Down
45 changes: 8 additions & 37 deletions clientconn_test.go
Expand Up @@ -808,44 +808,15 @@ func (s) TestMethodConfigDefaultService(t *testing.T) {
}
}

func (s) TestClientConn_Target(t *testing.T) {
tests := []struct {
name string
addr string
targetWant string
}{
{
name: "normal-case",
addr: "dns://a.server.com/google.com",
targetWant: "dns://a.server.com/google.com",
},
{
name: "canonical-target-not-specified",
addr: "no.scheme",
targetWant: "passthrough:///no.scheme",
},
{
name: "canonical-target-nonexistent",
addr: "nonexist:///non.existent",
targetWant: "passthrough:///nonexist:///non.existent",
},
{
name: "canonical-target-add-colon-slash",
addr: "dns:hostname:port",
targetWant: "dns:///hostname:port",
},
func (s) TestGetClientConnTarget(t *testing.T) {
addr := "nonexist:///non.existent"
cc, err := Dial(addr, WithTransportCredentials(insecure.NewCredentials()))
if err != nil {
t.Fatalf("Dial(%s, _) = _, %v, want _, <nil>", addr, err)
}
for _, test := range tests {
t.Run(test.name, func(t *testing.T) {
cc, err := Dial(test.addr, WithTransportCredentials(insecure.NewCredentials()))
if err != nil {
t.Fatalf("Dial(%s, _) = _, %v, want _, <nil>", test.addr, err)
}
defer cc.Close()
if cc.Target() != test.targetWant {
t.Fatalf("Target() = %s, want %s", cc.Target(), test.targetWant)
}
})
defer cc.Close()
if cc.Target() != addr {
t.Fatalf("Target() = %s, want %s", cc.Target(), addr)
}
}

Expand Down
4 changes: 2 additions & 2 deletions resolver/resolver.go
Expand Up @@ -281,9 +281,9 @@ func (t Target) Endpoint() string {
return strings.TrimPrefix(endpoint, "/")
}

// String returns the canonical string representation of Target.
// String returns a string representation of Target.
func (t Target) String() string {
return t.URL.Scheme + "://" + t.URL.Host + "/" + t.Endpoint()
return t.URL.String()
}

// Builder creates a resolver that will be used to watch name resolution updates.
Expand Down

0 comments on commit 586a39d

Please sign in to comment.