reassemble

Documentation

Index

• func Channels(config Config)
• type ChannelWithMetadata
• type Config
• type FrameWithMetadata
  • func LoadFrames(directory string, inbox common.Address) []FrameWithMetadata

Functions

func Channels

func Channels(config Config)

Channels loads all transactions from the given input directory that are submitted to the specified batch inbox and then re-assembles all channels & writes the re-assembled channels to the out directory.

Types

type ChannelWithMetadata

type ChannelWithMetadata struct {
	ID             derive.ChannelID    `json:"id"`
	IsReady        bool                `json:"is_ready"`
	InvalidFrames  bool                `json:"invalid_frames"`
	InvalidBatches bool                `json:"invalid_batches"`
	Frames         []FrameWithMetadata `json:"frames"`
	Batches        []derive.BatchV1    `json:"batches"`
}

type Config

type Config struct {
	BatchInbox   common.Address
	InDirectory  string
	OutDirectory string
}

type FrameWithMetadata

type FrameWithMetadata struct {
	TxHash         common.Hash  `json:"transaction_hash"`
	InclusionBlock uint64       `json:"inclusion_block"`
	Timestamp      uint64       `json:"timestamp"`
	BlockHash      common.Hash  `json:"block_hash"`
	Frame          derive.Frame `json:"frame"`
}

func LoadFrames

func LoadFrames(directory string, inbox common.Address) []FrameWithMetadata