go-streams
go-streams copied to clipboard
reugn
A lightweight stream processing library for Go
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...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.54.0 to 1.56.3. Release notes Sourced from google.golang.org/grpc's releases. Release 1.56.3 Security server: prohibit more than MaxConcurrentStreams handlers from running at once (CVE-2023-44487) In addition to this...
Bumps [google.golang.org/grpc](https://github.com/grpc/grpc-go) from 1.54.0 to 1.56.3. Release notes Sourced from google.golang.org/grpc's releases. Release 1.56.3 Security server: prohibit more than MaxConcurrentStreams handlers from running at once (CVE-2023-44487) In addition to this...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.8.0 to 0.17.0. Commits b225e7c http2: limit maximum handler goroutines to MaxConcurrentStreams 88194ad go.mod: update golang.org/x dependencies 2b60a61 quic: fix several bugs in flow control accounting 73d82ef...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.15.0 to 0.17.0. Commits b225e7c http2: limit maximum handler goroutines to MaxConcurrentStreams 88194ad go.mod: update golang.org/x dependencies 2b60a61 quic: fix several bugs in flow control accounting 73d82ef...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.15.0 to 0.17.0. Commits b225e7c http2: limit maximum handler goroutines to MaxConcurrentStreams 88194ad go.mod: update golang.org/x dependencies 2b60a61 quic: fix several bugs in flow control accounting 73d82ef...
We could describe the flow using a file dsl / idl. A type of config fike. Mythen the runner loads this config file. It’s almost like how Benthos works though...
## Motivation * Added ZipWith functionality, e.g. taking elements from several upstreams in a round-robin fashion, bundling them to a single element, then sending it downstream. * ## Modifications *...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.21.0 to 0.23.0. Commits c48da13 http2: fix TestServerContinuationFlood flakes 762b58d http2: fix tipos in comment ba87210 http2: close connections when receiving too many headers ebc8168 all: fix...
Bumps [golang.org/x/net](https://github.com/golang/net) from 0.21.0 to 0.23.0. Commits c48da13 http2: fix TestServerContinuationFlood flakes 762b58d http2: fix tipos in comment ba87210 http2: close connections when receiving too many headers ebc8168 all: fix...