| 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
|
| }
|
|
|
|
|