Retracted

numaflow-go

module

v0.4.1 Latest Latest Go to latest Published: Apr 6, 2023 License: Apache-2.0

Details

This SDK provides the interfaces to implement Numaflow User Defined Functions or Sinks in Golang.

Path	Synopsis
pkg
apis/proto/function/v1
apis/proto/function/v1/funcmock Package funcmock is a generated GoMock package.	Package funcmock is a generated GoMock package.
apis/proto/sink/v1
apis/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.
function/client
function/clienttest
function/examples/assign_event_time command
function/examples/counter command
function/examples/even_odd command
function/examples/event_time_filter command
function/examples/event_time_filter/impl
function/examples/flatmap command
function/examples/forward_message command
function/examples/sum command
function/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.
sink/client
sink/clienttest
sink/examples/log command
sink/server
sourcer/examples/simple_source module