types

package
v1.0.8 Latest Latest
Warning

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

 Go to latest Published: Mar 26, 2020 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var IdMsgType_name = map[int32]string{
	0: "broadcast_sigblk_id",
	1: "request_sigblk_by_id",
	2: "request_id_ack",
	3: "detect_former_ids",
}
View Source 
var IdMsgType_value = map[string]int32{
	"broadcast_sigblk_id":  0,
	"request_sigblk_by_id": 1,
	"request_id_ack":       2,
	"detect_former_ids":    3,
}

Functions

func WriteMessage 

func WriteMessage(sink *common.ZeroCopySink, msg Message, magic uint32) error

Types

type AddrReq 

type AddrReq struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddrReq) Descriptor added in v1.0.2 

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

func (*AddrReq) ProtoMessage added in v1.0.2 

func (*AddrReq) ProtoMessage()

func (*AddrReq) Reset added in v1.0.2 

func (m *AddrReq) Reset()

func (*AddrReq) String added in v1.0.2 

func (m *AddrReq) String() string

func (*AddrReq) XXX_DiscardUnknown added in v1.0.2 

func (m *AddrReq) XXX_DiscardUnknown()

func (*AddrReq) XXX_Marshal added in v1.0.2 

func (m *AddrReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddrReq) XXX_Merge added in v1.0.2 

func (m *AddrReq) XXX_Merge(src proto.Message)

func (*AddrReq) XXX_Size added in v1.0.2 

func (m *AddrReq) XXX_Size() int

func (*AddrReq) XXX_Unmarshal added in v1.0.2 

func (m *AddrReq) XXX_Unmarshal(b []byte) error

type Address added in v1.0.2 

type Address struct {
	Addr                 []*PeerAddr `protobuf:"bytes,1,rep,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Address) Descriptor added in v1.0.2 

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

func (*Address) GetAddr added in v1.0.2 

func (m *Address) GetAddr() []*PeerAddr

func (*Address) ProtoMessage added in v1.0.2 

func (*Address) ProtoMessage()

func (*Address) Reset added in v1.0.2 

func (m *Address) Reset()

func (*Address) String added in v1.0.2 

func (m *Address) String() string

func (*Address) XXX_DiscardUnknown added in v1.0.2 

func (m *Address) XXX_DiscardUnknown()

func (*Address) XXX_Marshal added in v1.0.2 

func (m *Address) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Address) XXX_Merge added in v1.0.2 

func (m *Address) XXX_Merge(src proto.Message)

func (*Address) XXX_Size added in v1.0.2 

func (m *Address) XXX_Size() int

func (*Address) XXX_Unmarshal added in v1.0.2 

func (m *Address) XXX_Unmarshal(b []byte) error

type BroadcastSigTrx added in v1.0.2 

type BroadcastSigTrx struct {
	SigTrx               *prototype.SignedTransaction `protobuf:"bytes,1,opt,name=SigTrx,proto3" json:"SigTrx,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*BroadcastSigTrx) Descriptor added in v1.0.2 

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

func (*BroadcastSigTrx) GetSigTrx added in v1.0.2 

func (m *BroadcastSigTrx) GetSigTrx() *prototype.SignedTransaction

func (*BroadcastSigTrx) ProtoMessage added in v1.0.2 

func (*BroadcastSigTrx) ProtoMessage()

func (*BroadcastSigTrx) Reset added in v1.0.2 

func (m *BroadcastSigTrx) Reset()

func (*BroadcastSigTrx) String added in v1.0.2 

func (m *BroadcastSigTrx) String() string

func (*BroadcastSigTrx) XXX_DiscardUnknown added in v1.0.2 

func (m *BroadcastSigTrx) XXX_DiscardUnknown()

func (*BroadcastSigTrx) XXX_Marshal added in v1.0.2 

func (m *BroadcastSigTrx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BroadcastSigTrx) XXX_Merge added in v1.0.2 

func (m *BroadcastSigTrx) XXX_Merge(src proto.Message)

func (*BroadcastSigTrx) XXX_Size added in v1.0.2 

func (m *BroadcastSigTrx) XXX_Size() int

func (*BroadcastSigTrx) XXX_Unmarshal added in v1.0.2 

func (m *BroadcastSigTrx) XXX_Unmarshal(b []byte) error

type ClearOutOfRangeState added in v1.0.2 

type ClearOutOfRangeState struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClearOutOfRangeState) Descriptor added in v1.0.2 

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

func (*ClearOutOfRangeState) ProtoMessage added in v1.0.2 

func (*ClearOutOfRangeState) ProtoMessage()

func (*ClearOutOfRangeState) Reset added in v1.0.2 

func (m *ClearOutOfRangeState) Reset()

func (*ClearOutOfRangeState) String added in v1.0.2 

