server

Documentation

Index

• Constants
• Variables
• type ContextCancel
• type DialOption
• type Forwarder
  • func NewForwarder(opts ForwarderOptions) (*Forwarder, error)
  • func (s *Forwarder) Close() error
  • func (s *Forwarder) Serve() (err error)
• type ForwarderOptions
• type InFlightUnderlayKey
  • func NewInFlightUnderlayKey(ttl time.Duration) *InFlightUnderlayKey
  • func (i *InFlightUnderlayKey) Evict(k [juicity.UnderlaySaltLen]byte) *juicity.UnderlayAuth
  • func (i *InFlightUnderlayKey) Store(k [juicity.UnderlaySaltLen]byte, auth *juicity.UnderlayAuth)
• type Mixed
  • func NewMixed(s string, d netproxy.Dialer) (*Mixed, error)
  • func (m *Mixed) ListenAndServe()
  • func (m *Mixed) Serve(c net.Conn)
• type Options
• type Server
  • func New(opts *Options) (*Server, error)
  • func (s *Server) Serve(addr string) (err error)
• type UdpEndpoint
  • func (ue *UdpEndpoint) Close() error
  • func (ue *UdpEndpoint) WriteTo(b []byte, addr string) (int, error)
• type UdpEndpointOptions
• type UdpEndpointPool
  • func NewUdpEndpointPool() *UdpEndpointPool
  • func (p *UdpEndpointPool) GetOrCreate(lAddr netip.AddrPort, createOption *UdpEndpointOptions) (udpEndpoint *UdpEndpoint, isNew bool, err error)
  • func (p *UdpEndpointPool) Remove(lAddr netip.AddrPort, udpEndpoint *UdpEndpoint) (err error)
• type UdpHandler

Constants

const (
	AuthenticateTimeout = 10 * time.Second
	AcceptTimeout       = AuthenticateTimeout
)

Variables

var (
	ErrUnexpectedVersion    = fmt.Errorf("unexpected version")
	ErrUnexpectedCmdType    = fmt.Errorf("unexpected cmd type")
	ErrAuthenticationFailed = fmt.Errorf("authentication failed")
	ErrDisabledTrafficType  = fmt.Errorf("disabled traffic type")
)

var DefaultUdpEndpointPool = NewUdpEndpointPool()

Types

type ContextCancel

type ContextCancel struct {
	Ctx    context.Context
	Cancel func()
}

type DialOption

type DialOption struct {
	Target   string
	Dialer   netproxy.Dialer
	Metadata any
}

type Forwarder

type Forwarder struct {
	ForwarderOptions
	// contains filtered or unexported fields
}

func NewForwarder

func NewForwarder(opts ForwarderOptions) (*Forwarder, error)

func (*Forwarder) Close

func (s *Forwarder) Close() error

func (*Forwarder) Serve

func (s *Forwarder) Serve() (err error)

type ForwarderOptions

type ForwarderOptions struct {
	Logger     *log.Logger
	Dialer     netproxy.Dialer
	LocalAddr  string
	RemoteAddr string
}

type InFlightUnderlayKey

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

func NewInFlightUnderlayKey

func NewInFlightUnderlayKey(ttl time.Duration) *InFlightUnderlayKey

func (*InFlightUnderlayKey) Evict

func (i *InFlightUnderlayKey) Evict(k [juicity.UnderlaySaltLen]byte) *juicity.UnderlayAuth

func (*InFlightUnderlayKey) Store

func (i *InFlightUnderlayKey) Store(k [juicity.UnderlaySaltLen]byte, auth *juicity.UnderlayAuth)

type Mixed

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

Mixed struct.

func NewMixed

func NewMixed(s string, d netproxy.Dialer) (*Mixed, error)

NewMixed returns a mixed proxy.

func (*Mixed) ListenAndServe

func (m *Mixed) ListenAndServe()

ListenAndServe listens on server's addr and serves connections.

func (*Mixed) Serve

func (m *Mixed) Serve(c net.Conn)

Serve serves connections.

type Options

type Options struct {
	Logger                *log.Logger
	Users                 map[string]string
	Certificate           string
	PrivateKey            string
	CongestionControl     string
	Fwmark                int
	SendThrough           string
	DialerLink            string
	DisableOutboundUdp443 bool
}

type Server

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

func New

func New(opts *Options) (*Server, error)

func (*Server) Serve

func (s *Server) Serve(addr string) (err error)

type UdpEndpoint

type UdpEndpoint struct {
	NatTimeout time.Duration

	Dialer     netproxy.Dialer
	Metadata   any
	DialTarget string
	// contains filtered or unexported fields
}

func (*UdpEndpoint) Close

func (ue *UdpEndpoint) Close() error

func (*UdpEndpoint) WriteTo

func (ue *UdpEndpoint) WriteTo(b []byte, addr string) (int, error)

type UdpEndpointOptions

type UdpEndpointOptions struct {
	Handler    UdpHandler
	NatTimeout time.Duration
	// GetTarget is useful only if the underlay does not support Full-cone.
	GetDialOption func() (option *DialOption, err error)
}

type UdpEndpointPool

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

UdpEndpointPool is a full-cone udp conn pool

func NewUdpEndpointPool

func NewUdpEndpointPool() *UdpEndpointPool

func (*UdpEndpointPool) GetOrCreate

func (p *UdpEndpointPool) GetOrCreate(lAddr netip.AddrPort, createOption *UdpEndpointOptions) (udpEndpoint *UdpEndpoint, isNew bool, err error)

func (*UdpEndpointPool) Remove

func (p *UdpEndpointPool) Remove(lAddr netip.AddrPort, udpEndpoint *UdpEndpoint) (err error)

type UdpHandler

type UdpHandler func(data []byte, from netip.AddrPort, metadata any) error