server

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

type Context struct {
	Ctx        context.Context
	Service    string
	Method     string
	RemoteAddr string
	Namespace  string
	Peer       string // 包含app_name的上游service_name
	Code       int32

	// rpc request raw header
	Header map[string]string

	// rpc request raw body
	Body     []byte
	Request  interface{}
	Response interface{}
	// contains filtered or unexported fields
}

type Handler interface {
	Name() string
	Handler() interface{}
}

type HandlerOption func(*HandlerOptions)

type HandlerOptions struct {
	HandlerName string
}

type Option func(*Options)

type Options struct {
	Codec    codec.Codec
	Address  string
	Name     string
	Tracer   opentracing.Tracer
	Kit      log.Kit
	Manager  *registry.ServiceManager
	Tags     map[string]string
	Registry registry.Backend
	Limiter  *ratelimit.Config
	Breaker  *breaker.Config
}

type Plugin func(c *Context)

type Server interface {
	NewHandler(interface{}, ...HandlerOption) Handler

	// registe a Handler to server
	Handle(Handler) error

	// registe middlewares to a handler
	Use(...Plugin) Server

	Start() error
	Stop() error

	GetPaths() []string
}