router

Documentation

Index

• type HandldFunc
• type HandleWrapper
• type MethodDesc
• type Router
  • func NewRouter() *Router
  • func (r *Router) Forward(rpcName string, handleFunc HandleWrapper)
  • func (r *Router) RegisterService(srvDesc *ServiceDesc, srvImpl interface{}) error
  • func (r *Router) Route(rpcName string) (HandleWrapper, error)
• type ServiceDesc
• type StreamDesc

Types

type HandldFunc

type HandldFunc = func(svr interface{}, ctx context.Context, req interface{}) (rsp interface{}, err error)

type HandleWrapper

type HandleWrapper func(ctx context.Context, req interface{}) (rsp interface{}, err error)

type MethodDesc

type MethodDesc struct {
	Name   string
	Method HandldFunc
}

method description

type Router

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

func NewRouter

func NewRouter() *Router

return a router

func (*Router) Forward

func (r *Router) Forward(rpcName string, handleFunc HandleWrapper)

func (*Router) RegisterService

func (r *Router) RegisterService(srvDesc *ServiceDesc, srvImpl interface{}) error

register service

func (*Router) Route

func (r *Router) Route(rpcName string) (HandleWrapper, error)

type ServiceDesc

type ServiceDesc struct {
	// like serviceName.serviceMethod
	Name   string
	Type   interface{}
	Method map[string]*MethodDesc
	Stream map[string]*StreamDesc
}

service description

type StreamDesc

type StreamDesc struct {
}

stream scription