fhttp

Apr 8, 2022

Changes in this version

+ var EnvoyRequestID = textproto.CanonicalMIMEHeaderKey("x-request-id")

+ var TraceHeader = textproto.CanonicalMIMEHeaderKey("b3")

+ var TraceHeadersPrefix = textproto.CanonicalMIMEHeaderKey("x-b3-")

+ func CopyHeaders(req, r *http.Request, all bool)

+ func CreateProxyClient() *http.Client

+ func EchoDebugPath(debugPath string) string

+ func FetcherHandler2(w http.ResponseWriter, r *http.Request)

+ func Gzip(next http.Handler) http.Handler

+ func LogAndCallNoArg(msg string, f func()) http.HandlerFunc

+ func MakeSimpleRequest(url string, r *http.Request, copyAllHeaders bool) *http.Request

+ func MultiServer(port string, cfg *MultiServerConfig) (*http.ServeMux, net.Addr)

+ func OnBehalfOfRequest(to *http.Request, from *http.Request)

+ type GzipResponseWriter struct

+ func NewGzipHTTPResponseWriter(w http.ResponseWriter) *GzipResponseWriter

+ func (w *GzipResponseWriter) Close() error

+ func (w *GzipResponseWriter) Write(b []byte) (int, error)

+ func (w *GzipResponseWriter) WriteHeader(status int)

type HTTPOptions

+ ID int

+ LogErrors bool

+ Resolve string

+ SequentialWarmup bool

+ type MultiServerConfig struct

+ Name string

+ Serial bool

+ Targets []TargetConf

+ func (mcfg *MultiServerConfig) TeeHandler(w http.ResponseWriter, r *http.Request)

+ func (mcfg *MultiServerConfig) TeeParallelHandler(w http.ResponseWriter, r *http.Request, data []byte)

+ func (mcfg *MultiServerConfig) TeeSerialHandler(w http.ResponseWriter, r *http.Request, data []byte)

+ type SyncReader struct

+ func NewSyncReader(reader io.Reader) *SyncReader

+ func (r *SyncReader) Read(p []byte) (n int, err error)

+ type TLSOptions struct

+ CACert string

+ Cert string

+ Insecure bool

+ Key string

+ UnixDomainSocket string

+ func (to *TLSOptions) TLSClientConfig() (*tls.Config, error)

+ type TargetConf struct

+ Destination string

+ MirrorOrigin bool

Aug 13, 2018

Changes in this version

+ func ServeTCP(port, debugPath string) (*http.ServeMux, *net.TCPAddr)

type HTTPOptions

+ ContentType string

+ Payload []byte

+ UnixDomainSocket string

+ func (h *HTTPOptions) AllHeaders() http.Header

+ func (h *HTTPOptions) GenerateHeaders() http.Header

+ func (h *HTTPOptions) Method() string

+ func (h *HTTPOptions) PayloadString() string

Jun 28, 2018

Changes in this version

type HTTPOptions

+ UserCredentials string

+ func (h *HTTPOptions) ValidateAndAddBasicAuthentication() error

Jun 14, 2018

Changes in this version

+ func AddHTTPS(url string) string

Apr 3, 2018

Changes in this version

+ func CacheOn(w http.ResponseWriter)

type HTTPRunnerOptions

+ AbortOn int

type HTTPRunnerResults

+ AbortOn int

Mar 20, 2018

Changes in this version

+ func ChangeMaxPayloadSize(newMaxPayloadSize int)

+ func Fetch(httpOptions *HTTPOptions) (int, []byte)

+ func FetcherHandler(w http.ResponseWriter, r *http.Request)

+ func HTTPServer(name string, port string) (*http.ServeMux, *net.TCPAddr)

+ func LogAndCall(msg string, hf http.HandlerFunc) http.HandlerFunc

+ func LogRequest(r *http.Request, msg string)

+ func NewHTMLEscapeWriter(w io.Writer) io.Writer

+ func OnBehalfOf(o *HTTPOptions, r *http.Request)

+ func RedirectToHTTPS(port string) *net.TCPAddr

+ func RedirectToHTTPSHandler(w http.ResponseWriter, r *http.Request)

+ func SetupPPROF(mux *http.ServeMux)

+ type HTMLEscapeWriter struct

