Support for NATS Streaming

[nguyenhoaibao]

I think this is more or less the same with NATS, but using https://github.com/nats-io/stan.go instead.

[blinktag]

@nguyenhoaibao This is definitely be doable! Give us a few days and I'll have a release for you

[blinktag]

@nguyenhoaibao streaming support has been added in v0.21.0. You may use the commands plumber read nats-streaming -h and plumber write nats-streaming -h to view available flags. Examples have also been added to https://github.com/batchcorp/plumber/blob/master/EXAMPLES.md#nats-streaming and https://github.com/batchcorp/plumber/blob/master/EXAMPLES.md#nats-streaming-1

Let us know if you needed any additional functionality for this

[nguyenhoaibao]

It works perfectly, thanks @blinktag.

BTW I think it will be great if we can support more options like this:

--last                           Deliver starting with last published message
--since  <time_ago>              Deliver messages in last interval (e.g. 1s, 1hr)
--seq    <seqno>                 Start at seqno
--new_only                       Only deliver new messages

[blinktag]

@nguyenhoaibao I added --all --since --last and --seq in the latest release, and made new-only the default behavior of the read command

[nguyenhoaibao]

Great. Thanks for doing this. I'll close this now.