Documentation
¶
Index ¶
- func OriginalParamMiddleware(w http.ResponseWriter, r *http.Request) error
- func OriginalTraceMiddleware(w http.ResponseWriter, r *http.Request) error
- func ParamMiddleware(next http.HandlerFunc) http.HandlerFunc
- func TraceInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error)
- func TraceMiddleware(next http.HandlerFunc) http.HandlerFunc
- func UnaryTracingInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
- type BaseDataMiddleware
- type CorsMiddleware
- type IPMiddleware
- type IdempotenceMiddleware
- type LimitMiddleware
- type LogMiddleware
- type RkBootMiddleware
- type TimeoutMiddleware
- type TokenMiddleware
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OriginalParamMiddleware ¶
func OriginalParamMiddleware(w http.ResponseWriter, r *http.Request) error
func OriginalTraceMiddleware ¶
func OriginalTraceMiddleware(w http.ResponseWriter, r *http.Request) error
func ParamMiddleware ¶
func ParamMiddleware(next http.HandlerFunc) http.HandlerFunc
func TraceInterceptor ¶
func TraceInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)
func TraceMiddleware ¶
func TraceMiddleware(next http.HandlerFunc) http.HandlerFunc
func UnaryTracingInterceptor ¶
func UnaryTracingInterceptor(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error
UnaryTracingInterceptor returns a grpc.UnaryClientInterceptor for opentelemetry.
Types ¶
type BaseDataMiddleware ¶
type BaseDataMiddleware struct {
// contains filtered or unexported fields
}
func NewBaseDataMiddleware ¶
func NewBaseDataMiddleware(r *redis.ClusterClient, key string, flags ...string) *BaseDataMiddleware
func (*BaseDataMiddleware) Handle ¶
func (m *BaseDataMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
func (*BaseDataMiddleware) OriginalHandle ¶
func (m *BaseDataMiddleware) OriginalHandle(w http.ResponseWriter, r *http.Request) error
type CorsMiddleware ¶
type CorsMiddleware struct {
AllowOrigin string
}
func CorsDataMiddleware ¶
func CorsDataMiddleware(f string) *CorsMiddleware
func (*CorsMiddleware) CorsMiddleware ¶
func (m *CorsMiddleware) CorsMiddleware(next http.HandlerFunc) http.HandlerFunc
func (*CorsMiddleware) OriginalCorsMiddleware ¶
func (m *CorsMiddleware) OriginalCorsMiddleware(w http.ResponseWriter, r *http.Request) error
type IPMiddleware ¶
type IPMiddleware struct {
// contains filtered or unexported fields
}
func NewIPMiddleware ¶
func NewIPMiddleware(r *redis.ClusterClient, key string) *IPMiddleware
func (*IPMiddleware) Handle ¶
func (l *IPMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
func (*IPMiddleware) OriginalHandle ¶
func (l *IPMiddleware) OriginalHandle(w http.ResponseWriter, r *http.Request) error
type IdempotenceMiddleware ¶
type IdempotenceMiddleware struct {
// contains filtered or unexported fields
}
IdempotenceMiddleware 幂等性中间件
func NewIdempotenceMiddleware ¶
func NewIdempotenceMiddleware(r *redis.ClusterClient, num int) *IdempotenceMiddleware
func (*IdempotenceMiddleware) Handle ¶
func (m *IdempotenceMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
func (*IdempotenceMiddleware) OriginalHandle ¶
func (m *IdempotenceMiddleware) OriginalHandle(w http.ResponseWriter, r *http.Request) error
type LimitMiddleware ¶
type LimitMiddleware struct {
// contains filtered or unexported fields
}
func NewLimitMiddleware ¶
func NewLimitMiddleware(fillInterval time.Duration, cap, quantum int64) *LimitMiddleware
NewLimitMiddleware 限流中间件 fillInterval 时间段 cap 容量 quantum 生产速度
func (*LimitMiddleware) Handle ¶
func (l *LimitMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
func (*LimitMiddleware) OriginalHandle ¶
func (l *LimitMiddleware) OriginalHandle(w http.ResponseWriter, r *http.Request) error
type LogMiddleware ¶
type LogMiddleware struct {
}
func NewLogMiddleware ¶
func NewLogMiddleware() *LogMiddleware
func (*LogMiddleware) Handle ¶
func (m *LogMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
func (*LogMiddleware) OriginalHandle ¶
func (m *LogMiddleware) OriginalHandle(w http.ResponseWriter, r *http.Request) error
type RkBootMiddleware ¶
type RkBootMiddleware struct {
// contains filtered or unexported fields
}
func NewRkBootMiddleware ¶
func NewRkBootMiddleware() *RkBootMiddleware
func (*RkBootMiddleware) Handle ¶
func (m *RkBootMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
Handle 监控中间件
type TimeoutMiddleware ¶
type TimeoutMiddleware struct {
// contains filtered or unexported fields
}
func NewTimeoutMiddleware ¶
func NewTimeoutMiddleware(n int) *TimeoutMiddleware
func (*TimeoutMiddleware) Handle ¶
func (m *TimeoutMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
func (*TimeoutMiddleware) OriginalHandle ¶
func (m *TimeoutMiddleware) OriginalHandle(w http.ResponseWriter, r *http.Request) error
type TokenMiddleware ¶
type TokenMiddleware struct {
// contains filtered or unexported fields
}
func NewTokenMiddleware ¶
func NewTokenMiddleware(r *redis.ClusterClient, key string, flag ...any) *TokenMiddleware
func (*TokenMiddleware) Handle ¶
func (m *TokenMiddleware) Handle(next http.HandlerFunc) http.HandlerFunc
func (*TokenMiddleware) OriginalHandle ¶
func (m *TokenMiddleware) OriginalHandle(w http.ResponseWriter, r *http.Request) error
Source Files
Click to show internal directories.
Click to hide internal directories.