proxy

type Pipe ¶

type Pipe interface {
	Run(ctx context.Context) error
}

A generalize representation of a pipe A pipe represents a stream of proxy traffic for a given session, either "up" (from client to upstream", or "down" (from upstream back to client)

func NewDelayedPipe(src net.Conn, dst net.Conn, delay time.Duration) Pipe

func NewSimplePipe(src net.Conn, dst net.Conn) Pipe

type Server ¶

type Server interface {
	Run(context.Context) error
}

func NewTcpDelayServer(listenPort int, upDelay time.Duration, downDelay time.Duration, randomizeDelay bool, upstreamAddr string) Server

type Session ¶

type Session interface {
	Run(ctx context.Context) error
}

func NewDelayedSession(upDelay time.Duration, downDelay time.Duration, clientConn net.Conn, upStreamAddr string) Session