store

package

v0.2.20 Latest Latest Go to latest Published: Jul 5, 2023 License: Apache-2.0, MIT Imports: 15 Imported by: 0

Documentation ¶

Index ¶

type AggregateError
- func (a AggregateError) Error() string
type ItemReferenceBlockStore
type PieceReader
- func NewPieceReader(ctx context.Context, car model.Car, source model.Source, ...) (*PieceReader, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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 ¶ added in v0.2.14

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 ¶ added in v0.2.13

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL