Categorygithub.com/uw-labs/substrate-toolsbatch
package
0.0.0-20210726101027-7ea25c77a95e
Repository: https://github.com/uw-labs/substrate-tools.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
6
Dependents
0
Files
122 SLOC

# Functions

NewMessageSource returns a batch message source,.
WithMaxWait specifies the longest time the source should wait until it gets a full batch.
WithSize specifies batch size.

# Constants

Default configuration for the batch message source.
Default configuration for the batch message source.

# Interfaces

MessageSource is a wrapper for substrate.AsyncMessageSource that hides the channel usage and instead allows the user to consume messages in batches.

# Type aliases

ConsumerMessageHandler represents a consumer that processes messages un batches.
The MessageSourceOption type defines a function that modifies a field of the batchMessageSource type.