sender

package
v1.23.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 26, 2026 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL