From b358de907ea15bdda6a61a963b1eb35f4f09edd7 Mon Sep 17 00:00:00 2001
From: Ken Hibino <ken.hibino7@gmail.com>
Date: Sat, 22 May 2021 12:13:19 -0700
Subject: [PATCH] Rename Inspector.CurrentStats to GetQueueInfo

---
 inspector.go      | 10 +++++-----
 inspector_test.go | 14 +++++++-------
 2 files changed, 12 insertions(+), 12 deletions(-)

diff --git a/inspector.go b/inspector.go
index 0f15435..a07137d 100644
--- a/inspector.go
+++ b/inspector.go
@@ -44,8 +44,8 @@ func (i *Inspector) Queues() ([]string, error) {
 	return i.rdb.AllQueues()
 }
 
-// QueueStats represents a state of queues at a certain time.
-type QueueStats struct {
+// QueueInfo represents a state of queues at a certain time.
+type QueueInfo struct {
 	// Name of the queue.
 	Queue string
 	// Total number of bytes that the queue and its tasks require to be stored in redis.
@@ -75,8 +75,8 @@ type QueueStats struct {
 	Timestamp time.Time
 }
 
-// CurrentStats returns a current stats of the given queue.
-func (i *Inspector) CurrentStats(qname string) (*QueueStats, error) {
+// GetQueueInfo returns current information of the given queue.
+func (i *Inspector) GetQueueInfo(qname string) (*QueueInfo, error) {
 	if err := base.ValidateQueueName(qname); err != nil {
 		return nil, err
 	}
@@ -84,7 +84,7 @@ func (i *Inspector) CurrentStats(qname string) (*QueueStats, error) {
 	if err != nil {
 		return nil, err
 	}
-	return &QueueStats{
+	return &QueueInfo{
 		Queue:       stats.Queue,
 		MemoryUsage: stats.MemoryUsage,
 		Size:        stats.Size,
diff --git a/inspector_test.go b/inspector_test.go
index 3868df7..6104541 100644
--- a/inspector_test.go
+++ b/inspector_test.go
@@ -254,7 +254,7 @@ func TestInspectorDeleteQueueErrorQueueNotFound(t *testing.T) {
 	}
 }
 
-func TestInspectorCurrentStats(t *testing.T) {
+func TestInspectorGetQueueInfo(t *testing.T) {
 	r := setup(t)
 	defer r.Close()
 	m1 := h.NewTaskMessage("task1", nil)
@@ -265,7 +265,7 @@ func TestInspectorCurrentStats(t *testing.T) {
 	m6 := h.NewTaskMessageWithQueue("task6", nil, "low")
 	now := time.Now()
 	timeCmpOpt := cmpopts.EquateApproxTime(time.Second)
-	ignoreMemUsg := cmpopts.IgnoreFields(QueueStats{}, "MemoryUsage")
+	ignoreMemUsg := cmpopts.IgnoreFields(QueueInfo{}, "MemoryUsage")
 
 	inspector := NewInspector(getRedisConnOpt(t))
 
@@ -278,7 +278,7 @@ func TestInspectorCurrentStats(t *testing.T) {
 		processed map[string]int
 		failed    map[string]int
 		qname     string
-		want      *QueueStats
+		want      *QueueInfo
 	}{
 		{
 			pending: map[string][]*base.TaskMessage{
@@ -320,7 +320,7 @@ func TestInspectorCurrentStats(t *testing.T) {
 				"low":      5,
 			},
 			qname: "default",
-			want: &QueueStats{
+			want: &QueueInfo{
 				Queue:     "default",
 				Size:      4,
 				Pending:   1,
@@ -352,14 +352,14 @@ func TestInspectorCurrentStats(t *testing.T) {
 			r.Set(failedKey, n, 0)
 		}
 
-		got, err := inspector.CurrentStats(tc.qname)
+		got, err := inspector.GetQueueInfo(tc.qname)
 		if err != nil {
-			t.Errorf("r.CurrentStats(%q) = %v, %v, want %v, nil",
+			t.Errorf("r.GetQueueInfo(%q) = %v, %v, want %v, nil",
 				tc.qname, got, err, tc.want)
 			continue
 		}
 		if diff := cmp.Diff(tc.want, got, timeCmpOpt, ignoreMemUsg); diff != "" {
-			t.Errorf("r.CurrentStats(%q) = %v, %v, want %v, nil; (-want, +got)\n%s",
+			t.Errorf("r.GetQueueInfo(%q) = %v, %v, want %v, nil; (-want, +got)\n%s",
 				tc.qname, got, err, tc.want, diff)
 			continue
 		}