tm34

Documentation

Index

• Variables
• func RunDataConnect(peerAddr string, marlinTo chan marlinTypes.MarlinMessage, ...)
• type BlockID
  • func BlockIDFromProto(bID *tmproto.BlockID) (*BlockID, error)
• type BlockPartMessage
• type HasVoteMessage
• type Message
  • func MsgFromProto(msg *tmcons.Message) (Message, error)
• type NewRoundStepMessage
• type NewValidBlockMessage
• type P2PConnection
• type Part
  • func PartFromProto(pb *tmproto.Part) (*Part, error)
• type PartSetHeader
  • func PartSetHeaderFromProto(ppsh *tmproto.PartSetHeader) (*PartSetHeader, error)
• type Proposal
  • func ProposalFromProto(pp *tmproto.Proposal) (*Proposal, error)
• type ProposalMessage
• type ProposalPOLMessage
• type TendermintHandler
• type Vote
  • func VoteFromProto(pv *tmproto.Vote) (*Vote, error)
• type VoteMessage
• type VoteSetBitsMessage
• type VoteSetMaj23Message

Variables

var ServicedKeyFile string = "tm34"

var ServicedTMCore chains.NodeType = chains.NodeType{Version: "0.34.7", Network: "tmv34", ProtocolVersionApp: "1", ProtocolVersionBlock: "11", ProtocolVersionP2p: "8"}

ServicedTMCore is a string associated with each TM core handler to decipher which handler is to be attached.

Functions

func RunDataConnect

func RunDataConnect(peerAddr string,
	marlinTo chan marlinTypes.MarlinMessage,
	marlinFrom chan marlinTypes.MarlinMessage,
	isConnectionOutgoing bool,
	keyFile string,
	listenPort int)

Types

type BlockID

type BlockID struct {
	Hash          []byte        `json:"hash"`
	PartSetHeader PartSetHeader `json:"parts"`
}

-------------------------------------

func BlockIDFromProto

func BlockIDFromProto(bID *tmproto.BlockID) (*BlockID, error)

FromProto sets a protobuf BlockID to the given pointer. It returns an error if the block id is invalid.

type BlockPartMessage

type BlockPartMessage struct {
	Height int64
	Round  int32
	Part   *Part
}

BlockPartMessage is sent when gossipping a piece of the proposed block.

type HasVoteMessage

type HasVoteMessage struct {
	Height int64
	Round  int32
	Type   tmproto.SignedMsgType
	Index  int32
}

HasVoteMessage is sent to indicate that a particular vote has been received.

type Message

type Message interface {
}

Message is a message that can be sent and received on the Reactor

func MsgFromProto

func MsgFromProto(msg *tmcons.Message) (Message, error)

MsgFromProto takes a consensus proto message and returns the native go type

type NewRoundStepMessage

type NewRoundStepMessage struct {
	Height                int64
	Round                 int32
	Step                  int8
	SecondsSinceStartTime int64
	LastCommitRound       int32
}

NewRoundStepMessage is sent for every step taken in the ConsensusState. For every height/round/step transition

type NewValidBlockMessage

type NewValidBlockMessage struct {
	Height             int64
	Round              int32
	BlockPartSetHeader PartSetHeader
	BlockParts         *bits.BitArray
	IsCommit           bool
}

NewValidBlockMessage is sent when a validator observes a valid block B in some round r, i.e., there is a Proposal for block B and 2/3+ prevotes for the block B in the round r. In case the block is also committed, then IsCommit flag is set to true.

type P2PConnection

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

type Part

type Part struct {
	Index uint32       `json:"index"`
	Bytes []byte       `json:"bytes"`
	Proof merkle.Proof `json:"proof"`
}

-------------------------------------

func PartFromProto

func PartFromProto(pb *tmproto.Part) (*Part, error)

type PartSetHeader

type PartSetHeader struct {
	Total uint32 `json:"total"`
	Hash  []byte `json:"hash"`
}

-------------------------------------

func PartSetHeaderFromProto

func PartSetHeaderFromProto(ppsh *tmproto.PartSetHeader) (*PartSetHeader, error)

FromProto sets a protobuf PartSetHeader to the given pointer

type Proposal

type Proposal struct {
	Type      tmproto.SignedMsgType
	Height    int64     `json:"height"`
	Round     int32     `json:"round"`     // there can not be greater than 2_147_483_647 rounds
	POLRound  int32     `json:"pol_round"` // -1 if null.
	BlockID   BlockID   `json:"block_id"`
	Timestamp time.Time `json:"timestamp"`
	Signature []byte    `json:"signature"`
}

func ProposalFromProto

func ProposalFromProto(pp *tmproto.Proposal) (*Proposal, error)

FromProto sets a protobuf Proposal to the given pointer. It returns an error if the proposal is invalid.

type ProposalMessage

type ProposalMessage struct {
	Proposal *Proposal
}

ProposalMessage is sent when a new block is proposed.

type ProposalPOLMessage

type ProposalPOLMessage struct {
	Height           int64
	ProposalPOLRound int32
	ProposalPOL      *bits.BitArray
}

ProposalPOLMessage is sent when a previous proposal is re-proposed.

type TendermintHandler

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

type Vote

type Vote struct {
	Type             tmproto.SignedMsgType `json:"type"`
	Height           int64                 `json:"height"`
	Round            int32                 `json:"round"`    // assume there will not be greater than 2_147_483_647 rounds
	BlockID          BlockID               `json:"block_id"` // zero if vote is nil.
	Timestamp        time.Time             `json:"timestamp"`
	ValidatorAddress crypto.Address        `json:"validator_address"`
	ValidatorIndex   int32                 `json:"validator_index"`
	Signature        []byte                `json:"signature"`
}

-------------------------------------

func VoteFromProto

func VoteFromProto(pv *tmproto.Vote) (*Vote, error)

FromProto converts a proto generetad type to a handwritten type return type, nil if everything converts safely, otherwise nil, error

type VoteMessage

type VoteMessage struct {
	Vote *Vote
}

VoteMessage is sent when voting for a proposal (or lack thereof).

type VoteSetBitsMessage

type VoteSetBitsMessage struct {
	Height  int64
	Round   int32
	Type    tmproto.SignedMsgType
	BlockID BlockID
	Votes   *bits.BitArray
}

VoteSetBitsMessage is sent to communicate the bit-array of votes seen for the BlockID.

type VoteSetMaj23Message

type VoteSetMaj23Message struct {
	Height  int64
	Round   int32
	Type    tmproto.SignedMsgType
	BlockID BlockID
}

VoteSetMaj23Message is sent to indicate that a given BlockID has seen +2/3 votes.