messages

package
v0.2.4 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2022 License: Apache-2.0, BSD-2-Clause Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MsgGetBlock = 1 + peering.FirstUserMsgCode + iota
	MsgBlock
	MsgSignedResult
	MsgSignedResultAck
	MsgOffLedgerRequest
	MsgMissingRequestIDs
	MsgMissingRequest
	MsgRequestAck
)

Message types for the committee communications.

Variables

This section is empty.

Functions

This section is empty.

Types

type AsynchronousCommonSubsetMsg 

type AsynchronousCommonSubsetMsg struct {
	ProposedBatchesBin [][]byte
	SessionID          uint64
}

AsynchronousCommonSubsetMsg

type BlockMsg 

type BlockMsg struct {
	BlockBytes []byte
}

BlockMsg StateManager in response to GetBlockMsg sends block data to the querying node's StateManager StateManager -> StateManager

func NewBlockMsg added in v0.2.3 

func NewBlockMsg(data []byte) (*BlockMsg, error)

func (*BlockMsg) Write 

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

type BlockMsgIn added in v0.2.3 

type BlockMsgIn struct {
	BlockMsg
	SenderPubKey *ed25519.PublicKey
}

type GetBlockMsg 

type GetBlockMsg struct {
	BlockIndex uint32
}

GetBlockMsg StateManager queries specific block data from another peer (access node) StateManager -> StateManager

func NewGetBlockMsg added in v0.2.3 

func NewGetBlockMsg(data []byte) (*GetBlockMsg, error)

func (*GetBlockMsg) Write 

func (msg *GetBlockMsg) Write(w io.Writer) error

type GetBlockMsgIn added in v0.2.3 

type GetBlockMsgIn struct {
	GetBlockMsg
	SenderPubKey *ed25519.PublicKey
}

type InclusionStateMsg 

type InclusionStateMsg struct {
	TxID  ledgerstate.TransactionID
	State ledgerstate.InclusionState
}

InclusionStateMsg txstream plugin sends inclusions state of the transaction to ConsensusOld

type MissingRequestIDsMsg 

type MissingRequestIDsMsg struct {
	IDs []iscp.RequestID
}

func NewMissingRequestIDsMsg 

func NewMissingRequestIDsMsg(data []byte) (*MissingRequestIDsMsg, error)

func (*MissingRequestIDsMsg) Bytes 

func (msg *MissingRequestIDsMsg) Bytes() []byte

type MissingRequestIDsMsgIn added in v0.2.3 

type MissingRequestIDsMsgIn struct {
	MissingRequestIDsMsg
	SenderPubKey *ed25519.PublicKey
}

type MissingRequestMsg 

type MissingRequestMsg struct {
	Request iscp.Request
}

func NewMissingRequestMsg 

func NewMissingRequestMsg(data []byte) (*MissingRequestMsg, error)

func (*MissingRequestMsg) Bytes 

func (msg *MissingRequestMsg) Bytes() []byte

type OffLedgerRequestMsg 

type OffLedgerRequestMsg struct {
	ChainID *iscp.ChainID
	Req     *request.OffLedger
}

func NewOffLedgerRequestMsg 

func NewOffLedgerRequestMsg(data []byte) (*OffLedgerRequestMsg, error)

func (*OffLedgerRequestMsg) Bytes 

func (msg *OffLedgerRequestMsg) Bytes() []byte

type OffLedgerRequestMsgIn added in v0.2.3 

type OffLedgerRequestMsgIn struct {
	OffLedgerRequestMsg
	SenderPubKey *ed25519.PublicKey
}

type RequestAckMsg added in v0.2.3 

type RequestAckMsg struct {
	ReqID *iscp.RequestID
}

func NewRequestAckMsg 

func NewRequestAckMsg(buf []byte) (*RequestAckMsg, error)

func (*RequestAckMsg) Bytes added in v0.2.3 

func (msg *RequestAckMsg) Bytes() []byte

type RequestAckMsgIn added in v0.2.3 

type RequestAckMsgIn struct {
	RequestAckMsg
	SenderPubKey *ed25519.PublicKey
}

type SignedResultAckMsg 

type SignedResultAckMsg struct {
	ChainInputID ledgerstate.OutputID
	EssenceHash  hashing.HashValue
}

Consensus -> Consensus

func NewSignedResultAckMsg added in v0.2.3 

func NewSignedResultAckMsg(data []byte) (*SignedResultAckMsg, error)

func (*SignedResultAckMsg) Write 

func (msg *SignedResultAckMsg) Write(w io.Writer) error

type SignedResultAckMsgIn added in v0.2.3 

type SignedResultAckMsgIn struct {
	SignedResultAckMsg
	SenderIndex uint16
}

type SignedResultMsg 

type SignedResultMsg struct {
	ChainInputID ledgerstate.OutputID
	EssenceHash  hashing.HashValue
	SigShare     tbls.SigShare
}

Consensus -> Consensus

func NewSignedResultMsg added in v0.2.3 

func NewSignedResultMsg(data []byte) (*SignedResultMsg, error)

func (*SignedResultMsg) Write 

func (msg *SignedResultMsg) Write(w io.Writer) error

type SignedResultMsgIn added in v0.2.3 

type SignedResultMsgIn struct {
	SignedResultMsg
	SenderIndex uint16
}

type StateCandidateMsg 

type StateCandidateMsg struct {
	State             state.VirtualStateAccess
	ApprovingOutputID ledgerstate.OutputID
}

StateCandidateMsg Consensus sends the finalized next state to StateManager

type StateMsg 

type StateMsg struct {
	ChainOutput *ledgerstate.AliasOutput
	Timestamp   time.Time
}

StateMsg txstream plugin sends the only existing AliasOutput in the chain's address to StateManager

type StateTransitionMsg 

type StateTransitionMsg struct {
	// new variable state
	State state.VirtualStateAccess
	// corresponding state transaction
	StateOutput *ledgerstate.AliasOutput
	//
	StateTimestamp time.Time
}

StateTransitionMsg Notifies chain about changed state

type TimerTick 

type TimerTick int

type VMResultMsg 

type VMResultMsg struct {
	Task *vm.VMTask
}

VMResultMsg Consensus -> Consensus. VM sends result of async task started by Consensus to itself

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.