Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

middleware

package

Go to main page

Versions in this module

v0

v0.1.0

Sep 24, 2024

Changes in this version

+ const ConnectionParentCtxKey

+ const LogWithIgnoreMethodsCtxKey

+ func GetClientConnection(ctx context.Context) *websocket.Conn

+ func GetClientConnectionContext(ctx context.Context) context.Context

+ type LoggerOption func(context.Context) context.Context

+ func LogWithIgnoreMethods(methods []string) LoggerOption

+ func LogWithParams() LoggerOption

v0.0.5

Jun 11, 2024

v0.0.4

Jun 7, 2024

Changes in this version

+ const ConnectionClientCancelCtxKey

+ func AcceptConnection(next http.Handler) http.Handler

+ func CancelConnection(w http.ResponseWriter, r *http.Request, err error)

+ func Logger(log *logrus.Logger, withParams bool) func(http.Handler) http.Handler

+ type JsonRPCMiddlewareOption func(http.Handler) http.Handler

v0.0.3

May 24, 2024

v0.0.2

May 23, 2024

v0.0.1

May 23, 2024

Changes in this version

+ const ConnectionClientIDCtxKey

+ const ConnectionClientWSCancelCtxKey

+ const ConnectionClientWSCtxKey

+ const ConnectionTypeCtxKey

+ const ConnectionTypeHTTPCtx

+ const ConnectionTypeWebsocketCtx

+ const ContextKeyUstreamAddr

+ const ContextKeyUstreamProvider

+ const LogFieldsCtxKey

+ const LogLoggerCtxKey

+ const LogRequestStartTime

+ const LogWithParamsCtxKey

+ const RPCMethodCtxKey

+ const RPCMiddlewareCtxKey

+ const RPCPayloadCtxKey

+ const RPCPayloadTypeBatchCtx

+ const RPCPayloadTypeFrameCtx

+ const RPCRequestID

+ func AcceptWebsocket(next http.Handler) http.Handler

+ func AddLogField(ctx context.Context, k string, v string)

+ func CancelWebsocket(ctx context.Context, err error)

+ func CopyHeader(dst, src http.Header)

+ func DenyRPCMethods(methods []string) func(http.Handler) http.Handler

+ func EndpointProvider(prov endpoint.Provider) func(http.Handler) http.Handler

+ func GetAssignedUpstream(ctx context.Context) string

+ func GetClientConnectionType(ctx context.Context) string

+ func GetConnectionID(ctx context.Context) string

+ func GetEndpointProvider(ctx context.Context) endpoint.Provider

+ func GetJsonRPCFrame(ctx context.Context) *dto.RPCFrame

+ func GetLogField(ctx context.Context, k string) string

+ func GetLogger(ctx context.Context) *logrus.Logger

+ func GetRPCMethod(ctx context.Context) string

+ func GetRPCRequestID(ctx context.Context) int

+ func IsWebsocket(r *http.Request) bool

+ func JsonRPC(log *logrus.Logger, withParams bool) func(http.Handler) http.Handler

+ func LogRequestDetails(r *http.Request)

+ func LogSubscriptionDetails(r *http.Request, method string, subscriptionId string)

+ func ThrottleWithOpts(opts ThrottleOpts) func(http.Handler) http.Handler

+ func WithContextValue(r *http.Request, key any, v any) *http.Request

+ func WithNewBody(r *http.Request, b []byte) *http.Request

+ type ErrorResponse struct

+ Err error

+ ErrorText string

+ HTTPStatusCode int

+ StatusText string

+ func ErrorBadGateway(err error) *ErrorResponse

+ func ErrorInternalServer(err error) *ErrorResponse

+ func ErrorInvalidRequest(err error) *ErrorResponse

+ func (e *ErrorResponse) Render(w http.ResponseWriter, r *http.Request) error

+ type HttpMetrics struct

+ func (m *HttpMetrics) GetMonitoringEventTypes() []string

+ func (m *HttpMetrics) Middleware() func(http.Handler) http.Handler

+ func (m *HttpMetrics) SetObserver(mon monitoring.Observer)

+ type InMemoryWriter struct

+ Buf []byte

+ Status int

+ func NewInMemoryWriter(w http.ResponseWriter) *InMemoryWriter

+ func (w *InMemoryWriter) Header() http.Header

+ func (w *InMemoryWriter) Write(b []byte) (int, error)

+ func (w *InMemoryWriter) WriteHeader(statusCode int)

+ type JsonRPCMiddleware struct

+ func GetJsonRPCMiddleware(r *http.Request) *JsonRPCMiddleware

+ func (m *JsonRPCMiddleware) NewFrameContext(ctx context.Context, f *dto.RPCFrame) context.Context

+ func (m *JsonRPCMiddleware) ParsePayload(payload []byte) interface{}

+ type RPCMiddleware interface

+ ParsePayload func(payload []byte) interface{}

+ type ThrottleOpts struct

+ BacklogLimit int

+ BacklogTimeout time.Duration

+ Context context.Context

+ Limit int

+ Observer monitoring.Observer

+ type WrapedWSWriter struct

+ func (w *WrapedWSWriter) Header() http.Header

+ func (w *WrapedWSWriter) Write(b []byte) (int, error)

+ func (w *WrapedWSWriter) WriteHeader(statusCode int)