gophersgang/go-rivers

Collection of stream processing / multiplexing / networking libs in Go

Go - Rivers

Stream processing / multiplexing / networking in Go The main purpose is reading / learning / teaching.

Background

• Making Badass Developers - Kathy Sierra (Serious Pony) - https://www.youtube.com/watch?v=FKTxC9pl-WM
• It isn’t about what skills you have but how quickly you learn.

Setup

$ make run

Update Readme with current stats

$ make crawl

Navigation

• By Size
• By Activity

Projects

• abcum/syncr - A rolling, append-only, local and remote data stream library for Go
  ( 2018-05-02 / 58 commits / 6 stars )
• acquia/fifo2kinesis - Continuously reads data from a named pipe and publishes it to a Kinesis stream.
  ( 2016-09-19 / 97 commits / 9 stars )
• adamdrake/gofstream - Turn a file into a stream (channel) of lines
  ( 2018-06-10 / 3 commits / 1 stars )
• anthonynsimon/iceberg - [Not maintained] PubSub message streams over TCP
  ( 2017-02-07 / 8 commits / 0 stars )
• bahadley/ssim - Stream simulator for exercising esp
  ( 2016-09-22 / 34 commits / 0 stars )
• banyek/binlogstreamer - Tool for creating streamed binlog backup with mysqlbinlog utility
  ( 2016-06-06 / 13 commits / 8 stars )
• benlubar/firehose - A constant stream of information.
  ( 2013-05-21 / 2 commits / 2 stars )
• bmkessler/streamstats - Streaming stats data structures and algorithms for golang
  ( 2017-02-10 / 53 commits / 1 stars )
• bradhe/epee - A (very) simple stream processor for golang based on Kafka and protobuf.
  ( 2015-11-16 / 43 commits / 8 stars )
• brentp/irelate - Streaming relation (overlap, distance, KNN) of (any number of) sorted genomic interval sets. #golang
  ( 2018-08-01 / 134 commits / 36 stars )
• brettallred/tumblr-mock-stream - Mock Tumblr Firehose Stream written in Go
  ( 2016-06-07 / 6 commits / 0 stars )
• cameront/gokc - A golang library for managing kinesis stream processing
  ( 2014-07-31 / 8 commits / 2 stars )
• catalyst-zero/cores-go - CatalystZero Realtime Event Stream
  ( 2014-04-03 / 10 commits / 0 stars )
• ceejsmith/tick-stream-go - Financial price tick streaming service
  ( 2016-02-02 / 11 commits / 1 stars )
• chenyoufu/yfstream - single point json event stream process and alert
  ( 2017-02-06 / 6 commits / 1 stars )
• cloudfoundry/noaa - NOAA is a client library to consume metric and log messages from Doppler.
  ( 2018-01-26 / 158 commits / 20 stars )
• daneharrigan/streamers - Concept: A distributed worker queue over HTTP
  ( 2014-01-02 / 1 commits / 1 stars )
• dgryski/go-entropy - go-entropy -- exact and streaming entropy estimates
  ( 2015-04-07 / 3 commits / 9 stars )
• dgryski/go-gk - gk: streaming quantiles
  ( 2014-08-19 / 12 commits / 35 stars )
• digaku/ndayak - High performance distributed stream generator
  ( 2010-12-17 / 21 commits / 2 stars )
• diggs/go-http-stream-reader - Consume long running HTTP streams (e.g. Twitter streams API) in Go
  ( 2015-03-20 / 12 commits / 6 stars )
• djherbis/stream - Stream bytes to multiple independent Readers #golang
  ( 2018-01-13 / 35 commits / 43 stars )
• dmcgowan/streams - Go interface for using multiplexed transports
  ( 2016-04-09 / 9 commits / 14 stars )
• drborges/rivers - Data Stream Processing API for GO
  ( 2015-12-02 / 110 commits / 31 stars )
• ejholmes/pgstream - Log streaming library for Go
  ( 2015-09-05 / 20 commits / 1 stars )
• facebookgo/runcmd - Package runcmd provides a convenience Run function for exec.Cmd which includes the original command along with the output and error streams.
  ( 2015-06-12 / 2 commits / 49 stars )
• farsightsec/golang-framestream - Frame Streams implementation in Go
  ( 2018-01-24 / 21 commits / 0 stars )
• fujiwara/kinesis-tailf - tail -f command for Amazon Kinesis Stream
  ( 2017-10-24 / 29 commits / 16 stars )
• ghthor/filu - Game engine[s] designed around immutable events and stream processing
  ( 2016-08-28 / 493 commits / 8 stars )
• grpc-ecosystem/grpc-simon-says - Multiplayer Simon Says game using bidirectional gRPC streaming
  ( 2016-11-09 / 15 commits / 68 stars )
• harlow/kinesis-connectors - Golang library for consuming Kinesis stream data
  ( 2018-07-29 / 131 commits / 105 stars )
