Documentation
¶
Index ¶
Constants ¶
View Source
const ( ErrUnknownClientPeer middlewareError = "auth failed: unknown client peer" ErrStreamReadError middlewareError = "stream reading failed" ErrInternalNodeError middlewareError = "internal node error" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WarpHandler ¶
type WarpHandler func(msg []byte, s warpnet.WarpStream) (any, error)
type WarpMiddleware ¶
type WarpMiddleware struct {
// contains filtered or unexported fields
}
func NewWarpMiddleware ¶
func NewWarpMiddleware() *WarpMiddleware
func (*WarpMiddleware) AuthMiddleware ¶
func (p *WarpMiddleware) AuthMiddleware(next warpnet.WarpStreamHandler) warpnet.WarpStreamHandler
func (*WarpMiddleware) LoggingMiddleware ¶
func (p *WarpMiddleware) LoggingMiddleware(next warpnet.WarpStreamHandler) warpnet.WarpStreamHandler
func (*WarpMiddleware) UnwrapStreamMiddleware ¶
func (p *WarpMiddleware) UnwrapStreamMiddleware(fn WarpHandler) warpnet.WarpStreamHandler
Source Files
Click to show internal directories.
Click to hide internal directories.