rpc

type CallType int32

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

type ClientConfig struct {
	// local address
	AppName     string `default:"rcp-client" yaml:"app_name" json:"app_name,omitempty"`
	Host        string `default:"127.0.0.1" yaml:"host" json:"host,omitempty"`
	ProfilePort int    `default:"10086" yaml:"profile_port" json:"profile_port,omitempty"`

	// session pool
	ConnectionNum int `default:"16" yaml:"connection_num" json:"connection_num,omitempty"`

	// heartbeat
	HeartbeatPeriod string `default:"15s" yaml:"heartbeat_period" json:"heartbeat_period, omitempty"`

	// session
	SessionTimeout string `default:"60s" yaml:"session_timeout" json:"session_timeout,omitempty"`

	// app
	FailFastTimeout string `default:"5s" yaml:"fail_fast_timeout" json:"fail_fast_timeout, omitempty"`

	// Connection Pool
	PoolSize int `default:"2" yaml:"pool_size" json:"pool_size,omitempty"`
	PoolTTL  int `default:"180" yaml:"pool_ttl" json:"pool_ttl,omitempty"`

	// session tcp parameters
	GettySessionParam GettySessionParam `required:"true" yaml:"getty_session_param" json:"getty_session_param,omitempty"`
	// contains filtered or unexported fields
}

type Codec interface {
	Encode(interface{}) ([]byte, error)
	Decode([]byte, interface{}) error
}

type CodecType int16

type GettyErrorCode int16

type GettyPackage struct {
	H GettyPackageHeader
	B RPCPackage
}

type GettyPackageHeader struct {
	Magic    MagicType    // magic number
	LogID    LogIDType    // log id
	Sequence SequenceType // request/response sequence

	Command   gettyCommand  // operation command code
	ServiceID ServiceIDType // service id

	Code      GettyErrorCode // error code
	CodecType CodecType
	PkgLen    PkgLenType
}

type GettyRPCHeaderLenType uint16

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

type GettyRPCRequestHeader struct {
	Service  string   `protobuf:"bytes,1,opt,name=Service" json:"Service"`
	Method   string   `protobuf:"bytes,2,opt,name=Method" json:"Method"`
	CallType CallType `protobuf:"varint,3,opt,name=CallType,enum=rpc.CallType" json:"CallType"`
}

type GettyRPCRequestPackage struct {
	H GettyPackageHeader
	// contains filtered or unexported fields
}

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

type GettyRPCResponseHeader struct {
	Error string `protobuf:"bytes,1,opt,name=Error" json:"Error"`
}

type GettyRPCResponsePackage struct {
	H GettyPackageHeader
	// contains filtered or unexported fields
}

type GettyRPCService interface {
	Service() string // Service Interface
	Version() string
}

type GettySessionParam struct {
	CompressEncoding bool   `default:"false" yaml:"compress_encoding" json:"compress_encoding,omitempty"`
	TcpNoDelay       bool   `default:"true" yaml:"tcp_no_delay" json:"tcp_no_delay,omitempty"`
	TcpKeepAlive     bool   `default:"true" yaml:"tcp_keep_alive" json:"tcp_keep_alive,omitempty"`
	KeepAlivePeriod  string `default:"180s" yaml:"keep_alive_period" json:"keep_alive_period,omitempty"`

	TcpRBufSize    int    `default:"262144" yaml:"tcp_r_buf_size" json:"tcp_r_buf_size,omitempty"`
	TcpWBufSize    int    `default:"65536" yaml:"tcp_w_buf_size" json:"tcp_w_buf_size,omitempty"`
	PkgRQSize      int    `default:"1024" yaml:"pkg_rq_size" json:"pkg_rq_size,omitempty"`
	PkgWQSize      int    `default:"1024" yaml:"pkg_wq_size" json:"pkg_wq_size,omitempty"`
	TcpReadTimeout string `default:"1s" yaml:"tcp_read_timeout" json:"tcp_read_timeout,omitempty"`

	TcpWriteTimeout string `default:"5s" yaml:"tcp_write_timeout" json:"tcp_write_timeout,omitempty"`

	WaitTimeout string `default:"7s" yaml:"wait_timeout" json:"wait_timeout,omitempty"`

	MaxMsgLen   int    `default:"1024" yaml:"max_msg_len" json:"max_msg_len,omitempty"`
	SessionName string `default:"rpc" yaml:"session_name" json:"session_name,omitempty"`
	// contains filtered or unexported fields
}

type JSONCodec struct{}

type LogIDType int32

type MagicType int32

type PBCodec struct{}

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

type PkgLenType int32

type RPCPackage interface {
	Marshal(CodecType, *bytes.Buffer) (int, error)
	// @buf length should be equal to GettyPkg.GettyPackageHeader.Len
	Unmarshal(sz CodecType, buf *bytes.Buffer) error
	GetBody() []byte
	GetHeader() interface{}
}

type RegistryConfig struct {
	Type             string `default:"etcd" yaml:"type" json:"type,omitempty"`
	Addr             string `default:"" yaml:"addr" json:"addr,omitempty"`
	KeepaliveTimeout int    `default:"5" yaml:"keepalive_time" json:"keepalive_timeout,omitempty"`
	Root             string `default:"getty" yaml:"keepalive_time" json:"keepalive_timeout,omitempty"`
	IDC              string `default:"idc-bj" yaml:"idc" json:"idc,omitempty"`
	NodeID           string `default:"node0" yaml:"node_id" json:"node_id,omitempty"`
}

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

type RpcClientPackageHandler struct {
}

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

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

type SequenceType uint64

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

type ServerConfig struct {
	// local address
	AppName     string   `default:"rcp-server" yaml:"app_name" json:"app_name,omitempty"`
	Host        string   `default:"127.0.0.1" yaml:"host" json:"host,omitempty"`
	Ports       []string `yaml:"ports" json:"ports,omitempty"` // `default:["10000"]`
	ProfilePort int      `default:"10086" yaml:"profile_port" json:"profile_port,omitempty"`

	// session
	SessionTimeout string `default:"60s" yaml:"session_timeout" json:"session_timeout,omitempty"`

	SessionNumber int `default:"1000" yaml:"session_number" json:"session_number,omitempty"`

	// app
	FailFastTimeout string `default:"5s" yaml:"fail_fast_timeout" json:"fail_fast_timeout,omitempty"`

	// session tcp parameters
	GettySessionParam GettySessionParam `required:"true" yaml:"getty_session_param" json:"getty_session_param,omitempty"`
	// contains filtered or unexported fields
}

type ServiceIDType int32