numaflow

package

v0.9.0 Latest Latest Go to latest Published: Nov 8, 2024 License: Apache-2.0 Imports: 1 Imported by: 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 section is empty.

This section is empty.

This section is empty.

type Server interface {
	// Start starts the server.
	Start(ctx context.Context) error
}

Server is the interface for the all the numaflow servers.

Path	Synopsis
apis
proto/map/v1
proto/map/v1/mapmock Package mapmock is a generated GoMock package.	Package mapmock is a generated GoMock package.
proto/reduce/v1
proto/reduce/v1/reducemock Package reducemock is a generated GoMock package.	Package reducemock is a generated GoMock package.
proto/sessionreduce/v1
proto/sessionreduce/v1/sessionreducemock Package sessionreducemock is a generated GoMock package.	Package sessionreducemock is a generated GoMock package.
proto/sideinput/v1
proto/sideinput/v1/sideinputmock Package sideinputmock is a generated GoMock package.	Package sideinputmock is a generated GoMock package.
proto/sink/v1
proto/sink/v1/sinkmock Package sinkmock is a generated GoMock package.	Package sinkmock is a generated GoMock package.
proto/source/v1
proto/source/v1/sourcemock Package sourcemock is a generated GoMock package.	Package sourcemock is a generated GoMock package.
proto/sourcetransform/v1
proto/sourcetransform/v1/transformmock Package transformermock is a generated GoMock package.	Package transformermock is a generated GoMock package.
batchmapper
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
examples/simple_source Module
sourcetransformer