Documentation
¶
Overview ¶
Copyright 2025 Redpanda Data, Inc.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DecorateDialer ¶
func DecorateDialer(d *net.Dialer, conf DialerConfig) error
DecorateDialer applies DialerConfig to a net.Dialer, configuring keep-alive and TCP socket options.
func DecorateListenerConfig ¶ added in v4.59.0
func DecorateListenerConfig(lc *net.ListenConfig, conf ListenerConfig) error
DecorateListenerConfig applies ListenerConfig settings to a net.ListenConfig. This configures socket options like SO_REUSEADDR and SO_REUSEPORT.
func DialerConfigSpec ¶
func DialerConfigSpec() *service.ConfigField
DialerConfigSpec returns the config spec for DialerConfig.
func ListenerConfigSpec ¶ added in v4.60.0
func ListenerConfigSpec() *service.ConfigField
ListenerConfigSpec returns the config spec for ListenerConfig.
Types ¶
type DialerConfig ¶
type DialerConfig struct {
// Timeout is the maximum amount of time a dial will wait for a connect to
// complete. If Deadline is also set, it may fail earlier.
//
// The default is no timeout.
Timeout time.Duration
KeepAliveConfig net.KeepAliveConfig
// TCPUserTimeout is only supported on Linux since 2.6.37, on other
// platforms it's ignored.
// See: https://www.man7.org/linux/man-pages/man7/tcp.7.html.
TCPUserTimeout time.Duration
}
DialerConfig contains TCP socket configuration options used to configure a net.Dialer.
func DialerConfigFromParsed ¶
func DialerConfigFromParsed(pConf *service.ParsedConfig) (DialerConfig, error)
DialerConfigFromParsed creates a DialerConfig from a parsed config.
func (DialerConfig) Validate ¶
func (c DialerConfig) Validate() error
Validate checks that the configuration is valid.
type ListenerConfig ¶ added in v4.59.0
type ListenerConfig struct {
// ReuseAddr enables SO_REUSEADDR, allowing binding to ports in TIME_WAIT state.
// Useful for graceful restarts and config reloads where the server needs to
// rebind to the same port immediately after shutdown.
ReuseAddr bool
// ReusePort enables SO_REUSEPORT, allowing multiple sockets to bind to the same
// port for load balancing across multiple processes/threads.
ReusePort bool
}
ListenerConfig contains TCP listener socket configuration options.
func ListenerConfigFromParsed ¶ added in v4.60.0
func ListenerConfigFromParsed(pConf *service.ParsedConfig) (ListenerConfig, error)
ListenerConfigFromParsed creates a ListenerConfig from a parsed config.
Source Files