Documentation ¶
Overview ¶
Package rpcpb is a generated protocol buffer package.
It is generated from these files:
rpc.proto
It has these top-level messages:
RPCInfo ResultInfo
Index ¶
- Variables
- type RPCInfo
- func (*RPCInfo) Descriptor() ([]byte, []int)
- func (m *RPCInfo) GetArgs() []byte
- func (m *RPCInfo) GetByteFn() int32
- func (m *RPCInfo) GetCid() string
- func (m *RPCInfo) GetExpired() int64
- func (m *RPCInfo) GetFn() string
- func (m *RPCInfo) GetReply() bool
- func (m *RPCInfo) GetReplyTo() string
- func (m *RPCInfo) GetSessionId() string
- func (m *RPCInfo) GetTrack() string
- func (m *RPCInfo) Marshal() (dAtA []byte, err error)
- func (m *RPCInfo) MarshalTo(dAtA []byte) (int, error)
- func (*RPCInfo) ProtoMessage()
- func (m *RPCInfo) Reset()
- func (m *RPCInfo) Size() (n int)
- func (m *RPCInfo) String() string
- func (m *RPCInfo) Unmarshal(dAtA []byte) error
- type ResultInfo
- func (*ResultInfo) Descriptor() ([]byte, []int)
- func (m *ResultInfo) GetCid() string
- func (m *ResultInfo) GetError() string
- func (m *ResultInfo) GetErrorCode() int32
- func (m *ResultInfo) GetResult() []byte
- func (m *ResultInfo) GetResultType() string
- func (m *ResultInfo) Marshal() (dAtA []byte, err error)
- func (m *ResultInfo) MarshalTo(dAtA []byte) (int, error)
- func (*ResultInfo) ProtoMessage()
- func (m *ResultInfo) Reset()
- func (m *ResultInfo) Size() (n int)
- func (m *ResultInfo) String() string
- func (m *ResultInfo) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") )
Functions ¶
This section is empty.
Types ¶
type RPCInfo ¶
type RPCInfo struct { Cid string `protobuf:"bytes,1,opt,name=Cid,proto3" json:"Cid,omitempty"` Fn string `protobuf:"bytes,2,opt,name=Fn,proto3" json:"Fn,omitempty"` ReplyTo string `protobuf:"bytes,3,opt,name=ReplyTo,proto3" json:"ReplyTo,omitempty"` Track string `protobuf:"bytes,4,opt,name=track,proto3" json:"track,omitempty"` Expired int64 `protobuf:"varint,5,opt,name=Expired,proto3" json:"Expired,omitempty"` Reply bool `protobuf:"varint,6,opt,name=Reply,proto3" json:"Reply,omitempty"` SessionId string `protobuf:"bytes,7,opt,name=SessionId,proto3" json:"SessionId,omitempty"` Args []byte `protobuf:"bytes,8,opt,name=Args,proto3" json:"Args,omitempty"` ByteFn int32 `protobuf:"varint,9,opt,name=ByteFn,proto3" json:"ByteFn,omitempty"` }
func (*RPCInfo) Descriptor ¶
func (*RPCInfo) GetExpired ¶
func (*RPCInfo) GetReplyTo ¶
func (*RPCInfo) GetSessionId ¶
func (*RPCInfo) ProtoMessage ¶
func (*RPCInfo) ProtoMessage()
type ResultInfo ¶
type ResultInfo struct { Cid string `protobuf:"bytes,1,opt,name=Cid,proto3" json:"Cid,omitempty"` Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"` ErrorCode int32 `protobuf:"varint,3,opt,name=ErrorCode,proto3" json:"ErrorCode,omitempty"` ResultType string `protobuf:"bytes,4,opt,name=ResultType,proto3" json:"ResultType,omitempty"` Result []byte `protobuf:"bytes,5,opt,name=Result,proto3" json:"Result,omitempty"` }
func NewResultInfo ¶
func (*ResultInfo) Descriptor ¶
func (*ResultInfo) Descriptor() ([]byte, []int)
func (*ResultInfo) GetCid ¶
func (m *ResultInfo) GetCid() string
func (*ResultInfo) GetError ¶
func (m *ResultInfo) GetError() string
func (*ResultInfo) GetErrorCode ¶
func (m *ResultInfo) GetErrorCode() int32
func (*ResultInfo) GetResult ¶
func (m *ResultInfo) GetResult() []byte
func (*ResultInfo) GetResultType ¶
func (m *ResultInfo) GetResultType() string
func (*ResultInfo) Marshal ¶
func (m *ResultInfo) Marshal() (dAtA []byte, err error)
func (*ResultInfo) ProtoMessage ¶
func (*ResultInfo) ProtoMessage()
func (*ResultInfo) Reset ¶
func (m *ResultInfo) Reset()
func (*ResultInfo) Size ¶
func (m *ResultInfo) Size() (n int)
func (*ResultInfo) String ¶
func (m *ResultInfo) String() string
func (*ResultInfo) Unmarshal ¶
func (m *ResultInfo) Unmarshal(dAtA []byte) error
Click to show internal directories.
Click to hide internal directories.