func (m *ClearOutOfRangeState) String() string

func (*ClearOutOfRangeState) XXX_DiscardUnknown added in v1.0.2 

func (m *ClearOutOfRangeState) XXX_DiscardUnknown()

func (*ClearOutOfRangeState) XXX_Marshal added in v1.0.2 

func (m *ClearOutOfRangeState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClearOutOfRangeState) XXX_Merge added in v1.0.2 

func (m *ClearOutOfRangeState) XXX_Merge(src proto.Message)

func (*ClearOutOfRangeState) XXX_Size added in v1.0.2 

func (m *ClearOutOfRangeState) XXX_Size() int

func (*ClearOutOfRangeState) XXX_Unmarshal added in v1.0.2 

func (m *ClearOutOfRangeState) XXX_Unmarshal(b []byte) error

type ConsMsg added in v1.0.2 

type ConsMsg struct {
	Length  uint32
	MsgData message.ConsensusMessage
	Extra   *ConsensusExtraData
}

func (*ConsMsg) CmdType added in v1.0.2 

func (this *ConsMsg) CmdType() string

func (*ConsMsg) Deserialization added in v1.0.2 

func (this *ConsMsg) Deserialization(source *common.ZeroCopySource) error

Deserialize message payload

func (*ConsMsg) Hash added in v1.0.2 

func (this *ConsMsg) Hash() [common.HashSize]byte

func (*ConsMsg) Serialization added in v1.0.2 

func (this *ConsMsg) Serialization(sink *common.ZeroCopySink) error

Serialize message payload

type ConsensusExtraData added in v1.0.2 

type ConsensusExtraData struct {
	Bcast                uint32   `protobuf:"varint,1,opt,name=bcast,proto3" json:"bcast,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConsensusExtraData) Descriptor added in v1.0.2 

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

func (*ConsensusExtraData) GetBcast added in v1.0.2 

func (m *ConsensusExtraData) GetBcast() uint32

func (*ConsensusExtraData) ProtoMessage added in v1.0.2 

func (*ConsensusExtraData) ProtoMessage()

func (*ConsensusExtraData) Reset added in v1.0.2 

func (m *ConsensusExtraData) Reset()

func (*ConsensusExtraData) String added in v1.0.2 

func (m *ConsensusExtraData) String() string

func (*ConsensusExtraData) XXX_DiscardUnknown added in v1.0.2 

func (m *ConsensusExtraData) XXX_DiscardUnknown()

func (*ConsensusExtraData) XXX_Marshal added in v1.0.2 

func (m *ConsensusExtraData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConsensusExtraData) XXX_Merge added in v1.0.2 

func (m *ConsensusExtraData) XXX_Merge(src proto.Message)

func (*ConsensusExtraData) XXX_Size added in v1.0.2 

func (m *ConsensusExtraData) XXX_Size() int

func (*ConsensusExtraData) XXX_Unmarshal added in v1.0.2 

func (m *ConsensusExtraData) XXX_Unmarshal(b []byte) error

type DetectFormerIds added in v1.0.2 

type DetectFormerIds struct {
	EndId                []byte   `protobuf:"bytes,1,opt,name=end_id,json=endId,proto3" json:"end_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DetectFormerIds) Descriptor added in v1.0.2 

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

func (*DetectFormerIds) GetEndId added in v1.0.2 

func (m *DetectFormerIds) GetEndId() []byte

func (*DetectFormerIds) ProtoMessage added in v1.0.2 

func (*DetectFormerIds) ProtoMessage()

func (*DetectFormerIds) Reset added in v1.0.2 

func (m *DetectFormerIds) Reset()

func (*DetectFormerIds) String added in v1.0.2 

func (m *DetectFormerIds) String() string

func (*DetectFormerIds) XXX_DiscardUnknown added in v1.0.2 

func (m *DetectFormerIds) XXX_DiscardUnknown()

func (*DetectFormerIds) XXX_Marshal added in v1.0.2 

func (m *DetectFormerIds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DetectFormerIds) XXX_Merge added in v1.0.2 

func (m *DetectFormerIds) XXX_Merge(src proto.Message)

func (*DetectFormerIds) XXX_Size added in v1.0.2 

func (m *DetectFormerIds) XXX_Size() int

func (*DetectFormerIds) XXX_Unmarshal added in v1.0.2 

func (m *DetectFormerIds) XXX_Unmarshal(b []byte) error

type Disconnected 

type Disconnected struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Disconnected) Descriptor added in v1.0.2 

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

func (*Disconnected) ProtoMessage added in v1.0.2 

func (*Disconnected) ProtoMessage()

func (*Disconnected) Reset added in v1.0.2 

func (m *Disconnected) Reset()

func (*Disconnected) String added in v1.0.2 

func (m *Disconnected) String() string

