rpcx

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

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

type RpcClientConf struct {
	Etcd    discov.EtcdConf `json:",optional"`
	Server  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]"`
}