migration

Documentation

Index

• func AfterInitSteps(sharkyPath string, sharkyNoOfShards int, chunkStore storage.ChunkStore) migration.Steps
• func BeforeIinitSteps() migration.Steps
• func RefCountSizeInc(s storage.BatchedStore) 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,
	chunkStore storage.ChunkStore,
) migration.Steps

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

func BeforeIinitSteps

func BeforeIinitSteps() migration.Steps

BeforeIinitSteps lists all migration steps for localstore IndexStore before the localstore is intiated.

func RefCountSizeInc

func RefCountSizeInc(s storage.BatchedStore) error

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