msg_proto

Documentation

Index

• Variables
• type MessageData
  • func (*MessageData) Descriptor() ([]byte, []int)
  • func (x *MessageData) GetClientVersion() string
  • func (x *MessageData) GetGossip() bool
  • func (x *MessageData) GetId() string
  • func (x *MessageData) GetNodeID() string
  • func (x *MessageData) GetNodePubKey() []byte
  • func (x *MessageData) GetPayload() []byte
  • func (x *MessageData) GetSign() []byte
  • func (x *MessageData) GetTimestamp() int64
  • func (*MessageData) ProtoMessage()
  • func (x *MessageData) ProtoReflect() protoreflect.Message
  • func (x *MessageData) Reset()
  • func (x *MessageData) String() string
• type NewBlockMessageData
  • func (*NewBlockMessageData) Descriptor() ([]byte, []int)
  • func (x *NewBlockMessageData) GetBlock() *types_pb.Block
  • func (x *NewBlockMessageData) GetHash() *types_pb.H256
  • func (x *NewBlockMessageData) GetNumber() *types_pb.H256
  • func (*NewBlockMessageData) ProtoMessage()
  • func (x *NewBlockMessageData) ProtoReflect() protoreflect.Message
  • func (x *NewBlockMessageData) Reset()
  • func (x *NewBlockMessageData) String() string
• type ProtocolHandshakeMessage
  • func (*ProtocolHandshakeMessage) Descriptor() ([]byte, []int)
  • func (x *ProtocolHandshakeMessage) GetCurrentHeight() *types_pb.H256
  • func (x *ProtocolHandshakeMessage) GetGenesisHash() *types_pb.H256
  • func (x *ProtocolHandshakeMessage) GetVersion() string
  • func (*ProtocolHandshakeMessage) ProtoMessage()
  • func (x *ProtocolHandshakeMessage) ProtoReflect() protoreflect.Message
  • func (x *ProtocolHandshakeMessage) Reset()
  • func (x *ProtocolHandshakeMessage) String() string
• type TopicScoreSnapshot
  • func (*TopicScoreSnapshot) Descriptor() ([]byte, []int)
  • func (x *TopicScoreSnapshot) GetFirstMessageDeliveries() float32
  • func (x *TopicScoreSnapshot) GetInvalidMessageDeliveries() float32
  • func (x *TopicScoreSnapshot) GetMeshMessageDeliveries() float32
  • func (x *TopicScoreSnapshot) GetTimeInMesh() uint64
  • func (*TopicScoreSnapshot) ProtoMessage()
  • func (x *TopicScoreSnapshot) ProtoReflect() protoreflect.Message
  • func (x *TopicScoreSnapshot) Reset()
  • func (x *TopicScoreSnapshot) String() string

Variables

var File_msg_proto protoreflect.FileDescriptor

Types

type MessageData

