Documentation
¶
Index ¶
- Variables
- type SendErrorMsg
- func (*SendErrorMsg) Descriptor() ([]byte, []int)deprecated
- func (x *SendErrorMsg) GetErrorCode() int32
- func (x *SendErrorMsg) GetErrorMessage() string
- func (x *SendErrorMsg) GetNodeId() []byte
- func (x *SendErrorMsg) GetRequestId() uint32
- func (*SendErrorMsg) ProtoMessage()
- func (x *SendErrorMsg) ProtoReflect() protoreflect.Message
- func (x *SendErrorMsg) Reset()
- func (x *SendErrorMsg) String() string
- type SendGossipMsg
- func (*SendGossipMsg) Descriptor() ([]byte, []int)deprecated
- func (x *SendGossipMsg) GetMsg() []byte
- func (x *SendGossipMsg) GetNodeIds() [][]byte
- func (x *SendGossipMsg) GetNonValidators() uint64
- func (x *SendGossipMsg) GetPeers() uint64
- func (x *SendGossipMsg) GetValidators() uint64
- func (*SendGossipMsg) ProtoMessage()
- func (x *SendGossipMsg) ProtoReflect() protoreflect.Message
- func (x *SendGossipMsg) Reset()
- func (x *SendGossipMsg) String() string
- type SendRequestMsg
- func (*SendRequestMsg) Descriptor() ([]byte, []int)deprecated
- func (x *SendRequestMsg) GetNodeIds() [][]byte
- func (x *SendRequestMsg) GetRequest() []byte
- func (x *SendRequestMsg) GetRequestId() uint32
- func (*SendRequestMsg) ProtoMessage()
- func (x *SendRequestMsg) ProtoReflect() protoreflect.Message
- func (x *SendRequestMsg) Reset()
- func (x *SendRequestMsg) String() string
- type SendResponseMsg
- func (*SendResponseMsg) Descriptor() ([]byte, []int)deprecated
- func (x *SendResponseMsg) GetNodeId() []byte
- func (x *SendResponseMsg) GetRequestId() uint32
- func (x *SendResponseMsg) GetResponse() []byte
- func (*SendResponseMsg) ProtoMessage()
- func (x *SendResponseMsg) ProtoReflect() protoreflect.Message
- func (x *SendResponseMsg) Reset()
- func (x *SendResponseMsg) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_proto_sender_sender_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type SendErrorMsg ¶
type SendErrorMsg struct {
// The node to send a response to
NodeId []byte `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// ID of this request
RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Application-defined error code
ErrorCode int32 `protobuf:"zigzag32,3,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
// Application-defined error message
ErrorMessage string `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
// contains filtered or unexported fields
}
func (*SendErrorMsg) Descriptor
deprecated
func (*SendErrorMsg) Descriptor() ([]byte, []int)
Deprecated: Use SendErrorMsg.ProtoReflect.Descriptor instead.
func (*SendErrorMsg) GetErrorCode ¶
func (x *SendErrorMsg) GetErrorCode() int32
func (*SendErrorMsg) GetErrorMessage ¶
func (x *SendErrorMsg) GetErrorMessage() string
func (*SendErrorMsg) GetNodeId ¶
func (x *SendErrorMsg) GetNodeId() []byte
func (*SendErrorMsg) GetRequestId ¶
func (x *SendErrorMsg) GetRequestId() uint32
func (*SendErrorMsg) ProtoMessage ¶
func (*SendErrorMsg) ProtoMessage()
func (*SendErrorMsg) ProtoReflect ¶
func (x *SendErrorMsg) ProtoReflect() protoreflect.Message
func (*SendErrorMsg) Reset ¶
func (x *SendErrorMsg) Reset()
func (*SendErrorMsg) String ¶
func (x *SendErrorMsg) String() string
type SendGossipMsg ¶
type SendGossipMsg struct {
// Who to send this message to
NodeIds [][]byte `protobuf:"bytes,1,rep,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
Validators uint64 `protobuf:"varint,2,opt,name=validators,proto3" json:"validators,omitempty"`
NonValidators uint64 `protobuf:"varint,3,opt,name=non_validators,json=nonValidators,proto3" json:"non_validators,omitempty"`
Peers uint64 `protobuf:"varint,4,opt,name=peers,proto3" json:"peers,omitempty"`
// The message body
Msg []byte `protobuf:"bytes,5,opt,name=msg,proto3" json:"msg,omitempty"`
// contains filtered or unexported fields
}
func (*SendGossipMsg) Descriptor
deprecated
func (*SendGossipMsg) Descriptor() ([]byte, []int)
Deprecated: Use SendGossipMsg.ProtoReflect.Descriptor instead.
func (*SendGossipMsg) GetMsg ¶
func (x *SendGossipMsg) GetMsg() []byte
func (*SendGossipMsg) GetNodeIds ¶
func (x *SendGossipMsg) GetNodeIds() [][]byte
func (*SendGossipMsg) GetNonValidators ¶
func (x *SendGossipMsg) GetNonValidators() uint64
func (*SendGossipMsg) GetPeers ¶
func (x *SendGossipMsg) GetPeers() uint64
func (*SendGossipMsg) GetValidators ¶
func (x *SendGossipMsg) GetValidators() uint64
func (*SendGossipMsg) ProtoMessage ¶
func (*SendGossipMsg) ProtoMessage()
func (*SendGossipMsg) ProtoReflect ¶
func (x *SendGossipMsg) ProtoReflect() protoreflect.Message
func (*SendGossipMsg) Reset ¶
func (x *SendGossipMsg) Reset()
func (*SendGossipMsg) String ¶
func (x *SendGossipMsg) String() string
type SendRequestMsg ¶
type SendRequestMsg struct {
// The nodes to send this request to
NodeIds [][]byte `protobuf:"bytes,1,rep,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
// The ID of this request
RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// The request body
Request []byte `protobuf:"bytes,3,opt,name=request,proto3" json:"request,omitempty"`
// contains filtered or unexported fields
}
func (*SendRequestMsg) Descriptor
deprecated
func (*SendRequestMsg) Descriptor() ([]byte, []int)
Deprecated: Use SendRequestMsg.ProtoReflect.Descriptor instead.
func (*SendRequestMsg) GetNodeIds ¶
func (x *SendRequestMsg) GetNodeIds() [][]byte
func (*SendRequestMsg) GetRequest ¶
func (x *SendRequestMsg) GetRequest() []byte
func (*SendRequestMsg) GetRequestId ¶
func (x *SendRequestMsg) GetRequestId() uint32
func (*SendRequestMsg) ProtoMessage ¶
func (*SendRequestMsg) ProtoMessage()
func (*SendRequestMsg) ProtoReflect ¶
func (x *SendRequestMsg) ProtoReflect() protoreflect.Message
func (*SendRequestMsg) Reset ¶
func (x *SendRequestMsg) Reset()
func (*SendRequestMsg) String ¶
func (x *SendRequestMsg) String() string
type SendResponseMsg ¶
type SendResponseMsg struct {
// The node to send a response to
NodeId []byte `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
// ID of this request
RequestId uint32 `protobuf:"varint,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// The response body
Response []byte `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"`
// contains filtered or unexported fields
}
func (*SendResponseMsg) Descriptor
deprecated
func (*SendResponseMsg) Descriptor() ([]byte, []int)
Deprecated: Use SendResponseMsg.ProtoReflect.Descriptor instead.
func (*SendResponseMsg) GetNodeId ¶
func (x *SendResponseMsg) GetNodeId() []byte
func (*SendResponseMsg) GetRequestId ¶
func (x *SendResponseMsg) GetRequestId() uint32
func (*SendResponseMsg) GetResponse ¶
func (x *SendResponseMsg) GetResponse() []byte
func (*SendResponseMsg) ProtoMessage ¶
func (*SendResponseMsg) ProtoMessage()
func (*SendResponseMsg) ProtoReflect ¶
func (x *SendResponseMsg) ProtoReflect() protoreflect.Message
func (*SendResponseMsg) Reset ¶
func (x *SendResponseMsg) Reset()
func (*SendResponseMsg) String ¶
func (x *SendResponseMsg) String() string
Click to show internal directories.
Click to hide internal directories.