netstore

Documentation

Overview

Package netstore provides an abstraction layer over the File local storage layer that leverages connectivity with other peers in order to retrieve chunks from the network that cannot be found locally.

Index

• Variables
• type Store
  • func New(s storage.Storer, r retrieval.Interface, logger logging.Logger, ...) *Store
  • func (s *Store) Get(ctx context.Context, mode storage.ModeGet, addr boson.Address, index int64) (ch boson.Chunk, err error)
  • func (s *Store) SetChunkInfo(chunkInfo chunkinfo.Interface)

Variables

var (
	ErrRecoveryAttempt = errors.New("failed to retrieve chunk, recovery initiated")
)

Types

type Store

type Store struct {
	storage.Storer
	// contains filtered or unexported fields
}

func New

func New(s storage.Storer, r retrieval.Interface, logger logging.Logger, addr boson.Address) *Store

New returns a new NetStore that wraps a given Storer.

func (*Store) Get

func (s *Store) Get(ctx context.Context, mode storage.ModeGet, addr boson.Address, index int64) (ch boson.Chunk, err error)

Get retrieves a given chunk address. It will request a chunk from the network whenever it cannot be found locally.

func (*Store) SetChunkInfo

func (s *Store) SetChunkInfo(chunkInfo chunkinfo.Interface)