move to batch placement remove API

pkg/controller/m3admin_client.go

@@ -273,7 +273,7 @@ func (c errorPlacementClient) Add([]*placementpb.Instance) error {
 	return c.err
 }
 
-func (c errorPlacementClient) Remove(string) error {
+func (c errorPlacementClient) Remove([]string) error {
 	return c.err
 }
 

pkg/controller/m3admin_client_test.go

@@ -242,7 +242,7 @@ func TestErrorPlacementClient(t *testing.T) {
 	err = cl.Add([]*placementpb.Instance{{}})
 	assert.Equal(t, clErr, err)
 
-	err = cl.Remove("foo")
+	err = cl.Remove([]string{"foo"})
 	assert.Equal(t, clErr, err)
 
 	err = cl.Replace("foo", placementpb.Instance{})

pkg/controller/update_cluster.go

@@ -563,7 +563,7 @@ func (c *M3DBController) shrinkPlacementForSet(
 	}
 
 	c.logger.Info("removing pod from placement", zap.String("instance", removeInst.ID()))
-	return c.adminClient.placementClientForCluster(cluster).Remove(removeInst.ID())
+	return c.adminClient.placementClientForCluster(cluster).Remove([]string{removeInst.ID()})
 }
 
 // findPodInstanceToRemove returns the pod (and associated placement instace)

pkg/controller/update_cluster_test.go

@@ -695,14 +695,14 @@ func TestShrinkPlacementForSet(t *testing.T) {
 	pl := placementFromPods(t, cluster, pods, deps.idProvider)
 
 	// Expect the last pod to be removed.
-	placementMock.EXPECT().Remove(`{"name":"cluster-zones-rep0-2","uid":"2"}`)
+	placementMock.EXPECT().Remove([]string{`{"name":"cluster-zones-rep0-2","uid":"2"}`})
 	err = controller.shrinkPlacementForSet(cluster, set, pl)
 	assert.NoError(t, err)
 
 	// If there are more pods in the set then in the placement, we expect the last
 	// in the set to be removed.
 	pl = placementFromPods(t, cluster, pods[:2], deps.idProvider)
-	placementMock.EXPECT().Remove(`{"name":"cluster-zones-rep0-1","uid":"1"}`)
+	placementMock.EXPECT().Remove([]string{`{"name":"cluster-zones-rep0-1","uid":"1"}`})
 	err = controller.shrinkPlacementForSet(cluster, set, pl)
 	assert.NoError(t, err)
 }

pkg/m3admin/placement/client.go

@@ -22,7 +22,6 @@ package placement
 
 import (
 	"errors"
-	"fmt"
 	"net/http"
 
 	"github.com/m3db/m3db-operator/pkg/m3admin"
@@ -38,7 +37,7 @@ const (
 	placementBaseURL    = "/api/v1/services/m3db/placement"
 	placementInitURL    = placementBaseURL + "/init"
 	placementReplaceURL = placementBaseURL + "/replace"
-	placementRemoveFmt  = placementBaseURL + "/%s"
+	placementRemoveURL  = placementBaseURL + "/remove"
 	placementSetURL     = placementBaseURL + "/set"
 )
 
@@ -129,9 +128,12 @@ func (p *placementClient) Add(instances []*placementpb.Instance) error {
 	return nil
 }
 
-func (p *placementClient) Remove(id string) error {
-	url := fmt.Sprintf(p.url+placementRemoveFmt, id)
-	return p.client.DoHTTPJSONPBRequest(http.MethodDelete, url, nil, nil)
+func (p *placementClient) Remove(instanceIds []string) error {
+	url := p.url + placementRemoveURL
+	req := &admin.PlacementRemoveRequest{
+		InstanceIds: instanceIds,
+	}
+	return p.client.DoHTTPJSONPBRequest(http.MethodPost, url, req, nil)
 }
 
 func (p *placementClient) Replace(leavingInstanceID string, newInst placementpb.Instance) error {

pkg/m3admin/placement/client_test.go

@@ -201,7 +201,7 @@ func TestGetErr(t *testing.T) {
 
 func TestRemove(t *testing.T) {
 	s := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
-		if r.URL.String() != "/api/v1/services/m3db/placement/instFoo" || r.Method != http.MethodDelete {
+		if r.URL.String() != "/api/v1/services/m3db/placement/remove" || r.Method != http.MethodPost {
 			w.WriteHeader(404)
 			return
 		}
@@ -211,7 +211,7 @@ func TestRemove(t *testing.T) {
 	defer s.Close()
 
 	client := newPlacementClient(t, s.URL)
-	err := client.Remove("instFoo")
+	err := client.Remove([]string{"instFoo"})
 	assert.NoError(t, err)
 }
 

pkg/m3admin/placement/types.go

@@ -34,12 +34,12 @@ type Client interface {
 	Set(request *admin.PlacementSetRequest) error
 	// Get will provide the current placement
 	Get() (placement m3placement.Placement, err error)
-	// Delete will delete the current placment
+	// Delete will delete the current placement
 	Delete() error
 	// Add will add an instance to the placement
 	Add(instances []*placementpb.Instance) error
-	// Remove removes a given instance with the given ID from the placement.
-	Remove(id string) error
+	// Remove removes instances with the given IDs from the placement.
+	Remove(instanceIds []string) error
 	// Replace replaces one instance with another.
 	Replace(leavingInstanceID string, newInstance placementpb.Instance) error
 }