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

# Functions

No description provided by the author
NewUDSgRPCBasedUDSource accepts a vertex instance, gRPC client and returns a new GRPCBasedUDSource.
NewUserDefinedSource returns a new user-defined source reader.
No description provided by the author
WithReadTimeout sets the read timeout.

# Structs

GRPCBasedUDSource applies a user-defined source over gRPC connection where server is the UDSource.

# Type aliases

No description provided by the author