Whoops

Author: davissp14

pkg/flypg/node.go

@@ -252,12 +252,13 @@ func (n *Node) PostInit(ctx context.Context) error {
 		}
 
 		// Setup repmgr database, extension, and register ourselves as the primary
-		fmt.Println("Perform Repmgr setup")
+		fmt.Println("Performing Repmgr setup")
 		if err := repmgr.setup(ctx, conn); err != nil {
 			fmt.Printf("failed to setup repmgr: %s\n", err)
 		}
 
 		// Register primary member with consul
+		fmt.Println("Registering member")
 		if err := cs.RegisterMember(repmgr.ID, n.PrivateIP, repmgr.Region, true); err != nil {
 			return fmt.Errorf("failed to register member with consul: %s", err)
 		}

pkg/flypg/state/cluster.go

@@ -185,8 +185,8 @@ func (c *ClusterState) clusterData() (*ClusterData, uint64, error) {
 	return &cluster, result.ModifyIndex, nil
 }
 
-func (c *ClusterState) updateClusterState(modifyIndex uint64, cluster *ClusterData) error {
-	clusterJSON, err := json.Marshal(c)
+func (c *ClusterState) updateClusterState(modifyIndex uint64, cd *ClusterData) error {
+	clusterJSON, err := json.Marshal(cd)
 	if err != nil {
 		return err
 	}