store

Documentation

Index

• type AppendConverter
  • func NewAppendConverter(pathName string, useCompactHashes, usePackedValues bool) (*AppendConverter, error)
  • func (c *AppendConverter) Close() error
  • func (c *AppendConverter) ConvertToBPTree(s *specializedstore.BPTreeFileStore) *TaskState
  • func (c *AppendConverter) ConvertToBadger(s *specializedstore.BadgerStore, iterations int) *TaskState
  • func (c *AppendConverter) GetControlRecordSizeInEntries() int64
  • func (c *AppendConverter) GetEntrySize() int64
  • func (c *AppendConverter) ReadRecords(id panako.ResourceId, recordIndex, n int64) (results []panako.StoreRecord)
  • func (c *AppendConverter) ReadSortedRecordsRange(id panako.ResourceId, recordIndex, n int64, start, stop uint64) (results []panako.StoreRecord)
  • func (c *AppendConverter) ScanControlData()
  • func (c *AppendConverter) SortHashes(s *AppendStore, workers int) *TaskState
• type AppendConverterControlData
• type AppendStore
  • func NewAppendStore(pathName string, useCompactHashes, usePackedValues bool) (*AppendStore, error)
  • func (s *AppendStore) Close() error
  • func (s *AppendStore) GetEntrySize() int
  • func (s *AppendStore) GetPanakoMatch(record panako.StoreRecord, lookupRange int) chan *panako.MatchedRecord
  • func (s *AppendStore) GetPanakoMatches(records []panako.StoreRecord, lookupRange int) chan *panako.MatchedRecord
  • func (s *AppendStore) GetPanakoRecords(resourceId panako.ResourceId) []panako.StoreRecord
  • func (s *AppendStore) StorePanakoPrint(record panako.StoreRecord)
  • func (s *AppendStore) StorePanakoPrints(records []panako.StoreRecord)
  • func (s *AppendStore) Sync() error
• type AppendStoreControlData
• type Bitfield
  • func NewBitfield(size uint64) *Bitfield
  • func (b *Bitfield) Get(n uint64) bool
  • func (b *Bitfield) GetNextValue(fromIndex uint64, value bool) uint64
  • func (b *Bitfield) Set(n uint64, value bool)
• type TaskState
  • func (t *TaskState) Progress() (int64, int64)
  • func (t *TaskState) Wait()

Types

type AppendConverter

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

func NewAppendConverter

func NewAppendConverter(pathName string, useCompactHashes, usePackedValues bool) (*AppendConverter, error)

func (*AppendConverter) Close

func (c *AppendConverter) Close() error

func (*AppendConverter) ConvertToBPTree

func (c *AppendConverter) ConvertToBPTree(s *specializedstore.BPTreeFileStore) *TaskState

func (*AppendConverter) ConvertToBadger

func (c *AppendConverter) ConvertToBadger(s *specializedstore.BadgerStore, iterations int) *TaskState

func (*AppendConverter) GetControlRecordSizeInEntries

func (c *AppendConverter) GetControlRecordSizeInEntries() int64

func (*AppendConverter) GetEntrySize

func (c *AppendConverter) GetEntrySize() int64

func (*AppendConverter) ReadRecords

func (c *AppendConverter) ReadRecords(id panako.ResourceId, recordIndex, n int64) (results []panako.StoreRecord)

func (*AppendConverter) ReadSortedRecordsRange

func (c *AppendConverter) ReadSortedRecordsRange(id panako.ResourceId, recordIndex, n int64, start, stop uint64) (results []panako.StoreRecord)

func (*AppendConverter) ScanControlData

func (c *AppendConverter) ScanControlData()

func (*AppendConverter) SortHashes

func (c *AppendConverter) SortHashes(s *AppendStore, workers int) *TaskState

type AppendConverterControlData

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

type AppendStore

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

func NewAppendStore

func NewAppendStore(pathName string, useCompactHashes, usePackedValues bool) (*AppendStore, error)

func (*AppendStore) Close

func (s *AppendStore) Close() error

func (*AppendStore) GetEntrySize

func (s *AppendStore) GetEntrySize() int

func (*AppendStore) GetPanakoMatch

func (s *AppendStore) GetPanakoMatch(record panako.StoreRecord, lookupRange int) chan *panako.MatchedRecord

func (*AppendStore) GetPanakoMatches

func (s *AppendStore) GetPanakoMatches(records []panako.StoreRecord, lookupRange int) chan *panako.MatchedRecord

func (*AppendStore) GetPanakoRecords

func (s *AppendStore) GetPanakoRecords(resourceId panako.ResourceId) []panako.StoreRecord

func (*AppendStore) StorePanakoPrint

func (s *AppendStore) StorePanakoPrint(record panako.StoreRecord)

func (*AppendStore) StorePanakoPrints

func (s *AppendStore) StorePanakoPrints(records []panako.StoreRecord)

func (*AppendStore) Sync

func (s *AppendStore) Sync() error

type AppendStoreControlData

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

type Bitfield

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

func NewBitfield

func NewBitfield(size uint64) *Bitfield

func (*Bitfield) Get

func (b *Bitfield) Get(n uint64) bool

func (*Bitfield) GetNextValue

func (b *Bitfield) GetNextValue(fromIndex uint64, value bool) uint64

func (*Bitfield) Set

func (b *Bitfield) Set(n uint64, value bool)

type TaskState

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

func (*TaskState) Progress

func (t *TaskState) Progress() (int64, int64)

func (*TaskState) Wait

func (t *TaskState) Wait()