package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev

# Packages

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

# Functions

No description provided by the author
NewDataForward creates a new DataForward.
WithAllowedLateness sets allowedLateness.
WithReadBatchSize sets the read batch size.

# Structs

DataForward is responsible for reading and forwarding the message from ISB to PBQ.
Options for forwarding the message.

# Type aliases

No description provided by the author