[WIP] API to Enable/Disable peer

glusterd2/commands/peers/addpeer.go

@@ -111,6 +111,10 @@ func addPeerHandler(w http.ResponseWriter, r *http.Request) {
 		newpeer.Metadata[key] = value
 	}
 
+	if req.Disabled {
+		newpeer.Disabled = req.Disabled
+	}
+
 	//check if remotePeerAddress already present
 	found := utils.StringInSlice(remotePeerAddress, newpeer.PeerAddresses)
 	//if not found prepend the remotePeerAddress to peer details
@@ -142,6 +146,7 @@ func createPeerAddResp(p *peer.Peer) *api.PeerAddResp {
 		Name:            p.Name,
 		PeerAddresses:   p.PeerAddresses,
 		ClientAddresses: p.ClientAddresses,
+		Disabled:        p.Disabled,
 		Metadata:        p.Metadata,
 	}
 }

glusterd2/peer/peer.go

@@ -13,6 +13,7 @@ type Peer struct {
 	Name            string
 	PeerAddresses   []string
 	ClientAddresses []string
+	Disabled        bool
 	Metadata        map[string]string
 }
 

glusterd2/peer/self.go

@@ -58,10 +58,11 @@ func AddSelfDetails() error {
 	if err == errors.ErrPeerNotFound {
 		p.Metadata = make(map[string]string)
 		p.Metadata["_zone"] = p.ID.String()
+		p.Disabled = false
 
 	} else if err == nil && peerInfo != nil {
 		p.Metadata = peerInfo.Metadata
-
+		p.Disabled = peerInfo.Disabled
 		found := utils.StringInSlice(p.PeerAddresses[0], peerInfo.PeerAddresses)
 		if !found {
 			p.PeerAddresses = append(peerInfo.PeerAddresses, p.PeerAddresses...)

pkg/api/peer_req_resp.go

@@ -12,13 +12,15 @@ type Peer struct {
 	ClientAddresses []string          `json:"client-addresses"`
 	Online          bool              `json:"online"`
 	PID             int               `json:"pid,omitempty"`
+	Disabled        bool              `json:"disabled,omitempty"`
 	Metadata        map[string]string `json:"metadata"`
 }
 
 // PeerAddReq represents an incoming request to add a peer to the cluster
 type PeerAddReq struct {
 	Addresses []string          `json:"addresses"`
 	Zone      string            `json:"zone,omitempty"`
+	Disabled  bool              `json:"disabled,omitempty"`
 	Metadata  map[string]string `json:"metadata,omitempty"`
 }