sdkserverinfo

package

v1.2.0-rc3 Latest Latest Go to latest Published: Apr 9, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/numaproj/numaflow

Links

Documentation ¶

Index ¶

Constants
func SDKServerInfo(inputOptions ...Option) (*info.ServerInfo, error)
type Option
- func WithServerInfoFilePath(f string) Option
- func WithServerInfoReadinessTimeout(t time.Duration) Option
type Options
- func DefaultOptions() *Options
- func (o *Options) ServerInfoFilePath() string
- func (o *Options) ServerInfoReadinessTimeout() time.Duration

Constants ¶

View Source

const (
	// 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"
	SourceServerInfoFile            = "/var/run/numaflow/sourcer-server-info"
	SourceTransformerServerInfoFile = "/var/run/numaflow/sourcetransformer-server-info"
)

Variables ¶

This section is empty.

Functions ¶

func SDKServerInfo ¶

func SDKServerInfo(inputOptions ...Option) (*info.ServerInfo, error)

SDKServerInfo wait for the server to start and return the server info.

Types ¶

type Option ¶

type Option func(*Options)

Option is the interface to apply Options.

func WithServerInfoFilePath ¶

func WithServerInfoFilePath(f string) Option

WithServerInfoFilePath sets the server info file path to the given path.

func WithServerInfoReadinessTimeout ¶

func WithServerInfoReadinessTimeout(t time.Duration) Option

WithServerInfoReadinessTimeout sets the server info readiness timeout to the given timeout.

type Options ¶

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

func DefaultOptions ¶

func DefaultOptions() *Options

DefaultOptions returns the default options.

func (*Options) ServerInfoFilePath ¶

func (o *Options) ServerInfoFilePath() string

ServerInfoFilePath returns the server info file path.

func (*Options) ServerInfoReadinessTimeout ¶

func (o *Options) ServerInfoReadinessTimeout() time.Duration

ServerInfoReadinessTimeout returns the server info readiness timeout.

Source Files ¶

View all Source files

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