Documentation ¶
Index ¶
- func BeegoOnAbort(bctx *beegoctx.Context, err error)
- func BeegoWithIP(bctx *beegoctx.Context) context.Context
- func EchoOnAbort(ectx echo.Context, err error) error
- func EchoWithIP(ectx echo.Context) context.Context
- func FastOnAbort(fctx *fasthttp.RequestCtx, err error)
- func FastWithIPBackground(fctx *fasthttp.RequestCtx) context.Context
- func GRPCStreamAbort(err error) error
- func GRPCStreamWithEmpty(ctx context.Context, msg interface{}) context.Context
- func GinOnAbort(gctx *gin.Context, err error)
- func GinWithIP(gctx *gin.Context) context.Context
- func IrisOnAbort(ictx iris.Context, err error)
- func IrisWithIP(ictx iris.Context) context.Context
- func KitOnAbort(err error) (interface{}, error)
- func KitWithEmpty(ctx context.Context, req interface{}) context.Context
- func MicroClientWithEmpty(ctx context.Context, req client.Request) context.Context
- func MicroOnAbort(err error) error
- func MicroServerEmpty(ctx context.Context, req server.Request) context.Context
- func MuxOnAbort(w http.ResponseWriter, err error)
- func MuxWithIP(req *http.Request) context.Context
- func NetConnAbort(err error) error
- func NetConnWithBackground() context.Context
- func NewGRPCClientStream(cs grpc.ClientStream, thr gohalt.Throttler, with GRPCStreamWith, ...) grpc.ClientStream
- func NewGrpServerStream(ss grpc.ServerStream, thr gohalt.Throttler, with GRPCStreamWith, ...) grpc.ServerStream
- func NewMicroClient(thr gohalt.Throttler, with MicroClientWith, on MicroOn) client.Wrapper
- func NewMicroHandler(thr gohalt.Throttler, with MicroServerWith, on MicroOn) server.HandlerWrapper
- func NewMiddlewareBeego(thr gohalt.Throttler, with BeegoWith, on BeegoOn) beego.FilterFunc
- func NewMiddlewareEcho(thr gohalt.Throttler, with EchoWith, on EchoOn) echo.MiddlewareFunc
- func NewMiddlewareFast(h fasthttp.RequestHandler, thr gohalt.Throttler, with FastWith, on FastOn) fasthttp.RequestHandler
- func NewMiddlewareGin(thr gohalt.Throttler, with GinWith, on GinOn) gin.HandlerFunc
- func NewMiddlewareIris(thr gohalt.Throttler, with IrisWith, on IrisOn) iris.Handler
- func NewMiddlewareKit(thr gohalt.Throttler, with KitWith, on KitOn) endpoint.Middleware
- func NewMiddlewareMux(h http.Handler, thr gohalt.Throttler, with MuxWith, on MuxOn) http.Handler
- func NewMiddlewareRevel(thr gohalt.Throttler, with RevealWith, on RevealOn) revel.Filter
- func NewMiddlewareRouter(h http.Handler, thr gohalt.Throttler, with RouterWith, on RouterOn) http.Handler
- func NewMiddlewareStd(h http.Handler, thr gohalt.Throttler, with StdWith, on StdOn) http.Handler
- func NewNetConn(conn net.Conn, thr gohalt.Throttler, with NetConnWith, on NetConnOn, ...) net.Conn
- func NewRPCClientCodec(cc rpc.ClientCodec, thr gohalt.Throttler, with RPCCodecWith, on RPCCodecOn) rpc.ClientCodec
- func NewRPCServerCodec(sc rpc.ServerCodec, thr gohalt.Throttler, with RPCCodecWith, on RPCCodecOn) rpc.ServerCodec
- func NewReader(r io.Reader, thr gohalt.Throttler, with RWWith, on RWOn) io.Reader
- func NewRoundTripperStd(rt http.RoundTripper, thr gohalt.Throttler, with RoundTripperStdWith, ...) http.RoundTripper
- func NewWriter(w io.Writer, thr gohalt.Throttler, with RWWith, on RWOn) io.Writer
- func RPCCodecOnAbort(err error) error
- func RPCCodecWithBackground(req *rpc.Request, resp *rpc.Response, msg interface{}) context.Context
- func RWAbort(err error) error
- func RWWithBackground() context.Context
- func RevealOnAbort(rc *revel.Controller, err error) revel.Result
- func RevealWithIP(rc *revel.Controller) context.Context
- func RoundTripperFastBackground(req *fasthttp.Request) context.Context
- func RoundTripperFastOnAbort(err error) error
- func RoundTripperStdOnAbort(err error) error
- func RoundTripperStdWithEmpty(req *http.Request) context.Context
- func RouterOnAbort(w http.ResponseWriter, err error)
- func RouterWithIP(req *http.Request) context.Context
- func SQLClientAbort(err error) error
- func SQLClientQuery(ctx context.Context, query string, args ...interface{}) context.Context
- func StdOnAbort(w http.ResponseWriter, err error)
- func StdWithIP(req *http.Request) context.Context
- type BeegoOn
- type BeegoWith
- type EchoOn
- type EchoWith
- type FastOn
- type FastWith
- type GRPCStreamOn
- type GRPCStreamWith
- type GinOn
- type GinWith
- type IrisOn
- type IrisWith
- type KitOn
- type KitWith
- type MicroClientWith
- type MicroOn
- type MicroServerWith
- type MuxOn
- type MuxWith
- type NetConnMode
- type NetConnOn
- type NetConnWith
- type RPCCodecOn
- type RPCCodecWith
- type RWOn
- type RWWith
- type RevealOn
- type RevealWith
- type RoundTripperFast
- type RoundTripperFastOn
- type RoundTripperFastWith
- type RoundTripperStdOn
- type RoundTripperStdWith
- type RouterOn
- type RouterWith
- type SQLClient
- type SQLClientOn
- type SQLClientWith
- type StdOn
- type StdWith
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BeegoOnAbort ¶
func FastOnAbort ¶
func FastOnAbort(fctx *fasthttp.RequestCtx, err error)
func FastWithIPBackground ¶
func FastWithIPBackground(fctx *fasthttp.RequestCtx) context.Context
func GRPCStreamAbort ¶
func GRPCStreamWithEmpty ¶
func GinOnAbort ¶
func IrisOnAbort ¶
func KitOnAbort ¶
func MicroClientWithEmpty ¶
func MicroOnAbort ¶
func MicroServerEmpty ¶
func MuxOnAbort ¶
func MuxOnAbort(w http.ResponseWriter, err error)
func NetConnAbort ¶
func NetConnWithBackground ¶
func NewGRPCClientStream ¶
func NewGRPCClientStream(cs grpc.ClientStream, thr gohalt.Throttler, with GRPCStreamWith, on GRPCStreamOn) grpc.ClientStream
func NewGrpServerStream ¶
func NewGrpServerStream(ss grpc.ServerStream, thr gohalt.Throttler, with GRPCStreamWith, on GRPCStreamOn) grpc.ServerStream
func NewMicroClient ¶
func NewMicroHandler ¶
func NewMicroHandler(thr gohalt.Throttler, with MicroServerWith, on MicroOn) server.HandlerWrapper
func NewMiddlewareBeego ¶
func NewMiddlewareEcho ¶
func NewMiddlewareFast ¶
func NewMiddlewareFast(h fasthttp.RequestHandler, thr gohalt.Throttler, with FastWith, on FastOn) fasthttp.RequestHandler
func NewMiddlewareGin ¶
func NewMiddlewareIris ¶
func NewMiddlewareKit ¶
func NewMiddlewareMux ¶
func NewMiddlewareRevel ¶
func NewMiddlewareRouter ¶
func NewMiddlewareStd ¶
func NewNetConn ¶
func NewNetConn(conn net.Conn, thr gohalt.Throttler, with NetConnWith, on NetConnOn, mode NetConnMode) net.Conn
func NewRPCClientCodec ¶
func NewRPCClientCodec(cc rpc.ClientCodec, thr gohalt.Throttler, with RPCCodecWith, on RPCCodecOn) rpc.ClientCodec
func NewRPCServerCodec ¶
func NewRPCServerCodec(sc rpc.ServerCodec, thr gohalt.Throttler, with RPCCodecWith, on RPCCodecOn) rpc.ServerCodec
func NewRoundTripperStd ¶
func NewRoundTripperStd( rt http.RoundTripper, thr gohalt.Throttler, with RoundTripperStdWith, on RoundTripperStdOn, ) http.RoundTripper
func RPCCodecOnAbort ¶
func RPCCodecWithBackground ¶
func RWWithBackground ¶
func RevealOnAbort ¶
func RevealOnAbort(rc *revel.Controller, err error) revel.Result
func RevealWithIP ¶
func RevealWithIP(rc *revel.Controller) context.Context
func RoundTripperFastOnAbort ¶
func RoundTripperStdOnAbort ¶
func RouterOnAbort ¶
func RouterOnAbort(w http.ResponseWriter, err error)
func SQLClientAbort ¶
func SQLClientQuery ¶
func StdOnAbort ¶
func StdOnAbort(w http.ResponseWriter, err error)
Types ¶
type FastOn ¶
type FastOn func(*fasthttp.RequestCtx, error)
type GRPCStreamOn ¶
type NetConnMode ¶
type NetConnMode int
const ( NetConnModeRead NetConnMode = iota NetConnModeWrite NetConnMode = iota )
type NetConnWith ¶
type RPCCodecOn ¶
type RPCCodecWith ¶
type RevealWith ¶
type RevealWith func(*revel.Controller) context.Context
type RoundTripperFast ¶
func NewRoundTripperFast ¶
func NewRoundTripperFast( rt RoundTripperFast, thr gohalt.Throttler, with RoundTripperFastWith, on RoundTripperFastOn, ) RoundTripperFast
type RoundTripperFastOn ¶
type RoundTripperStdOn ¶
type RouterWith ¶
type RouterWith StdWith
type SQLClient ¶
type SQLClient interface { ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row }
func NewSQLClient ¶
func NewSQLClient(cli SQLClient, thr gohalt.Throttler, with SQLClientWith, on SQLClientOn) SQLClient
type SQLClientOn ¶
type SQLClientWith ¶
type StdOn ¶
type StdOn func(http.ResponseWriter, error)
Click to show internal directories.
Click to hide internal directories.