Documentation ¶
Index ¶
- Constants
- func NewObjectStorage(config *storage.Config) storer.EncodedObjectStorer
- type ChaintreeLinkStorage
- type ObjectStorage
- func (s *ObjectStorage) Begin() storer.Transaction
- func (s *ObjectStorage) EncodedObject(t plumbing.ObjectType, h plumbing.Hash) (plumbing.EncodedObject, error)
- func (s *ObjectStorage) EncodedObjectSize(h plumbing.Hash) (size int64, err error)
- func (s *ObjectStorage) HasEncodedObject(h plumbing.Hash) (err error)
- func (s *ObjectStorage) IterEncodedObjects(t plumbing.ObjectType) (storer.EncodedObjectIter, error)
- func (s *ObjectStorage) PackfileWriter() (io.WriteCloser, error)
- func (s *ObjectStorage) SetEncodedObject(o plumbing.EncodedObject) (plumbing.Hash, error)
- type ObjectTransaction
- type SkylinkStore
- type Skynet
- type TemporalStorage
Constants ¶
View Source
const TupeloTxnBatchSize = 75
Variables ¶
This section is empty.
Functions ¶
func NewObjectStorage ¶
func NewObjectStorage(config *storage.Config) storer.EncodedObjectStorer
Types ¶
type ChaintreeLinkStorage ¶
func NewChaintreeLinkStorage ¶
func NewChaintreeLinkStorage(config *storage.Config) *ChaintreeLinkStorage
type ObjectStorage ¶
type ObjectStorage struct { *storage.ChaintreeObjectStorage // contains filtered or unexported fields }
func (*ObjectStorage) Begin ¶
func (s *ObjectStorage) Begin() storer.Transaction
func (*ObjectStorage) EncodedObject ¶
func (s *ObjectStorage) EncodedObject(t plumbing.ObjectType, h plumbing.Hash) (plumbing.EncodedObject, error)
func (*ObjectStorage) EncodedObjectSize ¶
func (s *ObjectStorage) EncodedObjectSize(h plumbing.Hash) (size int64, err error)
func (*ObjectStorage) HasEncodedObject ¶
func (s *ObjectStorage) HasEncodedObject(h plumbing.Hash) (err error)
func (*ObjectStorage) IterEncodedObjects ¶
func (s *ObjectStorage) IterEncodedObjects(t plumbing.ObjectType) (storer.EncodedObjectIter, error)
func (*ObjectStorage) PackfileWriter ¶
func (s *ObjectStorage) PackfileWriter() (io.WriteCloser, error)
func (*ObjectStorage) SetEncodedObject ¶
func (s *ObjectStorage) SetEncodedObject(o plumbing.EncodedObject) (plumbing.Hash, error)
type ObjectTransaction ¶
type ObjectTransaction struct {
// contains filtered or unexported fields
}
func (*ObjectTransaction) Commit ¶
func (ot *ObjectTransaction) Commit() error
func (*ObjectTransaction) EncodedObject ¶
func (ot *ObjectTransaction) EncodedObject(t plumbing.ObjectType, h plumbing.Hash) (plumbing.EncodedObject, error)
func (*ObjectTransaction) Rollback ¶
func (ot *ObjectTransaction) Rollback() error
func (*ObjectTransaction) SetEncodedObject ¶
func (ot *ObjectTransaction) SetEncodedObject(o plumbing.EncodedObject) (plumbing.Hash, error)
type SkylinkStore ¶
type Skynet ¶
func InitSkynet ¶
func (*Skynet) DownloadObject ¶
func (s *Skynet) DownloadObject(link string) (chan plumbing.EncodedObject, chan error)
func (*Skynet) UploadObject ¶
func (s *Skynet) UploadObject(o plumbing.EncodedObject) (chan string, chan error)
type TemporalStorage ¶
func NewTemporalStorage ¶
func NewTemporalStorage() *TemporalStorage
func (*TemporalStorage) SetEncodedObject ¶
func (ts *TemporalStorage) SetEncodedObject(o plumbing.EncodedObject) (plumbing.Hash, error)
func (*TemporalStorage) SetSkylink ¶
func (ts *TemporalStorage) SetSkylink(h plumbing.Hash, link string)
func (*TemporalStorage) Skylinks ¶
func (ts *TemporalStorage) Skylinks() SkylinkStore
Click to show internal directories.
Click to hide internal directories.