A place to keep useful golang functions and small libraries

Repository for the coredns fanout plugin used by Network Service Mesh

An in-process and in-memory PubSub, Broadcast, EventBus or Fanout implementation with type-safe topics implemented with generics. Respects context.

parallel executes any tasks in parallel by using Golang fanout fanin concurrency pattern

A wrapper of zap supporting file rotating and more humanfriendly console output.

A golang package which provides a fan out style reader writer pipe.

Fan Out design pattern (aka broadcasting channel using generics)

utility to enable flexible ETL scenarios, supports golang plug-in for built-in consumer|transformer|producer options

Broadcast with fanout exchange.

The fastest distributed system to monitor a power plant

Buffered io.Pipe

Golang exercises

Topic based Subscription Feed

Receive rtp packets from udp socket and send to subscribers

MultiplexReader duplicates read operations through to many readers

This code was written for the Medium Article "Using Golang Fan-Out Concurrency Pattern for Splitting Stream by Keys"

ForkJoin implements a fork(fanout) and join(fanin) patterns using goroutines