migration

package

v0.15.16 Latest Latest Go to latest Published: Dec 9, 2025 License: Apache-2.0 Imports: 28 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 ¶

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, httpConfig *HTTPConfig,
) error

func SchemaMetadata ¶ added in v0.8.0

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

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

Types ¶

type BucketMigrator ¶ added in v0.5.0

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

func NewBucketMigrator ¶ added in v0.5.0

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

func NewBucketMover ¶ added in v0.5.0

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

func (*BucketMigrator) Before ¶ added in v0.5.0

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

func (*BucketMigrator) Migrate ¶ added in v0.5.0

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

func (*BucketMigrator) WithBatchSize ¶ added in v0.5.0

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

func (*BucketMigrator) WithBefore ¶ added in v0.5.0

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

func (*BucketMigrator) WithKeyFilter ¶ added in v0.5.0

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

type BucketMigratorDoFunc ¶ added in v0.5.0

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

type BucketMigratorKeyFilter ¶ added in v0.5.0

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

type HTTPConfig ¶ added in v0.14.7

type HTTPConfig struct {
	Enabled bool
	Host    string
	Port    uint16
}

type Migration ¶ added in v0.5.0

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 ¶ added in v0.5.0

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

func (MigrationFunc) Before ¶ added in v0.5.0

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

Before is a no-op.

func (MigrationFunc) Migrate ¶ added in v0.5.0

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

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