• hayeah/gowatch - Turn file system events into text stream for processing
  ( 2014-11-29 / 3 commits / 2 stars )
• hyperboloide/dispatch - Dispatch messages to various pub/sub services with one interface.
  ( 2016-11-05 / 11 commits / 0 stars )
• hyperboloide/pipe - A simple Go stream processing library that works like Unix pipes
  ( 2017-10-29 / 41 commits / 4 stars )
• itspage/grpc-streaming - GRPC streaming in Go
  ( 2017-02-11 / 1 commits / 1 stars )
• jaderdias/movingmedian - Package movingmedian computes the median of a windowed stream of data.
  ( 2017-06-11 / 57 commits / 9 stars )
• jeffail/benthos - A dull, resilient and quick to deploy stream processor
  ( 2018-08-16 / 708 commits / 709 stars )
• jianchen2580/log-stream - streaming kafka logs
  ( 2016-12-14 / 5 commits / 1 stars )
• jmptrader/go_tcp_relay - A TCP server which duplicates a received stream of data received from N clients out to an arbitrary number of consumers.
  ( 2015-01-16 / 1 commits / 0 stars )
• joernweissenborn/eventual2go - Streams and Futures for Go.
  ( 2018-01-18 / 108 commits / 3 stars )
• joernweissenborn/future2go - A dart/javscript like Future/Promise API for Go
  ( 2015-05-20 / 8 commits / 0 stars )
• joernweissenborn/stream2go - A dart/javscript like Stream API for Go
  ( 2015-05-21 / 5 commits / 0 stars )
• jorgeolivero/hub - RPC & Streaming Library
  ( 2016-06-10 / 8 commits / 0 stars )
• jprichardson/readline-go - golang: Easily read lines from a stream such as stdin for a file. Supports either \n, \r\n, or mixed.
  ( 2014-11-25 / 7 commits / 18 stars )
• k0kubun/thunderbolt - Twitter client using Streaming API in Go language
  ( 2018-08-16 / 69 commits / 12 stars )
• karrick/gobsp - go binary streaming protocol
  ( 2018-04-27 / 17 commits / 1 stars )
• kevin-cantwell/logio - A server/client implementation for streaming logs over a network.
  ( 2016-12-13 / 15 commits / 4 stars )
• kho/stream - Iteratee and Enumerator in Go
  ( 2014-10-14 / 10 commits / 0 stars )
• klauspost/dedup - Streaming Deduplication Package for Go
  ( 2018-02-11 / 88 commits / 130 stars )
• kylef-archive/goreactive - Go library for Functional Reactive Programming, a library for representing and consuming asyncronous data streams with Observables
  ( 2015-08-20 / 11 commits / 15 stars )
• l0vest0rm/gostream - message/event streaming process with golang
  ( 2017-04-25 / 55 commits / 0 stars )
• libp2p/go-stream-muxer - stream multiplexor interface
  ( 2018-06-11 / 60 commits / 20 stars )
• mateuszdyminski/am-pipeline - Simple data pipeline showing how to create full text search over some dataset
  ( 2018-03-01 / 11 commits / 6 stars )
• mateuszdyminski/gomr - Simple map-reduce framework based on https://tip.golang.org/pkg/plugin/
  ( 2016-12-13 / 6 commits / 2 stars )
• mateuszdyminski/ordered-streams - Solution for sorting problem of infinite integers streams
  ( 2015-11-05 / 2 commits / 0 stars )
• matttproud/golang_protobuf_extensions - Support for streaming Protocol Buffer messages for the Go language (golang).
  ( 2016-04-24 / 25 commits / 22 stars )
• mechmind/sproc-go - The stream processor
  ( 2016-01-25 / 11 commits / 0 stars )
• mendsley/queuedwriter - io.Writer wrapper that buffers writes instead of blocking on the underlying stream
  ( 2015-04-02 / 8 commits / 0 stars )
• movio/kasper - Kasper is a lightweight library for processing Kafka topics.
  ( 2017-07-23 / 315 commits / 334 stars )
• myntra/pipeline - Pipeline is a package to build multi-staged concurrent workflows with a centralized logging output.
  ( 2018-06-18 / 23 commits / 310 stars )
• nats-io/go-nats-streaming - NATS Streaming System
  ( 2018-07-02 / 349 commits / 227 stars )
• nats-io/nats-streaming-server - NATS Streaming System Server
  ( 2018-08-15 / 1,187 commits / 968 stars )
• netlify/streamer - tail files and send them to nats
  ( 2016-10-19 / 15 commits / 8 stars )
• nsaje/dagger - Dynamic decentralized realtime stream processing framework
  ( 2016-03-09 / 158 commits / 13 stars )
• olivere/streaming-bulk - PoC for Elastic streaming bulk.
  ( 2016-12-07 / 1 commits / 1 stars )
