From 7c18deb9a9e6c2e99f4c5ecf245315a6eda29750 Mon Sep 17 00:00:00 2001 From: "R.I.Pienaar" Date: Wed, 25 Oct 2023 10:49:08 +0200 Subject: [PATCH] Remove some uses of Raft Signed-off-by: R.I.Pienaar --- cli/stream_command.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cli/stream_command.go b/cli/stream_command.go index b8d6cba2..a2cb9c94 100644 --- a/cli/stream_command.go +++ b/cli/stream_command.go @@ -252,7 +252,7 @@ func configureStreamCommand(app commandHost) { strReport.Flag("storage", "Sort by Storage type").Short('t').UnNegatableBoolVar(&c.reportSortStorage) strReport.Flag("raw", "Show un-formatted numbers").Short('r').UnNegatableBoolVar(&c.reportRaw) strReport.Flag("dot", "Produce a GraphViz graph of replication topology").StringVar(&c.outFile) - strReport.Flag("leaders", "Show details about RAFT leaders").Short('l').UnNegatableBoolVar(&c.reportLeaderDistrib) + strReport.Flag("leaders", "Show details about cluster leaders").Short('l').UnNegatableBoolVar(&c.reportLeaderDistrib) findHelp := `Expression format: @@ -705,7 +705,7 @@ func (c *streamCmd) leaderStandDown(_ *fisk.ParseContext) error { return fmt.Errorf("stream has no current leader") } - log.Printf("Requesting leader step down of %q in a %d peer RAFT group", leader, len(info.Cluster.Replicas)+1) + log.Printf("Requesting leader step down of %q in a %d peer cluster group", leader, len(info.Cluster.Replicas)+1) err = stream.LeaderStepDown() if err != nil { return err @@ -1937,7 +1937,7 @@ func (c *streamCmd) showStreamInfo(info *api.StreamInfo) { cols.AddSectionTitle("Cluster Information") cols.AddRow("Name", info.Cluster.Name) - cols.AddRowIfNotEmpty("Raft Group", info.Cluster.RaftGroup) + cols.AddRowIfNotEmpty("Cluster Group", info.Cluster.RaftGroup) cols.AddRow("Leader", info.Cluster.Leader) for _, r := range info.Cluster.Replicas { state := []string{r.Name}