소스 검색

etcd: move s.setClusterConfig to v2_admin.go

Xiang Li 11 년 전
부모
커밋
a922947bb0
2개의 변경된 파일11개의 추가작업 그리고 11개의 파일을 삭제
  1. 0 11
      etcd/etcd.go
  2. 11 0
      etcd/v2_admin.go

+ 0 - 11
etcd/etcd.go

@@ -511,17 +511,6 @@ func (s *Server) send(msgs []raft.Message) {
 	}
 }
 
-func (s *Server) setClusterConfig(c *config.ClusterConfig) error {
-	b, err := json.Marshal(c)
-	if err != nil {
-		return err
-	}
-	if _, err := s.Set(v2configKVPrefix, false, string(b), store.Permanent); err != nil {
-		return err
-	}
-	return nil
-}
-
 func (s *Server) fetchAddr(nodeId int64) error {
 	for seed := range s.nodes {
 		if err := s.peerHub.fetch(seed, nodeId); err == nil {

+ 11 - 0
etcd/v2_admin.go

@@ -112,6 +112,17 @@ func (s *Server) ClusterConfig() *config.ClusterConfig {
 	return c
 }
 
+func (s *Server) setClusterConfig(c *config.ClusterConfig) error {
+	b, err := json.Marshal(c)
+	if err != nil {
+		return err
+	}
+	if _, err := s.Set(v2configKVPrefix, false, string(b), store.Permanent); err != nil {
+		return err
+	}
+	return nil
+}
+
 // someMachineMessage return machine message of specified name.
 func (s *Server) someMachineMessage(name string) (*machineMessage, error) {
 	p := filepath.Join(v2machineKVPrefix, name)