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

# Constants

DefaultFetchLimit is the number of messages to fetch in each select query on a message stream.
DefaultPollInterval is the default time to wait between polls in MessageStream.Next().

# Structs

GlobalFetcher is a fetcher that fetches rows for the entire store.
Store is a MySQL-backed implementation of Ax's messagestore.GloballyOrderedStore interface.
Stream is a MySQL-backed implementation of Ax's messagestore.Stream interface.
StreamFetcher is a fetcher that fetches rows for a specific stream.

# Interfaces

Fetcher is an interface for fetching rows from the message store.