netutil

Documentation

Index

• Variables
• func Hash(backends []*ReverseProxyBackend) (*reverseHash, error)
• func Least(backends []*ReverseProxyBackend) (*reverseLeast, error)
• func Random(backends []*ReverseProxyBackend) (*reverseRandom, error)
• func RoundRobin(backends []*ReverseProxyBackend) (*reverseRoundRobin, error)
• type Balancer
• type ReverseProxyBackend
  • func NewReverseProxyBackend(rawBack string, target *url.URL, weight int, transport http.RoundTripper) *ReverseProxyBackend
  • func (this *ReverseProxyBackend) ServeHTTP(rw http.ResponseWriter, req *http.Request)
  • func (this *ReverseProxyBackend) String() string
• type Server
  • func NewServer(svr *http.Server) *Server
  • func (this *Server) Close()
  • func (this *Server) Run() error
• type Transport
  • func NewTransport(opt TransportOpt) *Transport
  • func (this *Transport) RoundTrip(req *http.Request) (*http.Response, error)
• type TransportOpt

Variables

var NextProtos = []string{http2.NextProtoTLS}

Functions

func Hash

func Hash(backends []*ReverseProxyBackend) (*reverseHash, error)

func Least

func Least(backends []*ReverseProxyBackend) (*reverseLeast, error)

func Random

func Random(backends []*ReverseProxyBackend) (*reverseRandom, error)

func RoundRobin

func RoundRobin(backends []*ReverseProxyBackend) (*reverseRoundRobin, error)

Types

type Balancer

type Balancer interface {
	Pick(req *http.Request) http.Handler
}

type ReverseProxyBackend

type ReverseProxyBackend struct {
	Weight int

	Count int64
	// contains filtered or unexported fields
}

func NewReverseProxyBackend

func NewReverseProxyBackend(rawBack string, target *url.URL, weight int, transport http.RoundTripper) *ReverseProxyBackend

func (*ReverseProxyBackend) ServeHTTP

func (this *ReverseProxyBackend) ServeHTTP(rw http.ResponseWriter, req *http.Request)

func (*ReverseProxyBackend) String

func (this *ReverseProxyBackend) String() string

type Server

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

func NewServer

func NewServer(svr *http.Server) *Server

func (*Server) Close

func (this *Server) Close()

func (*Server) Run

func (this *Server) Run() error

type Transport

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

func NewTransport

func NewTransport(opt TransportOpt) *Transport

func (*Transport) RoundTrip

func (this *Transport) RoundTrip(req *http.Request) (*http.Response, error)

type TransportOpt

type TransportOpt struct {
	Trailer         []string
	AllowHTTP       bool
	TLSClientConfig *tls.Config
}