From ea0eab84a425f2fd1f9d3fe77ffafdfe9a42fce3 Mon Sep 17 00:00:00 2001 From: davygeek Date: Thu, 30 Jun 2016 22:00:01 +0800 Subject: [PATCH] discovery: Uniform code style --- discovery/discovery.go | 2 +- discovery/discovery_test.go | 6 +++--- discovery/srv.go | 12 +++++++----- 3 files changed, 11 insertions(+), 9 deletions(-) diff --git a/discovery/discovery.go b/discovery/discovery.go index d53c46114..3c06d3c7c 100644 --- a/discovery/discovery.go +++ b/discovery/discovery.go @@ -243,7 +243,7 @@ func (d *discovery) checkCluster() ([]*client.Node, int, uint64, error) { } return nil, 0, 0, err } - nodes := make([]*client.Node, 0) + var nodes []*client.Node // append non-config keys to nodes for _, n := range resp.Node.Nodes { if !(path.Base(n.Key) == path.Base(configKey)) { diff --git a/discovery/discovery_test.go b/discovery/discovery_test.go index 683914084..bf0636af8 100644 --- a/discovery/discovery_test.go +++ b/discovery/discovery_test.go @@ -182,7 +182,7 @@ func TestCheckCluster(t *testing.T) { } for i, tt := range tests { - rs := make([]*client.Response, 0) + var rs []*client.Response if len(tt.nodes) > 0 { rs = append(rs, &client.Response{Node: tt.nodes[0], Index: tt.index}) rs = append(rs, &client.Response{ @@ -267,7 +267,7 @@ func TestWaitNodes(t *testing.T) { dBase := &discovery{cluster: "1000", c: c} // Retry case - retryScanResp := make([]*client.Response, 0) + var retryScanResp []*client.Response if len(tt.nodes) > 0 { retryScanResp = append(retryScanResp, &client.Response{ Node: &client.Node{ @@ -406,7 +406,7 @@ func TestSortableNodes(t *testing.T) { } sns := sortableNodes{ns} sort.Sort(sns) - cis := make([]int, 0) + var cis []int for _, n := range sns.Nodes { cis = append(cis, int(n.CreatedIndex)) } diff --git a/discovery/srv.go b/discovery/srv.go index 4dab35669..34884ddcb 100644 --- a/discovery/srv.go +++ b/discovery/srv.go @@ -33,9 +33,11 @@ var ( // Also doesn't do any lookups for the token (though it could) // Also sees each entry as a separate instance. func SRVGetCluster(name, dns string, defaultToken string, apurls types.URLs) (string, string, error) { - stringParts := make([]string, 0) + var ( + stringParts []string + tcpAPUrls []string + ) tempName := int(0) - tcpAPUrls := make([]string, 0) // First, resolve the apurls for _, url := range apurls { @@ -68,7 +70,7 @@ func SRVGetCluster(name, dns string, defaultToken string, apurls types.URLs) (st } if n == "" { n = fmt.Sprintf("%d", tempName) - tempName += 1 + tempName++ } stringParts = append(stringParts, fmt.Sprintf("%s=%s%s", n, prefix, host)) plog.Noticef("got bootstrap from DNS for %s at %s%s", service, prefix, host) @@ -81,12 +83,12 @@ func SRVGetCluster(name, dns string, defaultToken string, apurls types.URLs) (st srvErr := make([]string, 2) if err != nil { srvErr[0] = fmt.Sprintf("error querying DNS SRV records for _etcd-server-ssl %s", err) - failCount += 1 + failCount++ } err = updateNodeMap("etcd-server", "http://") if err != nil { srvErr[1] = fmt.Sprintf("error querying DNS SRV records for _etcd-server %s", err) - failCount += 1 + failCount++ } if failCount == 2 { plog.Warningf(srvErr[0])