httpz

Documentation

Index

• Constants
• func RemoveConnectionHeaders(h http.Header)
• func RunServer(ctx context.Context, srv *http.Server, listener net.Listener, ...) error
• type ContextConn
  • func NewContextConn(conn net.Conn) *ContextConn
  • func (c *ContextConn) Close() error
  • func (c *ContextConn) CloseOnDone(ctx context.Context)
• type Limiter
• type RateLimitingRoundTripper
  • func (r *RateLimitingRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)
• type UpgradeRoundTripper
  • func (u *UpgradeRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)
• type WriteTimeoutConn
  • func (c *WriteTimeoutConn) Write(b []byte) (int, error)

Constants

const (
	ConnectionHeader         = "Connection" // https://datatracker.ietf.org/doc/html/rfc7230#section-6.1
	ProxyConnectionHeader    = "Proxy-Connection"
	KeepAliveHeader          = "Keep-Alive"
	HostHeader               = "Host"
	ProxyAuthenticateHeader  = "Proxy-Authenticate"
	ProxyAuthorizationHeader = "Proxy-Authorization"
	TeHeader                 = "Te"      // canonicalized version of "TE"
	TrailerHeader            = "Trailer" // not Trailers as per rfc2616; See errata https://www.rfc-editor.org/errata_search.php?eid=4522
	TransferEncodingHeader   = "Transfer-Encoding"
	UpgradeHeader            = "Upgrade" // https://datatracker.ietf.org/doc/html/rfc7230#section-6.7
	UserAgentHeader          = "User-Agent"
	AuthorizationHeader      = "Authorization"
	ContentTypeHeader        = "Content-Type"
	AcceptHeader             = "Accept"
	ServerHeader             = "Server"
	ViaHeader                = "Via" // https://datatracker.ietf.org/doc/html/rfc7230#section-5.7.1
)

These headers must be in their canonical form. Only add headers used in production code, don't bother with tests.

Functions

func RemoveConnectionHeaders

func RemoveConnectionHeaders(h http.Header)

RemoveConnectionHeaders removes hop-by-hop headers listed in the "Connection" header of h. See https://datatracker.ietf.org/doc/html/rfc7230#section-6.1

func RunServer

func RunServer(ctx context.Context, srv *http.Server, listener net.Listener, listenerGracePeriod, shutdownTimeout time.Duration) error

Types

type ContextConn

type ContextConn struct {
	net.Conn
	// contains filtered or unexported fields
}

ContextConn is a wrapper around net.Conn that can be used to tie connection lifetime to context cancellation.

func NewContextConn

func NewContextConn(conn net.Conn) *ContextConn

func (*ContextConn) Close

func (c *ContextConn) Close() error

func (*ContextConn) CloseOnDone

func (c *ContextConn) CloseOnDone(ctx context.Context)

type Limiter

type Limiter interface {
	// Wait blocks until limiter permits an event to happen.
	// It returns an error if the Context is
	// canceled, or the expected wait time exceeds the Context's Deadline.
	Wait(context.Context) error
}

Limiter defines the interface to perform client-side request rate limiting. You can use golang.org/x/time/rate.Limiter as an implementation of this interface.

type RateLimitingRoundTripper

type RateLimitingRoundTripper struct {
	Delegate http.RoundTripper
	Limiter  Limiter
}

func (*RateLimitingRoundTripper) RoundTrip

func (r *RateLimitingRoundTripper) RoundTrip(request *http.Request) (*http.Response, error)

type UpgradeRoundTripper

type UpgradeRoundTripper struct {
	// Dialer is the dialer used to connect.
	Dialer *net.Dialer

	// TlsDialer is the dialer used to connect over TLS.
	TlsDialer *tls.Dialer

	// Conn is the underlying network connection to the remote server.
	Conn net.Conn

	// ConnReader is a buffered reader for Conn.
	// It may contain some data that has been buffered from Conn while reading the server's response.
	ConnReader *bufio.Reader
}

UpgradeRoundTripper allows to access the underlying network connection after round tripping a request/response. A http.RoundTripper must be safe for concurrent use by multiple goroutines, but this implementation is not. It does not pool network connections so it's not worth the complexity. Instead, the using code must use a new instance for each request. See http://golang.org/pkg/net/http/#RoundTripper

func (*UpgradeRoundTripper) RoundTrip

func (u *UpgradeRoundTripper) RoundTrip(req *http.Request) (*http.Response, error)

type WriteTimeoutConn

type WriteTimeoutConn struct {
	net.Conn
	Timeout time.Duration
}

func (*WriteTimeoutConn) Write

func (c *WriteTimeoutConn) Write(b []byte) (int, error)