http

Documentation

Index

• type FastHttpProxy
  • func (f *FastHttpProxy) HandleRequest(ctx *fasthttp.RequestCtx)
  • func (f *FastHttpProxy) RewriteQuery(config proxy.RequestConfig, userValues map[string][]byte, requestURI []byte, ...) error
  • func (f *FastHttpProxy) SetUserValues(userValues *map[string][]byte, header fasthttp.RequestHeader, ...)
• type FastStaticProxy
  • func NewFastStaticProxy(config FastStaticProxyConfig) *FastStaticProxy
  • func (f *FastStaticProxy) ListenAndServe(addr string) error
• type FastStaticProxyConfig
• type GraphqlJsonRequest
• type Proxy
  • func NewDefaultProxy(host string, provider proxy.RequestConfigProvider, ...) *Proxy
  • func (p *Proxy) AcceptRequest(userValues map[string][]byte, requestURI []byte, body io.Reader, ...) error
  • func (p *Proxy) AcceptResponse()
  • func (p *Proxy) DispatchRequest(buff *bytes.Buffer) (*http.Response, error)
  • func (p *Proxy) DispatchResponse()
  • func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type StaticProxy
  • func NewStaticProxy(config StaticProxyConfig) *StaticProxy
  • func (s *StaticProxy) ListenAndServe(addr string) error
• type StaticProxyConfig

Types

type FastHttpProxy

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

func (*FastHttpProxy) HandleRequest

func (f *FastHttpProxy) HandleRequest(ctx *fasthttp.RequestCtx)

func (*FastHttpProxy) RewriteQuery

func (f *FastHttpProxy) RewriteQuery(config proxy.RequestConfig, userValues map[string][]byte, requestURI []byte, query []byte, out io.Writer) error

func (*FastHttpProxy) SetUserValues

func (f *FastHttpProxy) SetUserValues(userValues *map[string][]byte, header fasthttp.RequestHeader, addHeaders [][]byte)

type FastStaticProxy

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

func NewFastStaticProxy

func NewFastStaticProxy(config FastStaticProxyConfig) *FastStaticProxy

func (*FastStaticProxy) ListenAndServe

func (f *FastStaticProxy) ListenAndServe(addr string) error

type FastStaticProxyConfig

type FastStaticProxyConfig struct {
	MiddleWares           []middleware.GraphqlMiddleware
	RequestConfigProvider proxy.RequestConfigProvider
}

type GraphqlJsonRequest

type GraphqlJsonRequest struct {
	OperationName string `json:"operationName"`
	Query         string `json:"query"`
}

type Proxy

type Proxy struct {
	RequestConfigProvider proxy.RequestConfigProvider
	Host                  string
	InvokerPool           sync.Pool
	Client                http.Client
	HandleError           func(err error, w http.ResponseWriter)
	BufferPool            sync.Pool
	BufferedReaderPool    sync.Pool
}

func NewDefaultProxy

func NewDefaultProxy(host string, provider proxy.RequestConfigProvider, middlewares ...middleware.GraphqlMiddleware) *Proxy

func (*Proxy) AcceptRequest

func (p *Proxy) AcceptRequest(userValues map[string][]byte, requestURI []byte, body io.Reader, buff *bytes.Buffer) error

func (*Proxy) AcceptResponse

func (p *Proxy) AcceptResponse()

func (*Proxy) DispatchRequest

func (p *Proxy) DispatchRequest(buff *bytes.Buffer) (*http.Response, error)

func (*Proxy) DispatchResponse

func (p *Proxy) DispatchResponse()

func (*Proxy) ServeHTTP

func (p *Proxy) ServeHTTP(w http.ResponseWriter, r *http.Request)

type StaticProxy

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

func NewStaticProxy

func NewStaticProxy(config StaticProxyConfig) *StaticProxy

func (*StaticProxy) ListenAndServe

func (s *StaticProxy) ListenAndServe(addr string) error

type StaticProxyConfig

type StaticProxyConfig struct {
	MiddleWares           []middleware.GraphqlMiddleware
	RequestConfigProvider proxy.RequestConfigProvider
}