store

Documentation

Index

• type AggregateError
  • func (a AggregateError) Error() string
• type ItemReferenceBlockStore
  • func (i ItemReferenceBlockStore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)
  • func (i ItemReferenceBlockStore) DeleteBlock(ctx context.Context, cid cid.Cid) error
  • func (i ItemReferenceBlockStore) Get(ctx context.Context, cid cid.Cid) (blocks.Block, error)
  • func (i ItemReferenceBlockStore) GetSize(ctx context.Context, c cid.Cid) (int, error)
  • func (i ItemReferenceBlockStore) Has(ctx context.Context, cid cid.Cid) (bool, error)
  • func (i ItemReferenceBlockStore) HashOnRead(enabled bool)
  • func (i ItemReferenceBlockStore) Put(ctx context.Context, block blocks.Block) error
  • func (i ItemReferenceBlockStore) PutMany(ctx context.Context, i2 []blocks.Block) error
• type PieceReader
  • func NewPieceReader(ctx context.Context, car model.Car, source model.Source, ...) (*PieceReader, error)
  • func (pr *PieceReader) Clone(ctx context.Context) *PieceReader
  • func (pr *PieceReader) Close() error
  • func (pr *PieceReader) Read(p []byte) (n int, err error)
  • func (pr *PieceReader) Seek(offset int64, whence int) (int64, error)

Types

type AggregateError

type AggregateError struct {
	Errors []error
}

func (AggregateError) Error

func (a AggregateError) Error() string

type ItemReferenceBlockStore

type ItemReferenceBlockStore struct {
	DB              *gorm.DB
	HandlerResolver datasource.HandlerResolver
}

func (ItemReferenceBlockStore) AllKeysChan

func (i ItemReferenceBlockStore) AllKeysChan(ctx context.Context) (<-chan cid.Cid, error)

func (ItemReferenceBlockStore) DeleteBlock

func (i ItemReferenceBlockStore) DeleteBlock(ctx context.Context, cid cid.Cid) error

func (ItemReferenceBlockStore) Get

func (i ItemReferenceBlockStore) Get(ctx context.Context, cid cid.Cid) (blocks.Block, error)

func (ItemReferenceBlockStore) GetSize

func (i ItemReferenceBlockStore) GetSize(ctx context.Context, c cid.Cid) (int, error)

func (ItemReferenceBlockStore) Has

func (i ItemReferenceBlockStore) Has(ctx context.Context, cid cid.Cid) (bool, error)

func (ItemReferenceBlockStore) HashOnRead

func (i ItemReferenceBlockStore) HashOnRead(enabled bool)

func (ItemReferenceBlockStore) Put

func (i ItemReferenceBlockStore) Put(ctx context.Context, block blocks.Block) error

func (ItemReferenceBlockStore) PutMany

func (i ItemReferenceBlockStore) PutMany(ctx context.Context, i2 []blocks.Block) error

type PieceReader

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

func NewPieceReader

func NewPieceReader(
	ctx context.Context,
	car model.Car,
	source model.Source,
	carBlocks []model.CarBlock,
	items []model.Item,
	resolver datasource.HandlerResolver,
) (
	*PieceReader,
	error,
)

func (*PieceReader) Clone

func (pr *PieceReader) Clone(ctx context.Context) *PieceReader

func (*PieceReader) Close

func (pr *PieceReader) Close() error

func (*PieceReader) Read

func (pr *PieceReader) Read(p []byte) (n int, err error)

func (*PieceReader) Seek

func (pr *PieceReader) Seek(offset int64, whence int) (int64, error)