agency

Documentation

Index

• Constants
• func ReverseServe(network string, tlsCfg *tls.Config, quicConf *quic.Config, handle http.Handler)
• func ReverseTrans(network string, tlsCfg *tls.Config, quicConf *quic.Config, upstream string)
• type FullDuplexStream
• type Proxy
  • func New(crt, key, ca string, bufsiz, rTimeout, wTimeout int) (*Proxy, error)
  • func (p *Proxy) ListenAndServe(comeFrom, upStream string) error
• type Response
  • func (resp *Response) Flush(body []byte) (int, error)
  • func (resp *Response) Header() http.Header
  • func (resp *Response) Write(body []byte) (int, error)
  • func (resp *Response) WriteHeader(statusCode int)

Constants

const RESPONSE_BUF_SIZ = 512

Functions

func ReverseServe

func ReverseServe(network string, tlsCfg *tls.Config, quicConf *quic.Config, handle http.Handler)

func ReverseTrans

func ReverseTrans(network string, tlsCfg *tls.Config, quicConf *quic.Config, upstream string)

Types

type FullDuplexStream

type FullDuplexStream interface {
	io.ReadWriteCloser
	SetDeadline(t time.Time) error
	SetReadDeadline(t time.Time) error
	SetWriteDeadline(t time.Time) error
}

type Proxy

type Proxy struct {
	TlsCfg       *tls.Config
	QuicConf     *quic.Config
	BufSiz       int
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	// contains filtered or unexported fields
}

func New

func New(crt, key, ca string, bufsiz, rTimeout, wTimeout int) (*Proxy, error)

func (*Proxy) ListenAndServe

func (p *Proxy) ListenAndServe(comeFrom, upStream string) error

type Response

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

func (*Response) Flush

func (resp *Response) Flush(body []byte) (int, error)

func (*Response) Header

func (resp *Response) Header() http.Header

func (*Response) Write

func (resp *Response) Write(body []byte) (int, error)

func (*Response) WriteHeader

func (resp *Response) WriteHeader(statusCode int)