gohalt

package module

Go to main page

Versions in this module

v0

v0.10.0

Apr 22, 2024

v0.9.0

Aug 14, 2021

Changes in this version

type Throttler

+ func NewThrottlerBucket(threshold uint64, interval time.Duration, monotone bool) Throttler

v0.8.0

Aug 14, 2021

Changes in this version

type Throttler

+ func NewThrottlerCellRate(threshold uint64, interval time.Duration, monotone bool) Throttler

v0.7.0

Apr 12, 2021

Changes in this version

+ func WithWeight(ctx context.Context, weight int64) context.Context

type Throttler

+ func NewThrottlerSemaphore(weight int64) Throttler

v0.6.3

Mar 21, 2021

v0.6.2

Mar 20, 2021

v0.6.1

Feb 17, 2021

v0.6.0

Feb 11, 2021

Changes in this version

+ type Generator func(string) (Throttler, error)

type Throttler

+ func NewThrottlerGenerator(gen Generator, capacity uint64, eviction float64) Throttler

v0.5.0

Jan 24, 2021

Changes in this version

type Throttler

+ func NewThrottlerFuture(threshold time.Time) Throttler

+ func NewThrottlerPast(threshold time.Time) Throttler

v0.4.0

Jan 24, 2021

Changes in this version

+ type ErrorInternal struct

+ Message string

+ Throttler string

+ func (err ErrorInternal) Error() string

+ type ErrorThreshold struct

+ Threshold fmt.Stringer

+ Throttler string

+ func (err ErrorThreshold) Error() string

type Stats

+ func (s Stats) Compare(stats Stats) bool

v0.3.0

Oct 20, 2020

v0.2.0

Oct 19, 2020

Changes in this version

type Throttler

+ func NewThrottlerCache(thr Throttler, cache time.Duration) Throttler

+ func NewThrottlerJitter(initial time.Duration, limit time.Duration, reset bool, jitter float64) Throttler

+ func NewThrottlerRetry(thr Throttler, retries uint64) Throttler

v0.1.0

Oct 15, 2020

Changes in this version

+ var DefaultRetriedDuration = 100 * time.Millisecond

+ 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 Throttler, with GRPCStreamWith, on GRPCStreamOn) grpc.ClientStream

+ func NewGrpServerStream(ss grpc.ServerStream, thr Throttler, with GRPCStreamWith, on GRPCStreamOn) grpc.ServerStream

+ func NewMicroClient(thr Throttler, with MicroClientWith, on MicroOn) client.Wrapper

+ func NewMicroHandler(thr Throttler, with MicroServerWith, on MicroOn) server.HandlerWrapper

+ func NewMiddlewareBeego(thr Throttler, with BeegoWith, on BeegoOn) beego.FilterFunc

+ func NewMiddlewareEcho(thr Throttler, with EchoWith, on EchoOn) echo.MiddlewareFunc

+ func NewMiddlewareFast(h fasthttp.RequestHandler, thr Throttler, with FastWith, on FastOn) fasthttp.RequestHandler

+ func NewMiddlewareGin(thr Throttler, with GinWith, on GinOn) gin.HandlerFunc

+ func NewMiddlewareIris(thr Throttler, with IrisWith, on IrisOn) iris.Handler

+ func NewMiddlewareKit(thr Throttler, with KitWith, on KitOn) endpoint.Middleware

+ func NewMiddlewareMux(h http.Handler, thr Throttler, with MuxWith, on MuxOn) http.Handler

+ func NewMiddlewareRevel(thr Throttler, with RevealWith, on RevealOn) revel.Filter

+ func NewMiddlewareRouter(h http.Handler, thr Throttler, with RouterWith, on RouterOn) http.Handler

+ func NewMiddlewareStd(h http.Handler, thr Throttler, with StdWith, on StdOn) http.Handler

+ func NewNetConn(conn net.Conn, thr Throttler, with NetConnWith, on NetConnOn, mode NetConnMode) net.Conn

+ func NewRPCClientCodec(cc rpc.ClientCodec, thr Throttler, with RPCCodecWith, on RPCCodecOn) rpc.ClientCodec

+ func NewRPCServerCodec(sc rpc.ServerCodec, thr Throttler, with RPCCodecWith, on RPCCodecOn) rpc.ServerCodec

+ func NewReader(r io.Reader, thr Throttler, with RWWith, on RWOn) io.Reader

+ func NewRoundTripperStd(rt http.RoundTripper, thr Throttler, with RoundTripperStdWith, ...) http.RoundTripper