• ooclab/es - Easy session/stream protocol
  ( 2018-04-04 / 98 commits / 8 stars )
• originalgremlin/stream - Stream processing framework in Go.
  ( 2017-03-01 / 3 commits / 0 stars )
• orivej/tcpassembly - Bidirectional TCP stream reassembly for gopacket/tcpassembly
  ( 2015-12-13 / 8 commits / 1 stars )
• otoolep/syslog-gollector - Syslog Collector written in Go, streams to Kafka 0.8
  ( 2018-06-12 / 102 commits / 123 stars )
• pdalinis/kinesisposter - Read from a Kinesis stream and conditionally perform http posts
  ( 2016-12-16 / 3 commits / 0 stars )
• progrium/go-streamkit - High level stream plumbing API in Go
  ( 2016-02-08 / 1 commits / 8 stars )
• reactivex/rxgo - Reactive Extensions for the Go language.
  ( 2018-04-27 / 133 commits / 1,506 stars )
• reiver/go-strm - A library that provides an opinionated framework for processing both finite and infinite data tables as streams, for the Go programming language.
  ( 2015-10-19 / 14 commits / 0 stars )
• replaygaming/go-eventsource - Server-sent stream to update game info in real-time
  ( 2018-04-27 / 140 commits / 2 stars )
• rgraphql/magellan - Real-time streaming GraphQL server for Go.
  ( 2017-06-05 / 53 commits / 161 stars )
• rgraphql/rgraphql-demo-server - Demo of Soyuz + Magellan.
  ( 2017-03-28 / 3 commits / 3 stars )
• rgraphql/soyuz - Real-time streaming GraphQL client for the web.
  ( 2018-08-03 / 84 commits / 46 stars )
• rlmcpherson/s3gof3r - Fast, concurrent, streaming access to Amazon S3, including gof3r, a CLI. http://godoc.org/github.com/rlmcpherson/s3gof3r
  ( 2017-02-10 / 273 commits / 942 stars )
• rosscartlidge/stream - stream processing in Go
  ( 2016-11-16 / 14 commits / 0 stars )
• saidinwot/gulf - Concurrent streaming build system in Go.
  ( 2016-04-25 / 28 commits / 1 stars )
• segmentio/throttle - Tool for throttling JSON streams.
  ( 2015-02-21 / 3 commits / 16 stars )
• sensorbee/sensorbee - Lightweight stream processing engine for IoT
  ( 2017-12-31 / 1,682 commits / 148 stars )
• serinth/gcp-twitter-stream - twitter -> pubsub -> big query example
  ( 2017-03-29 / 19 commits / 2 stars )
• shawnohare/go-minhash - Data structures for computing the MinHash signature for streaming data.
  ( 2016-07-13 / 77 commits / 6 stars )
• smartmq/smartmq - A Pub/Sub wrapper service over redis
  ( 2017-02-07 / 5 commits / 0 stars )
• splace/signals - Go language generation, manipulation, storage and streaming of continuous analogue signals.
  ( 2017-12-21 / 491 commits / 5 stars )
• spurge/actionqueuego - Data event stream lib and server
  ( 2017-03-25 / 13 commits / 1 stars )
• stratexio/protostream - Use protobufs efficiently with data streams
  ( 2016-10-31 / 11 commits / 0 stars )
• streadway/quantile - Space efficient streaming quantile estimator
  ( 2015-09-17 / 26 commits / 11 stars )
• suicidejack/kinesis_producer - A high level asynchronous kinesis stream producer that handles buffering and sending to multiple kinesis streams
  ( 2015-06-01 / 5 commits / 0 stars )
• technosophos/drift - An HTTP/2-based streaming PubSub server written in Go.
  ( 2017-03-17 / 17 commits / 4 stars )
• textnode/xml2json - Transform a stream of XML into a stream of JSON, without requiring a schema or structs, written in Go (golang.org)
  ( 2012-08-21 / 9 commits / 12 stars )
• thejerf/strinterp - Morally-correct string and stream interpolation for Go.
  ( 2016-04-23 / 21 commits / 21 stars )
• tideland/gocells - Tideland GoCells (Event Based Applications)
  ( 2017-09-10 / 214 commits / 52 stars )
• toby3d/hitgox - [DISCONTINUED] A simple library on Go for work with smashcast API streaming service
  ( 2018-06-08 / 40 commits / 5 stars )
• trivago/gollum - An n:m message multiplexer written in Go
  ( 2018-08-10 / 2,147 commits / 616 stars )
• tsne/flow - A small message streaming framework for Go.
  ( 2018-07-12 / 20 commits / 2 stars )
• twitchscience/kinsumer - Native Go consumer for AWS Kinesis streams.
  ( 2018-08-14 / 38 commits / 45 stars )
• tylertreat/boomfilters - Probabilistic data structures for processing continuous, unbounded streams.
  ( 2018-08-04 / 145 commits / 960 stars )
• unixpickle/gobplexer - Nested multiplexing for streams of Gobs
  ( 2017-06-06 / 15 commits / 1 stars )
• upworthy/ktail - AWS Kinesis stream tailing package and command line tool
  ( 2016-06-01 / 3 commits / 1 stars )
• urakozz/go-dynamodb-stream-subscriber - Go channel for streaming Dynamodb Updates
  ( 2018-08-03 / 13 commits / 5 stars )
• urjitbhatia/gopipe - A stream-filter like pipeline primitive for go
  ( 2018-02-20 / 26 commits / 2 stars )
• vidog/sewer - Golang asynchronous synchronizable functional reactive streams
  ( 2015-05-25 / 5 commits / 3 stars )
• vividcortex/gohistogram - Streaming approximate histograms in Go
  ( 2016-08-22 / 46 commits / 107 stars )
• vladimirvivien/automi - A stream API for Go (alpha)
  ( 2018-06-01 / 144 commits / 289 stars )
• vsco/autobahn-binlog - A Go package for tailing MySQL v5.5.x binary replication streams.
  ( 2016-09-06 / 3 commits / 47 stars )
• xtaci/sp - Stream Processors on Kafka in Golang
  ( 2017-04-19 / 93 commits / 27 stars )
• yinqiwen/ssf - Simple streaming process framework written in golang.
  ( 2016-01-13 / 28 commits / 0 stars )
• zenhotels/astranet - A Go (golang) library for managing highly concurrent independent network streams.
  ( 2017-01-31 / 111 commits / 74 stars )
• zenhotels/chanserv - Package chanserv is a simple message queue based upon nested Go-lang channels being served using AstraNet.
  ( 2016-11-24 / 53 commits / 33 stars )
• zhexuany/esm-filter - filtering streams via MapReduce framework
  ( 2016-12-13 / 21 commits / 0 stars )
• zph/moresql - MoreSQL streams changes from MongoDB to Postgres in realtime
  ( 2017-08-02 / 38 commits / 6 stars )

By Activity

• jeffail/benthos: 2018-08-16
  A dull, resilient and quick to deploy stream processor
• k0kubun/thunderbolt: 2018-08-16
  Twitter client using Streaming API in Go language
• nats-io/nats-streaming-server: 2018-08-15
  NATS Streaming System Server
• twitchscience/kinsumer: 2018-08-14
  Native Go consumer for AWS Kinesis streams.
• trivago/gollum: 2018-08-10
  An n:m message multiplexer written in Go
• tylertreat/boomfilters: 2018-08-04
  Probabilistic data structures for processing continuous, unbounded streams.
• rgraphql/soyuz: 2018-08-03
  Real-time streaming GraphQL client for the web.
• urakozz/go-dynamodb-stream-subscriber: 2018-08-03
  Go channel for streaming Dynamodb Updates
• brentp/irelate: 2018-08-01
  Streaming relation (overlap, distance, KNN) of (any number of) sorted genomic interval sets. #golang
• harlow/kinesis-connectors: 2018-07-29
  Golang library for consuming Kinesis stream data
• tsne/flow: 2018-07-12
  A small message streaming framework for Go.
• nats-io/go-nats-streaming: 2018-07-02
  NATS Streaming System
• myntra/pipeline: 2018-06-18
  Pipeline is a package to build multi-staged concurrent workflows with a centralized logging output.
• otoolep/syslog-gollector: 2018-06-12
  Syslog Collector written in Go, streams to Kafka 0.8
• libp2p/go-stream-muxer: 2018-06-11
  stream multiplexor interface
• adamdrake/gofstream: 2018-06-10
  Turn a file into a stream (channel) of lines
• toby3d/hitgox: 2018-06-08
  [DISCONTINUED] A simple library on Go for work with smashcast API streaming service
• vladimirvivien/automi: 2018-06-01
  A stream API for Go (alpha)
• abcum/syncr: 2018-05-02
  A rolling, append-only, local and remote data stream library for Go
• reactivex/rxgo: 2018-04-27
  Reactive Extensions for the Go language.
• replaygaming/go-eventsource: 2018-04-27
  Server-sent stream to update game info in real-time
• karrick/gobsp: 2018-04-27
  go binary streaming protocol
• ooclab/es: 2018-04-04
  Easy session/stream protocol
• mateuszdyminski/am-pipeline: 2018-03-01
  Simple data pipeline showing how to create full text search over some dataset
• urjitbhatia/gopipe: 2018-02-20
  A stream-filter like pipeline primitive for go
• klauspost/dedup: 2018-02-11
  Streaming Deduplication Package for Go
• cloudfoundry/noaa: 2018-01-26
  NOAA is a client library to consume metric and log messages from Doppler.
• farsightsec/golang-framestream: 2018-01-24
  Frame Streams implementation in Go
• joernweissenborn/eventual2go: 2018-01-18
  Streams and Futures for Go.
• djherbis/stream: 2018-01-13
  Stream bytes to multiple independent Readers #golang
• sensorbee/sensorbee: 2017-12-31
  Lightweight stream processing engine for IoT
• splace/signals: 2017-12-21
  Go language generation, manipulation, storage and streaming of continuous analogue signals.
• hyperboloide/pipe: 2017-10-29
  A simple Go stream processing library that works like Unix pipes
• fujiwara/kinesis-tailf: 2017-10-24
  tail -f command for Amazon Kinesis Stream
• tideland/gocells: 2017-09-10
  Tideland GoCells (Event Based Applications)
• zph/moresql: 2017-08-02
  MoreSQL streams changes from MongoDB to Postgres in realtime
• movio/kasper: 2017-07-23
  Kasper is a lightweight library for processing Kafka topics.
• jaderdias/movingmedian: 2017-06-11
  Package movingmedian computes the median of a windowed stream of data.
• unixpickle/gobplexer: 2017-06-06
  Nested multiplexing for streams of Gobs
• rgraphql/magellan: 2017-06-05
  Real-time streaming GraphQL server for Go.
• l0vest0rm/gostream: 2017-04-25
  message/event streaming process with golang
• xtaci/sp: 2017-04-19
  Stream Processors on Kafka in Golang
• serinth/gcp-twitter-stream: 2017-03-29
  twitter -> pubsub -> big query example
• rgraphql/rgraphql-demo-server: 2017-03-28
  Demo of Soyuz + Magellan.
• spurge/actionqueuego: 2017-03-25
  Data event stream lib and server
• technosophos/drift: 2017-03-17
  An HTTP/2-based streaming PubSub server written in Go.
• originalgremlin/stream: 2017-03-01
  Stream processing framework in Go.
• itspage/grpc-streaming: 2017-02-11
  GRPC streaming in Go
• bmkessler/streamstats: 2017-02-10
  Streaming stats data structures and algorithms for golang
• rlmcpherson/s3gof3r: 2017-02-10
  Fast, concurrent, streaming access to Amazon S3, including gof3r, a CLI. http://godoc.org/github.com/rlmcpherson/s3gof3r
• anthonynsimon/iceberg: 2017-02-07
  [Not maintained] PubSub message streams over TCP
• smartmq/smartmq: 2017-02-07
  A Pub/Sub wrapper service over redis
• chenyoufu/yfstream: 2017-02-06
  single point json event stream process and alert
• zenhotels/astranet: 2017-01-31
  A Go (golang) library for managing highly concurrent independent network streams.
• pdalinis/kinesisposter: 2016-12-16
  Read from a Kinesis stream and conditionally perform http posts
• jianchen2580/log-stream: 2016-12-14
  streaming kafka logs
• kevin-cantwell/logio: 2016-12-13
  A server/client implementation for streaming logs over a network.
• mateuszdyminski/gomr: 2016-12-13
  Simple map-reduce framework based on https://tip.golang.org/pkg/plugin/
• zhexuany/esm-filter: 2016-12-13
  filtering streams via MapReduce framework
• olivere/streaming-bulk: 2016-12-07
  PoC for Elastic streaming bulk.
• zenhotels/chanserv: 2016-11-24
  Package chanserv is a simple message queue based upon nested Go-lang channels being served using AstraNet.
• rosscartlidge/stream: 2016-11-16
  stream processing in Go
• grpc-ecosystem/grpc-simon-says: 2016-11-09
  Multiplayer Simon Says game using bidirectional gRPC streaming
• hyperboloide/dispatch: 2016-11-05
  Dispatch messages to various pub/sub services with one interface.
• stratexio/protostream: 2016-10-31
  Use protobufs efficiently with data streams
• netlify/streamer: 2016-10-19
  tail files and send them to nats
• bahadley/ssim: 2016-09-22
  Stream simulator for exercising esp
• acquia/fifo2kinesis: 2016-09-19
  Continuously reads data from a named pipe and publishes it to a Kinesis stream.
• vsco/autobahn-binlog: 2016-09-06
  A Go package for tailing MySQL v5.5.x binary replication streams.
• ghthor/filu: 2016-08-28
  Game engine[s] designed around immutable events and stream processing
• vividcortex/gohistogram: 2016-08-22
  Streaming approximate histograms in Go
• shawnohare/go-minhash: 2016-07-13
  Data structures for computing the MinHash signature for streaming data.
• jorgeolivero/hub: 2016-06-10
  RPC & Streaming Library
• brettallred/tumblr-mock-stream: 2016-06-07
  Mock Tumblr Firehose Stream written in Go
• banyek/binlogstreamer: 2016-06-06
  Tool for creating streamed binlog backup with mysqlbinlog utility
• upworthy/ktail: 2016-06-01
  AWS Kinesis stream tailing package and command line tool
• saidinwot/gulf: 2016-04-25
  Concurrent streaming build system in Go.
