Categorygithub.com/numaproj/numaflowpkgsharedidlehandler
package
1.3.2
Repository: https://github.com/numaproj/numaflow.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
10
Dependents
5
Files
147 SLOC

# Functions

NewSourceIdleHandler creates a new instance of SrcIdleHandler.
PublishIdleWatermark publishes a ctrl message with isb.Kind set to WMB.

# Structs

SourceIdleHandler handles operations related to idle watermarks for source.