server

Documentation

Index

• func Run(fn func(srv *Server))
• type Handler
• type Router
  • func (r *Router) DELETE(uri string, h Handler)
  • func (r *Router) GET(uri string, h Handler)
  • func (r *Router) NewRouterGroup(p string) *Router
  • func (r *Router) POST(uri string, h Handler)
  • func (r *Router) PUT(uri string, h Handler)
• type Server
  • func (srv *Server) Lifecycle(hooks ...*lifecycle.Hook)
  • func (srv *Server) Publish(topic string, v interface{}, opts ...broker.PublishOption)
  • func (srv *Server) RegisterRouter(fn func(r *Router))
  • func (srv *Server) RegisterRouterGroup(uri string, fn func(r *Router), handlers ...gin.HandlerFunc)
  • func (srv *Server) Subscribe(topic string, handler broker.Handler, opts ...broker.SubscribeOption)
  • func (srv *Server) Unmarshal(v interface{}) error
  • func (srv *Server) Use(middleware ...gin.HandlerFunc)

Functions

func Run

func Run(fn func(srv *Server))

Run .

Types

type Handler

type Handler func(ctx *hfwContext.Context) interface{}

Handler 业务处理。成功时返回 response, 失败时返回 webserver.WebError

type Router

type Router struct {
	*gin.RouterGroup
}

Router .

func (*Router) DELETE

func (r *Router) DELETE(uri string, h Handler)

DELETE .

func (*Router) GET

func (r *Router) GET(uri string, h Handler)

GET .

func (*Router) NewRouterGroup

func (r *Router) NewRouterGroup(p string) *Router

NewRouterGroup .

func (*Router) POST

func (r *Router) POST(uri string, h Handler)

POST .

func (*Router) PUT

func (r *Router) PUT(uri string, h Handler)

PUT .

type Server

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

Server .

func (*Server) Lifecycle

func (srv *Server) Lifecycle(hooks ...*lifecycle.Hook)

Lifecycle .

func (*Server) Publish

func (srv *Server) Publish(topic string, v interface{}, opts ...broker.PublishOption)

Publish 消息异步发布

func (*Server) RegisterRouter

func (srv *Server) RegisterRouter(fn func(r *Router))

RegisterRouter 注册路由

func (*Server) RegisterRouterGroup

func (srv *Server) RegisterRouterGroup(uri string, fn func(r *Router), handlers ...gin.HandlerFunc)

RegisterRouterGroup 注册路由组

func (*Server) Subscribe

func (srv *Server) Subscribe(topic string, handler broker.Handler, opts ...broker.SubscribeOption)

Subscribe 消息订阅

func (*Server) Unmarshal

func (srv *Server) Unmarshal(v interface{}) error

Unmarshal 序列化 configuration 中的自定义配置项

func (*Server) Use

func (srv *Server) Use(middleware ...gin.HandlerFunc)

Use .