web

Documentation

Index

• func WebsocketServerOptionBuffer(read, write int) func(ws.Upgrader)
• func WebsocketServerOptionCompression(enable bool) func(ws.Upgrader)
• func WithHTTP() plugins.Plugin
• func WithHTTPClient() plugins.Plugin
• func WithHTTPDebug() plugins.Plugin
• func WithWebsocketClient() plugins.Plugin
• func WithWebsocketServer(options ...func(ws.Upgrader)) plugins.Plugin
• func WithWebsocketServerPool(options ...func(ws.Upgrader)) plugins.Plugin
• type ClientHttp
• type ConfigDebug
  • func (v *ConfigDebug) Default()
• type ConfigHttp
  • func (v *ConfigHttp) Default()
• type Context
• type Cookie
• type ErrCtx
  • func (v ErrCtx) MarshalEasyJSON(w *jwriter.Writer)
  • func (v ErrCtx) MarshalJSON() ([]byte, error)
  • func (v *ErrCtx) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (v *ErrCtx) UnmarshalJSON(data []byte) error
• type Header
• type Middleware
  • func ThrottlingMiddleware(max int64) Middleware
• type Param
• type RouteCollector
• type Router
• type RouterPool
• type WebsocketClient
• type WebsocketClientConnect
• type WebsocketServer
• type WebsocketServerPool

Functions

func WebsocketServerOptionBuffer

func WebsocketServerOptionBuffer(read, write int) func(ws.Upgrader)

func WebsocketServerOptionCompression

func WebsocketServerOptionCompression(enable bool) func(ws.Upgrader)

func WithHTTP

func WithHTTP() plugins.Plugin

WithHTTP launch of HTTP service with default Router

func WithHTTPClient

func WithHTTPClient() plugins.Plugin

WithHTTPClient init pool http clients

func WithHTTPDebug

func WithHTTPDebug() plugins.Plugin

WithHTTPDebug debug service over HTTP protocol with pprof enabled

func WithWebsocketClient

func WithWebsocketClient() plugins.Plugin

func WithWebsocketServer

func WithWebsocketServer(options ...func(ws.Upgrader)) plugins.Plugin

func WithWebsocketServerPool

func WithWebsocketServerPool(options ...func(ws.Upgrader)) plugins.Plugin

Types

type ClientHttp

type ClientHttp interface {
	Create(opts ...webutil.ClientHttpOption) *webutil.ClientHttp
}

type ConfigDebug

type ConfigDebug struct {
	Config webutil.ConfigHttp `yaml:"debug"`
}

ConfigDebug config to initialize HTTP debug service

func (*ConfigDebug) Default

func (v *ConfigDebug) Default()

type ConfigHttp

type ConfigHttp struct {
	Config map[string]webutil.ConfigHttp `yaml:"http"`
}

ConfigHttp config to initialize HTTP service

func (*ConfigHttp) Default

func (v *ConfigHttp) Default()

type Context

type Context interface {
	URL() *url.URL
	Redirect(uri string)
	Param(key string) Param
	Header() Header
	Cookie() Cookie

	BindBytes(in *[]byte) error
	BindJSON(in interface{}) error
	BindXML(in interface{}) error
	Error(code int, err error)
	ErrorJSON(code int, err error, ctx ErrCtx)
	Bytes(code int, b []byte)
	String(code int, b string, args ...interface{})
	JSON(code int, in interface{})
	Stream(code int, in []byte, filename string)

	Context() context.Context
	Log() log.WriterContext
	Request() *http.Request
	Response() http.ResponseWriter
}

Context request and response interface

type Cookie

type Cookie interface {
	Get(key string) *http.Cookie
	Set(value *http.Cookie)
}

type ErrCtx

type ErrCtx map[string]interface{}

func (ErrCtx) MarshalEasyJSON

func (v ErrCtx) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (ErrCtx) MarshalJSON

func (v ErrCtx) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*ErrCtx) UnmarshalEasyJSON

func (v *ErrCtx) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ErrCtx) UnmarshalJSON

func (v *ErrCtx) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type Header

type Header interface {
	Get(key string) string
	Set(key, value string)
	Del(key string)
	Val(key string) string
	Copy()
}

type Middleware

type Middleware func(func(http.ResponseWriter, *http.Request)) func(http.ResponseWriter, *http.Request)

Middleware type of middleware

func ThrottlingMiddleware

func ThrottlingMiddleware(max int64) Middleware

ThrottlingMiddleware limits active requests

type Param

type Param interface {
	String() (string, error)
	Int() (int64, error)
	Float() (float64, error)
}

Param interface for typing a parameter from a URL

type RouteCollector

type RouteCollector interface {
	Get(path string, call func(ctx Context))
	Head(path string, call func(ctx Context))
	Post(path string, call func(ctx Context))
	Put(path string, call func(ctx Context))
	Delete(path string, call func(ctx Context))
	Options(path string, call func(ctx Context))
	Patch(path string, call func(ctx Context))
	Match(path string, call func(ctx Context), methods ...string)
	Collection(prefix string, args ...Middleware) RouteCollector
}

RouteCollector interface of the router collection

type Router

type Router interface {
	Use(args ...Middleware)
	NotFoundHandler(call func(ctx Context))
	RouteCollector
}

Router router handler interface

type RouterPool

type RouterPool interface {
	//All method to get all route handlers
	All(call func(name string, router Router))
	//Main method to get Main route handler
	Main() Router
	//Get method to get route handler by key
	Get(name string) Router
}

RouterPool router pool handler

type WebsocketClient

type WebsocketClient interface {
	Create(url string, opts ...func(websocket.ClientOption)) WebsocketClientConnect
}

type WebsocketClientConnect

type WebsocketClientConnect interface {
	Encode(eid websocket.EventID, in interface{})
	ConnectID() string
	Header(key, value string)
	SetHandler(call websocket.ClientHandler, eids ...websocket.EventID)
	DelHandler(eids ...websocket.EventID)
	OnClose(cb func(cid string))
	OnOpen(cb func(cid string))
	Close()
}

type WebsocketServer

type WebsocketServer interface {
	Handling(w http.ResponseWriter, r *http.Request)
	SendEvent(eid websocket.EventID, m interface{}, cids ...string)
	Broadcast(eid websocket.EventID, m interface{})
	SetHandler(call websocket.EventHandler, eids ...websocket.EventID)
	CloseAll()
	CountConn() int
}

type WebsocketServerPool

type WebsocketServerPool interface {
	Create(name string) WebsocketServer
}