s3

func (*S3Engine) AddBlock ¶

func (e *S3Engine) AddBlock(
	ctx context.Context,
	slot uint64,
	root []byte,
	dataCb func() (*types.BlockData, error),
) (bool, bool, error)

AddBlock stores block data. Returns (added, updated, error).

func (*S3Engine) AddExecData ¶ added in v1.20.3

func (e *S3Engine) AddExecData(ctx context.Context, slot uint64, blockHash []byte, data []byte) (int64, error)

AddExecData stores execution data for a block. Returns stored size.

func (*S3Engine) Close ¶

func (e *S3Engine) Close() error

func (*S3Engine) DeleteExecData ¶ added in v1.20.3

func (e *S3Engine) DeleteExecData(ctx context.Context, slot uint64, blockHash []byte) error

DeleteExecData deletes execution data for a specific block.

func (*S3Engine) GetBlock ¶

func (e *S3Engine) GetBlock(
	ctx context.Context,
	slot uint64,
	root []byte,
	flags types.BlockDataFlags,
	parseBlock func(uint64, []byte) (any, error),
	parsePayload func(uint64, []byte) (any, error),
) (*types.BlockData, error)

GetBlock retrieves block data with selective loading based on flags.

func (*S3Engine) GetExecData ¶ added in v1.20.3

func (e *S3Engine) GetExecData(ctx context.Context, slot uint64, blockHash []byte) ([]byte, error)

GetExecData retrieves full execution data for a block.

func (*S3Engine) GetExecDataRange ¶ added in v1.20.3

func (e *S3Engine) GetExecDataRange(ctx context.Context, slot uint64, blockHash []byte, offset int64, length int64) ([]byte, error)

GetExecDataRange retrieves a byte range of execution data using S3 Range header.

func (*S3Engine) GetExecDataTxSections ¶ added in v1.20.3

func (e *S3Engine) GetExecDataTxSections(ctx context.Context, slot uint64, blockHash []byte, txHash []byte, sections uint32) (*types.ExecDataTxSections, error)

GetExecDataTxSections retrieves all requested compressed sections for a single transaction using range reads. Three requests total:

1. Read first 28 bytes (header + tx count)
2. Read full index (tx count * 100 bytes)
3. Read contiguous data range covering all requested sections

func (*S3Engine) GetStats ¶ added in v1.20.4

func (e *S3Engine) GetStats() *S3Stats

GetStats returns current S3 operation statistics.

func (*S3Engine) GetStoredComponents ¶ added in v1.21.0

func (e *S3Engine) GetStoredComponents(ctx context.Context, slot uint64, root []byte) (types.BlockDataFlags, error)

GetStoredComponents returns which components exist for a block by reading metadata.

func (*S3Engine) HasExecData ¶ added in v1.20.3

func (e *S3Engine) HasExecData(ctx context.Context, slot uint64, blockHash []byte) (bool, error)

HasExecData checks if execution data exists for a block.

func (*S3Engine) PruneExecDataBefore ¶ added in v1.20.3

func (e *S3Engine) PruneExecDataBefore(ctx context.Context, maxSlot uint64) (int64, error)

PruneExecDataBefore deletes execution data for all slots before maxSlot. Uses the shared tier prefix, filtering for _exec suffix.