middle

Documentation

Overview

recover handler for phi mux

Index

• Variables
• func ClientIP(ctx *fasthttp.RequestCtx) string
• func ExpvarHandler(ctx *fasthttp.RequestCtx)
• func FastGetJson(url string, timeOut time.Duration) (*fasthttp.Response, error)
• func FastGetWithSession(url string, timeOut time.Duration, sid string) (*fasthttp.Response, error)
• func FastPostJson(url string, body []byte, timeOut time.Duration) (*fasthttp.Response, error)
• func HostClient()
• func InitExpvarServer()
• func NewGracefulListener(ln net.Listener, maxWaitTime time.Duration) net.Listener
• func PostStruct(url string, body interface{}, timeOut time.Duration) (*fasthttp.Response, error)
• func Recoverer(next phi.RequestHandlerFunc) phi.RequestHandlerFunc
• func UploadClient(uploadUri, filename, fieldname string) (string, error)
• type GracefulListener
  • func (ln *GracefulListener) Accept() (net.Conn, error)
  • func (ln *GracefulListener) Addr() net.Addr
  • func (ln *GracefulListener) Close() error

Variables

var (
	ProxyAddr string
	Log       zerolog.Logger
)

Functions

func ClientIP

func ClientIP(ctx *fasthttp.RequestCtx) string

func ExpvarHandler

func ExpvarHandler(ctx *fasthttp.RequestCtx)

func FastGetJson

func FastGetJson(url string, timeOut time.Duration) (*fasthttp.Response, error)

func FastGetWithSession

func FastGetWithSession(url string, timeOut time.Duration, sid string) (*fasthttp.Response, error)

func FastPostJson

func FastPostJson(url string, body []byte, timeOut time.Duration) (*fasthttp.Response, error)

func HostClient

func HostClient()

func InitExpvarServer

func InitExpvarServer()

func NewGracefulListener

func NewGracefulListener(ln net.Listener, maxWaitTime time.Duration) net.Listener

NewGracefulListener wraps the given listener into 'graceful shutdown' listener.

func PostStruct

func PostStruct(url string, body interface{}, timeOut time.Duration) (*fasthttp.Response, error)

func Recoverer

func Recoverer(next phi.RequestHandlerFunc) phi.RequestHandlerFunc

Recoverer(next phi.HandlerFunc) phi.HandlerFunc

func UploadClient

func UploadClient(uploadUri, filename, fieldname string) (string, error)

Types

type GracefulListener

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

func (*GracefulListener) Accept

func (ln *GracefulListener) Accept() (net.Conn, error)

func (*GracefulListener) Addr

func (ln *GracefulListener) Addr() net.Addr

func (*GracefulListener) Close

func (ln *GracefulListener) Close() error

Close closes the inner listener and waits until all the pending open connections are closed before returning.