listener

Documentation

Index

• Variables
• func CreateDirectListener(Context context.Context, URL *url.URL, config *ListenerConfig) (net.Listener, []url.URL, error)
• type ListenerConfig
• type MultiLis
  • func New(Context context.Context) *MultiLis
  • 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

Variables

var (
	// The probing interval for publisher to check the publish status.
	// This is required in case discovery server does not send close signal.
	DiscoveryClientPingInterval = time.Minute
	ErrNoListenerConfigured     = fmt.Errorf("url must contain port= or relay=1 field")

	SessionMinRetryDuration = time.Second
	SessionMaxRetryDuration = time.Minute
)

Functions

func CreateDirectListener

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

RegisterURLListener creates a listener on the given URL. This URL can only be TCP or UDP for direct access cases. Append query `enc=1` for e2e encryption (Only works on TCP).

Types

type ListenerConfig

type ListenerConfig struct {
	IdleUDPTimeout time.Duration
	XConfig        *xconn.Config

	// This will cause receiver returns merged packets.
	GSOGROOptimization bool
}

type MultiLis

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

func New

func New(Context context.Context) *MultiLis

func (*MultiLis) Accept

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

func (*MultiLis) Addr

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

func (*MultiLis) Close

func (l *MultiLis) Close() error

func (*MultiLis) RegisterChannel

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

func (*MultiLis) RegisterListener

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

func (*MultiLis) URLs

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