proxy

package

v0.0.3 Latest Latest Go to latest Published: Dec 16, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

var HandlerCreators = &registry.Registry[ConnHandlerCreatorFunc]{}

func ConnCopy(dst, src net.Conn, logger logging.Logger, wg *sync.WaitGroup, copyDone chan struct{})

func DuplexCopy(conn, rConn net.Conn, logger logging.Logger, wg *sync.WaitGroup, ch chan struct{})

type ConnHandlerCreatorFunc func(addr string, transportParams url.Values) (ConnHandlerFunc, error)

type ConnHandlerFunc func(incoming net.Conn, logger logging.Logger, wg *sync.WaitGroup, done <-chan struct{})

func CreateDirectDialHandler(addr string, transportParams url.Values) (ConnHandlerFunc, error)

func CreateHandler(addr string, transportParams url.Values) (ConnHandlerFunc, error)

func PrimedDialerToHandler(addr string, dialer N.PrimedDialerFunc) (ConnHandlerFunc, error)

type Endpoint struct {
	Addr            string
	TransportParams url.Values
}

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

func NewProxy(localEndpoint, remoteEndpoint Endpoint, logger logging.Logger, sigChan chan os.Signal) *Proxy

func (c *Proxy) Run() error

func (c *Proxy) Shutdown()