codec

Documentation

Index

• Constants
• func DecodeBenchmarkConsensusCommitMessage(payloads [][]byte) (*gossipmessages.BenchmarkConsensusCommitMessage, error)
• func DecodeBenchmarkConsensusCommittedMessage(payloads [][]byte) (*gossipmessages.BenchmarkConsensusCommittedMessage, error)
• func DecodeBlockAvailabilityRequest(payloads [][]byte) (*gossipmessages.BlockAvailabilityRequestMessage, error)
• func DecodeBlockAvailabilityResponse(payloads [][]byte) (*gossipmessages.BlockAvailabilityResponseMessage, error)
• func DecodeBlockPair(payloads [][]byte) (*protocol.BlockPairContainer, error)
• func DecodeBlockPairs(payloads [][]byte) (results []*protocol.BlockPairContainer, err error)
• func DecodeBlockSyncRequest(payloads [][]byte) (*gossipmessages.BlockSyncRequestMessage, error)
• func DecodeBlockSyncResponse(payloads [][]byte) (*gossipmessages.BlockSyncResponseMessage, error)
• func DecodeForwardedTransactions(payloads [][]byte) (*gossipmessages.ForwardedTransactionsMessage, error)
• func DecodeLeanHelixMessage(header *gossipmessages.Header, payloads [][]byte) (*gossipmessages.LeanHelixMessage, error)
• func EncodeBenchmarkConsensusCommitMessage(header *gossipmessages.Header, ...) ([][]byte, error)
• func EncodeBenchmarkConsensusCommittedMessage(header *gossipmessages.Header, ...) ([][]byte, error)
• func EncodeBlockAvailabilityRequest(header *gossipmessages.Header, ...) ([][]byte, error)
• func EncodeBlockAvailabilityResponse(header *gossipmessages.Header, ...) ([][]byte, error)
• func EncodeBlockPair(blockPair *protocol.BlockPairContainer) ([][]byte, error)
• func EncodeBlockPairs(blockPairs []*protocol.BlockPairContainer) ([][]byte, error)
• func EncodeBlockSyncRequest(header *gossipmessages.Header, message *gossipmessages.BlockSyncRequestMessage) ([][]byte, error)
• func EncodeBlockSyncResponse(header *gossipmessages.Header, ...) ([][]byte, error)
• func EncodeForwardedTransactions(header *gossipmessages.Header, ...) ([][]byte, error)
• func EncodeLeanHelixMessage(header *gossipmessages.Header, message *gossipmessages.LeanHelixMessage) ([][]byte, error)

Constants

const NUM_HARDCODED_PAYLOADS_FOR_BLOCK_PAIR = 5 // txHeader, txMetadata, rxHeader..

Functions

func DecodeBenchmarkConsensusCommitMessage

func DecodeBenchmarkConsensusCommitMessage(payloads [][]byte) (*gossipmessages.BenchmarkConsensusCommitMessage, error)

func DecodeBenchmarkConsensusCommittedMessage

func DecodeBenchmarkConsensusCommittedMessage(payloads [][]byte) (*gossipmessages.BenchmarkConsensusCommittedMessage, error)

func DecodeBlockAvailabilityRequest

func DecodeBlockAvailabilityRequest(payloads [][]byte) (*gossipmessages.BlockAvailabilityRequestMessage, error)

func DecodeBlockAvailabilityResponse

func DecodeBlockAvailabilityResponse(payloads [][]byte) (*gossipmessages.BlockAvailabilityResponseMessage, error)

func DecodeBlockPair

func DecodeBlockPair(payloads [][]byte) (*protocol.BlockPairContainer, error)

func DecodeBlockPairs

func DecodeBlockPairs(payloads [][]byte) (results []*protocol.BlockPairContainer, err error)

func DecodeBlockSyncRequest

func DecodeBlockSyncRequest(payloads [][]byte) (*gossipmessages.BlockSyncRequestMessage, error)

func DecodeBlockSyncResponse

func DecodeBlockSyncResponse(payloads [][]byte) (*gossipmessages.BlockSyncResponseMessage, error)

func DecodeForwardedTransactions

func DecodeForwardedTransactions(payloads [][]byte) (*gossipmessages.ForwardedTransactionsMessage, error)

func DecodeLeanHelixMessage

func DecodeLeanHelixMessage(header *gossipmessages.Header, payloads [][]byte) (*gossipmessages.LeanHelixMessage, error)

func EncodeBenchmarkConsensusCommitMessage

func EncodeBenchmarkConsensusCommitMessage(header *gossipmessages.Header, message *gossipmessages.BenchmarkConsensusCommitMessage) ([][]byte, error)

func EncodeBenchmarkConsensusCommittedMessage

func EncodeBenchmarkConsensusCommittedMessage(header *gossipmessages.Header, message *gossipmessages.BenchmarkConsensusCommittedMessage) ([][]byte, error)

func EncodeBlockAvailabilityRequest

func EncodeBlockAvailabilityRequest(header *gossipmessages.Header, message *gossipmessages.BlockAvailabilityRequestMessage) ([][]byte, error)

func EncodeBlockAvailabilityResponse

func EncodeBlockAvailabilityResponse(header *gossipmessages.Header, message *gossipmessages.BlockAvailabilityResponseMessage) ([][]byte, error)

func EncodeBlockPair

func EncodeBlockPair(blockPair *protocol.BlockPairContainer) ([][]byte, error)

func EncodeBlockPairs

func EncodeBlockPairs(blockPairs []*protocol.BlockPairContainer) ([][]byte, error)

func EncodeBlockSyncRequest

func EncodeBlockSyncRequest(header *gossipmessages.Header, message *gossipmessages.BlockSyncRequestMessage) ([][]byte, error)

func EncodeBlockSyncResponse

func EncodeBlockSyncResponse(header *gossipmessages.Header, message *gossipmessages.BlockSyncResponseMessage) ([][]byte, error)

func EncodeForwardedTransactions

func EncodeForwardedTransactions(header *gossipmessages.Header, message *gossipmessages.ForwardedTransactionsMessage) ([][]byte, error)

func EncodeLeanHelixMessage

func EncodeLeanHelixMessage(header *gossipmessages.Header, message *gossipmessages.LeanHelixMessage) ([][]byte, error)