kcphttp

Documentation

Overview

Out-of-Order HTTP-like protocol with keepalive messages/heartbeat. Useful for use with KCP.

Index

• Variables
• type Client
  • func NewClient(Dial func() (net.Conn, error)) *Client
  • func (c *Client) Destroy()
  • func (c *Client) DoDeadline(req *fasthttp.Request, resp *fasthttp.Response, deadline time.Time) error
• type Server
  • func NewServer(hn fasthttp.RequestHandler) *Server
  • func (sr *Server) Handle(c net.Conn)
• type WIQueue
  • func NewWIQueue() *WIQueue
  • func (w *WIQueue) EvictAll()
  • func (w *WIQueue) EvictExpired()
  • func (w *WIQueue) Get(ni uint64) *WorkItem
  • func (w *WIQueue) Push(wi *WorkItem) uint64
• type WorkItem

Variables

var ETimeout = errors.New("deadline timeout")

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(Dial func() (net.Conn, error)) *Client

func (*Client) Destroy

func (c *Client) Destroy()

func (*Client) DoDeadline

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

type Server

type Server struct {
	// contains filtered or unexported fields
}

func NewServer

func NewServer(hn fasthttp.RequestHandler) *Server

func (*Server) Handle

func (sr *Server) Handle(c net.Conn)

type WIQueue

type WIQueue struct {
	// contains filtered or unexported fields
}

func NewWIQueue

func NewWIQueue() *WIQueue

func (*WIQueue) EvictAll

func (w *WIQueue) EvictAll()

func (*WIQueue) EvictExpired

func (w *WIQueue) EvictExpired()

func (*WIQueue) Get

func (w *WIQueue) Get(ni uint64) *WorkItem

func (*WIQueue) Push

func (w *WIQueue) Push(wi *WorkItem) uint64

type WorkItem

type WorkItem struct {
	WG   sync.WaitGroup
	Req  *fasthttp.Request
	Resp *fasthttp.Response
	Dead time.Time
	Err  error
}