Skip to content

Pull requests: reugn/go-streams

New pull request New
Clear current search query, filters, and sorts
6 Open 145 Closed
6 Open 145 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

fix(flow): emit partial sliding window on early close
#192 by reugn was merged Nov 15, 2025 Loading…
1
1
fix(aws): allocate read buffer in S3 source
#187 by reugn was merged Aug 16, 2025 Loading…
1
deps(connectors): update dependency versions
#183 by reugn was merged May 10, 2025 Loading…
1
ci: upgrade golangci-lint to v2.1.5
#182 by reugn was merged May 3, 2025 Loading…
1
docs(flow): enhance keyed flow documentation
#181 by reugn was merged May 2, 2025 Loading…
1
1
refactor(flow): rework parallel processing of stream elements
#178 by reugn was merged Apr 25, 2025 Loading…
1
feat(flow): add support for allowed lateness in sliding window
#177 by reugn was merged Apr 26, 2025 Loading…
1
1
fix(flow): use of sliding window in keyed flow
#176 by reugn was merged Apr 21, 2025 Loading…
1
1
chore(deps): bump golang.org/x/net from 0.26.0 to 0.38.0 in /aerospike dependencies Pull requests that update a dependency file go Pull requests that update go code
#175 by dependabot bot was closed May 10, 2025 Loading…
1
chore(deps): bump golang.org/x/crypto from 0.26.0 to 0.35.0 in /pulsar dependencies Pull requests that update a dependency file go Pull requests that update go code
#173 by dependabot bot was closed Nov 20, 2025 Loading…
1
refactor(flow): use atomic.Int64 in Throttler
#169 by reugn was merged Mar 22, 2025 Loading…
1
chore(deps): bump github.com/golang-jwt/jwt/v5 from 5.2.1 to 5.2.2 in /examples dependencies Pull requests that update a dependency file go Pull requests that update go code
#168 by dependabot bot was closed May 10, 2025 Loading…
1
chore: update code documentation and rework the maze example
#167 by reugn was merged Mar 21, 2025 Loading…
1
chore(deps): bump github.com/redis/go-redis/v9 from 9.7.0 to 9.7.3 in /examples dependencies Pull requests that update a dependency file go Pull requests that update go code
#166 by dependabot bot was closed May 10, 2025 Loading…
1
fix(flow)!: sliding window blocks until the first window is elapsed
#165 by reugn was merged Mar 14, 2025 Loading…
1
Remove initial time.Sleep statement on SlidingWindow
#164 by johnjones4 was closed Mar 14, 2025 Loading…
1 task done
2
chore(deps): bump golang.org/x/net from 0.26.0 to 0.36.0 in /aerospike dependencies Pull requests that update a dependency file go Pull requests that update go code
#163 by dependabot bot was closed Apr 16, 2025 Loading…
1
feat(flow): implement rolling fold transformation
#162 by Wkkkkk was merged Mar 21, 2025 Loading…
1 task done
3
ci: update golangci-lint configuration
#161 by reugn was merged Mar 1, 2025 Loading…
1
chore(deps): bump github.com/go-jose/go-jose/v4 from 4.0.3 to 4.0.5 in /examples dependencies Pull requests that update a dependency file
#160 by dependabot bot was closed Mar 14, 2025 Loading…
1
docs(contributing): update minimum go version requirement
#159 by reugn was merged Feb 22, 2025 Loading…
1
chore(deps): bump golang.org/x/net from 0.26.0 to 0.33.0 in /aerospike dependencies Pull requests that update a dependency file
#158 by dependabot bot was closed Mar 13, 2025 Loading…
1
feat!: rework standard connector implementations
#157 by reugn was merged Feb 17, 2025 Loading…
1
feat(flow): implement ZipWith stream transformation
#156 by reugn was merged Feb 8, 2025 Loading…
1
chore: reorganize the extension package
#155 by reugn was merged Jan 31, 2025 Loading…
ProTip! Exclude everything labeled bug with -label:bug.