indexcache

Documentation

Index

• Variables
• type Builder
• type FileBuilder
  • func NewFileBuilder(workdir string) *FileBuilder
  • func (f *FileBuilder) AddPackIndex(ctx context.Context, h arq.ShaHash, pi arq.ArqPackIndex) error
  • func (fb *FileBuilder) Build(ctx context.Context) error
  • func (f *FileBuilder) HasPackIndex(ctx context.Context, h arq.ShaHash) (bool, error)
• type FileSearcher
  • func NewFileSearcher(workdir string) *FileSearcher
  • func (fs *FileSearcher) Close()
  • func (fs *FileSearcher) Find(ctx context.Context, h arq.ShaHash) (PackLocation, error)
  • func (fs *FileSearcher) Open(ctx context.Context) error
• type MapBackedCache
  • func NewMapBackedCache() *MapBackedCache
  • func (m *MapBackedCache) AddPackIndex(ctx context.Context, h arq.ShaHash, pi arq.ArqPackIndex) error
  • func (m *MapBackedCache) Build(ctx context.Context) error
  • func (m *MapBackedCache) Find(ctx context.Context, oH arq.ShaHash) (PackLocation, error)
  • func (m *MapBackedCache) HasPackIndex(ctx context.Context, h arq.ShaHash) (bool, error)
• type PackLocation
• type Searcher

Variables

var (
	ErrAlreadyIndexedPack = errors.New("already indexed this pack index")
	ErrNotFound           = errors.New("ErrNotFound")
)

var (
	ErrTooManyPacksets = errors.New("ErrTooManyPacksets")
)

Types

type Builder

type Builder interface {
	HasPackIndex(ctx context.Context, h arq.ShaHash) (bool, error)
	AddPackIndex(ctx context.Context, h arq.ShaHash, pi arq.ArqPackIndex) error
	Build(ctx context.Context) error
}

type FileBuilder

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

func NewFileBuilder

func NewFileBuilder(workdir string) *FileBuilder

func (*FileBuilder) AddPackIndex

func (f *FileBuilder) AddPackIndex(ctx context.Context, h arq.ShaHash, pi arq.ArqPackIndex) error

func (*FileBuilder) Build

func (fb *FileBuilder) Build(ctx context.Context) error

func (*FileBuilder) HasPackIndex

func (f *FileBuilder) HasPackIndex(ctx context.Context, h arq.ShaHash) (bool, error)

type FileSearcher

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

func NewFileSearcher

func NewFileSearcher(workdir string) *FileSearcher

func (*FileSearcher) Close

func (fs *FileSearcher) Close()

func (*FileSearcher) Find

func (fs *FileSearcher) Find(ctx context.Context, h arq.ShaHash) (PackLocation, error)

func (*FileSearcher) Open

func (fs *FileSearcher) Open(ctx context.Context) error

type MapBackedCache

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

func NewMapBackedCache

func NewMapBackedCache() *MapBackedCache

func (*MapBackedCache) AddPackIndex

func (m *MapBackedCache) AddPackIndex(ctx context.Context, h arq.ShaHash, pi arq.ArqPackIndex) error

func (*MapBackedCache) Build

func (m *MapBackedCache) Build(ctx context.Context) error

func (*MapBackedCache) Find

func (m *MapBackedCache) Find(ctx context.Context, oH arq.ShaHash) (PackLocation, error)

func (*MapBackedCache) HasPackIndex

func (m *MapBackedCache) HasPackIndex(ctx context.Context, h arq.ShaHash) (bool, error)

type PackLocation

type PackLocation struct {
	Offset   uint64
	Length   uint64
	PackHash arq.ShaHash
}

type Searcher

type Searcher interface {
	Find(ctx context.Context, h arq.ShaHash) (PackLocation, error)
}