• matttproud/golang_protobuf_extensions: 2016-04-24
  Support for streaming Protocol Buffer messages for the Go language (golang).
• thejerf/strinterp: 2016-04-23
  Morally-correct string and stream interpolation for Go.
• dmcgowan/streams: 2016-04-09
  Go interface for using multiplexed transports
• nsaje/dagger: 2016-03-09
  Dynamic decentralized realtime stream processing framework
• progrium/go-streamkit: 2016-02-08
  High level stream plumbing API in Go
• ceejsmith/tick-stream-go: 2016-02-02
  Financial price tick streaming service
• mechmind/sproc-go: 2016-01-25
  The stream processor
• yinqiwen/ssf: 2016-01-13
  Simple streaming process framework written in golang.
• orivej/tcpassembly: 2015-12-13
  Bidirectional TCP stream reassembly for gopacket/tcpassembly
• drborges/rivers: 2015-12-02
  Data Stream Processing API for GO
• bradhe/epee: 2015-11-16
  A (very) simple stream processor for golang based on Kafka and protobuf.
• mateuszdyminski/ordered-streams: 2015-11-05
  Solution for sorting problem of infinite integers streams
• reiver/go-strm: 2015-10-19
  A library that provides an opinionated framework for processing both finite and infinite data tables as streams, for the Go programming language.
• streadway/quantile: 2015-09-17
  Space efficient streaming quantile estimator
• ejholmes/pgstream: 2015-09-05
  Log streaming library for Go
• kylef-archive/goreactive: 2015-08-20
  Go library for Functional Reactive Programming, a library for representing and consuming asyncronous data streams with Observables
• facebookgo/runcmd: 2015-06-12
  Package runcmd provides a convenience Run function for exec.Cmd which includes the original command along with the output and error streams.
• suicidejack/kinesis_producer: 2015-06-01
  A high level asynchronous kinesis stream producer that handles buffering and sending to multiple kinesis streams
• vidog/sewer: 2015-05-25
  Golang asynchronous synchronizable functional reactive streams
• joernweissenborn/stream2go: 2015-05-21
  A dart/javscript like Stream API for Go
• joernweissenborn/future2go: 2015-05-20
  A dart/javscript like Future/Promise API for Go
• dgryski/go-entropy: 2015-04-07
  go-entropy -- exact and streaming entropy estimates
• mendsley/queuedwriter: 2015-04-02
  io.Writer wrapper that buffers writes instead of blocking on the underlying stream
• diggs/go-http-stream-reader: 2015-03-20
  Consume long running HTTP streams (e.g. Twitter streams API) in Go
• segmentio/throttle: 2015-02-21
  Tool for throttling JSON streams.
• jmptrader/go_tcp_relay: 2015-01-16
  A TCP server which duplicates a received stream of data received from N clients out to an arbitrary number of consumers.
• hayeah/gowatch: 2014-11-29
  Turn file system events into text stream for processing
• jprichardson/readline-go: 2014-11-25
  golang: Easily read lines from a stream such as stdin for a file. Supports either \n, \r\n, or mixed.
• kho/stream: 2014-10-14
  Iteratee and Enumerator in Go
• dgryski/go-gk: 2014-08-19
  gk: streaming quantiles
• cameront/gokc: 2014-07-31
  A golang library for managing kinesis stream processing
• catalyst-zero/cores-go: 2014-04-03
  CatalystZero Realtime Event Stream
• daneharrigan/streamers: 2014-01-02
  Concept: A distributed worker queue over HTTP
• benlubar/firehose: 2013-05-21
  A constant stream of information.
• textnode/xml2json: 2012-08-21
  Transform a stream of XML into a stream of JSON, without requiring a schema or structs, written in Go (golang.org)
• digaku/ndayak: 2010-12-17
  High performance distributed stream generator

By size

• trivago/gollum: 81.90 MB
  (25.89 MB git / 56.01 MB code)
• acquia/fifo2kinesis: 66.31 MB
  (11.33 MB git / 54.99 MB code)
• mateuszdyminski/am-pipeline: 36.21 MB
  (8.17 MB git / 28.04 MB code)
• replaygaming/go-eventsource: 30.69 MB
  (18.48 MB git / 12.21 MB code)
• splace/signals: 23.92 MB
  (21.80 MB git / 2.12 MB code)
• xtaci/sp: 15.41 MB
  (1.41 MB git / 13.99 MB code)
• nats-io/nats-streaming-server: 15.21 MB
  (6.19 MB git / 9.02 MB code)
• ghthor/filu: 11.68 MB
  (5.97 MB git / 5.72 MB code)
• jeffail/benthos: 11.17 MB
  (8.97 MB git / 2.20 MB code)
• zph/moresql: 10.20 MB
  (2.81 MB git / 7.38 MB code)
• grpc-ecosystem/grpc-simon-says: 9.11 MB
  (3.76 MB git / 5.35 MB code)
