zrpc

type Client interface {
	AddInterceptor(interceptor grpc.UnaryClientInterceptor)
	Conn() *grpc.ClientConn
}

type ClientOption = internal.ClientOption

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

type RpcClientConf struct {
	Etcd      discov.EtcdConf `json:",optional"`
	Endpoints []string        `json:",optional=!Etcd"`
	App       string          `json:",optional"`
	Token     string          `json:",optional"`
	Timeout   int64           `json:",optional"`
}

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

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

type RpcServerConf struct {
	service.ServiceConf
	ListenOn      string
	Etcd          discov.EtcdConf    `json:",optional"`
	Auth          bool               `json:",optional"`
	Redis         redis.RedisKeyConf `json:",optional"`
	StrictControl bool               `json:",optional"`
	// pending forever is not allowed
	// never set it to 0, if zero, the underlying will set to 2s automatically
	Timeout      int64 `json:",default=2000"`
	CpuThreshold int64 `json:",default=900,range=[0:1000]"`
}