listener

Oct 15, 2024

Changes in this version

+ var DynamicAddressStateMonitorInterval = time.Minute

+ type DynamicAddressGetter = func() ([]url.URL, error)

Jul 20, 2024

Changes in this version

+ var SessionMaxRetryDuration = time.Minute

+ var SessionMinRetryDuration = time.Second

+ type MultiLis struct

+ func (l *MultiLis) Accept() (net.Conn, error)

+ func (l *MultiLis) Addr() net.Addr

+ func (l *MultiLis) Close() error

+ func (l *MultiLis) RegisterChannel(channel string, discoveryDialer func() (net.Conn, error))

+ func (l *MultiLis) RegisterListener(alias string, listenerCreator func() (net.Listener, []url.URL, error))

+ func (l *MultiLis) URLs() []url.URL

May 26, 2024

Changes in this version

+ var DiscoveryClientPingInterval = time.Minute

+ var ErrNoListenerConfigured = fmt.Errorf("url must contain port= or relay=1 field")

+ func CreateDirectListener(Context context.Context, URL *url.URL, config *ListenerConfig) (net.Listener, []url.URL, error)

+ type ListenerConfig struct

+ GSOGROOptimization bool

+ IdleUDPTimeout time.Duration

+ XConfig *xconn.Config

+ type MultiListener struct

+ func New(Context context.Context) *MultiListener

+ func (l *MultiListener) Accept() (net.Conn, error)

+ func (l *MultiListener) Addr() net.Addr

+ func (l *MultiListener) AllURLs() []url.URL

+ func (l *MultiListener) Close() error

+ func (l *MultiListener) Initialize() error

+ func (l *MultiListener) PublishToDiscoveryServer(DiscoveryServerConn net.Conn, Channel string) error

+ func (l *MultiListener) RegisterListener(InnerListener net.Listener, URL []url.URL) error