http

Documentation

Index

• Variables
• type Kernel
  • func NewKernel(router *router.Router, app *kernel.Application) *Kernel
  • func (k *Kernel) FastHttpHandler(ctx *fasthttp.RequestCtx)
  • func (k *Kernel) Handle(r contract.RequestContract) (resp contract.ResponseContract)
  • func (k *Kernel) IsKeepAlive() bool
  • func (k *Kernel) KeepAlive(b ...bool) *Kernel
  • func (k *Kernel) SendRequestToRouter(r contract.RequestContract) contract.ResponseContract
  • func (k *Kernel) SetErrorHandler(handler errors.ErrorHandler)
  • func (k *Kernel) SetMiddleware(ms []RequestMiddleware)
  • func (k *Kernel) SetMiddlewareGroup(middlewareGroup map[string][]RequestMiddleware)
• type KernelContact
• type MiddlewareGroup
• type PipeFunc
• type PipeHandler
• type Pipeline
  • func (p *Pipeline) Send(r contract.RequestContract) *Pipeline
  • func (p *Pipeline) Then(handler PipeHandler) contract.ResponseContract
  • func (p *Pipeline) Through(pipe interface{}) *Pipeline
  • func (p *Pipeline) ThroughFunc(pipe PipeFunc) *Pipeline
  • func (p *Pipeline) ThroughMiddleware(pipe RequestMiddleware) *Pipeline
• type RequestMiddleware

Variables

var (
	ServerName = "valyala/fasthttp"
)

Types

type Kernel

type Kernel struct {
	RequestCurrency int
	OutputLog       bool
	// contains filtered or unexported fields
}

func NewKernel

func NewKernel(router *router.Router, app *kernel.Application) *Kernel

func (*Kernel) FastHttpHandler

func (k *Kernel) FastHttpHandler(ctx *fasthttp.RequestCtx)

func (*Kernel) Handle

func (k *Kernel) Handle(r contract.RequestContract) (resp contract.ResponseContract)

func (*Kernel) IsKeepAlive

func (k *Kernel) IsKeepAlive() bool

func (*Kernel) KeepAlive

func (k *Kernel) KeepAlive(b ...bool) *Kernel

func (*Kernel) SendRequestToRouter

func (k *Kernel) SendRequestToRouter(r contract.RequestContract) contract.ResponseContract

func (*Kernel) SetErrorHandler

func (k *Kernel) SetErrorHandler(handler errors.ErrorHandler)

func (*Kernel) SetMiddleware

func (k *Kernel) SetMiddleware(ms []RequestMiddleware)

func (*Kernel) SetMiddlewareGroup

func (k *Kernel) SetMiddlewareGroup(middlewareGroup map[string][]RequestMiddleware)

type KernelContact

type KernelContact interface {
	Handle(r contract.RequestContract) (resp contract.ResponseContract)
	SetMiddleware(ms []RequestMiddleware)
	FastHttpHandler(ctx *fasthttp.RequestCtx)
}

/KernelContact is interface of http kernel

type MiddlewareGroup

type MiddlewareGroup map[string][]RequestMiddleware

type PipeFunc

type PipeFunc func(r contract.RequestContract, next PipeHandler) contract.ResponseContract

PipeFunc request middleware function

type PipeHandler

type PipeHandler func(r contract.RequestContract) contract.ResponseContract

PipeHandler destination handler

type Pipeline

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

Pipeline is request pipeline prepare for request middleware

func (*Pipeline) Send

func (p *Pipeline) Send(r contract.RequestContract) *Pipeline

Send request to pipeline

func (*Pipeline) Then

func (p *Pipeline) Then(handler PipeHandler) contract.ResponseContract

Then final destination

func (*Pipeline) Through

func (p *Pipeline) Through(pipe interface{}) *Pipeline

Through middleware

func (*Pipeline) ThroughFunc

func (p *Pipeline) ThroughFunc(pipe PipeFunc) *Pipeline

ThroughFunc through middleware function

func (*Pipeline) ThroughMiddleware

func (p *Pipeline) ThroughMiddleware(pipe RequestMiddleware) *Pipeline

ThroughMiddleware through middleware struct

type RequestMiddleware

type RequestMiddleware interface {
	Handle(r contract.RequestContract, next PipeHandler) contract.ResponseContract
}

RequestMiddleware request middleware