oohttp

Documentation

Overview

Out-of-order HTTP!

Index

• Constants
• func InitServer(s *fastrpc.Server, hnd fasthttp.RequestHandler)
• func NewFakeResponse() fastrpc.ResponseReader
• func NewHandler(hnd fasthttp.RequestHandler) func(ctx fastrpc.HandlerCtx) fastrpc.HandlerCtx
• func NewHandlerCtx() fastrpc.HandlerCtx
• type Client
  • func (c *Client) DoDeadline(req *fasthttp.Request, resp *fasthttp.Response, deadline time.Time) error
  • func (c *Client) Init()
  • func (c *Client) PendingRequests() int
• type WrappedCtx
  • func (w *WrappedCtx) ConcurrencyLimitError(concurrency int)
  • func (w *WrappedCtx) Init(conn net.Conn, logger fasthttp.Logger)
  • func (w *WrappedCtx) ReadRequest(br *bufio.Reader) error
  • func (w *WrappedCtx) WriteResponse(bw *bufio.Writer) error
• type WrappedRequest
  • func (w *WrappedRequest) WriteRequest(bw *bufio.Writer) error
• type WrappedResponse
  • func (w *WrappedResponse) ReadResponse(br *bufio.Reader) error

Constants

const ProtocolVersion byte = 1

const SniffHeader = "OOHttp"

Functions

func InitServer

func InitServer(s *fastrpc.Server, hnd fasthttp.RequestHandler)

func NewFakeResponse

func NewFakeResponse() fastrpc.ResponseReader

func NewHandler

func NewHandler(hnd fasthttp.RequestHandler) func(ctx fastrpc.HandlerCtx) fastrpc.HandlerCtx

func NewHandlerCtx

func NewHandlerCtx() fastrpc.HandlerCtx

Types

type Client

type Client struct {
	Inner fastrpc.Client
}

func (*Client) DoDeadline

func (c *Client) DoDeadline(req *fasthttp.Request, resp *fasthttp.Response, deadline time.Time) error

func (*Client) Init

func (c *Client) Init()

func (*Client) PendingRequests

func (c *Client) PendingRequests() int

type WrappedCtx

type WrappedCtx struct {
	Ctx fasthttp.RequestCtx
}

func (*WrappedCtx) ConcurrencyLimitError

func (w *WrappedCtx) ConcurrencyLimitError(concurrency int)

func (*WrappedCtx) Init

func (w *WrappedCtx) Init(conn net.Conn, logger fasthttp.Logger)

func (*WrappedCtx) ReadRequest

func (w *WrappedCtx) ReadRequest(br *bufio.Reader) error

func (*WrappedCtx) WriteResponse

func (w *WrappedCtx) WriteResponse(bw *bufio.Writer) error

type WrappedRequest

type WrappedRequest struct {
	Req *fasthttp.Request
}

func (*WrappedRequest) WriteRequest

func (w *WrappedRequest) WriteRequest(bw *bufio.Writer) error

type WrappedResponse

type WrappedResponse struct {
	Resp *fasthttp.Response
}

func (*WrappedResponse) ReadResponse

func (w *WrappedResponse) ReadResponse(br *bufio.Reader) error