convert

package
v0.25.15-tx-dedup-fix Latest Latest
Warning

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

 Go to latest Published: May 31, 2022 License: AGPL-3.0 Imports: 13 Imported by: 22

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrEmptyMessage = errors.New("protobuf message is empty")
View Source 
var ValidChainIds = map[string]bool{
	flow.Mainnet.String():           true,
	flow.Testnet.String():           true,
	flow.Canary.String():            true,
	flow.Benchnet.String():          true,
	flow.Localnet.String():          true,
	flow.Emulator.String():          true,
	flow.BftTestnet.String():        true,
	flow.MonotonicEmulator.String(): true,
}

Functions

func AccountKeyToMessage 

func AccountKeyToMessage(a flow.AccountPublicKey) (*entities.AccountKey, error)

func AccountToMessage 

func AccountToMessage(a *flow.Account) (*entities.Account, error)

func Address 

func Address(rawAddress []byte, chain flow.Chain) (flow.Address, error)

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 BlockID 

func BlockID(blockID []byte) (flow.Identifier, error)

func BlockIDs 

func BlockIDs(blockIDs [][]byte) ([]flow.Identifier, error)

func BlockSealToMessage added in v0.24.8 

func BlockSealToMessage(s *flow.Seal) *entities.BlockSeal

func BlockSealsToMessages added in v0.24.8 

func BlockSealsToMessages(b []*flow.Seal) []*entities.BlockSeal

func BlockToMessage 

func BlockToMessage(h *flow.Block) (*entities.Block, error)

func BlockToMessageLight added in v0.24.8 

func BlockToMessageLight(h *flow.Block) *entities.Block

func BytesToInmemSnapshot added in v0.15.0 

func BytesToInmemSnapshot(bytes []byte) (*inmem.Snapshot, error)

BytesToInmemSnapshot converts an array of bytes to `inmem.Snapshot`

func ChunkToMessage added in v0.24.8 

func ChunkToMessage(chunk *flow.Chunk) *entities.Chunk

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 EventToMessage 

func EventToMessage(e flow.Event) *entities.Event

func EventType 

func EventType(eventType string) (string, error)

func EventsToMessages 

func EventsToMessages(flowEvents []flow.Event) []*entities.Event

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 MessageToAccount 

func MessageToAccount(m *entities.Account) (*flow.Account, error)

func MessageToAccountKey 

func MessageToAccountKey(m *entities.AccountKey) (*flow.AccountPublicKey, error)

func MessageToBlock added in v0.24.8 

func MessageToBlock(m *entities.Block) (*flow.Block, error)

func MessageToBlockHeader added in v0.24.8 

func MessageToBlockHeader(m *entities.BlockHeader) (*flow.Header, error)

func MessageToBlockSeal added in v0.24.8 

func MessageToBlockSeal(m *entities.BlockSeal) (*flow.Seal, error)

func MessageToChainId added in v0.24.8 

func MessageToChainId(m string) (*flow.ChainID, error)

MessageToChainId checks chainId from enumeration to prevent a panic on Chain() being called

func MessageToChunk added in v0.24.8 

func MessageToChunk(m *entities.Chunk) (*flow.Chunk, error)

func MessageToCollectionGuarantee added in v0.24.8 

func MessageToCollectionGuarantee(m *entities.CollectionGuarantee) *flow.CollectionGuarantee

func MessageToEvent 

func MessageToEvent(m *entities.Event) flow.Event

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 MessageToSignature(m []byte) crypto.Signature

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 MessagesToBlockSeals(m []*entities.BlockSeal) ([]*flow.Seal, error)

func MessagesToChunkList added in v0.24.8 

func MessagesToChunkList(m []*entities.Chunk) (flow.ChunkList, error)

func MessagesToCollectionGuarantees added in v0.24.8 

func MessagesToCollectionGuarantees(m []*entities.CollectionGuarantee) []*flow.CollectionGuarantee

func MessagesToEvents 

func MessagesToEvents(l []*entities.Event) []flow.Event

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 MessagesToSignatures(m [][]byte) []crypto.Signature

func PayloadFromMessage added in v0.24.8 

func PayloadFromMessage(m *entities.Block) (*flow.Payload, error)

func ServiceEventToMessage added in v0.24.8 

func ServiceEventToMessage(event flow.ServiceEvent) (*entities.ServiceEvent, error)

func SignatureToMessage added in v0.24.8 

func SignatureToMessage(s crypto.Signature) []byte

func SignaturesToMessages added in v0.24.8 

func SignaturesToMessages(s []crypto.Signature) [][]byte

func SnapshotToBytes added in v0.15.0 

func SnapshotToBytes(snapshot protocol.Snapshot) ([]byte, error)

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

func TransactionsToMessages added in v0.24.11 

func TransactionsToMessages(transactions []*flow.TransactionBody) []*entities.Transaction

Types

This section is empty.

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.