state_synchronization

Documentation

Index

• Constants
• Variables
• func NewExecutionDataService(codec encoding.Codec, compressor network.Compressor, ...) *executionDataServiceImpl
• type BlobNotFoundError
  • func (e *BlobNotFoundError) Error() string
• type BlobSizeLimitExceededError
  • func (e *BlobSizeLimitExceededError) Error() string
• type ExecutionData
• type ExecutionDataService
• type MalformedDataError
  • func (e *MalformedDataError) Error() string
  • func (e *MalformedDataError) Unwrap() error

Constants

const (
	CodeRecursiveCIDs = iota + 1
	CodeExecutionData
)

header codes to distinguish between different types of data

Variables

var ErrBlobTreeDepthExceeded = errors.New("blob tree depth exceeded")

Functions

func NewExecutionDataService

func NewExecutionDataService(
	codec encoding.Codec,
	compressor network.Compressor,
	blobService network.BlobService,
	metrics module.ExecutionDataServiceMetrics,
	logger zerolog.Logger,
) *executionDataServiceImpl

Types

type BlobNotFoundError

type BlobNotFoundError struct {
	// contains filtered or unexported fields
}

BlobNotFoundError is returned when the blobservice failed to find a blob.

func (*BlobNotFoundError) Error

func (e *BlobNotFoundError) Error() string

type BlobSizeLimitExceededError

type BlobSizeLimitExceededError struct {
	// contains filtered or unexported fields
}

BlobSizeLimitExceededError is returned when a blob exceeds the maximum size allowed.

func (*BlobSizeLimitExceededError) Error

func (e *BlobSizeLimitExceededError) Error() string

type ExecutionData

type ExecutionData struct {
	BlockID            flow.Identifier
	Collections        []*flow.Collection
	Events             []*flow.Event
	TrieUpdates        []*ledger.TrieUpdate
	TransactionResults []*flow.TransactionResult
}

ExecutionData represents the execution data of a block

type ExecutionDataService

type ExecutionDataService interface {
	// Add constructs a blob tree for the given ExecutionData and
	// adds it to the blobservice, and then returns the root CID.
	Add(ctx context.Context, sd *ExecutionData) (cid.Cid, error)

	// Get gets the ExecutionData for the given root CID from the blobservice.
	Get(ctx context.Context, rootCid cid.Cid) (*ExecutionData, error)
}

ExecutionDataService handles adding/getting execution data to/from a blobservice

type MalformedDataError

type MalformedDataError struct {
	// contains filtered or unexported fields
}

MalformedDataError is returned when malformed data is found at some level of the requested blob tree. It likely indicates that the tree was generated incorrectly, and hence the request should not be retried.

func (*MalformedDataError) Error

func (e *MalformedDataError) Error() string

func (*MalformedDataError) Unwrap

func (e *MalformedDataError) Unwrap() error