Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

storage

package

Go to main page

Versions in this module

v0

v0.4.3

Jul 25, 2019

v0.4.2

Jun 28, 2019

Changes in this version

+ var ErrNoSuitablePeer = errors.New("no suitable peer")

+ type Fetcher struct

+ CreatedAt time.Time

+ CreatedBy string

+ Delivered chan struct{}

+ RequestedBySyncer bool

+ func NewFetcher() *Fetcher

+ func (fi *Fetcher) SafeClose()

+ type LNetStore struct

+ func NewLNetStore(store *NetStore) *LNetStore

+ func (n *LNetStore) Get(ctx context.Context, mode chunk.ModeGet, ref Address) (ch Chunk, err error)

type NetStore

+ RemoteGet RemoteGetFunc

+ func (n *NetStore) GetOrCreateFetcher(ctx context.Context, ref Address, interestedParty string) (f *Fetcher, loaded bool, ok bool)

+ func (n *NetStore) Has(ctx context.Context, ref Address) (bool, error)

+ func (n *NetStore) RemoteFetch(ctx context.Context, req *Request, fi *Fetcher) error

+ type RemoteGetFunc func(ctx context.Context, req *Request, localID enode.ID) (*enode.ID, error)

+ type Request struct

+ Addr Address

+ Origin enode.ID

+ PeersToSkip sync.Map

+ func NewRequest(addr Address) *Request

+ func (r *Request) SkipPeer(nodeID string) bool

v0.4.1

Jun 13, 2019

Changes in this version

+ const AddressLength

+ const BMTHash

+ const ChunkProcessors

+ const DefaultHash

+ const ErrDataOverflow

+ const ErrInit

+ const ErrInvalidSignature

+ const ErrInvalidValue

+ const ErrNotFound

+ const ErrNotSynced

+ const ErrNothingToReturn

+ const ErrUnauthorized

+ const MaxPO

+ const SHA3Hash

+ var ErrChunkInvalid = chunk.ErrChunkNotFound

+ var ErrChunkNotFound = chunk.ErrChunkNotFound

+ var NewChunk = chunk.NewChunk

+ var Proximity = chunk.Proximity

+ var ZeroAddr = chunk.ZeroAddr

+ func NewHasherStore(store ChunkStore, hashFunc SwarmHasher, toEncrypt bool, tag *chunk.Tag) *hasherStore

+ type Address = chunk.Address

+ func PyramidAppend(ctx context.Context, addr Address, reader io.Reader, putter Putter, ...) (Address, func(context.Context) error, error)

+ func PyramidSplit(ctx context.Context, reader io.Reader, putter Putter, getter Getter, ...) (Address, func(context.Context) error, error)

+ func TreeSplit(ctx context.Context, data io.Reader, size int64, putter Putter) (k Address, wait func(context.Context) error, err error)

+ type AddressCollection []Address

+ func NewAddressCollection(l int) AddressCollection

+ func (c AddressCollection) Len() int

+ func (c AddressCollection) Less(i, j int) bool

+ func (c AddressCollection) Swap(i, j int)

+ type Chunk = chunk.Chunk

+ func GenerateRandomChunk(dataSize int64) Chunk

+ func GenerateRandomChunks(dataSize int64, count int) (chunks []Chunk)

+ type ChunkData []byte

+ func (c ChunkData) Size() uint64

+ type ChunkStore = chunk.Store

+ type ChunkValidator = chunk.Validator

+ type ChunkerParams struct

+ type ContentAddressValidator struct

+ Hasher SwarmHasher

+ func NewContentAddressValidator(hasher SwarmHasher) *ContentAddressValidator

+ func (v *ContentAddressValidator) Validate(ch Chunk) bool

+ type FakeChunkStore struct

+ func (f *FakeChunkStore) Close() error

+ func (f *FakeChunkStore) Get(_ context.Context, _ chunk.ModeGet, ref Address) (Chunk, error)

+ func (f *FakeChunkStore) Has(_ context.Context, ref Address) (bool, error)

+ func (f *FakeChunkStore) LastPullSubscriptionBinID(bin uint8) (id uint64, err error)

+ func (f *FakeChunkStore) Put(_ context.Context, _ chunk.ModePut, ch Chunk) (bool, error)

+ func (f *FakeChunkStore) Set(ctx context.Context, mode chunk.ModeSet, addr chunk.Address) (err error)

+ func (f *FakeChunkStore) SubscribePull(ctx context.Context, bin uint8, since, until uint64) (c <-chan chunk.Descriptor, stop func())

+ type FileStore struct

+ func NewFileStore(store ChunkStore, params *FileStoreParams, tags *chunk.Tags) *FileStore

