Documentation
¶
Index ¶
- Constants
- type WarpMiddleware
- func (p *WarpMiddleware) AuthMiddleware(next warpnet.StreamHandler) warpnet.StreamHandler
- func (p *WarpMiddleware) Close()
- func (p *WarpMiddleware) LoggingMiddleware(next warpnet.StreamHandler) warpnet.StreamHandler
- func (p *WarpMiddleware) UnwrapStreamMiddleware(handler warpnet.WarpHandlerFunc) warpnet.StreamHandler
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??? // ImportTweetMaxLimit is the inbound cap for the per-tweet streaming import // route: one tweet plus up to four base64 photos. The browser parses and // filters the archive client-side and streams kept tweets one by one, so // the node never buffers the whole archive. ImportTweetMaxLimit = units.MiB * 32 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) Close ¶ added in v0.6.316
func (p *WarpMiddleware) Close()
Close releases background resources owned by the middleware (currently the idempotency cache's expirable-LRU janitor goroutine). Safe to call multiple times.
func (*WarpMiddleware) LoggingMiddleware ¶
func (p *WarpMiddleware) LoggingMiddleware(next warpnet.StreamHandler) warpnet.StreamHandler
func (*WarpMiddleware) UnwrapStreamMiddleware ¶
func (p *WarpMiddleware) UnwrapStreamMiddleware(handler warpnet.WarpHandlerFunc) warpnet.StreamHandler
Click to show internal directories.
Click to hide internal directories.