gofluxMessaging Patterns for Go

Generic, transport-agnostic messaging with acknowledgments, request-reply, pull consumers, composable pipelines, and built-in observability.

Type-Safe Generics

Publisher[T], Subscriber[T], Consumer[T], Requester[Req, Resp] with compile-time type safety. No interface{} casts.

Write handlers once, swap between channels, NATS, JetStream, and HTTP without changing business logic.

Auto-ack by default, explicit Ack/Nak/NakWithDelay/Term per message. Fire-and-forget or at-least-once delivery.

Type-safe Requester and Responder interfaces for synchronous messaging over NATS and HTTP.

Pipe, PipeMap, FanOut, FanIn, RoundRobin for composable message routing, transformation, and distribution.

Tracing and metrics baked into every transport. Span links for async, parent-child for sync. No middleware setup required.