MessageLimit and MemberLimit should be pointers (#107)

GetStream · Dec 10, 2020 · f80a88b · f80a88b
1 parent 76e0e38
commit f80a88b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/query.go b/query.go
@@ -15,8 +15,8 @@ type QueryOption struct {
 	UserID       string `json:"user_id,omitempty"`
 	Limit        int    `json:"limit,omitempty"`  // pagination option: limit number of results
 	Offset       int    `json:"offset,omitempty"` // pagination option: offset to return items from
-	MessageLimit int    `json:"message_limit,omitempty"`
-	MemberLimit  int    `json:"member_limit,omitempty"`
+	MessageLimit *int   `json:"message_limit,omitempty"`
+	MemberLimit  *int   `json:"member_limit,omitempty"`
 }
 
 type SortOption struct {
@@ -32,8 +32,8 @@ type queryRequest struct {
 	UserID       string `json:"user_id,omitempty"`
 	Limit        int    `json:"limit,omitempty"`
 	Offset       int    `json:"offset,omitempty"`
-	MemberLimit  int    `json:"member_limit,omitempty"`
-	MessageLimit int    `json:"message_limit,omitempty"`
+	MemberLimit  *int   `json:"member_limit,omitempty"`
+	MessageLimit *int   `json:"message_limit,omitempty"`
 
 	FilterConditions map[string]interface{} `json:"filter_conditions,omitempty"`
 	Sort             []*SortOption          `json:"sort,omitempty"`

diff --git a/query_test.go b/query_test.go
@@ -82,7 +82,7 @@ func TestClient_QueryChannels(t *testing.T) {
 				"$eq": ch.ID,
 			},
 		},
-		MessageLimit: messageLimit,
+		MessageLimit: &messageLimit,
 	})
 
 	require.NoError(t, err, "query channels error")