store

package
v0.0.0-...-b88af98 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 30, 2022 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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()

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.