• myntra/pipeline: 8.95 MB
  (1.00 MB git / 7.95 MB code)
• sensorbee/sensorbee: 6.02 MB
  (3.93 MB git / 2.08 MB code)
• hyperboloide/pipe: 5.51 MB
  (2.77 MB git / 2.75 MB code)
• brentp/irelate: 4.95 MB
  (2.54 MB git / 2.41 MB code)
• nats-io/go-nats-streaming: 3.82 MB
  (3.59 MB git / 0.23 MB code)
• ooclab/es: 3.57 MB
  (3.25 MB git / 0.32 MB code)
• brettallred/tumblr-mock-stream: 2.92 MB
  (2.91 MB git / 0.00 MB code)
• chenyoufu/yfstream: 2.78 MB
  (0.82 MB git / 1.96 MB code)
• tideland/gocells: 2.53 MB
  (2.36 MB git / 0.17 MB code)
• rosscartlidge/stream: 1.93 MB
  (1.90 MB git / 0.03 MB code)
• mateuszdyminski/gomr: 1.01 MB
  (0.42 MB git / 0.59 MB code)
• vladimirvivien/automi: 0.69 MB
  (0.61 MB git / 0.08 MB code)
• zenhotels/astranet: 0.68 MB
  (0.30 MB git / 0.38 MB code)
• rlmcpherson/s3gof3r: 0.61 MB
  (0.42 MB git / 0.19 MB code)
• suicidejack/kinesis_producer: 0.60 MB
  (0.16 MB git / 0.44 MB code)
• nsaje/dagger: 0.55 MB
  (0.34 MB git / 0.21 MB code)
• rgraphql/soyuz: 0.50 MB
  (0.34 MB git / 0.16 MB code)
• drborges/rivers: 0.48 MB
  (0.38 MB git / 0.10 MB code)
• serinth/gcp-twitter-stream: 0.47 MB
  (0.19 MB git / 0.28 MB code)
• movio/kasper: 0.47 MB
  (0.36 MB git / 0.11 MB code)
• cloudfoundry/noaa: 0.38 MB
  (0.27 MB git / 0.12 MB code)
• reactivex/rxgo: 0.34 MB
  (0.27 MB git / 0.07 MB code)
• tylertreat/boomfilters: 0.33 MB
  (0.17 MB git / 0.16 MB code)
• harlow/kinesis-connectors: 0.28 MB
  (0.24 MB git / 0.04 MB code)
• matttproud/golang_protobuf_extensions: 0.27 MB
  (0.09 MB git / 0.18 MB code)
• tsne/flow: 0.27 MB
  (0.17 MB git / 0.10 MB code)
• rgraphql/magellan: 0.26 MB
  (0.15 MB git / 0.11 MB code)
• joernweissenborn/eventual2go: 0.22 MB
  (0.13 MB git / 0.09 MB code)
• klauspost/dedup: 0.22 MB
  (0.10 MB git / 0.12 MB code)
• twitchscience/kinsumer: 0.22 MB
  (0.11 MB git / 0.11 MB code)
• libp2p/go-stream-muxer: 0.21 MB
  (0.19 MB git / 0.02 MB code)
• toby3d/hitgox: 0.20 MB
  (0.13 MB git / 0.08 MB code)
• bmkessler/streamstats: 0.19 MB
  (0.09 MB git / 0.10 MB code)
• yinqiwen/ssf: 0.18 MB
  (0.09 MB git / 0.10 MB code)
• mechmind/sproc-go: 0.17 MB
  (0.09 MB git / 0.08 MB code)
• abcum/syncr: 0.17 MB
  (0.09 MB git / 0.08 MB code)
• vsco/autobahn-binlog: 0.16 MB
  (0.06 MB git / 0.10 MB code)
• cameront/gokc: 0.14 MB
  (0.09 MB git / 0.05 MB code)
• vividcortex/gohistogram: 0.14 MB
  (0.06 MB git / 0.09 MB code)
• thejerf/strinterp: 0.14 MB
  (0.10 MB git / 0.04 MB code)
• l0vest0rm/gostream: 0.14 MB
  (0.11 MB git / 0.02 MB code)
• diggs/go-http-stream-reader: 0.14 MB
  (0.07 MB git / 0.07 MB code)
• smartmq/smartmq: 0.13 MB
  (0.06 MB git / 0.07 MB code)
• otoolep/syslog-gollector: 0.12 MB
  (0.09 MB git / 0.03 MB code)
• karrick/gobsp: 0.12 MB
  (0.07 MB git / 0.05 MB code)
• saidinwot/gulf: 0.12 MB
  (0.06 MB git / 0.05 MB code)
• technosophos/drift: 0.11 MB
  (0.06 MB git / 0.06 MB code)
• farsightsec/golang-framestream: 0.11 MB
  (0.08 MB git / 0.02 MB code)
