| 1083 | } |
| 1084 | |
| 1085 | func (epc *EtcdProcessCluster) Close() error { |
| 1086 | epc.lg.Info("closing test cluster...") |
| 1087 | err := epc.Stop() |
| 1088 | for _, p := range epc.Procs { |
| 1089 | // p is nil when NewEtcdProcess fails in the middle |
| 1090 | // Close still gets called to clean up test data |
| 1091 | if p == nil { |
| 1092 | continue |
| 1093 | } |
| 1094 | if cerr := p.Close(); cerr != nil { |
| 1095 | err = cerr |
| 1096 | } |
| 1097 | } |
| 1098 | epc.lg.Info("closed test cluster.") |
| 1099 | return err |
| 1100 | } |
| 1101 | |
| 1102 | func findMemberIDByEndpoint(members []*etcdserverpb.Member, endpoint string) (uint64, error) { |
| 1103 | for _, m := range members { |