migrations

Documentation

Index

• func KeyToRegisterID(key ledger.Key) (flow.RegisterID, error)
• func NewView(payloads []ledger.Payload) *view
• func NoOpMigration(p []ledger.Payload) ([]ledger.Payload, error)
• func PruneMigration(payload []ledger.Payload) ([]ledger.Payload, error)
• func StorageFeesMigration(payload []ledger.Payload) ([]ledger.Payload, error)
• type AccountsAtreeLedger
  • func NewAccountsAtreeLedger(accounts environment.Accounts) *AccountsAtreeLedger
  • func (a *AccountsAtreeLedger) AllocateStorageIndex(owner []byte) (atree.StorageIndex, error)
  • func (a *AccountsAtreeLedger) GetValue(owner, key []byte) ([]byte, error)
  • func (a *AccountsAtreeLedger) SetValue(owner, key, value []byte) error
  • func (a *AccountsAtreeLedger) ValueExists(owner, key []byte) (exists bool, err error)
• type StorageUsedUpdateMigration
  • func (m *StorageUsedUpdateMigration) Migrate(payload []ledger.Payload) ([]ledger.Payload, error)

Functions

func KeyToRegisterID

func KeyToRegisterID(key ledger.Key) (flow.RegisterID, error)

func NewView

func NewView(payloads []ledger.Payload) *view

func NoOpMigration

func NoOpMigration(p []ledger.Payload) ([]ledger.Payload, error)

func PruneMigration

func PruneMigration(payload []ledger.Payload) ([]ledger.Payload, error)

PruneMigration removes all the payloads with empty value this prunes the trie for values that has been deleted

func StorageFeesMigration

func StorageFeesMigration(payload []ledger.Payload) ([]ledger.Payload, error)

iterates through registers keeping a map of register sizes after it has reached the end it add storage used and storage capacity for each address

Types

type AccountsAtreeLedger

type AccountsAtreeLedger struct {
	Accounts environment.Accounts
}

func NewAccountsAtreeLedger

func NewAccountsAtreeLedger(accounts environment.Accounts) *AccountsAtreeLedger

func (*AccountsAtreeLedger) AllocateStorageIndex

func (a *AccountsAtreeLedger) AllocateStorageIndex(owner []byte) (atree.StorageIndex, error)

AllocateStorageIndex allocates new storage index under the owner accounts to store a new register

func (*AccountsAtreeLedger) GetValue

func (a *AccountsAtreeLedger) GetValue(owner, key []byte) ([]byte, error)

func (*AccountsAtreeLedger) SetValue

func (a *AccountsAtreeLedger) SetValue(owner, key, value []byte) error

func (*AccountsAtreeLedger) ValueExists

func (a *AccountsAtreeLedger) ValueExists(owner, key []byte) (exists bool, err error)

type StorageUsedUpdateMigration

type StorageUsedUpdateMigration struct {
	Log       zerolog.Logger
	OutputDir string
}

func (*StorageUsedUpdateMigration) Migrate

func (m *StorageUsedUpdateMigration) Migrate(payload []ledger.Payload) ([]ledger.Payload, error)

iterates through registers keeping a map of register sizes after it has reached the end it add storage used and storage capacity for each address