storage

package
v0.38.0-preview.0.0.4 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2024 License: AGPL-3.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	FINAL  = "final"
	SEALED = "sealed"
)
View Source 
const Max_Range_Block_Limit = uint64(10001)

10001 instead of 10000, because 10000 won't allow a range from 10000 to 20000, which is easier to type than [10001, 20000]

View Source 
const Max_Range_Cluster_Block_Limit = uint64(10001)

10001 instead of 10000, because 10000 won't allow a range from 10000 to 20000, which is easier to type than [10001, 20000]

Variables

This section is empty.

Functions

func NewBackfillTxErrorMessagesCommand 

func NewBackfillTxErrorMessagesCommand(
	state protocol.State,
	txErrorMessagesCore *tx_error_messages.TxErrorMessagesCore,
) commands.AdminCommand

NewBackfillTxErrorMessagesCommand creates a new instance of BackfillTxErrorMessagesCommand

func NewReadBlocksCommand 

func NewReadBlocksCommand(state protocol.State, storage storage.Blocks) commands.AdminCommand

func NewReadRangeBlocksCommand added in v0.31.7 

func NewReadRangeBlocksCommand(blocks storage.Blocks) commands.AdminCommand

func NewReadRangeClusterBlocksCommand added in v0.31.7 

func NewReadRangeClusterBlocksCommand(db *badger.DB, headers *storage.Headers, payloads *storage.ClusterPayloads) commands.AdminCommand

func NewReadResultsCommand 

func NewReadResultsCommand(state protocol.State, storage storage.ExecutionResults) commands.AdminCommand

func NewReadSealsCommand 

func NewReadSealsCommand(state protocol.State, storage storage.Seals, index storage.Index) commands.AdminCommand

Types

type BackfillTxErrorMessagesCommand 

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

BackfillTxErrorMessagesCommand executes a command to backfill transaction error messages by fetching them from execution nodes.

func (*BackfillTxErrorMessagesCommand) Handler 

func (b *BackfillTxErrorMessagesCommand) Handler(ctx context.Context, request *admin.CommandRequest) (interface{}, error)

Handler performs the backfilling operation by fetching missing transaction error messages for blocks within the specified height range. Uses execution nodes from data.executionNodeIds if available, otherwise defaults to valid execution nodes.

No errors are expected during normal operation.

func (*BackfillTxErrorMessagesCommand) Validator 

func (b *BackfillTxErrorMessagesCommand) Validator(request *admin.CommandRequest) error

Validator validates the input for the backfill command. The input is validated for field types, boundaries, and coherence of start and end heights.

Expected errors during normal operation:

  • admin.InvalidAdminReqError - if start-height is greater than end-height or if the input format is invalid, if an invalid execution node ID is provided.

type GetTransactionsCommand added in v0.27.0 

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

func NewGetTransactionsCommand added in v0.27.0 

func NewGetTransactionsCommand(state protocol.State, payloads storage.Payloads, collections storage.Collections) *GetTransactionsCommand

func (*GetTransactionsCommand) Handler added in v0.27.0 

func (c *GetTransactionsCommand) Handler(ctx context.Context, req *admin.CommandRequest) (interface{}, error)

func (*GetTransactionsCommand) Validator added in v0.27.0 

func (c *GetTransactionsCommand) Validator(req *admin.CommandRequest) error

Validator validates the request. Returns admin.InvalidAdminReqError for invalid/malformed requests.

type ProtocolSnapshotCommand added in v0.33.15 

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

ProtocolSnapshotCommand is a command that generates a protocol snapshot for a checkpoint (usually latest checkpoint) This command is only available for execution node

func NewProtocolSnapshotCommand added in v0.33.15 

func NewProtocolSnapshotCommand(
	logger zerolog.Logger,
	state protocol.State,
	headers storage.Headers,
	seals storage.Seals,
	checkpointDir string,
) *ProtocolSnapshotCommand

func (*ProtocolSnapshotCommand) Handler added in v0.33.15 

func (s *ProtocolSnapshotCommand) Handler(_ context.Context, req *admin.CommandRequest) (interface{}, error)

func (*ProtocolSnapshotCommand) Validator added in v0.33.15 

func (s *ProtocolSnapshotCommand) Validator(req *admin.CommandRequest) error

type ReadBlocksCommand 

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

func (*ReadBlocksCommand) Handler 

func (r *ReadBlocksCommand) Handler(ctx context.Context, req *admin.CommandRequest) (interface{}, error)

func (*ReadBlocksCommand) Validator 

func (r *ReadBlocksCommand) Validator(req *admin.CommandRequest) error

Validator validates the request. Returns admin.InvalidAdminReqError for invalid/malformed requests.

type ReadRangeBlocksCommand added in v0.31.7 

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

func (*ReadRangeBlocksCommand) Handler added in v0.31.7 

func (c *ReadRangeBlocksCommand) Handler(ctx context.Context, req *admin.CommandRequest) (interface{}, error)

func (*ReadRangeBlocksCommand) Validator added in v0.31.7 

func (c *ReadRangeBlocksCommand) Validator(req *admin.CommandRequest) error

type ReadRangeClusterBlocksCommand added in v0.31.7 

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

func (*ReadRangeClusterBlocksCommand) Handler added in v0.31.7 

func (c *ReadRangeClusterBlocksCommand) Handler(ctx context.Context, req *admin.CommandRequest) (interface{}, error)

func (*ReadRangeClusterBlocksCommand) Validator added in v0.31.7 

func (c *ReadRangeClusterBlocksCommand) Validator(req *admin.CommandRequest) error

type ReadResultsCommand 

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

func (*ReadResultsCommand) Handler 

func (r *ReadResultsCommand) Handler(ctx context.Context, req *admin.CommandRequest) (interface{}, error)

func (*ReadResultsCommand) Validator 

func (r *ReadResultsCommand) Validator(req *admin.CommandRequest) error

Validator validates the request. Returns admin.InvalidAdminReqError for invalid/malformed requests.

type ReadSealsCommand 

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

func (*ReadSealsCommand) Handler 

func (r *ReadSealsCommand) Handler(ctx context.Context, req *admin.CommandRequest) (interface{}, error)

func (*ReadSealsCommand) Validator 

func (r *ReadSealsCommand) Validator(req *admin.CommandRequest) error

Validator validates the request. Returns admin.InvalidAdminReqError for invalid/malformed requests.

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.