diff --git a/go.mod b/go.mod index 1da2fc6..ae49a78 100644 --- a/go.mod +++ b/go.mod @@ -15,8 +15,8 @@ require ( github.com/gosuri/uiprogress v0.0.1 github.com/guptarohit/asciigraph v0.4.2 github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 - github.com/nats-io/jsm.go v0.0.19-0.20201016110218-002482fa4d8e - github.com/nats-io/nats-server/v2 v2.1.8-0.20201013002018-a4c68521bafa + github.com/nats-io/jsm.go v0.0.19 + github.com/nats-io/nats-server/v2 v2.1.8-0.20201015210146-e846dab45dad github.com/nats-io/nats.go v1.10.1-0.20201013114232-5a33ce07522f github.com/tylertreat/hdrhistogram-writer v0.0.0-20180430173243-73b8d31ba571 github.com/xeipuuv/gojsonpointer v0.0.0-20190905194746-02993c407bfb // indirect diff --git a/go.sum b/go.sum index 71c86e1..109d4ca 100644 --- a/go.sum +++ b/go.sum @@ -65,10 +65,8 @@ github.com/mgutz/ansi v0.0.0-20170206155736-9520e82c474b h1:j7+1HpAFS1zy5+Q4qx1f github.com/mgutz/ansi v0.0.0-20170206155736-9520e82c474b/go.mod h1:01TrycV0kFyexm33Z7vhZRXopbI8J3TDReVlkTgMUxE= github.com/minio/highwayhash v1.0.0 h1:iMSDhgUILCr0TNm8LWlSjF8N0ZIj2qbO8WHp6Q/J2BA= github.com/minio/highwayhash v1.0.0/go.mod h1:xQboMTeM9nY9v/LlAOxFctujiv5+Aq2hR5dxBpaMbdc= -github.com/nats-io/jsm.go v0.0.19-0.20201014101052-9f5d953d7af0 h1:aPEQbqlqO0guorrQv6pdBX4eW+f8zI9/7LlQ38KkGmE= -github.com/nats-io/jsm.go v0.0.19-0.20201014101052-9f5d953d7af0/go.mod h1:nB+1waJuSDcn/2YbyyETYvGZa6wJsV1/rPVFLmjzUP8= -github.com/nats-io/jsm.go v0.0.19-0.20201016110218-002482fa4d8e h1:hggn2v5pHIsgxrSF70U7bYPOOslz1c1pVcrM794W/zE= -github.com/nats-io/jsm.go v0.0.19-0.20201016110218-002482fa4d8e/go.mod h1:nB+1waJuSDcn/2YbyyETYvGZa6wJsV1/rPVFLmjzUP8= +github.com/nats-io/jsm.go v0.0.19 h1:hThK19z4nNM8NbgR6wwcuT2GEMNaxmtmfL+h2ZcfQLQ= +github.com/nats-io/jsm.go v0.0.19/go.mod h1:nB+1waJuSDcn/2YbyyETYvGZa6wJsV1/rPVFLmjzUP8= github.com/nats-io/jwt v0.3.2/go.mod h1:/euKqTS1ZD+zzjYrY7pseZrTtWQSjujC7xjPc8wL6eU= github.com/nats-io/jwt v0.3.3-0.20200519195258-f2bf5ce574c7 h1:RnGotxlghqR5D2KDAu4TyuLqyjuylOsJiAFhXvMvQIc= github.com/nats-io/jwt v0.3.3-0.20200519195258-f2bf5ce574c7/go.mod h1:n3cvmLfBfnpV4JJRN7lRYCyZnw48ksGsbThGXEk4w9M= @@ -76,11 +74,15 @@ github.com/nats-io/jwt/v2 v2.0.0-20200916203241-1f8ce17dff02 h1:WloZv3SCb55D/rOH github.com/nats-io/jwt/v2 v2.0.0-20200916203241-1f8ce17dff02/go.mod h1:vs+ZEjP+XKy8szkBmQwCB7RjYdIlMaPsFPs4VdS4bTQ= github.com/nats-io/jwt/v2 v2.0.0-20201006231922-e00ffcea7738 h1:MlwwastrhUZSIvSs4M70vT0fOWTCF6WxOu9S4/NtY9U= github.com/nats-io/jwt/v2 v2.0.0-20201006231922-e00ffcea7738/go.mod h1:vs+ZEjP+XKy8szkBmQwCB7RjYdIlMaPsFPs4VdS4bTQ= +github.com/nats-io/jwt/v2 v2.0.0-20201015190852-e11ce317263c h1:Hc1D9ChlsCMVwCxJ6QT5xqfk2zJ4XNea+LtdfaYhd20= +github.com/nats-io/jwt/v2 v2.0.0-20201015190852-e11ce317263c/go.mod h1:vs+ZEjP+XKy8szkBmQwCB7RjYdIlMaPsFPs4VdS4bTQ= github.com/nats-io/nats-server/v2 v2.1.8-0.20200524125952-51ebd92a9093/go.mod h1:rQnBf2Rv4P9adtAs/Ti6LfFmVtFG6HLhl/H7cVshcJU= github.com/nats-io/nats-server/v2 v2.1.8-0.20200601203034-f8d6dd992b71/go.mod h1:Nan/1L5Sa1JRW+Thm4HNYcIDcVRFc5zK9OpSZeI2kk4= github.com/nats-io/nats-server/v2 v2.1.8-0.20200929001935-7f44d075f7ad/go.mod h1:TkHpUIDETmTI7mrHN40D1pzxfzHZuGmtMbtb83TGVQw= github.com/nats-io/nats-server/v2 v2.1.8-0.20201013002018-a4c68521bafa h1:8DtTf+ojuEJF5JaC+SPZPpkMhNy5pfveWfVH7gDxQXc= github.com/nats-io/nats-server/v2 v2.1.8-0.20201013002018-a4c68521bafa/go.mod h1:H+80yAu7oH5rFAvdB2yO4xIl9YlUpFd3QsLeulM2Sik= +github.com/nats-io/nats-server/v2 v2.1.8-0.20201015210146-e846dab45dad h1:jVTy7bIYD1g6amwPVpsuMuF0hkBo1H+Zn4K+15AvuTk= +github.com/nats-io/nats-server/v2 v2.1.8-0.20201015210146-e846dab45dad/go.mod h1:SU/HfCYkvQJMQmxl/fIesRYDTAojGclPg0nSFZ2x8gQ= github.com/nats-io/nats.go v1.10.0/go.mod h1:AjGArbfyR50+afOUotNX2Xs5SYHf+CoOa5HH1eEl2HE= github.com/nats-io/nats.go v1.10.1-0.20200531124210-96f2130e4d55/go.mod h1:ARiFsjW9DVxk48WJbO3OSZ2DG8fjkMi7ecLmXoY/n9I= github.com/nats-io/nats.go v1.10.1-0.20200606002146-fc6fed82929a h1:gzSKZOBlu/DpbuPbt34paXCOvA6+E+lVfU2BmomQ9HA= diff --git a/nats/stream_command.go b/nats/stream_command.go index dcb927c..9f0a7f9 100644 --- a/nats/stream_command.go +++ b/nats/stream_command.go @@ -165,7 +165,7 @@ func configureStreamCommand(app *kingpin.Application) { strView := str.Command("view", "View messages in a stream").Action(c.viewAction) strView.Arg("stream", "Stream name").StringVar(&c.stream) strView.Arg("size", "Page size").Default("10").IntVar(&c.vwPageSize) - strView.Flag("id", "Start at a specific message ID").Default("-1").IntVar(&c.vwStartId) + strView.Flag("id", "Start at a specific message ID").IntVar(&c.vwStartId) strView.Flag("since", "Start at a time delta").DurationVar(&c.vwStartDelta) strView.Flag("raw", "Show the raw data received").BoolVar(&c.vwRaw) @@ -207,7 +207,7 @@ func (c *streamCmd) viewAction(_ *kingpin.ParseContext) error { switch { case c.vwStartDelta > 0: pops = append(pops, jsm.PagerStartDelta(c.vwStartDelta)) - case c.vwStartId > -1: + case c.vwStartId > 0: pops = append(pops, jsm.PagerStartId(c.vwStartId)) }