commitlog

Documentation

Index

• func NewWriter(w *os.File) *bufWriter
• func NewWriterSize(w *os.File, size int) *bufWriter
• type HnswCommitType
• type Logger
  • func NewLogger(fileName string) *Logger
  • func NewLoggerWithFile(file *os.File) *Logger
  • func (l *Logger) AddLinkAtLevel(id uint64, level int, target uint64) error
  • func (l *Logger) AddLinksAtLevel(id uint64, level int, targets []uint64) error
  • func (l *Logger) AddNode(id uint64, level int) error
  • func (l *Logger) AddPQ(data compressionhelpers.PQData) error
  • func (l *Logger) AddTombstone(id uint64) error
  • func (l *Logger) ClearLinks(id uint64) error
  • func (l *Logger) ClearLinksAtLevel(id uint64, level uint16) error
  • func (l *Logger) Close() error
  • func (l *Logger) DeleteNode(id uint64) error
  • func (l *Logger) FileName() (string, error)
  • func (l *Logger) FileSize() (int64, error)
  • func (l *Logger) Flush() error
  • func (l *Logger) RemoveTombstone(id uint64) error
  • func (l *Logger) ReplaceLinksAtLevel(id uint64, level int, targets []uint64) error
  • func (l *Logger) Reset() error
  • func (l *Logger) SetEntryPointWithMaxLayer(id uint64, level int) error

Functions

func NewWriter

func NewWriter(w *os.File) *bufWriter

NewWriter returns a new Writer whose buffer has the default size.

func NewWriterSize

func NewWriterSize(w *os.File, size int) *bufWriter

NewWriterSize returns a new Writer whose buffer has at least the specified size. If the argument *os.File is already a Writer with large enough size, it returns the underlying Writer.

Types

type HnswCommitType

type HnswCommitType uint8 // 256 options, plenty of room for future extensions

TODO: these are duplicates with the hnsw package, unify them

const (
	AddNode HnswCommitType = iota
	SetEntryPointMaxLevel
	AddLinkAtLevel
	ReplaceLinksAtLevel
	AddTombstone
	RemoveTombstone
	ClearLinks
	DeleteNode
	ResetIndex
	ClearLinksAtLevel // added in v1.8.0-rc.1, see https://github.com/weaviate/weaviate/issues/1701
	AddLinksAtLevel   // added in v1.8.0-rc.1, see https://github.com/weaviate/weaviate/issues/1705
	AddPQ
)

TODO: these are duplicates with the hnsw package, unify them

type Logger

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

func NewLogger

func NewLogger(fileName string) *Logger

func NewLoggerWithFile

func NewLoggerWithFile(file *os.File) *Logger

func (*Logger) AddLinkAtLevel

func (l *Logger) AddLinkAtLevel(id uint64, level int, target uint64) error

func (*Logger) AddLinksAtLevel

func (l *Logger) AddLinksAtLevel(id uint64, level int, targets []uint64) error

func (*Logger) AddNode

func (l *Logger) AddNode(id uint64, level int) error

func (*Logger) AddPQ

func (l *Logger) AddPQ(data compressionhelpers.PQData) error

func (*Logger) AddTombstone

func (l *Logger) AddTombstone(id uint64) error

func (*Logger) ClearLinks

func (l *Logger) ClearLinks(id uint64) error

func (*Logger) ClearLinksAtLevel

func (l *Logger) ClearLinksAtLevel(id uint64, level uint16) error

func (*Logger) Close

func (l *Logger) Close() error

func (*Logger) DeleteNode

func (l *Logger) DeleteNode(id uint64) error

func (*Logger) FileName

func (l *Logger) FileName() (string, error)

func (*Logger) FileSize

func (l *Logger) FileSize() (int64, error)

func (*Logger) Flush

func (l *Logger) Flush() error

func (*Logger) RemoveTombstone

func (l *Logger) RemoveTombstone(id uint64) error

func (*Logger) ReplaceLinksAtLevel

func (l *Logger) ReplaceLinksAtLevel(id uint64, level int, targets []uint64) error

chunks links in increments of 8, so that we never have to allocate a dynamic []byte size which would be guaranteed to escape to the heap

func (*Logger) Reset

func (l *Logger) Reset() error

func (*Logger) SetEntryPointWithMaxLayer

func (l *Logger) SetEntryPointWithMaxLayer(id uint64, level int) error