migration

Documentation

Index

• func AfterInitSteps(sharkyPath string, sharkyNoOfShards int, st transaction.Storage, ...) migration.Steps
• func BeforeInitSteps(st storage.BatchStore, logger log.Logger) migration.Steps
• func RefCountSizeInc(s storage.BatchStore, logger log.Logger) func() error
• func ReserveRepairer(st transaction.Storage, chunkTypeFunc func(swarm.Chunk) swarm.ChunkType, ...) func() error
• type OldRetrievalIndexItem
  • func (r *OldRetrievalIndexItem) Clone() storage.Item
  • func (r *OldRetrievalIndexItem) ID() string
  • func (r *OldRetrievalIndexItem) Marshal() ([]byte, error)
  • func (OldRetrievalIndexItem) Namespace() string
  • func (r OldRetrievalIndexItem) String() string
  • func (r *OldRetrievalIndexItem) Unmarshal(buf []byte) error

Functions

func AfterInitSteps

func AfterInitSteps(
	sharkyPath string,
	sharkyNoOfShards int,
	st transaction.Storage,
	logger log.Logger,
) migration.Steps

AfterInitSteps lists all migration steps for localstore IndexStore after the localstore is initiated.

func BeforeInitSteps

func BeforeInitSteps(st storage.BatchStore, logger log.Logger) migration.Steps

BeforeInitSteps lists all migration steps for localstore IndexStore before the localstore is initiated.

func RefCountSizeInc

func RefCountSizeInc(s storage.BatchStore, logger log.Logger) func() error

func ReserveRepairer

func ReserveRepairer(
	st transaction.Storage,
	chunkTypeFunc func(swarm.Chunk) swarm.ChunkType,
	logger log.Logger,
) func() error

ReserveRepairer is a migration step that removes all BinItem entries and migrates ChunkBinItem and BatchRadiusItem entries to use a new BinID field.

Types

type OldRetrievalIndexItem

type OldRetrievalIndexItem struct {
	Address   swarm.Address
	Timestamp uint64
	Location  sharky.Location
	RefCnt    uint8
}

OldRetrievalIndexItem is the index which gives us the sharky location from the swarm.Address. The RefCnt stores the reference of each time a Put operation is issued on this Address.

func (*OldRetrievalIndexItem) Clone

func (r *OldRetrievalIndexItem) Clone() storage.Item

func (*OldRetrievalIndexItem) ID

func (r *OldRetrievalIndexItem) ID() string

func (*OldRetrievalIndexItem) Marshal

func (r *OldRetrievalIndexItem) Marshal() ([]byte, error)

Stored in bytes as: |--Address(32)--|--Timestamp(8)--|--Location(7)--|--RefCnt(1)--|

func (OldRetrievalIndexItem) Namespace

func (OldRetrievalIndexItem) Namespace() string

func (OldRetrievalIndexItem) String

func (r OldRetrievalIndexItem) String() string

func (*OldRetrievalIndexItem) Unmarshal

func (r *OldRetrievalIndexItem) Unmarshal(buf []byte) error