+ func NewWriter(w io.Writer, thr 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

+ func WithKey(ctx context.Context, key string) context.Context

+ func WithMarshaler(ctx context.Context, mrsh Marshaler) context.Context

+ func WithMessage(ctx context.Context, message interface{}) context.Context

+ func WithParams(ctx context.Context, ts time.Time, priority uint8, key string, ...) context.Context

+ func WithPriority(ctx context.Context, priority uint8) context.Context

+ func WithThrottler(ctx context.Context, thr Throttler, freq time.Duration) context.Context

+ func WithTimestamp(ctx context.Context, ts time.Time) context.Context

+ type BeegoOn func(*beegoctx.Context, error)

+ type BeegoWith func(*beegoctx.Context) context.Context

+ type EchoOn func(echo.Context, error) error

+ type EchoWith func(echo.Context) context.Context

+ type Enqueuer interface

+ Enqueue func(context.Context, []byte) error

+ func NewEnqueuerKafka(net string, url string, topic string, retries uint64) Enqueuer

+ func NewEnqueuerRabbit(url string, queue string, retries uint64) Enqueuer

+ type FastOn func(*fasthttp.RequestCtx, error)

+ type FastWith func(*fasthttp.RequestCtx) context.Context

+ type GRPCStreamOn func(error) error

+ type GRPCStreamWith func(context.Context, interface{}) context.Context

+ type GinOn func(*gin.Context, error)

+ type GinWith func(*gin.Context) context.Context

+ type IrisOn func(iris.Context, error)

+ type IrisWith func(iris.Context) context.Context

+ type KitOn func(error) (interface{}, error)

+ type KitWith func(context.Context, interface{}) context.Context

+ type Logger func(string, ...interface{})

+ var DefaultLogger Logger = stdlog.Printf

+ type Marshaler func(interface{}) ([]byte, error)

+ var DefaultMarshaler Marshaler = json.Marshal

+ type Metric interface

+ Query func(context.Context) (bool, error)

+ func NewMetricPrometheus(url string, query string, cache time.Duration) Metric

+ type MicroClientWith func(context.Context, client.Request) context.Context

+ type MicroOn func(error) error

+ type MicroServerWith func(context.Context, server.Request) context.Context

+ type Monitor interface

+ Stats func(context.Context) (Stats, error)

+ func NewMonitorSystem(cache time.Duration, tp time.Duration) Monitor

+ type MuxOn StdOn

+ type MuxWith StdWith

+ type NetConnMode int

+ const NetConnModeRead

+ const NetConnModeWrite

+ type NetConnOn func(error) error

+ type NetConnWith func() context.Context

+ type Pattern struct

+ Pattern *regexp.Regexp

+ Throttler Throttler

+ type RPCCodecOn func(error) error

+ type RPCCodecWith func(*rpc.Request, *rpc.Response, interface{}) context.Context

+ type RWOn func(error) error

+ type RWWith func() context.Context

+ type RevealOn func(error) revel.Result

+ type RevealWith func(*revel.Controller) context.Context

+ type RoundTripperFast interface

+ Do func(req *fasthttp.Request, resp *fasthttp.Response) error

+ func NewRoundTripperFast(rt RoundTripperFast, thr Throttler, with RoundTripperFastWith, ...) RoundTripperFast

+ type RoundTripperFastOn func(error) error

+ type RoundTripperFastWith func(*fasthttp.Request) context.Context

+ type RoundTripperStdOn func(error) error

+ type RoundTripperStdWith func(*http.Request) context.Context

+ type RouterOn StdOn

+ type RouterWith StdWith

+ type Runnable func(context.Context) error

+ type Runner interface

+ Result func() error

+ Run func(Runnable)

+ func NewRunnerAsync(ctx context.Context, thr Throttler) Runner

+ func NewRunnerSync(ctx context.Context, thr Throttler) Runner

+ type SQLClient interface

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func NewSQLClient(cli SQLClient, thr Throttler, with SQLClientWith, on SQLClientOn) SQLClient

+ type SQLClientOn func(error) error

+ type SQLClientWith func(context.Context, string, ...interface{}) context.Context

+ type Stats struct

+ CPUPause uint64

+ CPUUsage float64

+ MEMAlloc uint64

+ MEMSystem uint64

+ type StdOn func(http.ResponseWriter, error)

+ type StdWith func(*http.Request) context.Context

+ type Throttler interface

+ Acquire func(context.Context) error

+ Release func(context.Context) error

+ func NewThrottlerAdaptive(threshold uint64, interval time.Duration, quantum time.Duration, step uint64, ...) Throttler

+ func NewThrottlerAfter(threshold uint64) Throttler

+ func NewThrottlerAll(thrs ...Throttler) Throttler

+ func NewThrottlerAny(thrs ...Throttler) Throttler

+ func NewThrottlerBefore(threshold uint64) Throttler

+ func NewThrottlerBuffered(threshold uint64) Throttler

+ func NewThrottlerChance(threshold float64) Throttler

+ func NewThrottlerContext() Throttler

+ func NewThrottlerEach(threshold uint64) Throttler

+ func NewThrottlerEcho(err error) Throttler

+ func NewThrottlerEnqueue(enq Enqueuer) Throttler

+ func NewThrottlerLatency(threshold time.Duration, retention time.Duration) Throttler

+ func NewThrottlerMetric(mtc Metric) Throttler

+ func NewThrottlerMonitor(mnt Monitor, threshold Stats) Throttler

+ func NewThrottlerNot(thr Throttler) Throttler

+ func NewThrottlerPanic() Throttler

+ func NewThrottlerPattern(patterns ...Pattern) Throttler

+ func NewThrottlerPercentile(threshold time.Duration, capacity uint8, percentile float64, ...) Throttler

+ func NewThrottlerPriority(threshold uint64, levels uint8) Throttler

+ func NewThrottlerRing(thrs ...Throttler) Throttler

+ func NewThrottlerRunning(threshold uint64) Throttler

+ func NewThrottlerSquare(duration time.Duration, limit time.Duration, reset bool) Throttler

+ func NewThrottlerSuppress(thr Throttler) Throttler

+ func NewThrottlerTimed(threshold uint64, interval time.Duration, quantum time.Duration) Throttler

+ func NewThrottlerWait(duration time.Duration) Throttler

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL