rm_replica.go

package app

import (
	"errors"
	"github.com/openebs/jiva/alertlog"

	"github.com/openebs/jiva/controller/client"
	"github.com/sirupsen/logrus"
	"github.com/urfave/cli"
)

func RmReplicaCmd() cli.Command {
	return cli.Command{
		Name:      "rm-replica",
		ShortName: "rm",
		Action: func(c *cli.Context) {
			if err := rmReplica(c); err != nil {
				logrus.Fatalf("Error running rm replica command: %v", err)
			}
		},
	}
}

func rmReplica(c *cli.Context) error {
	if c.NArg() == 0 {
		return errors.New("replica address is required")
	}
	replica := c.Args()[0]

	controllerClient := getCli(c)
	_, err := controllerClient.DeleteReplica(replica)
	if err != nil {
		alertlog.Logger.Errorw("",
			"eventcode", "jiva.volume.replica.remove.failure",
			"msg", "Failed to remove Jiva volume replica",
			"rname", replica,
		)
	} else {
		alertlog.Logger.Infow("",
			"eventcode", "jiva.volume.replica.remove.success",
			"msg", "Successfully removed Jiva volume replica",
			"rname", replica,
		)
	}
	return err
}

func AutoRmReplica(frontendIP string, replica string) error {
	url := "http://" + frontendIP + ":9501"
	controllerClient := client.NewControllerClient(url)
	_, err := controllerClient.DeleteReplica(replica)
	if err != nil {
		alertlog.Logger.Errorw("",
			"eventcode", "jiva.volume.replica.remove.failure",
			"msg", "Failed to remove Jiva volume replica",
			"rname", replica,
		)
	} else {
		alertlog.Logger.Infow("",
			"eventcode", "jiva.volume.replica.remove.success",
			"msg", "Successfully removed Jiva volume replica",
			"rname", replica,
		)
	}
	return err
}