package
0.5.0
Repository: https://github.com/jmalloc/ax.git
Documentation: pkg.go.dev

# Structs

GlobalStoreConsumer reads messages from all streams in a message store and forwards them to an application-defined projector to produce a projection.
MessageHandler is an adaptor that presents a Projector as a routing.MessageHandler.

# Interfaces

OffsetStore is an interface for persisting a consumer's current position in a message stream.
Projector is an interface for a specialized form of application-defined message handler which produces a "projection" of state from the messages it receives.