pkg/

Details

Path	Synopsis
apis
proto/function/v1
proto/function/v1/funcmock Package funcmock is a generated GoMock package.	Package funcmock is a generated GoMock package.
proto/sink/v1
proto/sink/v1/sinkmock Package sinkmock is a generated GoMock package.	Package sinkmock is a generated GoMock package.
function Package function implements the server code for User Defined Function in golang.	Package function implements the server code for User Defined Function in golang.
client
clienttest
examples/counter command
examples/even_odd command
examples/flatmap command
examples/forward_message command
examples/sum command
server
sink Package sink implements the server code for User Defined Sink in golang.	Package sink implements the server code for User Defined Sink in golang.
client
clienttest
examples/log command
server
sourcer
examples/simple_source module