storage

Documentation

Index

• Variables
• func ObjectReadPath(h plumbing.Hash) []string
• func ObjectWritePath(h plumbing.Hash) string
• func ZlibBufferForObject(o plumbing.EncodedObject) (*bytes.Buffer, error)
• type ChaintreeObjectStorage
  • func (s *ChaintreeObjectStorage) Chaintree() *chaintree.ChainTree
  • func (s *ChaintreeObjectStorage) NewEncodedObject() plumbing.EncodedObject
• type ChaintreeObjectStorer
• type Config
• type EncodedObjectIter
  • func NewEncodedObjectIter(store ChaintreeObjectStorer, t plumbing.ObjectType) *EncodedObjectIter
  • func (iter *EncodedObjectIter) Close()
  • func (iter *EncodedObjectIter) ForEach(cb func(plumbing.EncodedObject) error) error
  • func (iter *EncodedObjectIter) Next() (plumbing.EncodedObject, error)
• type PackWriter
  • func NewPackWriter(s ChaintreeObjectStorer) *PackWriter
  • func (pw *PackWriter) Close() error
  • func (pw *PackWriter) Write(p []byte) (n int, err error)
• type PackfileObserver
  • func (po *PackfileObserver) OnFooter(_ plumbing.Hash) error
  • func (po *PackfileObserver) OnHeader(_ uint32) error
  • func (po *PackfileObserver) OnInflatedObjectContent(h plumbing.Hash, _ int64, _ uint32, content []byte) error
  • func (po *PackfileObserver) OnInflatedObjectHeader(t plumbing.ObjectType, objSize, _ int64) error

Variables

var ObjectsBasePath = []string{"tree", "data", "objects"}

Functions

func ObjectReadPath

func ObjectReadPath(h plumbing.Hash) []string

func ObjectWritePath

func ObjectWritePath(h plumbing.Hash) string

func ZlibBufferForObject

func ZlibBufferForObject(o plumbing.EncodedObject) (*bytes.Buffer, error)

Types

type ChaintreeObjectStorage

type ChaintreeObjectStorage struct {
	*Config
}

func (*ChaintreeObjectStorage) Chaintree

func (s *ChaintreeObjectStorage) Chaintree() *chaintree.ChainTree

func (*ChaintreeObjectStorage) NewEncodedObject

func (s *ChaintreeObjectStorage) NewEncodedObject() plumbing.EncodedObject

type ChaintreeObjectStorer

type ChaintreeObjectStorer interface {
	storer.EncodedObjectStorer
	Chaintree() *chaintree.ChainTree
}

type Config

type Config struct {
	Ctx        context.Context
	Tupelo     *tupelo.Client
	ChainTree  *consensus.SignedChainTree
	PrivateKey *ecdsa.PrivateKey
}

type EncodedObjectIter

type EncodedObjectIter struct {
	storer.EncodedObjectIter
	// contains filtered or unexported fields
}

func NewEncodedObjectIter

func NewEncodedObjectIter(store ChaintreeObjectStorer, t plumbing.ObjectType) *EncodedObjectIter

func (*EncodedObjectIter) Close

func (iter *EncodedObjectIter) Close()

func (*EncodedObjectIter) ForEach

func (iter *EncodedObjectIter) ForEach(cb func(plumbing.EncodedObject) error) error

func (*EncodedObjectIter) Next

func (iter *EncodedObjectIter) Next() (plumbing.EncodedObject, error)

Next returns the next object from the iterator. If the iterator has reached the end it will return io.EOF as an error. If the object is retreieved successfully error will be nil.

type PackWriter

type PackWriter struct {
	// contains filtered or unexported fields
}

func NewPackWriter

func NewPackWriter(s ChaintreeObjectStorer) *PackWriter

func (*PackWriter) Close

func (pw *PackWriter) Close() error

func (*PackWriter) Write

func (pw *PackWriter) Write(p []byte) (n int, err error)

type PackfileObserver

type PackfileObserver struct {
	// contains filtered or unexported fields
}

func (*PackfileObserver) OnFooter

func (po *PackfileObserver) OnFooter(_ plumbing.Hash) error

func (*PackfileObserver) OnHeader

func (po *PackfileObserver) OnHeader(_ uint32) error

func (*PackfileObserver) OnInflatedObjectContent

func (po *PackfileObserver) OnInflatedObjectContent(h plumbing.Hash, _ int64, _ uint32, content []byte) error

func (*PackfileObserver) OnInflatedObjectHeader

func (po *PackfileObserver) OnInflatedObjectHeader(t plumbing.ObjectType, objSize, _ int64) error