+ Flusher http.Flusher

+ NextWriter io.Writer

+ func (w *HTMLEscapeWriter) Write(p []byte) (int, error)

type HTTPOptions

+ FollowRedirects bool

Mar 5, 2018

Changes in this version

+ const RetryOnce

+ const SocketError

type HTTPOptions

+ func (h *HTTPOptions) InitHeaders()

type HTTPRunnerResults

+ SocketCount int

Mar 1, 2018

Changes in this version

type Client

+ func (c *Client) Close()

+ type FastClient struct

+ func (c *FastClient) Close()

+ func (c *FastClient) Fetch() (int, []byte, int)

type Fetcher

+ func NewFastClient(o *HTTPOptions) Fetcher

+ Close func()

Feb 21, 2018

Changes in this version

+ const MaxPayloadSize

type HTTPOptions

+ Insecure bool

Jan 26, 2018

Changes in this version

type HTTPOptions

+ func (h *HTTPOptions) URLSchemeCheck()

Jan 19, 2018

Changes in this version

type Client

+ func (c *Client) ChangeURL(urlStr string) (err error)

Jan 8, 2018

Changes in this version

+ const HTTPReqTimeOutDefaultValue

+ const MaxDelay

type HTTPOptions

+ HTTPReqTimeOut time.Duration

Dec 19, 2017

Changes in this version

type HTTPRunnerOptions

+ AllowInitialErrors bool

Dec 4, 2017

Changes in this version

type Fetcher

+ func NewClient(o *HTTPOptions) Fetcher

+ type HTTPOptions struct

+ AllowHalfClose bool

+ Compression bool

+ DisableFastClient bool

+ DisableKeepAlive bool

+ HTTP10 bool

+ NumConnections int

+ URL string

+ func NewHTTPOptions(url string) *HTTPOptions

+ func (h *HTTPOptions) AddAndValidateExtraHeader(hdr string) error

+ func (h *HTTPOptions) GetHeaders() http.Header

+ func (h *HTTPOptions) Init(url string) *HTTPOptions

+ func (h *HTTPOptions) ResetHeaders()

type HTTPRunnerResults

+ func (httpstate *HTTPRunnerResults) Run(t int)

Nov 21, 2017

Changes in this version

+ func GetHeaders() http.Header

+ func ResetHeaders()

+ func RoundDuration(d time.Duration) time.Duration

+ func Serve(port int, debugPath string)

type HTTPRunnerOptions

+ AllowHalfClose bool

type HTTPRunnerResults

+ URL string

Oct 13, 2017

Changes in this version

+ const Version

+ var BufferSizeKb = 32

+ var CheckConnectionClosedHeader = false

+ var EchoRequests int64

+ func ASCIIToUpper(str string) []byte

+ func AddAndValidateExtraHeader(h string) error

+ func DebugHandler(w http.ResponseWriter, r *http.Request)

+ func DebugSummary(buf []byte, max int) string

+ func DynamicHTTPServer(secure bool) int

+ func EchoHandler(w http.ResponseWriter, r *http.Request)

+ func EchoServer(port int, debugPath string)

+ func EscapeBytes(buf []byte) string

+ func FetchURL(url string) (int, []byte, int)

+ func FoldFind(haystack []byte, needle []byte) (bool, int)

+ func ParseChunkSize(inp []byte) (int, int)

+ func ParseDecimal(inp []byte) int

+ func TestHTTP(t int)

+ type BasicClient struct

+ func (c *BasicClient) Fetch() (int, []byte, int)

+ type Client struct

+ func (c *Client) Fetch() (int, []byte, int)

+ type Fetcher interface

+ Fetch func() (int, []byte, int)

+ func NewBasicClient(urlStr string, proto string, keepAlive bool) Fetcher

+ func NewStdClient(url string, numConnections int, compression bool) Fetcher

+ type HTTPRunnerOptions struct

+ Compression bool

+ DisableFastClient bool

+ DisableKeepAlive bool

+ HTTP10 bool

+ Profiler string

+ URL string

+ type HTTPRunnerResults struct

+ HeaderSizes *stats.Histogram

+ RetCodes map[int]int64

+ Sizes *stats.Histogram

+ func RunHTTPTest(o *HTTPRunnerOptions) (*HTTPRunnerResults, error)