convert

package
v0.31.16-num-compactors Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2023 License: AGPL-3.0 Imports: 18 Imported by: 18

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.Sandboxnet.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 BlockExecutionDataEventPayloadsToJson added in v0.31.11 

func BlockExecutionDataEventPayloadsToJson(m *entities.BlockExecutionData) error

BlockExecutionDataEventPayloadsToJson converts all event payloads from CCF to JSON-CDC in place This is a temporary workaround until a more robust solution is implemented

func BlockExecutionDataToMessage added in v0.29.0 

func BlockExecutionDataToMessage(data *execution_data.BlockExecutionData) (
	*entities.BlockExecutionData,
	error,
)

func BlockHeaderToMessage 

func BlockHeaderToMessage(
	h *flow.Header,
	signerIDs flow.IdentifierList,
) (*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, signerIDs flow.IdentifierList) (
	*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 CcfEventToJsonEvent added in v0.31.0 

func CcfEventToJsonEvent(e flow.Event) (*flow.Event, error)

func CcfPayloadToJsonPayload added in v0.31.0 

func CcfPayloadToJsonPayload(p []byte) ([]byte, error)

func ChunkExecutionDataToMessage added in v0.29.0 

func ChunkExecutionDataToMessage(data *execution_data.ChunkExecutionData) (
	*entities.ChunkExecutionData,
	error,
)

ChunkExecutionDataToMessage converts a ChunkExecutionData to a protobuf message

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 EventToMessageFromVersion added in v0.31.11 

func EventToMessageFromVersion(e flow.Event, version execproto.EventEncodingVersion) (*entities.Event, error)

func EventType 

func EventType(eventType string) (string, error)

func EventsToMessages 

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

func EventsToMessagesFromVersion added in v0.31.11 

func EventsToMessagesFromVersion(flowEvents []flow.Event, version execproto.EventEncodingVersion) ([]*entities.Event, 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 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 MessageToBlockExecutionData added in v0.29.0 

func MessageToBlockExecutionData(
	m *entities.BlockExecutionData,
	chain flow.Chain,
) (*execution_data.BlockExecutionData, 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 MessageToChunkExecutionData added in v0.29.0 

func MessageToChunkExecutionData(
	m *entities.ChunkExecutionData,
	chain flow.Chain,
) (*execution_data.ChunkExecutionData, 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 MessageToEventFromVersion added in v0.31.0 

func MessageToEventFromVersion(m *entities.Event, version execproto.EventEncodingVersion) (*flow.Event, error)

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 MessageToTrieUpdate added in v0.29.12 

func MessageToTrieUpdate(m *entities.TrieUpdate) (*ledger.TrieUpdate, 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 MessagesToEventsFromVersion added in v0.31.0 

func MessagesToEventsFromVersion(l []*entities.Event, version execproto.EventEncodingVersion) ([]flow.Event, error)

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

func TrieUpdateToMessage added in v0.31.14 

func TrieUpdateToMessage(t *ledger.TrieUpdate) (*entities.TrieUpdate, error)

TrieUpdateToMessage converts a TrieUpdate to a protobuf message

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.