func (*Disconnected) XXX_DiscardUnknown added in v1.0.2 

func (m *Disconnected) XXX_DiscardUnknown()

func (*Disconnected) XXX_Marshal added in v1.0.2 

func (m *Disconnected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Disconnected) XXX_Merge added in v1.0.2 

func (m *Disconnected) XXX_Merge(src proto.Message)

func (*Disconnected) XXX_Size added in v1.0.2 

func (m *Disconnected) XXX_Size() int

func (*Disconnected) XXX_Unmarshal added in v1.0.2 

func (m *Disconnected) XXX_Unmarshal(b []byte) error

type IdMsg added in v1.0.2 

type IdMsg struct {
	Msgtype              IdMsgType `protobuf:"varint,1,opt,name=msgtype,proto3,enum=types.IdMsgType" json:"msgtype,omitempty"`
	Value                [][]byte  `protobuf:"bytes,2,rep,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*IdMsg) Descriptor added in v1.0.2 

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

func (*IdMsg) GetMsgtype added in v1.0.2 

func (m *IdMsg) GetMsgtype() IdMsgType

func (*IdMsg) GetValue added in v1.0.2 

func (m *IdMsg) GetValue() [][]byte

func (*IdMsg) ProtoMessage added in v1.0.2 

func (*IdMsg) ProtoMessage()

func (*IdMsg) Reset added in v1.0.2 

func (m *IdMsg) Reset()

func (*IdMsg) String added in v1.0.2 

func (m *IdMsg) String() string

func (*IdMsg) XXX_DiscardUnknown added in v1.0.2 

func (m *IdMsg) XXX_DiscardUnknown()

func (*IdMsg) XXX_Marshal added in v1.0.2 

func (m *IdMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IdMsg) XXX_Merge added in v1.0.2 

func (m *IdMsg) XXX_Merge(src proto.Message)

func (*IdMsg) XXX_Size added in v1.0.2 

func (m *IdMsg) XXX_Size() int

func (*IdMsg) XXX_Unmarshal added in v1.0.2 

func (m *IdMsg) XXX_Unmarshal(b []byte) error

type IdMsgType added in v1.0.2 

type IdMsgType int32
const (
	IdMsg_broadcast_sigblk_id  IdMsgType = 0
	IdMsg_request_sigblk_by_id IdMsgType = 1
	IdMsg_request_id_ack       IdMsgType = 2
	IdMsg_detect_former_ids    IdMsgType = 3
)

func (IdMsgType) EnumDescriptor added in v1.0.2 

func (IdMsgType) EnumDescriptor() ([]byte, []int)

func (IdMsgType) String added in v1.0.2 

func (x IdMsgType) String() string

type Message 

type Message interface {
	Serialization(sink *common.ZeroCopySink) error
	Deserialization(source *common.ZeroCopySource) error
	CmdType() string
}

func MakeEmptyMessage 

func MakeEmptyMessage(cmdType string) (Message, error)

func ReadMessage 

func ReadMessage(reader io.Reader, magic uint32) (Message, uint32, error)

type MsgPayload 

type MsgPayload struct {
	Id          uint64  //peer ID
	Addr        string  //link address
	PayloadSize uint32  //payload size
	Payload     Message //msg payload
}

MsgPayload in link channel

type PeerAddr added in v1.0.2 

type PeerAddr struct {
	Time                 int64    `protobuf:"varint,1,opt,name=Time,proto3" json:"Time,omitempty"`
	Services             uint64   `protobuf:"varint,2,opt,name=Services,proto3" json:"Services,omitempty"`
	IpAddr               []byte   `protobuf:"bytes,3,opt,name=IpAddr,proto3" json:"IpAddr,omitempty"`
	Port                 uint32   `protobuf:"varint,4,opt,name=Port,proto3" json:"Port,omitempty"`
	ConsensusPort        uint32   `protobuf:"varint,5,opt,name=ConsensusPort,proto3" json:"ConsensusPort,omitempty"`
	ID                   uint64   `protobuf:"varint,6,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerAddr) Descriptor added in v1.0.2 

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

func (*PeerAddr) GetConsensusPort added in v1.0.2 

func (m *PeerAddr) GetConsensusPort() uint32

func (*PeerAddr) GetID added in v1.0.2 

func (m *PeerAddr) GetID() uint64

func (*PeerAddr) GetIpAddr added in v1.0.2 

func (m *PeerAddr) GetIpAddr() []byte

func (*PeerAddr) GetPort added in v1.0.2 

func (m *PeerAddr) GetPort() uint32

func (*PeerAddr) GetServices added in v1.0.2 

func (m *PeerAddr) GetServices() uint64

func (*PeerAddr) GetTime added in v1.0.2 

func (m *PeerAddr) GetTime() int64

func (*PeerAddr) ProtoMessage added in v1.0.2 

func (*PeerAddr) ProtoMessage()

func (*PeerAddr) Reset added in v1.0.2 

func (m *PeerAddr) Reset()

func (*PeerAddr) String added in v1.0.2 

func (m *PeerAddr) String() string

func (*PeerAddr) XXX_DiscardUnknown added in v1.0.2 

func (m *PeerAddr) XXX_DiscardUnknown()

func (*PeerAddr) XXX_Marshal added in v1.0.2 

func (m *PeerAddr) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerAddr) XXX_Merge added in v1.0.2 

