numaflow

package

v0.12.0 Latest Latest Go to latest Published: Jul 3, 2026 License: Apache-2.0 Imports: 1 Imported by: 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

Documentation ¶

Index ¶

type Server

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Server ¶

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

Server is the interface for the all the numaflow servers.

Source Files ¶

View all Source files

interface.go

Directories ¶

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

Path	Synopsis
accumulator Package accumulator implements the server code for accumulate operation.	Package accumulator implements the server code for accumulate operation.
apis
proto/accumulator/v1
proto/accumulator/v1/accumulatoremock Package accumulatormock is a generated GoMock package.	Package accumulatormock is a generated GoMock package.
proto/common
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/serving/v1
proto/serving/v1/servingmock Package servingmock is a generated GoMock package.	Package servingmock 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 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.
examples/simple_source module
sourcetransformer Package sourcetransformer implements the server code for Source Transformer in golang.	Package sourcetransformer implements the server code for Source Transformer in golang.