From 468bfedf3418ec8170c493918515e09bad833f74 Mon Sep 17 00:00:00 2001 From: Cong Ding Date: Thu, 12 Dec 2013 14:53:22 -0800 Subject: [PATCH] gofmt --- server/config.go | 4 ++-- server/cors_handler.go | 4 +--- server/peer_server.go | 36 ++++++++++++++++++------------------ tests/server_utils.go | 4 ++-- 4 files changed, 23 insertions(+), 25 deletions(-) diff --git a/server/config.go b/server/config.go index c645da173..6b0751885 100644 --- a/server/config.go +++ b/server/config.go @@ -13,8 +13,8 @@ import ( "strconv" "strings" - "github.com/coreos/etcd/log" "github.com/BurntSushi/toml" + "github.com/coreos/etcd/log" ) // The default location for the etcd configuration file. @@ -69,7 +69,7 @@ type Config struct { VeryVerbose bool `toml:"very_verbose" env:"ETCD_VERY_VERBOSE"` HeartbeatTimeout int `toml:"peer_heartbeat_timeout" env:"ETCD_PEER_HEARTBEAT_TIMEOUT"` ElectionTimeout int `toml:"peer_election_timeout" env:"ETCD_PEER_ELECTION_TIMEOUT"` - Peer struct { + Peer struct { Addr string `toml:"addr" env:"ETCD_PEER_ADDR"` BindAddr string `toml:"bind_addr" env:"ETCD_PEER_BIND_ADDR"` CAFile string `toml:"ca_file" env:"ETCD_PEER_CA_FILE"` diff --git a/server/cors_handler.go b/server/cors_handler.go index 89af218f6..fec3c4abc 100644 --- a/server/cors_handler.go +++ b/server/cors_handler.go @@ -25,7 +25,7 @@ import ( ) type corsHandler struct { - router *mux.Router + router *mux.Router corsOrigins map[string]bool } @@ -74,5 +74,3 @@ func (h *corsHandler) ServeHTTP(w http.ResponseWriter, req *http.Request) { h.router.ServeHTTP(w, req) } - - diff --git a/server/peer_server.go b/server/peer_server.go index 4670e602f..2a903a2a0 100644 --- a/server/peer_server.go +++ b/server/peer_server.go @@ -23,23 +23,23 @@ import ( const retryInterval = 10 type PeerServer struct { - raftServer raft.Server - server *Server - httpServer *http.Server - listener net.Listener - joinIndex uint64 - name string - url string - bindAddr string - tlsConf *TLSConfig - tlsInfo *TLSInfo - followersStats *raftFollowersStats - serverStats *raftServerStats - registry *Registry - store store.Store - snapConf *snapshotConf - MaxClusterSize int - RetryTimes int + raftServer raft.Server + server *Server + httpServer *http.Server + listener net.Listener + joinIndex uint64 + name string + url string + bindAddr string + tlsConf *TLSConfig + tlsInfo *TLSInfo + followersStats *raftFollowersStats + serverStats *raftServerStats + registry *Registry + store store.Store + snapConf *snapshotConf + MaxClusterSize int + RetryTimes int HeartbeatTimeout time.Duration ElectionTimeout time.Duration } @@ -81,7 +81,7 @@ func NewPeerServer(name string, path string, url string, bindAddr string, tlsCon }, }, HeartbeatTimeout: defaultHeartbeatTimeout, - ElectionTimeout: defaultElectionTimeout, + ElectionTimeout: defaultElectionTimeout, } // Create transporter for raft diff --git a/tests/server_utils.go b/tests/server_utils.go index 496f8af4b..c396ed877 100644 --- a/tests/server_utils.go +++ b/tests/server_utils.go @@ -26,11 +26,11 @@ func RunServer(f func(*server.Server)) { store := store.New() registry := server.NewRegistry(store) - ps := server.NewPeerServer(testName, path, "http://" + testRaftURL, testRaftURL, &server.TLSConfig{Scheme: "http"}, &server.TLSInfo{}, registry, store, testSnapshotCount) + ps := server.NewPeerServer(testName, path, "http://"+testRaftURL, testRaftURL, &server.TLSConfig{Scheme: "http"}, &server.TLSInfo{}, registry, store, testSnapshotCount) ps.MaxClusterSize = 9 ps.ElectionTimeout = testElectionTimeout ps.HeartbeatTimeout = testHeartbeatTimeout - s := server.New(testName, "http://" + testClientURL, testClientURL, &server.TLSConfig{Scheme: "http"}, &server.TLSInfo{}, ps, registry, store) + s := server.New(testName, "http://"+testClientURL, testClientURL, &server.TLSConfig{Scheme: "http"}, &server.TLSInfo{}, ps, registry, store) ps.SetServer(s) // Start up peer server.