func (m *PeerAddr) XXX_Merge(src proto.Message)

func (*PeerAddr) XXX_Size added in v1.0.2 

func (m *PeerAddr) XXX_Size() int

func (*PeerAddr) XXX_Unmarshal added in v1.0.2 

func (m *PeerAddr) XXX_Unmarshal(b []byte) error

type Ping 

type Ping struct {
	Height               uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Ping) Descriptor added in v1.0.2 

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

func (*Ping) GetHeight added in v1.0.2 

func (m *Ping) GetHeight() uint64

func (*Ping) ProtoMessage added in v1.0.2 

func (*Ping) ProtoMessage()

func (*Ping) Reset added in v1.0.2 

func (m *Ping) Reset()

func (*Ping) String added in v1.0.2 

func (m *Ping) String() string

func (*Ping) XXX_DiscardUnknown added in v1.0.2 

func (m *Ping) XXX_DiscardUnknown()

func (*Ping) XXX_Marshal added in v1.0.2 

func (m *Ping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ping) XXX_Merge added in v1.0.2 

func (m *Ping) XXX_Merge(src proto.Message)

func (*Ping) XXX_Size added in v1.0.2 

func (m *Ping) XXX_Size() int

func (*Ping) XXX_Unmarshal added in v1.0.2 

func (m *Ping) XXX_Unmarshal(b []byte) error

type Pong 

