persistence

package
v0.13.1 Latest Latest
Warning

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

Go to latest
Published: Mar 25, 2025 License: MIT Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FileReader

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

func NewFileReader

func NewFileReader(name string, bitsPerLabel uint) (*FileReader, error)

func (*FileReader) Close

func (r *FileReader) Close() error

func (*FileReader) NumLabels

func (r *FileReader) NumLabels() (uint64, error)

func (*FileReader) Read

func (r *FileReader) Read(p []byte) (int, error)

type FileWriter

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

func NewFileWriter

func NewFileWriter(filename string, bitsPerLabel uint) (*FileWriter, error)

func NewLabelsWriter

func NewLabelsWriter(datadir string, index int, bitsPerLabel uint) (*FileWriter, error)

func (*FileWriter) Close

func (w *FileWriter) Close() error

func (*FileWriter) Flush

func (w *FileWriter) Flush() error

func (*FileWriter) NumLabelsWritten

func (w *FileWriter) NumLabelsWritten() (uint64, error)

func (*FileWriter) Truncate

func (w *FileWriter) Truncate(numLabels uint64) error

func (*FileWriter) Write

func (w *FileWriter) Write(b []byte) error

type GroupReader

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

func Group

func Group(readers []Reader) (*GroupReader, error)

Group groups a slice of Reader into one continuous Reader.

func (*GroupReader) Close

func (g *GroupReader) Close() error

func (*GroupReader) NumLabels

func (g *GroupReader) NumLabels() (uint64, error)

func (*GroupReader) Read

func (g *GroupReader) Read(p []byte) (int, error)

type NumericalSorter added in v0.8.9

type NumericalSorter []os.FileInfo

func (NumericalSorter) Len added in v0.8.9

func (s NumericalSorter) Len() int

func (NumericalSorter) Less added in v0.8.9

func (s NumericalSorter) Less(i, j int) bool

func (NumericalSorter) Swap added in v0.8.9

func (s NumericalSorter) Swap(i, j int)

type Reader

type Reader interface {
	Read(p []byte) (n int, err error)
	NumLabels() (uint64, error)
	Close() error
}

func GetReaders

func GetReaders(datadir string, bitsPerLabel uint) ([]Reader, error)

func NewLabelsReader

func NewLabelsReader(datadir string, bitsPerLabel uint) (Reader, error)

NewLabelsReader returns a new labels reader from the initialization files. If the initialization was split into multiple files, they will be grouped into one unified reader.

Jump to

Keyboard shortcuts

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