deprecatedmigration

package

v0.15.18 Latest Latest Go to latest Published: Jan 30, 2026 License: Apache-2.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/NethermindEth/juno

Links

Open Source Insights

Documentation ¶

Overview ¶

Package deprecatedmigration contains the legacy migration system.

Deprecated: This package is deprecated and will be removed in a future version. Use the migration package instead for new migrations.

Index ¶

Variables
func MigrateIfNeeded(ctx context.Context, targetDB db.KeyValueStore, network *utils.Network, ...) error
func SchemaMetadata(log utils.SimpleLogger, targetDB db.KeyValueStore) (schemaMetadata, error)
type BucketMigrator
- func NewBucketMigrator(target db.Bucket, do BucketMigratorDoFunc) *BucketMigrator
- func NewBucketMover(source, destination db.Bucket) *BucketMigrator
type BucketMigratorDoFunc
type BucketMigratorKeyFilter
type HTTPConfig
type Migration
type MigrationFunc
- func (f MigrationFunc) Before(_ []byte) error
- func (f MigrationFunc) Migrate(_ context.Context, database db.KeyValueStore, network *utils.Network, ...) ([]byte, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrCallWithNewTransaction = errors.New("call with new transaction")

Functions ¶

func MigrateIfNeeded ¶

func MigrateIfNeeded(
	ctx context.Context,
	targetDB db.KeyValueStore,
	network *utils.Network,
	log utils.SimpleLogger,
) error

func SchemaMetadata ¶

func SchemaMetadata(log utils.SimpleLogger, targetDB db.KeyValueStore) (schemaMetadata, error)

SchemaMetadata retrieves metadata about a database schema from the given database.

Types ¶

type BucketMigrator ¶

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

func NewBucketMigrator ¶

func NewBucketMigrator(target db.Bucket, do BucketMigratorDoFunc) *BucketMigrator

func NewBucketMover ¶

func NewBucketMover(source, destination db.Bucket) *BucketMigrator

func (*BucketMigrator) Before ¶

func (m *BucketMigrator) Before(_ []byte) error

func (*BucketMigrator) Migrate ¶

func (m *BucketMigrator) Migrate(
	ctx context.Context,
	database db.KeyValueStore,
	network *utils.Network,
	log utils.SimpleLogger,
) ([]byte, error)

func (*BucketMigrator) WithBatchSize ¶

func (m *BucketMigrator) WithBatchSize(batchSize uint) *BucketMigrator

func (*BucketMigrator) WithBefore ¶

func (m *BucketMigrator) WithBefore(before func()) *BucketMigrator

func (*BucketMigrator) WithKeyFilter ¶

func (m *BucketMigrator) WithKeyFilter(keyFilter BucketMigratorKeyFilter) *BucketMigrator

type BucketMigratorDoFunc ¶

type BucketMigratorDoFunc func(t db.KeyValueWriter, b1, b2 []byte, n *utils.Network) error

type BucketMigratorKeyFilter ¶

type BucketMigratorKeyFilter func([]byte) (bool, error)

type HTTPConfig ¶

type HTTPConfig struct {
	Enabled bool
	Host    string
	Port    uint16
}

type Migration ¶

type Migration interface {
	Before(intermediateState []byte) error
	// Migration should return intermediate state whenever it requests new txn or detects cancelled ctx.
	Migrate(context.Context, db.KeyValueStore, *utils.Network, utils.SimpleLogger) ([]byte, error)
}

type MigrationFunc ¶

type MigrationFunc func(db.IndexedBatch, *utils.Network) error

func (MigrationFunc) Before ¶

func (f MigrationFunc) Before(_ []byte) error

Before is a no-op.

func (MigrationFunc) Migrate ¶

func (f MigrationFunc) Migrate(_ context.Context, database db.KeyValueStore, network *utils.Network, _ utils.SimpleLogger) ([]byte, error)

Migrate returns f(txn).

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
casmhashmetadata
l1handlermapping
progresslogger

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL