pinstore

func CleanupDirty ¶

func CleanupDirty(st transaction.Storage) error

CleanupDirty will iterate over all the dirty collections and delete them.

func DeletePin ¶

func DeletePin(ctx context.Context, st transaction.Storage, root swarm.Address) error

DeletePin will delete the root pin and all the chunks that are part of this collection.

func GetCollectionUUIDs ¶ added in v2.7.0

func GetCollectionUUIDs(st storage.Reader) ([][]byte, error)

GetCollectionUUIDs returns all collection UUIDs from pin collections.

func HasPin ¶

func HasPin(st storage.Reader, root swarm.Address) (bool, error)

HasPin function will check if the address represents a valid pin collection.

func IsChunkPinnedInCollection ¶ added in v2.7.0

func IsChunkPinnedInCollection(st storage.Reader, chunkAddr swarm.Address, uuid []byte) (bool, error)

IsChunkPinnedInCollection checks if a chunk address is pinned under the given collection uuid.

func IterateCollection ¶

func IterateCollection(st storage.Reader, root swarm.Address, fn func(addr swarm.Address) (bool, error)) error

func IterateCollectionStats ¶

func IterateCollectionStats(st storage.Reader, iterateFn func(st CollectionStat) (bool, error)) error

func NewCollection ¶

func NewCollection(st storage.IndexStore) (internal.PutterCloserWithReference, error)

NewCollection returns a putter wrapped around the passed storage. The putter will add the chunk to Chunk store if it doesn't exists within this collection. It will create a new UUID for the collection which can be used to iterate on all the chunks that are part of this collection. The root pin is only updated on successful close of this. Calls to the Putter MUST be mutex locked to prevent concurrent upload data races.

func Pins ¶

func Pins(st storage.Reader) ([]swarm.Address, error)

Pins lists all the added pinning collections.