numaflow-go

module

v0.6.0 Latest Latest Go to latest Published: Dec 15, 2023 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

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

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/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
shared
sideinput
sinker
sourcer
sourcetransformer
sourcer/examples/simple_source Module