Lines Matching refs:Member

45 		srv.Member = req.Member
92 			Member:  req.Member,
96 	err := fileutil.TouchDirAll(srv.Member.BaseDir)
100 	srv.lg.Info("created base directory", zap.String("path", srv.Member.BaseDir))
129 		Member:  srv.Member,
134 	if srv.Member.EtcdClientProxy {
135 …advertiseClientURL, advertiseClientURLPort, err := getURLAndPort(srv.Member.Etcd.AdvertiseClientUR…
139 		listenClientURL, _, err := getURLAndPort(srv.Member.Etcd.ListenClientURLs[0])
157 	if srv.Member.EtcdPeerProxy {
158 		advertisePeerURL, advertisePeerURLPort, err := getURLAndPort(srv.Member.Etcd.AdvertisePeerURLs[0])
162 		listenPeerURL, _, err := getURLAndPort(srv.Member.Etcd.ListenPeerURLs[0])
183 	if srv.Member.EtcdClientProxy && len(srv.advertiseClientPortToProxy) > 0 {
203 	if srv.Member.EtcdPeerProxy && len(srv.advertisePeerPortToProxy) > 0 {
227 	srv.etcdLogFile, err = os.Create(srv.Member.EtcdLogPath)
231 	srv.lg.Info("created etcd log file", zap.String("path", srv.Member.EtcdLogPath))
236 	etcdPath, etcdFlags := srv.Member.EtcdExecPath, srv.Member.Etcd.Flags()
238 		etcdFlags = srv.Member.EtcdOnSnapshotRestore.Flags()
240 	u, _ := url.Parse(srv.Member.FailpointHTTPAddr)
244 		zap.String("failpoint-http-addr", srv.Member.FailpointHTTPAddr),
256 	if srv.Member.PeerCertPath != "" {
257 		if srv.Member.PeerCertData == "" {
258 			return fmt.Errorf("got empty data for %q", srv.Member.PeerCertPath)
260 …if err := ioutil.WriteFile(srv.Member.PeerCertPath, []byte(srv.Member.PeerCertData), 0644); err !=…
264 	if srv.Member.PeerKeyPath != "" {
265 		if srv.Member.PeerKeyData == "" {
266 			return fmt.Errorf("got empty data for %q", srv.Member.PeerKeyPath)
268 …if err := ioutil.WriteFile(srv.Member.PeerKeyPath, []byte(srv.Member.PeerKeyData), 0644); err != n…
272 	if srv.Member.PeerTrustedCAPath != "" {
273 		if srv.Member.PeerTrustedCAData == "" {
274 			return fmt.Errorf("got empty data for %q", srv.Member.PeerTrustedCAPath)
276 …if err := ioutil.WriteFile(srv.Member.PeerTrustedCAPath, []byte(srv.Member.PeerTrustedCAData), 064…
280 	if srv.Member.PeerCertPath != "" &&
281 		srv.Member.PeerKeyPath != "" &&
282 		srv.Member.PeerTrustedCAPath != "" {
285 			zap.String("peer-cert", srv.Member.PeerCertPath),
286 			zap.String("peer-key", srv.Member.PeerKeyPath),
287 			zap.String("peer-trusted-ca", srv.Member.PeerTrustedCAPath),
291 	if srv.Member.ClientCertPath != "" {
292 		if srv.Member.ClientCertData == "" {
293 			return fmt.Errorf("got empty data for %q", srv.Member.ClientCertPath)
295 …if err := ioutil.WriteFile(srv.Member.ClientCertPath, []byte(srv.Member.ClientCertData), 0644); er…
299 	if srv.Member.ClientKeyPath != "" {
300 		if srv.Member.ClientKeyData == "" {
301 			return fmt.Errorf("got empty data for %q", srv.Member.ClientKeyPath)
303 …if err := ioutil.WriteFile(srv.Member.ClientKeyPath, []byte(srv.Member.ClientKeyData), 0644); err …
307 	if srv.Member.ClientTrustedCAPath != "" {
308 		if srv.Member.ClientTrustedCAData == "" {
309 			return fmt.Errorf("got empty data for %q", srv.Member.ClientTrustedCAPath)
311 …if err := ioutil.WriteFile(srv.Member.ClientTrustedCAPath, []byte(srv.Member.ClientTrustedCAData),…
315 	if srv.Member.ClientCertPath != "" &&
316 		srv.Member.ClientKeyPath != "" &&
317 		srv.Member.ClientTrustedCAPath != "" {
320 			zap.String("client-cert", srv.Member.ClientCertPath),
321 			zap.String("client-key", srv.Member.ClientKeyPath),
322 			zap.String("client-trusted-ca", srv.Member.ClientTrustedCAPath),
330 	if srv.Member.Etcd.PeerAutoTLS {
334 		fdir := filepath.Join(srv.Member.Etcd.DataDir, "fixtures", "peer")
350 		srv.Member.PeerCertData = string(certData)
360 		srv.Member.PeerKeyData = string(keyData)
371 	if srv.Member.Etcd.ClientAutoTLS {
375 		fdir := filepath.Join(srv.Member.Etcd.DataDir, "fixtures", "client")
391 		srv.Member.ClientCertData = string(certData)
401 		srv.Member.ClientKeyData = string(keyData)
422 	if !fileutil.Exist(srv.Member.BaseDir) {
423 		err = fileutil.TouchDirAll(srv.Member.BaseDir)
454 		Member:  srv.Member,
486 	if err = os.RemoveAll(srv.Member.BaseDir + ".backup"); err != nil {
489 	if err = os.Rename(srv.Member.BaseDir, srv.Member.BaseDir+".backup"); err != nil {
494 		zap.String("base-dir", srv.Member.BaseDir),
495 		zap.String("new-dir", srv.Member.BaseDir+".backup"),
499 	if !fileutil.Exist(srv.Member.BaseDir) {
500 		err = fileutil.TouchDirAll(srv.Member.BaseDir)
516 	err := srv.Member.SaveSnapshot(srv.lg)
523 		SnapshotInfo: srv.Member.SnapshotInfo,
528 	err = srv.Member.RestoreSnapshot(srv.lg)
565 		SnapshotInfo: srv.Member.SnapshotInfo,
584 		srv.Member.BaseDir,
585 		srv.Member.EtcdLogPath,
586 		srv.Member.Etcd.DataDir,
590 	srv.lg.Info("archived data", zap.String("base-dir", srv.Member.BaseDir))
621 	err = os.RemoveAll(srv.Member.BaseDir)
625 	srv.lg.Info("removed base directory", zap.String("dir", srv.Member.BaseDir))