type Pong struct {
	Height               uint64   `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pong) Descriptor added in v1.0.2 

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

func (*Pong) GetHeight added in v1.0.2 

func (m *Pong) GetHeight() uint64

func (*Pong) ProtoMessage added in v1.0.2 

func (*Pong) ProtoMessage()

func (*Pong) Reset added in v1.0.2 

func (m *Pong) Reset()

func (*Pong) String added in v1.0.2 

func (m *Pong) String() string

func (*Pong) XXX_DiscardUnknown added in v1.0.2 

func (m *Pong) XXX_DiscardUnknown()

func (*Pong) XXX_Marshal added in v1.0.2 

func (m *Pong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Pong) XXX_Merge added in v1.0.2 

func (m *Pong) XXX_Merge(src proto.Message)

func (*Pong) XXX_Size added in v1.0.2 

func (m *Pong) XXX_Size() int

func (*Pong) XXX_Unmarshal added in v1.0.2 

func (m *Pong) XXX_Unmarshal(b []byte) error

type ReqIdMsg added in v1.0.2 

type ReqIdMsg struct {
	HeadBlockId          []byte   `protobuf:"bytes,1,opt,name=head_block_id,json=headBlockId,proto3" json:"head_block_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqIdMsg) Descriptor added in v1.0.2 

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

func (*ReqIdMsg) GetHeadBlockId added in v1.0.2 

func (m *ReqIdMsg) GetHeadBlockId() []byte

func (*ReqIdMsg) ProtoMessage added in v1.0.2 

func (*ReqIdMsg) ProtoMessage()

func (*ReqIdMsg) Reset added in v1.0.2 

func (m *ReqIdMsg) Reset()

func (*ReqIdMsg) String added in v1.0.2 

func (m *ReqIdMsg) String() string

func (*ReqIdMsg) XXX_DiscardUnknown added in v1.0.2 

func (m *ReqIdMsg) XXX_DiscardUnknown()

func (*ReqIdMsg) XXX_Marshal added in v1.0.2 

func (m *ReqIdMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReqIdMsg) XXX_Merge added in v1.0.2 

func (m *ReqIdMsg) XXX_Merge(src proto.Message)

func (*ReqIdMsg) XXX_Size added in v1.0.2 

func (m *ReqIdMsg) XXX_Size() int

func (*ReqIdMsg) XXX_Unmarshal added in v1.0.2 

func (m *ReqIdMsg) XXX_Unmarshal(b []byte) error

type RequestBlockBatch added in v1.0.2 

type RequestBlockBatch struct {
	StartId              []byte   `protobuf:"bytes,1,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"`
	EndId                []byte   `protobuf:"bytes,2,opt,name=end_id,json=endId,proto3" json:"end_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

(start_id, end_id]

func (*RequestBlockBatch) Descriptor added in v1.0.2 

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

func (*RequestBlockBatch) GetEndId added in v1.0.2 

func (m *RequestBlockBatch) GetEndId() []byte

func (*RequestBlockBatch) GetStartId added in v1.0.2 

func (m *RequestBlockBatch) GetStartId() []byte

func (*RequestBlockBatch) ProtoMessage added in v1.0.2 

func (*RequestBlockBatch) ProtoMessage()

func (*RequestBlockBatch) Reset added in v1.0.2 

func (m *RequestBlockBatch) Reset()

func (*RequestBlockBatch) String added in v1.0.2 

func (m *RequestBlockBatch) String() string

func (*RequestBlockBatch) XXX_DiscardUnknown added in v1.0.2 

func (m *RequestBlockBatch) XXX_DiscardUnknown()

func (*RequestBlockBatch) XXX_Marshal added in v1.0.2 

func (m *RequestBlockBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestBlockBatch) XXX_Merge added in v1.0.2 

func (m *RequestBlockBatch) XXX_Merge(src proto.Message)

func (*RequestBlockBatch) XXX_Size added in v1.0.2 

func (m *RequestBlockBatch) XXX_Size() int

func (*RequestBlockBatch) XXX_Unmarshal added in v1.0.2 

func (m *RequestBlockBatch) XXX_Unmarshal(b []byte) error

type RequestCheckpointBatch added in v1.0.2 

type RequestCheckpointBatch struct {
	Start                uint64   `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  uint64   `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestCheckpointBatch) Descriptor added in v1.0.2 

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

func (*RequestCheckpointBatch) GetEnd added in v1.0.2 

func (m *RequestCheckpointBatch) GetEnd() uint64

func (*RequestCheckpointBatch) GetStart added in v1.0.2 

func (m *RequestCheckpointBatch) GetStart() uint64

func (*RequestCheckpointBatch) ProtoMessage added in v1.0.2 

func (*RequestCheckpointBatch) ProtoMessage()

func (*RequestCheckpointBatch) Reset added in v1.0.2 

func (m *RequestCheckpointBatch) Reset()

func (*RequestCheckpointBatch) String added in v1.0.2 

func (m *RequestCheckpointBatch) String() string

func (*RequestCheckpointBatch) XXX_DiscardUnknown added in v1.0.2 

func (m *RequestCheckpointBatch) XXX_DiscardUnknown()

func (*RequestCheckpointBatch) XXX_Marshal added in v1.0.2 

func (m *RequestCheckpointBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestCheckpointBatch) XXX_Merge added in v1.0.2 

func (m *RequestCheckpointBatch) XXX_Merge(src proto.Message)

func (*RequestCheckpointBatch) XXX_Size added in v1.0.2 

func (m *RequestCheckpointBatch) XXX_Size() int

func (*RequestCheckpointBatch) XXX_Unmarshal added in v1.0.2 

func (m *RequestCheckpointBatch) XXX_Unmarshal(b []byte) error

type RequestOutOfRangeIds added in v1.0.2 

type RequestOutOfRangeIds struct {
	StartId              []byte   `protobuf:"bytes,1,opt,name=start_id,json=startId,proto3" json:"start_id,omitempty"`
	TargetId             []byte   `protobuf:"bytes,2,opt,name=target_id,json=targetId,proto3" json:"target_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestOutOfRangeIds) Descriptor added in v1.0.2 

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

func (*RequestOutOfRangeIds) GetStartId added in v1.0.2 

func (m *RequestOutOfRangeIds) GetStartId() []byte

func (*RequestOutOfRangeIds) GetTargetId added in v1.0.2 

func (m *RequestOutOfRangeIds) GetTargetId() []byte

func (*RequestOutOfRangeIds) ProtoMessage added in v1.0.2 

func (*RequestOutOfRangeIds) ProtoMessage()

func (*RequestOutOfRangeIds) Reset added in v1.0.2 

func (m *RequestOutOfRangeIds) Reset()

func (*RequestOutOfRangeIds) String added in v1.0.2 

func (m *RequestOutOfRangeIds) String() string

func (*RequestOutOfRangeIds) XXX_DiscardUnknown added in v1.0.2 

func (m *RequestOutOfRangeIds) XXX_DiscardUnknown()

func (*RequestOutOfRangeIds) XXX_Marshal added in v1.0.2 

func (m *RequestOutOfRangeIds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestOutOfRangeIds) XXX_Merge added in v1.0.2 

func (m *RequestOutOfRangeIds) XXX_Merge(src proto.Message)

func (*RequestOutOfRangeIds) XXX_Size added in v1.0.2 

func (m *RequestOutOfRangeIds) XXX_Size() int

func (*RequestOutOfRangeIds) XXX_Unmarshal added in v1.0.2 

func (m *RequestOutOfRangeIds) XXX_Unmarshal(b []byte) error

type SigBlkMsg added in v1.0.2 

type SigBlkMsg struct {
	SigBlk               *prototype.SignedBlock `protobuf:"bytes,1,opt,name=SigBlk,proto3" json:"SigBlk,omitempty"`
	NeedTriggerFetch     bool                   `protobuf:"varint,2,opt,name=need_trigger_fetch,json=needTriggerFetch,proto3" json:"need_trigger_fetch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*SigBlkMsg) Descriptor added in v1.0.2 

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

func (*SigBlkMsg) GetNeedTriggerFetch added in v1.0.2 

func (m *SigBlkMsg) GetNeedTriggerFetch() bool

func (*SigBlkMsg) GetSigBlk added in v1.0.2 

func (m *SigBlkMsg) GetSigBlk() *prototype.SignedBlock

func (*SigBlkMsg) ProtoMessage added in v1.0.2 

func (*SigBlkMsg) ProtoMessage()

func (*SigBlkMsg) Reset added in v1.0.2 

func (m *SigBlkMsg) Reset()

func (*SigBlkMsg) String added in v1.0.2 

func (m *SigBlkMsg) String() string

func (*SigBlkMsg) XXX_DiscardUnknown added in v1.0.2 

func (m *SigBlkMsg) XXX_DiscardUnknown()

func (*SigBlkMsg) XXX_Marshal added in v1.0.2 

func (m *SigBlkMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SigBlkMsg) XXX_Merge added in v1.0.2 

func (m *SigBlkMsg) XXX_Merge(src proto.Message)

func (*SigBlkMsg) XXX_Size added in v1.0.2 

func (m *SigBlkMsg) XXX_Size() int

func (*SigBlkMsg) XXX_Unmarshal added in v1.0.2 

func (m *SigBlkMsg) XXX_Unmarshal(b []byte) error

type TransferMsg added in v1.0.2 

type TransferMsg struct {
	// Types that are valid to be assigned to Msg:
	//	*TransferMsg_Msg1
	//	*TransferMsg_Msg2
	//	*TransferMsg_Msg3
	//	*TransferMsg_Msg4
	//	*TransferMsg_Msg5
	//	*TransferMsg_Msg6
	//	*TransferMsg_Msg7
	//	*TransferMsg_Msg8
	//	*TransferMsg_Msg9
	//	*TransferMsg_Msg10
	//	*TransferMsg_Msg11
	//	*TransferMsg_Msg12
	//	*TransferMsg_Msg13
	//	*TransferMsg_Msg14
	//	*TransferMsg_Msg15
	//	*TransferMsg_Msg16
	Msg                  isTransferMsg_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TransferMsg) CmdType added in v1.0.2 

func (this *TransferMsg) CmdType() (res string)

func (*TransferMsg) Descriptor added in v1.0.2 

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

func (*TransferMsg) Deserialization added in v1.0.2 

func (this *TransferMsg) Deserialization(source *common.ZeroCopySource) error

Deserialize message payload

func (*TransferMsg) GetMsg added in v1.0.2 

func (m *TransferMsg) GetMsg() isTransferMsg_Msg

func (*TransferMsg) GetMsg1 added in v1.0.2 

func (m *TransferMsg) GetMsg1() *BroadcastSigTrx

func (*TransferMsg) GetMsg10 added in v1.0.2 

func (m *TransferMsg) GetMsg10() *VerAck

func (*TransferMsg) GetMsg11 added in v1.0.2 

func (m *TransferMsg) GetMsg11() *Version

func (*TransferMsg) GetMsg12 added in v1.0.2 

func (m *TransferMsg) GetMsg12() *RequestCheckpointBatch

func (*TransferMsg) GetMsg13 added in v1.0.2 

func (m *TransferMsg) GetMsg13() *RequestOutOfRangeIds

func (*TransferMsg) GetMsg14 added in v1.0.2 

func (m *TransferMsg) GetMsg14() *RequestBlockBatch

func (*TransferMsg) GetMsg15 added in v1.0.2 

func (m *TransferMsg) GetMsg15() *DetectFormerIds

func (*TransferMsg) GetMsg16 added in v1.0.2 

func (m *TransferMsg) GetMsg16() *ClearOutOfRangeState

func (*TransferMsg) GetMsg2 added in v1.0.2 

func (m *TransferMsg) GetMsg2() *IdMsg

func (*TransferMsg) GetMsg3 added in v1.0.2 

func (m *TransferMsg) GetMsg3() *SigBlkMsg

func (*TransferMsg) GetMsg4 added in v1.0.2 

func (m *TransferMsg) GetMsg4() *ReqIdMsg

func (*TransferMsg) GetMsg5 added in v1.0.2 

func (m *TransferMsg) GetMsg5() *Address

func (*TransferMsg) GetMsg6 added in v1.0.2 

func (m *TransferMsg) GetMsg6() *AddrReq

func (*TransferMsg) GetMsg7 added in v1.0.2 

func (m *TransferMsg) GetMsg7() *Disconnected

func (*TransferMsg) GetMsg8 added in v1.0.2 

func (m *TransferMsg) GetMsg8() *Ping

func (*TransferMsg) GetMsg9 added in v1.0.2 

func (m *TransferMsg) GetMsg9() *Pong

func (*TransferMsg) ProtoMessage added in v1.0.2 

func (*TransferMsg) ProtoMessage()

func (*TransferMsg) Reset added in v1.0.2 

func (m *TransferMsg) Reset()

func (*TransferMsg) Serialization added in v1.0.2 

func (this *TransferMsg) Serialization(sink *common.ZeroCopySink) error

Serialize message payload

func (*TransferMsg) String added in v1.0.2 

func (m *TransferMsg) String() string

func (*TransferMsg) XXX_DiscardUnknown added in v1.0.2 

func (m *TransferMsg) XXX_DiscardUnknown()

func (*TransferMsg) XXX_Marshal added in v1.0.2 

func (m *TransferMsg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransferMsg) XXX_Merge added in v1.0.2 

func (m *TransferMsg) XXX_Merge(src proto.Message)

func (*TransferMsg) XXX_OneofWrappers added in v1.0.2 

func (*TransferMsg) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TransferMsg) XXX_Size added in v1.0.2 

func (m *TransferMsg) XXX_Size() int

func (*TransferMsg) XXX_Unmarshal added in v1.0.2 

func (m *TransferMsg) XXX_Unmarshal(b []byte) error

type TransferMsg_Msg1 added in v1.0.2 

type TransferMsg_Msg1 struct {
	Msg1 *BroadcastSigTrx `protobuf:"bytes,1,opt,name=msg1,proto3,oneof"`
}

type TransferMsg_Msg10 added in v1.0.2 

type TransferMsg_Msg10 struct {
	Msg10 *VerAck `protobuf:"bytes,10,opt,name=msg10,proto3,oneof"`
}

type TransferMsg_Msg11 added in v1.0.2 

type TransferMsg_Msg11 struct {
	Msg11 *Version `protobuf:"bytes,11,opt,name=msg11,proto3,oneof"`
}

type TransferMsg_Msg12 added in v1.0.2 

type TransferMsg_Msg12 struct {
	Msg12 *RequestCheckpointBatch `protobuf:"bytes,12,opt,name=msg12,proto3,oneof"`
}

type TransferMsg_Msg13 added in v1.0.2 

type TransferMsg_Msg13 struct {
	Msg13 *RequestOutOfRangeIds `protobuf:"bytes,13,opt,name=msg13,proto3,oneof"`
}

type TransferMsg_Msg14 added in v1.0.2 

type TransferMsg_Msg14 struct {
	Msg14 *RequestBlockBatch `protobuf:"bytes,14,opt,name=msg14,proto3,oneof"`
}

type TransferMsg_Msg15 added in v1.0.2 

type TransferMsg_Msg15 struct {
	Msg15 *DetectFormerIds `protobuf:"bytes,15,opt,name=msg15,proto3,oneof"`
}

type TransferMsg_Msg16 added in v1.0.2 

type TransferMsg_Msg16 struct {
	Msg16 *ClearOutOfRangeState `protobuf:"bytes,16,opt,name=msg16,proto3,oneof"`
}

type TransferMsg_Msg2 added in v1.0.2 

type TransferMsg_Msg2 struct {
	Msg2 *IdMsg `protobuf:"bytes,2,opt,name=msg2,proto3,oneof"`
}

type TransferMsg_Msg3 added in v1.0.2 

type TransferMsg_Msg3 struct {
	Msg3 *SigBlkMsg `protobuf:"bytes,3,opt,name=msg3,proto3,oneof"`
}

type TransferMsg_Msg4 added in v1.0.2 

type TransferMsg_Msg4 struct {
	Msg4 *ReqIdMsg `protobuf:"bytes,4,opt,name=msg4,proto3,oneof"`
}

type TransferMsg_Msg5 added in v1.0.2 

type TransferMsg_Msg5 struct {
	Msg5 *Address `protobuf:"bytes,5,opt,name=msg5,proto3,oneof"`
}

type TransferMsg_Msg6 added in v1.0.2 

type TransferMsg_Msg6 struct {
	Msg6 *AddrReq `protobuf:"bytes,6,opt,name=msg6,proto3,oneof"`
}

type TransferMsg_Msg7 added in v1.0.2 

type TransferMsg_Msg7 struct {
	Msg7 *Disconnected `protobuf:"bytes,7,opt,name=msg7,proto3,oneof"`
}

type TransferMsg_Msg8 added in v1.0.2 

type TransferMsg_Msg8 struct {
	Msg8 *Ping `protobuf:"bytes,8,opt,name=msg8,proto3,oneof"`
}

type TransferMsg_Msg9 added in v1.0.2 

type TransferMsg_Msg9 struct {
	Msg9 *Pong `protobuf:"bytes,9,opt,name=msg9,proto3,oneof"`
}

type VerAck added in v1.0.2 

type VerAck struct {
	IsConsensus          bool     `protobuf:"varint,1,opt,name=IsConsensus,proto3" json:"IsConsensus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VerAck) Descriptor added in v1.0.2 

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

func (*VerAck) GetIsConsensus added in v1.0.2 

func (m *VerAck) GetIsConsensus() bool

func (*VerAck) ProtoMessage added in v1.0.2 

func (*VerAck) ProtoMessage()

func (*VerAck) Reset added in v1.0.2 

func (m *VerAck) Reset()

func (*VerAck) String added in v1.0.2 

func (m *VerAck) String() string

func (*VerAck) XXX_DiscardUnknown added in v1.0.2 

func (m *VerAck) XXX_DiscardUnknown()

func (*VerAck) XXX_Marshal added in v1.0.2 

func (m *VerAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VerAck) XXX_Merge added in v1.0.2 

func (m *VerAck) XXX_Merge(src proto.Message)

func (*VerAck) XXX_Size added in v1.0.2 

func (m *VerAck) XXX_Size() int

func (*VerAck) XXX_Unmarshal added in v1.0.2 

func (m *VerAck) XXX_Unmarshal(b []byte) error

type Version 

type Version struct {
	Version              uint32   `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Services             uint64   `protobuf:"varint,2,opt,name=services,proto3" json:"services,omitempty"`
	Timestamp            int64    `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	SyncPort             uint32   `protobuf:"varint,4,opt,name=syncPort,proto3" json:"syncPort,omitempty"`
	ConsPort             uint32   `protobuf:"varint,5,opt,name=consPort,proto3" json:"consPort,omitempty"`
	Cap                  []byte   `protobuf:"bytes,6,opt,name=cap,proto3" json:"cap,omitempty"`
	Nonce                uint64   `protobuf:"varint,7,opt,name=nonce,proto3" json:"nonce,omitempty"`
	StartHeight          uint64   `protobuf:"varint,8,opt,name=startHeight,proto3" json:"startHeight,omitempty"`
	Relay                uint32   `protobuf:"varint,9,opt,name=relay,proto3" json:"relay,omitempty"`
	IsConsensus          bool     `protobuf:"varint,10,opt,name=IsConsensus,proto3" json:"IsConsensus,omitempty"`
	RunningCodeVersion   string   `protobuf:"bytes,11,opt,name=RunningCodeVersion,proto3" json:"RunningCodeVersion,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Version) Descriptor added in v1.0.2 

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

func (*Version) GetCap added in v1.0.2 

func (m *Version) GetCap() []byte

func (*Version) GetConsPort added in v1.0.2 

func (m *Version) GetConsPort() uint32

func (*Version) GetIsConsensus added in v1.0.2 

func (m *Version) GetIsConsensus() bool

func (*Version) GetNonce added in v1.0.2 

func (m *Version) GetNonce() uint64

func (*Version) GetRelay added in v1.0.2 

func (m *Version) GetRelay() uint32

func (*Version) GetRunningCodeVersion added in v1.0.2 

func (m *Version) GetRunningCodeVersion() string

func (*Version) GetServices added in v1.0.2 

func (m *Version) GetServices() uint64

func (*Version) GetStartHeight added in v1.0.2 

func (m *Version) GetStartHeight() uint64

func (*Version) GetSyncPort added in v1.0.2 

func (m *Version) GetSyncPort() uint32

func (*Version) GetTimestamp added in v1.0.2 

func (m *Version) GetTimestamp() int64

func (*Version) GetVersion added in v1.0.2 

func (m *Version) GetVersion() uint32

func (*Version) ProtoMessage added in v1.0.2 

func (*Version) ProtoMessage()

func (*Version) Reset added in v1.0.2 

func (m *Version) Reset()

func (*Version) String added in v1.0.2 

func (m *Version) String() string

func (*Version) XXX_DiscardUnknown added in v1.0.2 

func (m *Version) XXX_DiscardUnknown()

func (*Version) XXX_Marshal added in v1.0.2 

func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Version) XXX_Merge added in v1.0.2 

func (m *Version) XXX_Merge(src proto.Message)

func (*Version) XXX_Size added in v1.0.2 

func (m *Version) XXX_Size() int

func (*Version) XXX_Unmarshal added in v1.0.2 

func (m *Version) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.