Categorygithub.com/uw-labs/substrateproximo
package
0.0.0-20240327161656-5cd769b67f2b
Repository: https://github.com/uw-labs/substrate.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
24
Dependents
1
Files
593 SLOC

# Functions

No description provided by the author
No description provided by the author

# Constants

OffsetNewest indicates the next appropriate message available on the broker.
OffsetOldest indicates the oldest appropriate message available on the broker.

# Structs

No description provided by the author
AsyncMessageSource represents a proximo message source and implements the substrate.AsyncMessageSource interface.
No description provided by the author
KeepAlive provides configuration for the gRPC keep alive.

# Type aliases

Offset is the type used to specify the initial subscription offset.