numaflow

package

v0.7.0-rc2 Latest Latest Go to latest Published: Apr 18, 2024 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

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
apis
proto/map/v1
proto/map/v1/mapmock Package mapmock is a generated GoMock package.	Package mapmock is a generated GoMock package.
proto/mapstream/v1
proto/mapstream/v1/mapstreammock Package mapstreammock is a generated GoMock package.	Package mapstreammock 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.
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

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