+ func NewLocalFileStore(datadir string, basekey []byte, tags *chunk.Tags) (*FileStore, func(), error)

+ func (f *FileStore) GetAllReferences(ctx context.Context, data io.Reader, toEncrypt bool) (addrs AddressCollection, err error)

+ func (f *FileStore) HashSize() int

+ func (f *FileStore) Retrieve(ctx context.Context, addr Address) (reader *LazyChunkReader, isEncrypted bool)

+ func (f *FileStore) Store(ctx context.Context, data io.Reader, size int64, toEncrypt bool) (addr Address, wait func(context.Context) error, err error)

+ type FileStoreParams struct

+ Hash string

+ func NewFileStoreParams() *FileStoreParams

+ type Getter interface

+ Get func(context.Context, Reference) (ChunkData, error)

+ type HashWithLength struct

+ func (h *HashWithLength) ResetWithLength(length []byte)

+ type JoinerParams struct

+ type LazyChunkReader struct

+ func TreeJoin(ctx context.Context, addr Address, getter Getter, depth int) *LazyChunkReader

+ func (r *LazyChunkReader) Context() context.Context

+ func (r *LazyChunkReader) Read(b []byte) (read int, err error)

+ func (r *LazyChunkReader) ReadAt(b []byte, off int64) (read int, err error)

+ func (r *LazyChunkReader) Seek(offset int64, whence int) (int64, error)

+ func (r *LazyChunkReader) Size(ctx context.Context, quitC chan bool) (n int64, err error)

+ type LazySectionReader interface

+ Context func() context.Context

+ Size func(context.Context, chan bool) (int64, error)

+ type LazyTestSectionReader struct

+ func (r *LazyTestSectionReader) Context() context.Context

+ func (r *LazyTestSectionReader) Size(context.Context, chan bool) (int64, error)

+ type NetFetcher interface

+ Offer func(source *enode.ID)

+ Request func(hopCount uint8)

+ type NetStore struct

+ NewNetFetcherFunc NewNetFetcherFunc

+ func NewNetStore(store chunk.Store, nnf NewNetFetcherFunc) (*NetStore, error)

+ func (n *NetStore) Close() (err error)

+ func (n *NetStore) FetchFunc(ctx context.Context, ref Address) func(context.Context) error

+ func (n *NetStore) Get(rctx context.Context, mode chunk.ModeGet, ref Address) (Chunk, error)

+ func (n *NetStore) Put(ctx context.Context, mode chunk.ModePut, ch Chunk) (bool, error)

+ func (n *NetStore) RequestsCacheLen() int

+ type NewNetFetcherFunc func(ctx context.Context, addr Address, peers *sync.Map) NetFetcher

+ type Putter interface

+ Close func()

+ Put func(context.Context, ChunkData) (Reference, error)

+ RefSize func() int64

+ Wait func(context.Context) error

+ type PyramidChunker struct

+ func NewPyramidSplitter(params *PyramidSplitterParams, tag *chunk.Tag) (pc *PyramidChunker)

+ func (pc *PyramidChunker) Append(ctx context.Context) (k Address, wait func(context.Context) error, err error)

+ func (pc *PyramidChunker) Join(addr Address, getter Getter, depth int) LazySectionReader

+ func (pc *PyramidChunker) Split(ctx context.Context) (k Address, wait func(context.Context) error, err error)

+ type PyramidSplitterParams struct

+ func NewPyramidSplitterParams(addr Address, reader io.Reader, putter Putter, getter Getter, chunkSize int64) *PyramidSplitterParams

+ type Reference []byte

+ type SplitterParams struct

+ type StoreParams struct

+ BaseKey []byte

+ CacheCapacity uint

+ DbCapacity uint64

+ Hash SwarmHasher

+ func NewDefaultStoreParams() *StoreParams

+ func NewStoreParams(ldbCap uint64, cacheCap uint, hash SwarmHasher, basekey []byte) *StoreParams

+ type SwarmHash interface

+ ResetWithLength func([]byte)

+ type SwarmHasher func() SwarmHash

+ func MakeHashFunc(hash string) SwarmHasher

+ type TreeChunker struct

+ func NewTreeJoiner(params *JoinerParams) *TreeChunker

+ func NewTreeSplitter(params *TreeSplitterParams) *TreeChunker

+ func (tc *TreeChunker) Join(ctx context.Context) *LazyChunkReader

+ func (tc *TreeChunker) Split(ctx context.Context) (k Address, wait func(context.Context) error, err error)

+ type TreeEntry struct

+ func NewTreeEntry(pyramid *PyramidChunker) *TreeEntry

+ type TreeSplitterParams struct