Documentation ¶
Index ¶
- Variables
- func AccountKeyToMessage(a flow.AccountPublicKey) (*entities.AccountKey, error)
- func AccountToMessage(a *flow.Account) (*entities.Account, error)
- func Address(rawAddress []byte, chain flow.Chain) (flow.Address, error)
- func AggregatedSignaturesToMessages(a []flow.AggregatedSignature) []*entities.AggregatedSignature
- func BlockHeaderToMessage(h *flow.Header) (*entities.BlockHeader, error)
- func BlockID(blockID []byte) (flow.Identifier, error)
- func BlockIDs(blockIDs [][]byte) ([]flow.Identifier, error)
- func BlockSealToMessage(s *flow.Seal) *entities.BlockSeal
- func BlockSealsToMessages(b []*flow.Seal) []*entities.BlockSeal
- func BlockToMessage(h *flow.Block) (*entities.Block, error)
- func BlockToMessageLight(h *flow.Block) *entities.Block
- func BytesToInmemSnapshot(bytes []byte) (*inmem.Snapshot, error)
- func ChunkToMessage(chunk *flow.Chunk) *entities.Chunk
- func CollectionGuaranteeToMessage(g *flow.CollectionGuarantee) *entities.CollectionGuarantee
- func CollectionGuaranteesToMessages(c []*flow.CollectionGuarantee) []*entities.CollectionGuarantee
- func CollectionID(collectionID []byte) (flow.Identifier, error)
- func CollectionToMessage(c *flow.Collection) (*entities.Collection, error)
- func EventToMessage(e flow.Event) *entities.Event
- func EventType(eventType string) (string, error)
- func EventsToMessages(flowEvents []flow.Event) []*entities.Event
- func ExecutionResultMetaListToMessages(e flow.ExecutionReceiptMetaList) []*entities.ExecutionReceiptMeta
- func ExecutionResultToMessage(er *flow.ExecutionResult) (*entities.ExecutionResult, error)
- func ExecutionResultsToMessages(e []*flow.ExecutionResult) ([]*entities.ExecutionResult, error)
- func IdentifierToMessage(i flow.Identifier) []byte
- func IdentifiersToMessages(l []flow.Identifier) [][]byte
- func LightCollectionToMessage(c *flow.LightCollection) (*entities.Collection, error)
- func MessageToAccount(m *entities.Account) (*flow.Account, error)
- func MessageToAccountKey(m *entities.AccountKey) (*flow.AccountPublicKey, error)
- func MessageToBlock(m *entities.Block) (*flow.Block, error)
- func MessageToBlockHeader(m *entities.BlockHeader) (*flow.Header, error)
- func MessageToBlockSeal(m *entities.BlockSeal) (*flow.Seal, error)
- func MessageToChainId(m string) (*flow.ChainID, error)
- func MessageToChunk(m *entities.Chunk) (*flow.Chunk, error)
- func MessageToCollectionGuarantee(m *entities.CollectionGuarantee) *flow.CollectionGuarantee
- func MessageToEvent(m *entities.Event) flow.Event
- func MessageToExecutionResult(m *entities.ExecutionResult) (*flow.ExecutionResult, error)
- func MessageToIdentifier(b []byte) flow.Identifier
- func MessageToServiceEvent(m *entities.ServiceEvent) (*flow.ServiceEvent, error)
- func MessageToSignature(m []byte) crypto.Signature
- func MessageToStateCommitment(bytes []byte) (sc flow.StateCommitment, err error)
- func MessageToTransaction(m *entities.Transaction, chain flow.Chain) (flow.TransactionBody, error)
- func MessagesToAggregatedSignatures(m []*entities.AggregatedSignature) []flow.AggregatedSignature
- func MessagesToBlockSeals(m []*entities.BlockSeal) ([]*flow.Seal, error)
- func MessagesToChunkList(m []*entities.Chunk) (flow.ChunkList, error)
- func MessagesToCollectionGuarantees(m []*entities.CollectionGuarantee) []*flow.CollectionGuarantee
- func MessagesToEvents(l []*entities.Event) []flow.Event
- func MessagesToExecutionResultMetaList(m []*entities.ExecutionReceiptMeta) flow.ExecutionReceiptMetaList
- func MessagesToExecutionResults(m []*entities.ExecutionResult) ([]*flow.ExecutionResult, error)
- func MessagesToIdentifiers(l [][]byte) []flow.Identifier
- func MessagesToServiceEventList(m []*entities.ServiceEvent) (flow.ServiceEventList, error)
- func MessagesToSignatures(m [][]byte) []crypto.Signature
- func PayloadFromMessage(m *entities.Block) (*flow.Payload, error)
- func ServiceEventToMessage(event flow.ServiceEvent) (*entities.ServiceEvent, error)
- func SignatureToMessage(s crypto.Signature) []byte
- func SignaturesToMessages(s []crypto.Signature) [][]byte
- func SnapshotToBytes(snapshot protocol.Snapshot) ([]byte, error)
- func StateCommitmentToMessage(s flow.StateCommitment) []byte
- func TransactionID(txID []byte) (flow.Identifier, error)
- func TransactionToMessage(tb flow.TransactionBody) *entities.Transaction
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrEmptyMessage = errors.New("protobuf message is empty")
Functions ¶
func AccountKeyToMessage ¶
func AccountKeyToMessage(a flow.AccountPublicKey) (*entities.AccountKey, error)
func Address ¶
Address validates the input address and returns a Flow address if valid and error otherwise
func AggregatedSignaturesToMessages ¶ added in v0.24.8
func AggregatedSignaturesToMessages(a []flow.AggregatedSignature) []*entities.AggregatedSignature
func BlockHeaderToMessage ¶
func BlockHeaderToMessage(h *flow.Header) (*entities.BlockHeader, error)
func BlockSealToMessage ¶ added in v0.24.8
func BlockSealsToMessages ¶ added in v0.24.8
func BytesToInmemSnapshot ¶ added in v0.15.0
BytesToInmemSnapshot converts an array of bytes to `inmem.Snapshot`
func CollectionGuaranteeToMessage ¶ added in v0.24.8
func CollectionGuaranteeToMessage(g *flow.CollectionGuarantee) *entities.CollectionGuarantee
func CollectionGuaranteesToMessages ¶ added in v0.24.8
func CollectionGuaranteesToMessages(c []*flow.CollectionGuarantee) []*entities.CollectionGuarantee
func CollectionID ¶
func CollectionID(collectionID []byte) (flow.Identifier, error)
func CollectionToMessage ¶
func CollectionToMessage(c *flow.Collection) (*entities.Collection, error)
func ExecutionResultMetaListToMessages ¶ added in v0.24.8
func ExecutionResultMetaListToMessages(e flow.ExecutionReceiptMetaList) []*entities.ExecutionReceiptMeta
func ExecutionResultToMessage ¶ added in v0.24.8
func ExecutionResultToMessage(er *flow.ExecutionResult) (*entities.ExecutionResult, error)
func ExecutionResultsToMessages ¶ added in v0.24.8
func ExecutionResultsToMessages(e []*flow.ExecutionResult) ([]*entities.ExecutionResult, error)
func IdentifierToMessage ¶
func IdentifierToMessage(i flow.Identifier) []byte
func IdentifiersToMessages ¶
func IdentifiersToMessages(l []flow.Identifier) [][]byte
func LightCollectionToMessage ¶
func LightCollectionToMessage(c *flow.LightCollection) (*entities.Collection, error)
func MessageToAccountKey ¶
func MessageToAccountKey(m *entities.AccountKey) (*flow.AccountPublicKey, error)
func MessageToBlockHeader ¶ added in v0.24.8
func MessageToBlockHeader(m *entities.BlockHeader) (*flow.Header, error)
func MessageToBlockSeal ¶ added in v0.24.8
func MessageToChainId ¶ added in v0.24.8
MessageToChainId checks chainId from enumeration to prevent a panic on Chain() being called
func MessageToCollectionGuarantee ¶ added in v0.24.8
func MessageToCollectionGuarantee(m *entities.CollectionGuarantee) *flow.CollectionGuarantee
func MessageToExecutionResult ¶ added in v0.24.8
func MessageToExecutionResult(m *entities.ExecutionResult) (*flow.ExecutionResult, error)
func MessageToIdentifier ¶
func MessageToIdentifier(b []byte) flow.Identifier
func MessageToServiceEvent ¶ added in v0.24.8
func MessageToServiceEvent(m *entities.ServiceEvent) (*flow.ServiceEvent, error)
func MessageToSignature ¶ added in v0.24.8
func MessageToStateCommitment ¶ added in v0.21.0
func MessageToStateCommitment(bytes []byte) (sc flow.StateCommitment, err error)
func MessageToTransaction ¶
func MessageToTransaction(m *entities.Transaction, chain flow.Chain) (flow.TransactionBody, error)
func MessagesToAggregatedSignatures ¶ added in v0.24.8
func MessagesToAggregatedSignatures(m []*entities.AggregatedSignature) []flow.AggregatedSignature
func MessagesToBlockSeals ¶ added in v0.24.8
func MessagesToChunkList ¶ added in v0.24.8
func MessagesToCollectionGuarantees ¶ added in v0.24.8
func MessagesToCollectionGuarantees(m []*entities.CollectionGuarantee) []*flow.CollectionGuarantee
func MessagesToExecutionResultMetaList ¶ added in v0.24.8
func MessagesToExecutionResultMetaList(m []*entities.ExecutionReceiptMeta) flow.ExecutionReceiptMetaList
func MessagesToExecutionResults ¶ added in v0.24.8
func MessagesToExecutionResults(m []*entities.ExecutionResult) ([]*flow.ExecutionResult, error)
func MessagesToIdentifiers ¶
func MessagesToIdentifiers(l [][]byte) []flow.Identifier
func MessagesToServiceEventList ¶ added in v0.24.8
func MessagesToServiceEventList(m []*entities.ServiceEvent) (flow.ServiceEventList, error)
func MessagesToSignatures ¶ added in v0.24.8
func PayloadFromMessage ¶ added in v0.24.8
func ServiceEventToMessage ¶ added in v0.24.8
func ServiceEventToMessage(event flow.ServiceEvent) (*entities.ServiceEvent, error)
func SignatureToMessage ¶ added in v0.24.8
func SignaturesToMessages ¶ added in v0.24.8
func SnapshotToBytes ¶ added in v0.15.0
SnapshotToBytes converts a `protocol.Snapshot` to bytes, encoded as JSON
func StateCommitmentToMessage ¶ added in v0.21.0
func StateCommitmentToMessage(s flow.StateCommitment) []byte
func TransactionID ¶
func TransactionID(txID []byte) (flow.Identifier, error)
func TransactionToMessage ¶
func TransactionToMessage(tb flow.TransactionBody) *entities.Transaction
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.