Documentation
¶
Index ¶
Constants ¶
View Source
const ( ErrUnknownClientPeer middlewareError = `["middleware: auth: unknown client peer"]` ErrStreamReadError middlewareError = `["middleware: stream: reading failed"]` ErrInternalNodeError middlewareError = `["middleware: internal node error"]` )
View Source
const ( MaxLimit = units.MiB * 5 // TODO size limit??? InternalNodeErrorCode = 5000 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WarpMiddleware ¶
type WarpMiddleware struct {
// contains filtered or unexported fields
}
func NewWarpMiddleware ¶
func NewWarpMiddleware(ownNodeId warpnet.WarpPeerID) *WarpMiddleware
func (*WarpMiddleware) AuthMiddleware ¶
func (p *WarpMiddleware) AuthMiddleware(next warpnet.StreamHandler) warpnet.StreamHandler
func (*WarpMiddleware) LoggingMiddleware ¶
func (p *WarpMiddleware) LoggingMiddleware(next warpnet.StreamHandler) warpnet.StreamHandler
func (*WarpMiddleware) UnwrapStreamMiddleware ¶
func (p *WarpMiddleware) UnwrapStreamMiddleware(handler warpnet.WarpHandlerFunc) warpnet.StreamHandler
Source Files
Click to show internal directories.
Click to hide internal directories.