server

type Handler struct {
	Resource       string                 // resource name
	Collection     string                 // collection name
	Name           string                 // method name
	Rtype          reflect.Type           // 结构体
	Receiver       reflect.Value          // receiver of method
	Method         reflect.Method         // method stub
	Query          reflect.Type           // 请求url query pram参数校验器
	Request        reflect.Type           // 请求参数
	QueryValidator *gojsonschema.Schema   // 请求参数校验器
	BodyValidator  *gojsonschema.Schema   // 请求载荷校验器
	Response       reflect.Type           // 返回参数
	Metadata       map[string]string      // 元数据
	Internal       bool                   // 内部rpc，不对外, 文档接口与http api需要屏蔽
	Hooks          []micro.PreExecuteHook // 执行前
}

type Option func(*Options)

type Options struct {
	Id            uint64
	Name          string
	MaxMsgSize    int
	Version       *micro.Version // 当前服务版本号
	Min           *micro.Version // 支持的最小版本(默认当前版本)
	Max           *micro.Version // 支持的最大版本(默认当前版本)
	Interval      time.Duration
	Listener      net.Listener
	Broker        broker.Broker
	Registry      micro.Registry
	Components    []micro.Component
	GrpcOpts      []grpc.ServerOption
	BrokerOpts    []broker.SubscribeOption
	RegisterCheck func(context.Context) error
	WaitGroup     *sync.WaitGroup
	Metadata      map[string]string

	Credentials credentials.TransportCredentials
}

type RPCServer struct {
	tp.UnimplementedTransportServer

	sync.RWMutex
	// contains filtered or unexported fields
}

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