type MessageData struct {
	ClientVersion string `protobuf:"bytes,2,opt,name=clientVersion,proto3" json:"clientVersion,omitempty"` //client version
	Timestamp     int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`        //unix time
	Id            string `protobuf:"bytes,4,opt,name=id,proto3" json:"id,omitempty"`                       // message id hash256(payload)
	NodeID        string `protobuf:"bytes,5,opt,name=nodeID,proto3" json:"nodeID,omitempty"`               //id of peer that created the message, not the peer that may have send it.
	NodePubKey    []byte `protobuf:"bytes,6,opt,name=nodePubKey,proto3" json:"nodePubKey,omitempty"`       // peer public key
	Sign          []byte `protobuf:"bytes,7,opt,name=sign,proto3" json:"sign,omitempty"`                   // signature of message data
	Payload       []byte `protobuf:"bytes,8,opt,name=payload,proto3" json:"payload,omitempty"`             // payload
	Gossip        bool   `protobuf:"varint,9,opt,name=gossip,proto3" json:"gossip,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageData) Descriptor

func (*MessageData) Descriptor() ([]byte, []int)

Deprecated: Use MessageData.ProtoReflect.Descriptor instead.

func (*MessageData) GetClientVersion

func (x *MessageData) GetClientVersion() string

func (*MessageData) GetGossip

func (x *MessageData) GetGossip() bool

func (*MessageData) GetId

func (x *MessageData) GetId() string

func (*MessageData) GetNodeID

func (x *MessageData) GetNodeID() string

func (*MessageData) GetNodePubKey

func (x *MessageData) GetNodePubKey() []byte

func (*MessageData) GetPayload

func (x *MessageData) GetPayload() []byte

func (*MessageData) GetSign

func (x *MessageData) GetSign() []byte

func (*MessageData) GetTimestamp

func (x *MessageData) GetTimestamp() int64

func (*MessageData) ProtoMessage

func (*MessageData) ProtoMessage()

func (*MessageData) ProtoReflect

func (x *MessageData) ProtoReflect() protoreflect.Message

func (*MessageData) Reset

func (x *MessageData) Reset()

func (*MessageData) String

func (x *MessageData) String() string

type NewBlockMessageData

type NewBlockMessageData struct {
	Hash   *types_pb.H256  `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Number *types_pb.H256  `protobuf:"bytes,2,opt,name=Number,proto3" json:"Number,omitempty"`
	Block  *types_pb.Block `protobuf:"bytes,3,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

func (*NewBlockMessageData) Descriptor

func (*NewBlockMessageData) Descriptor() ([]byte, []int)

Deprecated: Use NewBlockMessageData.ProtoReflect.Descriptor instead.

func (*NewBlockMessageData) GetBlock

func (x *NewBlockMessageData) GetBlock() *types_pb.Block

func (*NewBlockMessageData) GetHash

func (x *NewBlockMessageData) GetHash() *types_pb.H256

func (*NewBlockMessageData) GetNumber

func (x *NewBlockMessageData) GetNumber() *types_pb.H256

func (*NewBlockMessageData) ProtoMessage

func (*NewBlockMessageData) ProtoMessage()

func (*NewBlockMessageData) ProtoReflect

func (x *NewBlockMessageData) ProtoReflect() protoreflect.Message

func (*NewBlockMessageData) Reset

func (x *NewBlockMessageData) Reset()

func (*NewBlockMessageData) String

func (x *NewBlockMessageData) String() string

type ProtocolHandshakeMessage

type ProtocolHandshakeMessage struct {
	Version       string         `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	GenesisHash   *types_pb.H256 `protobuf:"bytes,2,opt,name=genesisHash,proto3" json:"genesisHash,omitempty"`
	CurrentHeight *types_pb.H256 `protobuf:"bytes,3,opt,name=currentHeight,proto3" json:"currentHeight,omitempty"`
	// contains filtered or unexported fields
}

func (*ProtocolHandshakeMessage) Descriptor

func (*ProtocolHandshakeMessage) Descriptor() ([]byte, []int)

Deprecated: Use ProtocolHandshakeMessage.ProtoReflect.Descriptor instead.

func (*ProtocolHandshakeMessage) GetCurrentHeight

func (x *ProtocolHandshakeMessage) GetCurrentHeight() *types_pb.H256

func (*ProtocolHandshakeMessage) GetGenesisHash

func (x *ProtocolHandshakeMessage) GetGenesisHash() *types_pb.H256

func (*ProtocolHandshakeMessage) GetVersion

func (x *ProtocolHandshakeMessage) GetVersion() string

func (*ProtocolHandshakeMessage) ProtoMessage

func (*ProtocolHandshakeMessage) ProtoMessage()

func (*ProtocolHandshakeMessage) ProtoReflect

func (x *ProtocolHandshakeMessage) ProtoReflect() protoreflect.Message

func (*ProtocolHandshakeMessage) Reset

func (x *ProtocolHandshakeMessage) Reset()

func (*ProtocolHandshakeMessage) String

func (x *ProtocolHandshakeMessage) String() string

type TopicScoreSnapshot

type TopicScoreSnapshot struct {

	// Time a peer has spent in the gossip mesh.
	TimeInMesh uint64 `protobuf:"varint,1,opt,name=time_in_mesh,json=timeInMesh,proto3" json:"time_in_mesh,omitempty"`
	// This is the number of first message deliveries in the topic.
	FirstMessageDeliveries float32 `` /* 131-byte string literal not displayed */
	// This is the number of message deliveries in the mesh, within the MeshMessageDeliveriesWindow of
	// message validation.It effectively tracks first and near-first
	// deliveries, ie a message seen from a mesh peer before we have forwarded it to them.
	MeshMessageDeliveries float32 `` /* 128-byte string literal not displayed */
	// This is the number of invalid messages in the topic from the peer.
	InvalidMessageDeliveries float32 `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TopicScoreSnapshot) Descriptor

func (*TopicScoreSnapshot) Descriptor() ([]byte, []int)

Deprecated: Use TopicScoreSnapshot.ProtoReflect.Descriptor instead.

func (*TopicScoreSnapshot) GetFirstMessageDeliveries

func (x *TopicScoreSnapshot) GetFirstMessageDeliveries() float32

func (*TopicScoreSnapshot) GetInvalidMessageDeliveries

func (x *TopicScoreSnapshot) GetInvalidMessageDeliveries() float32

func (*TopicScoreSnapshot) GetMeshMessageDeliveries

func (x *TopicScoreSnapshot) GetMeshMessageDeliveries() float32

func (*TopicScoreSnapshot) GetTimeInMesh

func (x *TopicScoreSnapshot) GetTimeInMesh() uint64

func (*TopicScoreSnapshot) ProtoMessage

func (*TopicScoreSnapshot) ProtoMessage()

func (*TopicScoreSnapshot) ProtoReflect

func (x *TopicScoreSnapshot) ProtoReflect() protoreflect.Message

func (*TopicScoreSnapshot) Reset

func (x *TopicScoreSnapshot) Reset()

func (*TopicScoreSnapshot) String

func (x *TopicScoreSnapshot) String() string