# Functions
NewProcessAndForward returns a new ProcessAndForward.
WithBatchSize sets the batch size for forwarding messages to ISB.
WithFlushDuration sets the flush duration for forwarding messages to ISB.
WithGCEventsTracker sets the GCEventsWAL option.
WithWindowType sets the window type option.
# Structs
ProcessAndForward invokes the UDF for each partition separately in a go routine and writes the response to the ISBs.
# Type aliases
No description provided by the author