Index: common/logdog/coordinator/stream_params.go |
diff --git a/common/logdog/coordinator/stream_params.go b/common/logdog/coordinator/stream_params.go |
index 9642278045dd081d0d3ba186e4211511f1e4b0a5..c2ed3895c71376d344743cba72a0a0c89fbe0786 100644 |
--- a/common/logdog/coordinator/stream_params.go |
+++ b/common/logdog/coordinator/stream_params.go |
@@ -41,7 +41,7 @@ func (p *StreamGetParams) Index(i types.MessageIndex) *StreamGetParams { |
// Limit limits the returned logs either by count or by byte count. If either |
// limit is <= 0, then no limit will be applied and the server will choose how |
// many logs to return. |
-func (p *StreamGetParams) Limit(bytes, count int) *StreamGetParams { |
+func (p *StreamGetParams) Limit(bytes, count int32) *StreamGetParams { |
p = p.clone() |
if bytes < 0 { |
@@ -51,7 +51,7 @@ func (p *StreamGetParams) Limit(bytes, count int) *StreamGetParams { |
count = 0 |
} |
- p.r.ByteCount, p.r.LogCount = int32(bytes), int32(count) |
+ p.r.ByteCount, p.r.LogCount = bytes, count |
return p |
} |