numaflow-go

module

v0.11.0 Latest Latest Go to latest Published: Oct 29, 2025 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 ¶

Path	Synopsis
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
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
mapstreamer
reducer
reducestreamer
servingstore
sessionreducer
shared
sideinput
sinker
sourcer
sourcetransformer
sourcer/examples/simple_source module

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