go-streams
go-streams copied to clipboard
reugn
A lightweight stream processing library for Go
## Motivation * Fixes #___ * ## Modifications * Introduce a new flow util similar to FanOut, but balances the work across go funcs. I feel like this could be...
There are many instances running in Distributed architecture. Some status are shared between instances, like time windows. We could put it on Redis, or other storage.
Is there a way to support grouping data by time and length？ like: ``` ch := make(chan any, 5) go func() { for i := 0; i < 10000; i++...
Bumps [github.com/dvsekhvalnov/jose2go](https://github.com/dvsekhvalnov/jose2go) from 1.5.0 to 1.6.0. Commits 48ba0b7 Merge pull request #32 from dvsekhvalnov/issue-31-security-tuning 05eb007 docs e0264a2 added helper matchers: Alg and Eng 0f6c7c3 MatchAlg helper cf0a53b docs 2995762 docs...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [github.com/dvsekhvalnov/jose2go](https://github.com/dvsekhvalnov/jose2go) from 1.5.0 to 1.6.0. Commits 48ba0b7 Merge pull request #32 from dvsekhvalnov/issue-31-security-tuning 05eb007 docs e0264a2 added helper matchers: Alg and Eng 0f6c7c3 MatchAlg helper cf0a53b docs 2995762 docs...
Hi, developer, So glad the redis stream is supported right now and I appreciate your effort very much. This morning I read your code and try to figure out how...
Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.6.0 to 0.17.0. Commits 9d2ee97 ssh: implement strict KEX protocol changes 4e5a261 ssh: close net.Conn on all NewServerConn errors 152cdb1 x509roots/fallback: update bundle fdfe1f8 ssh: defer channel...
Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.13.0 to 0.17.0. Commits 9d2ee97 ssh: implement strict KEX protocol changes 4e5a261 ssh: close net.Conn on all NewServerConn errors 152cdb1 x509roots/fallback: update bundle fdfe1f8 ssh: defer channel...
Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.13.0 to 0.17.0. Commits 9d2ee97 ssh: implement strict KEX protocol changes 4e5a261 ssh: close net.Conn on all NewServerConn errors 152cdb1 x509roots/fallback: update bundle fdfe1f8 ssh: defer channel...
Bumps [github.com/nats-io/nkeys](https://github.com/nats-io/nkeys) from 0.4.5 to 0.4.6. Commits 62e5d8c Merge pull request #60 from nats-io/0_4_6 f63761b [BUMP] release version and dependencies d2e442e Merge pull request #59 from nats-io/empty 58fb9d6 Make sure...