conn

Documentation

Index

• Variables
• func NewWSConn(conn net.Conn, isServer bool) *wsConn
• type RateLimitedConn
  • func NewRateLimitedConn(conn net.Conn, kbps int64) *RateLimitedConn
  • func (r *RateLimitedConn) Read(p []byte) (int, error)
• type RelayConn
  • func NewRelayConn(clientConn, remoteConn net.Conn, opts ...RelayConnOption) RelayConn
• type RelayConnOption
  • func WithConnType(connType string) RelayConnOption
  • func WithLogger(l *zap.SugaredLogger) RelayConnOption
  • func WithRelayLabel(relayLabel string) RelayConnOption
  • func WithRelayOptions(opts *conf.Options) RelayConnOption
  • func WithRemote(remote *lb.Node) RelayConnOption
• type Stats
  • func (s *Stats) Record(up, down int64)
  • func (s *Stats) String() string
• type UDPListener
  • func NewUDPListener(ctx context.Context, cfg *conf.Config) (*UDPListener, error)
  • func (l *UDPListener) Accept() (*uc, error)
  • func (l *UDPListener) Close() error

Variables

var ErrIdleTimeout = errors.New("connection closed due to idle timeout")

Functions

func NewWSConn

func NewWSConn(conn net.Conn, isServer bool) *wsConn

Types

type RateLimitedConn

type RateLimitedConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func NewRateLimitedConn

func NewRateLimitedConn(conn net.Conn, kbps int64) *RateLimitedConn

func (*RateLimitedConn) Read

func (r *RateLimitedConn) Read(p []byte) (int, error)

type RelayConn

type RelayConn interface {
	// Transport transports data between the client and the remote connection.
	Transport() error
	GetRelayLabel() string
	GetStats() *Stats
	Close() error
}

RelayConn is the interface that represents a relay connection. it contains two connections: clientConn and remoteConn clientConn is the connection from the client to the relay server remoteConn is the connection from the relay server to the remote server and the main function is to transport data between the two connections

func NewRelayConn

func NewRelayConn(clientConn, remoteConn net.Conn, opts ...RelayConnOption) RelayConn

type RelayConnOption

type RelayConnOption func(*relayConnImpl)

func WithConnType

func WithConnType(connType string) RelayConnOption

func WithLogger

func WithLogger(l *zap.SugaredLogger) RelayConnOption

func WithRelayLabel

func WithRelayLabel(relayLabel string) RelayConnOption

func WithRelayOptions

func WithRelayOptions(opts *conf.Options) RelayConnOption

func WithRemote

func WithRemote(remote *lb.Node) RelayConnOption

type Stats

type Stats struct {
	Up               int64
	Down             int64
	HandShakeLatency time.Duration
}

func (*Stats) Record

func (s *Stats) Record(up, down int64)

func (*Stats) String

func (s *Stats) String() string

type UDPListener

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

func NewUDPListener

func NewUDPListener(ctx context.Context, cfg *conf.Config) (*UDPListener, error)

func (*UDPListener) Accept

func (l *UDPListener) Accept() (*uc, error)

func (*UDPListener) Close

func (l *UDPListener) Close() error