variantproxy

Documentation

Index

• Constants
• Variables
• type CuriousResponseWriter
  • func NewCuriousResponseWriter(rw http.ResponseWriter) *CuriousResponseWriter
  • func (crw *CuriousResponseWriter) Header() http.Header
  • func (crw *CuriousResponseWriter) Write(bytes []byte) (int, error)
  • func (crw *CuriousResponseWriter) WriteHeader(h int)
• type Node
  • func NewNode(nodeConfig *config.Node) *Node
  • func (n *Node) Load() float64
  • func (n *Node) ServeHTTP(w http.ResponseWriter, incomingRequest *http.Request)
• type Proxy
  • func NewProxy(c []*config.Node) *Proxy
  • func (p *Proxy) ResolveNode(incomingRequest *http.Request) (n *Node, cookieName string, sessionID string)
  • func (p *Proxy) Serve(w http.ResponseWriter, incomingRequest *http.Request) (sessionID string, cookieName string, err error)
• type SnifferResponseWriter
  • func (srw *SnifferResponseWriter) Header() http.Header
  • func (srw *SnifferResponseWriter) Write(bytes []byte) (int, error)
  • func (srw *SnifferResponseWriter) WriteHeader(code int)

Constants

const (
	NodeHeaderKey = "Server-Node"
)

Variables

var CloseIdleProxyTransportConnectionsAfter = time.Second * 60

var Debug = false

Debug enable debugging for this package

Types

type CuriousResponseWriter

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

func NewCuriousResponseWriter

func NewCuriousResponseWriter(rw http.ResponseWriter) *CuriousResponseWriter

func (*CuriousResponseWriter) Header

func (crw *CuriousResponseWriter) Header() http.Header

func (*CuriousResponseWriter) Write

func (crw *CuriousResponseWriter) Write(bytes []byte) (int, error)

func (*CuriousResponseWriter) WriteHeader

func (crw *CuriousResponseWriter) WriteHeader(h int)

type Node

type Node struct {
	Server            string
	URL               *url.URL
	SessionCookieName string
	ID                string

	Hits         int64
	ReverseProxy *httputil.ReverseProxy
	// contains filtered or unexported fields
}

Node of a variant

func NewNode

func NewNode(nodeConfig *config.Node) *Node

func (*Node) Load

func (n *Node) Load() float64

Load calculate current load

func (*Node) ServeHTTP

func (n *Node) ServeHTTP(w http.ResponseWriter, incomingRequest *http.Request)

type Proxy

type Proxy struct {
	Nodes []*Node
}

Proxy a proxy for a variant

func NewProxy

func NewProxy(c []*config.Node) *Proxy

NewProxy constructor

func (*Proxy) ResolveNode

func (p *Proxy) ResolveNode(incomingRequest *http.Request) (n *Node, cookieName string, sessionID string)

func (*Proxy) Serve

func (p *Proxy) Serve(w http.ResponseWriter, incomingRequest *http.Request) (sessionID string, cookieName string, err error)

Serve serve a http request

type SnifferResponseWriter

type SnifferResponseWriter struct {
	SessionId string
	// contains filtered or unexported fields
}

func (*SnifferResponseWriter) Header

func (srw *SnifferResponseWriter) Header() http.Header

func (*SnifferResponseWriter) Write

func (srw *SnifferResponseWriter) Write(bytes []byte) (int, error)

func (*SnifferResponseWriter) WriteHeader

func (srw *SnifferResponseWriter) WriteHeader(code int)