Documentation
¶
Index ¶
Constants ¶
const ( // DefaultShutdownTimeout - default shutdown timeout used for graceful http server shutdown. DefaultShutdownTimeout = 5 * time.Second // DefaultTCPKeepAliveTimeout - default TCP keep alive timeout for accepted connection. DefaultTCPKeepAliveTimeout = 30 * time.Second // DefaultReadTimeout - default timout to read data from accepted connection. DefaultReadTimeout = 5 * time.Minute // DefaultWriteTimeout - default timout to write data to accepted connection. DefaultWriteTimeout = 5 * time.Minute // DefaultMaxHeaderBytes - default maximum HTTP header size in bytes. DefaultMaxHeaderBytes = 1 * humanize.MiByte // DefaultHTTP2MaxConcurrentStreams - default value for HTTP 2.0 maximum concurrent streams allowed. DefaultHTTP2MaxConcurrentStreams = 1024 )
Variables ¶
This section is empty.
Functions ¶
func DrainBody ¶
func DrainBody(respBody io.ReadCloser)
DrainBody close non nil response with any response Body. convenient wrapper to drain any remaining data on response body.
Subsequently this allows golang http RoundTripper to re-use the same connection for future requests.
Types ¶
type BufConn ¶
type BufConn struct {
QuirkConn
// contains filtered or unexported fields
}
BufConn - is a generic stream-oriented network connection supporting buffered reader and read/write timeout.
func (*BufConn) Peek ¶
Peek - returns the next n bytes without advancing the reader. It just wraps bufio.Reader.Peek().
func (*BufConn) RemoveTimeout ¶
func (c *BufConn) RemoveTimeout()
RemoveTimeout - removes all configured read and write timeouts. Used by callers which control net.Conn behavior themselves.
type QuirkConn ¶
QuirkConn - similar to golang net.Conn struct, but contains a workaround of the following the go bug reported here https://github.com/golang/go/issues/21133. Once the bug will be fixed, we can remove this structure and replaces it with the standard net.Conn
type Server ¶
type Server struct {
http.Server
Addrs []string // addresses on which the server listens for new connection.
ShutdownTimeout time.Duration // timeout used for graceful server shutdown.
TCPKeepAliveTimeout time.Duration // timeout used for underneath TCP connection.
UpdateBytesReadFunc func(int) // function to be called to update bytes read in bufConn.
UpdateBytesWrittenFunc func(int) // function to be called to update bytes written in bufConn.
// contains filtered or unexported fields
}
Server - extended http.Server supports multiple addresses to serve and enhanced connection handling.
func (*Server) GetRequestCount ¶
GetRequestCount - returns number of request in progress.
type TimeoutConn ¶
type TimeoutConn struct {
QuirkConn
// contains filtered or unexported fields
}
TimeoutConn - is wrapped net.Conn with read/write timeouts.
func NewTimeoutConn ¶
func NewTimeoutConn(c net.Conn, readTimeout, writeTimeout time.Duration) *TimeoutConn
NewTimeoutConn - creates a new timeout connection.
Source Files