numaflow-go

module

v0.12.0 Latest Latest Go to latest Published: Jul 3, 2026 License: Apache-2.0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/numaproj/numaflow-go

Links

Open Source Insights

README ¶

Numaflow Golang SDK

This SDK provides the interfaces to implement Numaflow User Defined Sources, Source Transformer, Functions, Sinks or SideInputs in Golang.

Implement User Defined Sources
Implement User Defined Source Transformers
Implement User Defined Functions
- Map
- Reduce
Implement User Defined Sinks
Implement User Defined SideInputs

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Path	Synopsis
internal
metadata Package metadata provides shared metadata types for Numaflow SDK components.	Package metadata provides shared metadata types for Numaflow SDK components.
nackoptions Package nackoptions provides the shared per-message nack options type for Numaflow SDK components.	Package nackoptions provides the shared per-message nack options type for Numaflow SDK components.
shared Package shared provides utility functions for implementing Numaflow gRPC servers.	Package shared provides utility functions for implementing Numaflow gRPC servers.
pkg
accumulator Package accumulator implements the server code for accumulate operation.	Package accumulator implements the server code for accumulate operation.
apis/proto/accumulator/v1
apis/proto/accumulator/v1/accumulatoremock Package accumulatormock is a generated GoMock package.	Package accumulatormock is a generated GoMock package.
apis/proto/common
apis/proto/map/v1
apis/proto/map/v1/mapmock Package mapmock is a generated GoMock package.	Package mapmock is a generated GoMock package.
apis/proto/reduce/v1
apis/proto/reduce/v1/reducemock Package reducemock is a generated GoMock package.	Package reducemock is a generated GoMock package.
apis/proto/serving/v1
apis/proto/serving/v1/servingmock Package servingmock is a generated GoMock package.	Package servingmock is a generated GoMock package.
apis/proto/sessionreduce/v1
apis/proto/sessionreduce/v1/sessionreducemock Package sessionreducemock is a generated GoMock package.	Package sessionreducemock is a generated GoMock package.
apis/proto/sideinput/v1
apis/proto/sideinput/v1/sideinputmock Package sideinputmock is a generated GoMock package.	Package sideinputmock 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.
apis/proto/source/v1
apis/proto/source/v1/sourcemock Package sourcemock is a generated GoMock package.	Package sourcemock is a generated GoMock package.
apis/proto/sourcetransform/v1
apis/proto/sourcetransform/v1/transformmock Package transformermock is a generated GoMock package.	Package transformermock is a generated GoMock package.
batchmapper Package batchmapper implements the server code for BatchMap Operation.	Package batchmapper implements the server code for BatchMap Operation.
errors Package related to error handling and utilities	Package related to error handling and utilities
info Package info is used for the gRPC server to provide the information such as protocol, sdk version, language, etc, to the client.	Package info is used for the gRPC server to provide the information such as protocol, sdk version, language, etc, to the client.
mapper Package mapper implements the server code for Map Operation.	Package mapper implements the server code for Map Operation.
mapstreamer Package mapstreamer implements the server code for Map Stream Operation.	Package mapstreamer implements the server code for Map Stream Operation.
reducer Package reducer implements the server code for reduce operation.	Package reducer implements the server code for reduce operation.
reducestreamer Package reduceStreamer implements the server code for reduceStream operation.	Package reduceStreamer implements the server code for reduceStream operation.
servingstore Package servingstore implements the server code for writing user-defined serving store.	Package servingstore implements the server code for writing user-defined serving store.
sessionreducer Package sessionreducer implements the server code for sessionReduce operation.	Package sessionreducer implements the server code for sessionReduce operation.
sideinput package sideinput implements the server code for user-defined SideInputs in golang.	package sideinput implements the server code for user-defined SideInputs in golang.
sinker Package sinker implements the server code for user defined sink.	Package sinker implements the server code for user defined sink.
sourcer Package sourcer implements the server code for User Defined Sourcer in golang.	Package sourcer implements the server code for User Defined Sourcer in golang.
sourcetransformer Package sourcetransformer implements the server code for Source Transformer in golang.	Package sourcetransformer implements the server code for Source Transformer in golang.
sourcer/examples/simple_source module