numaflow-go

module

v0.7.0 Latest Latest Go to latest Published: Apr 23, 2024 License: Apache-2.0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
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
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/mapstream/v1
apis/proto/mapstream/v1/mapstreammock Package mapstreammock is a generated GoMock package.	Package mapstreammock 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/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.
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
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