sdkclient

Documentation

Index

• Constants
• type Option
  • func WithBatchMapMode() Option
  • func WithMaxMessageSize(size int) Option
  • func WithUdsSockAddr(addr string) Option
• type Options
  • func DefaultOptions(address string) *Options
  • func (o *Options) BatchMapMode() bool
  • func (o *Options) MaxMessageSize() int
  • func (o *Options) UdsSockAddr() string

Constants

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"
	BatchMapAddr          = "/var/run/numaflow/batchmap.sock"

	// Server information file configs
	MapServerInfoFile               = "/var/run/numaflow/mapper-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"
)

Types

type Option

type Option func(*Options)

Option is the interface to apply Options.

func WithBatchMapMode

func WithBatchMapMode() Option

WithBatchMapMode sets the client to batch map mode.

func WithMaxMessageSize

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

func WithUdsSockAddr(addr string) Option

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

type Options

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

func DefaultOptions

func DefaultOptions(address string) *Options

DefaultOptions returns the default options.

func (*Options) BatchMapMode

func (o *Options) BatchMapMode() bool

BatchMapMode returns the batch map mode.

func (*Options) MaxMessageSize

func (o *Options) MaxMessageSize() int

MaxMessageSize returns the max message size.

func (*Options) UdsSockAddr

func (o *Options) UdsSockAddr() string

UdsSockAddr returns the UDS sock addr.