carlog

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

type CarLog struct {

	// index = dir, data = file
	IndexPath, DataPath string
	// contains filtered or unexported fields
}

type CarStorageProvider interface {
	Upload(ctx context.Context, size int64, src func(writer io.Writer) error) error
	Has(ctx context.Context) (bool, error)

	io.ReaderAt
}

type Head struct {
	Version int64

	// something that's not zero
	Valid bool

	// byte offset just after the last retired op. If finalized, but layers aren't set
	// this points to the end of first (bottom) layer
	RetiredAt int64

	DataStart int64

	// byte offset of the start of the second layer
	DataEnd int64

	ReadOnly  bool // if true, no more writes are allowed
	Finalized bool // if true, no more writes are allowed, and the bsst index is finalized
	Offloaded bool // if true, the data file is offloaded to external storage, only hash samples are kept
	External  bool // if true, the data is moved to external storage on finalize

	// Layer stats, set after Finalized (Finalized can be true and layers may still not be set)
	LayerOffsets []int64 // byte offsets of the start of each layer
}

type IndexSource interface {
	bsst.Source
	Entries() (int64, error)
}

type LevelDBIndex struct {
	*leveldb.DB
}

type ReadableIndex interface {
	// todo maybe callback calling with sequential indexes of what we don't have
	//  to pipeline better?
	Has(c []mh.Multihash) ([]bool, error)

	// Get returns offsets to data, -1 if not found
	Get(c []mh.Multihash) ([]int64, error)

	// bsst creation
	Entries() (int64, error)
	bsst.Source

	Close() error
}

type TruncCleanup func(to int64, h []mh.Multihash) error

type WritableIndex interface {
	// Put records entries in the index
	// sync for now, todo
	// -1 offset means 'skip'
	Put(c []mh.Multihash, offs []int64) error

	Del(c []mh.Multihash) error

	// Truncate returns a list of multihashes to remove from the index
	ToTruncate(atOrAbove int64) ([]mh.Multihash, error)

	Close() error
}