numaflow

package

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

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
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
examples/simple_source module
sourcetransformer

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