Versions in this module Expand all Collapse all v0 v0.1.2 Oct 1, 2020 v0.1.1 Oct 1, 2020 Changes in this version + var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") + var RPCResponse_Status_name = map[int32]string + var RPCResponse_Status_value = map[string]int32 + type RPCRequest struct + CallerId *string + Data []byte + Deadline *int64 + Procedure *string + RpcId *string + Srvc *string + WantTrace *bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RPCRequest) Descriptor() ([]byte, []int) + func (*RPCRequest) ProtoMessage() + func (m *RPCRequest) GetCallerId() string + func (m *RPCRequest) GetData() []byte + func (m *RPCRequest) GetDeadline() int64 + func (m *RPCRequest) GetProcedure() string + func (m *RPCRequest) GetRpcId() string + func (m *RPCRequest) GetSrvc() string + func (m *RPCRequest) GetWantTrace() bool + func (m *RPCRequest) Marshal() (dAtA []byte, err error) + func (m *RPCRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RPCRequest) Reset() + func (m *RPCRequest) Size() (n int) + func (m *RPCRequest) String() string + func (m *RPCRequest) Unmarshal(dAtA []byte) error + func (m *RPCRequest) XXX_DiscardUnknown() + func (m *RPCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RPCRequest) XXX_Merge(src proto.Message) + func (m *RPCRequest) XXX_Size() int + func (m *RPCRequest) XXX_Unmarshal(b []byte) error + type RPCResponse struct + ErrorMessage *string + ResponseData []byte + ResponseStatus *RPCResponse_Status + RpcId *string + Traceinfo *TraceInfo + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RPCResponse) Descriptor() ([]byte, []int) + func (*RPCResponse) ProtoMessage() + func (m *RPCResponse) GetErrorMessage() string + func (m *RPCResponse) GetResponseData() []byte + func (m *RPCResponse) GetResponseStatus() RPCResponse_Status + func (m *RPCResponse) GetRpcId() string + func (m *RPCResponse) GetTraceinfo() *TraceInfo + func (m *RPCResponse) Marshal() (dAtA []byte, err error) + func (m *RPCResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RPCResponse) Reset() + func (m *RPCResponse) Size() (n int) + func (m *RPCResponse) String() string + func (m *RPCResponse) Unmarshal(dAtA []byte) error + func (m *RPCResponse) XXX_DiscardUnknown() + func (m *RPCResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RPCResponse) XXX_Merge(src proto.Message) + func (m *RPCResponse) XXX_Size() int + func (m *RPCResponse) XXX_Unmarshal(b []byte) error + type RPCResponse_Status int32 + const RPCResponse_STATUS_CLIENT_CALLED_WRONG + const RPCResponse_STATUS_CLIENT_NETWORK_ERROR + const RPCResponse_STATUS_CLIENT_REQUEST_ERROR + const RPCResponse_STATUS_LOADSHED + const RPCResponse_STATUS_MISSED_DEADLINE + const RPCResponse_STATUS_NOT_FOUND + const RPCResponse_STATUS_NOT_OK + const RPCResponse_STATUS_OK + const RPCResponse_STATUS_OVERLOADED_RETRY + const RPCResponse_STATUS_SERVER_ERROR + const RPCResponse_STATUS_TIMEOUT + const RPCResponse_STATUS_UNHEALTHY + const RPCResponse_STATUS_UNKNOWN + func (RPCResponse_Status) EnumDescriptor() ([]byte, []int) + func (x *RPCResponse_Status) UnmarshalJSON(data []byte) error + func (x RPCResponse_Status) Enum() *RPCResponse_Status + func (x RPCResponse_Status) String() string + type TraceInfo struct + ChildCalls []*TraceInfo + EndpointName *string + ErrorMessage *string + MachineName *string + ReceivedTime *int64 + Redirect *string + RepliedTime *int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TraceInfo) Descriptor() ([]byte, []int) + func (*TraceInfo) ProtoMessage() + func (m *TraceInfo) GetChildCalls() []*TraceInfo + func (m *TraceInfo) GetEndpointName() string + func (m *TraceInfo) GetErrorMessage() string + func (m *TraceInfo) GetMachineName() string + func (m *TraceInfo) GetReceivedTime() int64 + func (m *TraceInfo) GetRedirect() string + func (m *TraceInfo) GetRepliedTime() int64 + func (m *TraceInfo) Marshal() (dAtA []byte, err error) + func (m *TraceInfo) MarshalTo(dAtA []byte) (int, error) + func (m *TraceInfo) Reset() + func (m *TraceInfo) Size() (n int) + func (m *TraceInfo) String() string + func (m *TraceInfo) Unmarshal(dAtA []byte) error + func (m *TraceInfo) XXX_DiscardUnknown() + func (m *TraceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TraceInfo) XXX_Merge(src proto.Message) + func (m *TraceInfo) XXX_Size() int + func (m *TraceInfo) XXX_Unmarshal(b []byte) error