Skip to content

Commit b854969

Browse files
committed
etcdmain: simplify proxy start logic
1 parent 58b171b commit b854969

File tree

2 files changed

+16
-15
lines changed

2 files changed

+16
-15
lines changed

etcdmain/etcd.go

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -141,8 +141,8 @@ func init() {
141141

142142
func Main() {
143143
fs.Usage = flags.UsageWithIgnoredFlagsFunc(fs, ignored)
144-
err := fs.Parse(os.Args[1:])
145-
switch err {
144+
perr := fs.Parse(os.Args[1:])
145+
switch perr {
146146
case nil:
147147
case flag.ErrHelp:
148148
os.Exit(0)
@@ -157,20 +157,20 @@ func Main() {
157157

158158
flags.SetFlagsFromEnv(fs)
159159

160-
if proxyFlag.String() == proxyFlagOff {
161-
if err := startEtcd(); err == nil {
162-
// Block indefinitely
163-
<-make(chan struct{})
164-
} else {
165-
if err == discovery.ErrFullCluster && fallbackFlag.String() == fallbackFlagProxy {
166-
fmt.Printf("etcd: discovery cluster full, falling back to %s", fallbackFlagProxy)
167-
} else {
168-
log.Fatalf("etcd: %v", err)
169-
}
160+
var err error
161+
shouldProxy := proxyFlag.String() != proxyFlagOff
162+
if !shouldProxy {
163+
err = startEtcd()
164+
if err == discovery.ErrFullCluster && fallbackFlag.String() == fallbackFlagProxy {
165+
log.Printf("etcd: discovery cluster full, falling back to %s", fallbackFlagProxy)
166+
shouldProxy = true
170167
}
171168
}
172-
if err = startProxy(); err != nil {
173-
log.Fatalf("proxy: %v", err)
169+
if shouldProxy {
170+
err = startProxy()
171+
}
172+
if err != nil {
173+
log.Fatalf("etcd: %v", err)
174174
}
175175
// Block indefinitely
176176
<-make(chan struct{})

hack/insta-discovery/discovery

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
#!/bin/sh
22

3-
disc=$(curl https://discovery.etcd.io/new?size=3)
3+
rm -rf infra*.etcd
4+
disc=$(curl -s https://discovery.etcd.io/new?size=3)
45
echo ETCD_DISCOVERY=${disc} > .env
56
echo "setup discovery start your cluster"
67
cat .env

0 commit comments

Comments
 (0)