• bradhe/epee: 0.10 MB
  (0.07 MB git / 0.04 MB code)
• zenhotels/chanserv: 0.10 MB
  (0.07 MB git / 0.03 MB code)
• djherbis/stream: 0.09 MB
  (0.06 MB git / 0.03 MB code)
• originalgremlin/stream: 0.09 MB
  (0.05 MB git / 0.05 MB code)
• spurge/actionqueuego: 0.09 MB
  (0.05 MB git / 0.04 MB code)
• shawnohare/go-minhash: 0.09 MB
  (0.07 MB git / 0.02 MB code)
• progrium/go-streamkit: 0.09 MB
  (0.04 MB git / 0.05 MB code)
• jorgeolivero/hub: 0.08 MB
  (0.05 MB git / 0.03 MB code)
• streadway/quantile: 0.08 MB
  (0.07 MB git / 0.01 MB code)
• k0kubun/thunderbolt: 0.08 MB
  (0.06 MB git / 0.02 MB code)
• digaku/ndayak: 0.08 MB
  (0.05 MB git / 0.03 MB code)
• urjitbhatia/gopipe: 0.07 MB
  (0.05 MB git / 0.02 MB code)
• zhexuany/esm-filter: 0.07 MB
  (0.05 MB git / 0.03 MB code)
• kevin-cantwell/logio: 0.07 MB
  (0.06 MB git / 0.02 MB code)
• anthonynsimon/iceberg: 0.07 MB
  (0.05 MB git / 0.02 MB code)
• fujiwara/kinesis-tailf: 0.07 MB
  (0.05 MB git / 0.02 MB code)
• adamdrake/gofstream: 0.07 MB
  (0.03 MB git / 0.03 MB code)
• catalyst-zero/cores-go: 0.06 MB
  (0.05 MB git / 0.01 MB code)
• ejholmes/pgstream: 0.06 MB
  (0.05 MB git / 0.01 MB code)
• netlify/streamer: 0.06 MB
  (0.05 MB git / 0.01 MB code)
• jaderdias/movingmedian: 0.06 MB
  (0.05 MB git / 0.01 MB code)
• unixpickle/gobplexer: 0.06 MB
  (0.05 MB git / 0.01 MB code)
• dmcgowan/streams: 0.06 MB
  (0.04 MB git / 0.02 MB code)
• bahadley/ssim: 0.05 MB
  (0.04 MB git / 0.01 MB code)
• kho/stream: 0.05 MB
  (0.04 MB git / 0.01 MB code)
• vidog/sewer: 0.05 MB
  (0.03 MB git / 0.02 MB code)
• kylef-archive/goreactive: 0.05 MB
  (0.04 MB git / 0.01 MB code)
• reiver/go-strm: 0.05 MB
  (0.03 MB git / 0.01 MB code)
• urakozz/go-dynamodb-stream-subscriber: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• stratexio/protostream: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• hyperboloide/dispatch: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• banyek/binlogstreamer: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• joernweissenborn/stream2go: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• joernweissenborn/future2go: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• mendsley/queuedwriter: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• orivej/tcpassembly: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• rgraphql/rgraphql-demo-server: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• dgryski/go-gk: 0.04 MB
  (0.03 MB git / 0.01 MB code)
• textnode/xml2json: 0.03 MB
  (0.03 MB git / 0.01 MB code)
• olivere/streaming-bulk: 0.03 MB
  (0.02 MB git / 0.01 MB code)
• ceejsmith/tick-stream-go: 0.03 MB
  (0.03 MB git / 0.00 MB code)
• pdalinis/kinesisposter: 0.03 MB
  (0.02 MB git / 0.01 MB code)
• jianchen2580/log-stream: 0.03 MB
  (0.03 MB git / 0.01 MB code)
• upworthy/ktail: 0.03 MB
  (0.02 MB git / 0.01 MB code)
• mateuszdyminski/ordered-streams: 0.03 MB
  (0.02 MB git / 0.01 MB code)
• itspage/grpc-streaming: 0.03 MB
  (0.02 MB git / 0.01 MB code)
• facebookgo/runcmd: 0.03 MB
  (0.02 MB git / 0.01 MB code)
• jprichardson/readline-go: 0.03 MB
  (0.02 MB git / 0.00 MB code)
• jmptrader/go_tcp_relay: 0.02 MB
  (0.02 MB git / 0.01 MB code)
• benlubar/firehose: 0.02 MB
  (0.02 MB git / 0.00 MB code)
• dgryski/go-entropy: 0.02 MB
  (0.02 MB git / 0.00 MB code)
• hayeah/gowatch: 0.02 MB
  (0.02 MB git / 0.00 MB code)
• daneharrigan/streamers: 0.02 MB
  (0.02 MB git / 0.00 MB code)
• segmentio/throttle: 0.02 MB
  (0.02 MB git / 0.00 MB code)