sdkclient

package

v1.2.1 Latest Latest Go to latest Published: May 7, 2024 License: Apache-2.0 Imports: 0 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

Repository

github.com/numaproj/numaflow

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Option
- func WithMaxMessageSize(size int) Option
- func WithUdsSockAddr(addr string) Option
type Options
- func DefaultOptions(address string) *Options
- func (o *Options) MaxMessageSize() int
- func (o *Options) UdsSockAddr() string

Constants ¶

View Source

const (
	UDS                       = "unix"
	WinStartTime              = "x-numaflow-win-start-time"
	WinEndTime                = "x-numaflow-win-end-time"
	DefaultGRPCMaxMessageSize = 64 * 1024 * 1024

	// Socket configs
	MapAddr               = "/var/run/numaflow/map.sock"
	MapStreamAddr         = "/var/run/numaflow/mapstream.sock"
	ReduceAddr            = "/var/run/numaflow/reduce.sock"
	ReduceStreamAddr      = "/var/run/numaflow/reducestream.sock"
	SessionReduceAddr     = "/var/run/numaflow/sessionreduce.sock"
	SideInputAddr         = "/var/run/numaflow/sideinput.sock"
	SinkAddr              = "/var/run/numaflow/sink.sock"
	FbSinkAddr            = "/var/run/numaflow/fb-sink.sock"
	SourceAddr            = "/var/run/numaflow/source.sock"
	SourceTransformerAddr = "/var/run/numaflow/sourcetransform.sock"
	MultiProcAddr         = "/var/run/numaflow/multiproc"

	// Server information file configs
	MapServerInfoFile               = "/var/run/numaflow/mapper-server-info"
	MapStreamServerInfoFile         = "/var/run/numaflow/mapstreamer-server-info"
	ReduceServerInfoFile            = "/var/run/numaflow/reducer-server-info"
	ReduceStreamServerInfoFile      = "/var/run/numaflow/reducestreamer-server-info"
	SessionReduceServerInfoFile     = "/var/run/numaflow/sessionreducer-server-info"
	SideInputServerInfoFile         = "/var/run/numaflow/sideinput-server-info"
	SinkServerInfoFile              = "/var/run/numaflow/sinker-server-info"
	FbSinkServerInfoFile            = "/var/run/numaflow/fb-sinker-server-info"
	SourceServerInfoFile            = "/var/run/numaflow/sourcer-server-info"
	SourceTransformerServerInfoFile = "/var/run/numaflow/sourcetransformer-server-info"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Option ¶ added in v1.2.0

type Option func(*Options)

Option is the interface to apply Options.

func WithMaxMessageSize ¶ added in v1.2.0

func WithMaxMessageSize(size int) Option

WithMaxMessageSize sets the server max receive message size and the server max send message size to the given size.

func WithUdsSockAddr ¶ added in v1.2.0

func WithUdsSockAddr(addr string) Option

WithUdsSockAddr start the client with the given UDS sock addr. This is mainly used for testing purpose.

type Options ¶ added in v1.2.0

type Options struct {
	// contains filtered or unexported fields
}

func DefaultOptions ¶ added in v1.2.0

func DefaultOptions(address string) *Options

DefaultOptions returns the default options.

func (*Options) MaxMessageSize ¶ added in v1.2.0

func (o *Options) MaxMessageSize() int

MaxMessageSize returns the max message size.

func (*Options) UdsSockAddr ¶ added in v1.2.0

func (o *Options) UdsSockAddr() string

UdsSockAddr returns the UDS sock addr.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
error
grpc
grpc_resolver
mapper
mapstreamer
reducer
serverinfo
sessionreducer
sideinput
sinker
source
sourcetransformer

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