msg

Documentation

Index

• Constants
• type BlockMsg
  • func NewBlockMsg(data []byte) *BlockMsg
  • func (msg *BlockMsg) CMD() string
  • func (msg *BlockMsg) Deserialize(r io.Reader) error
  • func (msg *BlockMsg) GetData() []byte
  • func (msg *BlockMsg) MaxLength() uint32
  • func (msg *BlockMsg) Serialize(w io.Writer) error
• type ConfirmMsg
  • func NewConfirmMsg(confirm *payload.Confirm, height uint64) *ConfirmMsg
  • func (msg *ConfirmMsg) CMD() string
  • func (msg *ConfirmMsg) Deserialize(r io.Reader) error
  • func (msg *ConfirmMsg) MaxLength() uint32
  • func (msg *ConfirmMsg) Serialize(w io.Writer) error
• type ConsensusStatus
  • func (s *ConsensusStatus) Deserialize(r io.Reader) error
  • func (s *ConsensusStatus) Serialize(w io.Writer) error
• type FailedWithdrawTx
  • func NewFailedWithdrawTx(sig string, hash string) *FailedWithdrawTx
  • func (msg *FailedWithdrawTx) CMD() string
  • func (msg *FailedWithdrawTx) Deserialize(r io.Reader) error
  • func (msg *FailedWithdrawTx) GetHash() string
  • func (msg *FailedWithdrawTx) GetSignature() string
  • func (msg *FailedWithdrawTx) MaxLength() uint32
  • func (msg *FailedWithdrawTx) Serialize(w io.Writer) error
• type RequestConsensus
  • func (msg *RequestConsensus) CMD() string
  • func (msg *RequestConsensus) Deserialize(r io.Reader) error
  • func (msg *RequestConsensus) MaxLength() uint32
  • func (msg *RequestConsensus) Serialize(w io.Writer) error
• type ResponseConsensus
  • func (msg *ResponseConsensus) CMD() string
  • func (msg *ResponseConsensus) Deserialize(r io.Reader) error
  • func (msg *ResponseConsensus) MaxLength() uint32
  • func (msg *ResponseConsensus) Serialize(w io.Writer) error
• type SmallCroTx
  • func NewSmallCroTx(sig string, rawtx string) *SmallCroTx
  • func (msg *SmallCroTx) CMD() string
  • func (msg *SmallCroTx) Deserialize(r io.Reader) error
  • func (msg *SmallCroTx) GetRawTx() string
  • func (msg *SmallCroTx) GetSignature() string
  • func (msg *SmallCroTx) MaxLength() uint32
  • func (msg *SmallCroTx) Serialize(w io.Writer) error

Constants

const (
	CmdConfirm          = "confirm"
	CmdSmallCroTx       = "smallCroTx"
	CmdFailedWithdrawTx = "failedWTx"
)

const DefaultResponseConsensusMessageDataSize = 8000000 * 10

Types

type BlockMsg

type BlockMsg struct {
	// contains filtered or unexported fields
}

func NewBlockMsg

func NewBlockMsg(data []byte) *BlockMsg

func (*BlockMsg) CMD

func (msg *BlockMsg) CMD() string

func (*BlockMsg) Deserialize

func (msg *BlockMsg) Deserialize(r io.Reader) error

func (*BlockMsg) GetData

func (msg *BlockMsg) GetData() []byte

func (*BlockMsg) MaxLength

func (msg *BlockMsg) MaxLength() uint32

func (*BlockMsg) Serialize

func (msg *BlockMsg) Serialize(w io.Writer) error

type ConfirmMsg

type ConfirmMsg struct {
	Confirm *payload.Confirm
	Height  uint64
}

func NewConfirmMsg

func NewConfirmMsg(confirm *payload.Confirm, height uint64) *ConfirmMsg

func (*ConfirmMsg) CMD

func (msg *ConfirmMsg) CMD() string

func (*ConfirmMsg) Deserialize

func (msg *ConfirmMsg) Deserialize(r io.Reader) error

func (*ConfirmMsg) MaxLength

func (msg *ConfirmMsg) MaxLength() uint32

func (*ConfirmMsg) Serialize

func (msg *ConfirmMsg) Serialize(w io.Writer) error

type ConsensusStatus

type ConsensusStatus struct {
	ConsensusStatus uint32
	ViewOffset      uint32
	ViewStartTime   time.Time

	AcceptVotes      []payload.DPOSProposalVote
	RejectedVotes    []payload.DPOSProposalVote
	PendingProposals []payload.DPOSProposal
	PendingVotes     []payload.DPOSProposalVote

	WorkingHeight uint64
}

func (*ConsensusStatus) Deserialize

func (s *ConsensusStatus) Deserialize(r io.Reader) error

func (*ConsensusStatus) Serialize

func (s *ConsensusStatus) Serialize(w io.Writer) error

type FailedWithdrawTx

type FailedWithdrawTx struct {
	// contains filtered or unexported fields
}

func NewFailedWithdrawTx

func NewFailedWithdrawTx(sig string, hash string) *FailedWithdrawTx

func (*FailedWithdrawTx) CMD

func (msg *FailedWithdrawTx) CMD() string

func (*FailedWithdrawTx) Deserialize

func (msg *FailedWithdrawTx) Deserialize(r io.Reader) error

func (*FailedWithdrawTx) GetHash

func (msg *FailedWithdrawTx) GetHash() string

func (*FailedWithdrawTx) GetSignature

func (msg *FailedWithdrawTx) GetSignature() string

func (*FailedWithdrawTx) MaxLength

func (msg *FailedWithdrawTx) MaxLength() uint32

func (*FailedWithdrawTx) Serialize

func (msg *FailedWithdrawTx) Serialize(w io.Writer) error

type RequestConsensus

type RequestConsensus struct {
	Height uint64
}

func (*RequestConsensus) CMD

func (msg *RequestConsensus) CMD() string

func (*RequestConsensus) Deserialize

func (msg *RequestConsensus) Deserialize(r io.Reader) error

func (*RequestConsensus) MaxLength

func (msg *RequestConsensus) MaxLength() uint32

func (*RequestConsensus) Serialize

func (msg *RequestConsensus) Serialize(w io.Writer) error

type ResponseConsensus

type ResponseConsensus struct {
	Consensus ConsensusStatus
}

func (*ResponseConsensus) CMD

func (msg *ResponseConsensus) CMD() string

func (*ResponseConsensus) Deserialize

func (msg *ResponseConsensus) Deserialize(r io.Reader) error

func (*ResponseConsensus) MaxLength

func (msg *ResponseConsensus) MaxLength() uint32

func (*ResponseConsensus) Serialize

func (msg *ResponseConsensus) Serialize(w io.Writer) error

type SmallCroTx

type SmallCroTx struct {
	// contains filtered or unexported fields
}

func NewSmallCroTx

func NewSmallCroTx(sig string, rawtx string) *SmallCroTx

func (*SmallCroTx) CMD

func (msg *SmallCroTx) CMD() string

func (*SmallCroTx) Deserialize

func (msg *SmallCroTx) Deserialize(r io.Reader) error

func (*SmallCroTx) GetRawTx

func (msg *SmallCroTx) GetRawTx() string

func (*SmallCroTx) GetSignature

func (msg *SmallCroTx) GetSignature() string

func (*SmallCroTx) MaxLength

func (msg *SmallCroTx) MaxLength() uint32

func (*SmallCroTx) Serialize

func (msg *SmallCroTx) Serialize(w io.Writer) error