http

Documentation

Index

• func IsPortOpenWithRetry(host string, connectionTimeout time.Duration, maxRetries int) error
• type HttpRequestHandler
• type HttpServer
  • func New() *HttpServer
  • func (srv *HttpServer) HandleRequest(request *fasthttp.Request) (*fasthttp.Response, error)
  • func (h *HttpServer) Proxy(stream httppb.Http_ProxyServer) error
  • func (h *HttpServer) WorkerCount() int

Functions

func IsPortOpenWithRetry

func IsPortOpenWithRetry(host string, connectionTimeout time.Duration, maxRetries int) error

IsPortOpen returns true if the port is open, false otherwise returns false if the timeout elapses before a connection is established

Types

type HttpRequestHandler

type HttpRequestHandler interface {
	httppb.HttpServer
	HandleRequest(request *fasthttp.Request) (*fasthttp.Response, error)
	WorkerCount() int
}

type HttpServer

type HttpServer struct {
	Output chan error
	// contains filtered or unexported fields
}

func New

func New() *HttpServer

func (*HttpServer) HandleRequest

func (srv *HttpServer) HandleRequest(request *fasthttp.Request) (*fasthttp.Response, error)

HandleRequest forwards proxy request to the underlying HTTP server

func (*HttpServer) Proxy

func (h *HttpServer) Proxy(stream httppb.Http_ProxyServer) error

func (*HttpServer) WorkerCount

func (h *HttpServer) WorkerCount() int