stream_index

package
v0.0.0-...-037439e Latest Latest
Warning

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

Go to latest
Published: Sep 30, 2024 License: MIT Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const (
	StateUnread = State(iota)
	StateChanged
)
View Source
const (
	DigitWidth = 1
	PageCount  = 1 << (DigitWidth * 4)
)

Variables

This section is empty.

Functions

func MakeErrConcurrentPageAccess

func MakeErrConcurrentPageAccess() error

Types

type Index

type Index struct {
	interfaces.CacheIOFactory
	// contains filtered or unexported fields
}

func MakeIndex

func MakeIndex(
	s fs_home.Home,
	k *config.Compiled,
	dir string,
) (i *Index, err error)

func (*Index) Add

func (i *Index) Add(
	z *sku.Transacted,
	v string,
	mode objekte_mode.Mode,
) (err error)

func (*Index) Flush

func (i *Index) Flush(
	printerHeader interfaces.FuncIter[string],
) (err error)

func (*Index) GetPagePair

func (i *Index) GetPagePair(n uint8) (p *Page)

func (*Index) GetProbeIndex

func (i *Index) GetProbeIndex() *probe_index

func (*Index) Initialize

func (i *Index) Initialize() (err error)

func (*Index) PageForObjectId

func (i *Index) PageForObjectId(h ids.IdLike) (n uint8, err error)

func (*Index) PageForSha

func (i *Index) PageForSha(s interfaces.Sha) (n uint8, err error)

func (*Index) PageForString

func (i *Index) PageForString(s string) (n uint8, err error)

func (*Index) ReadOneObjectId

func (s *Index) ReadOneObjectId(
	id string,
	sk *sku.Transacted,
) (err error)

func (*Index) ReadOneObjectIdTai

func (s *Index) ReadOneObjectIdTai(
	k interfaces.ObjectId,
	t ids.Tai,
) (sk *sku.Transacted, err error)

func (*Index) ReadOneSha

func (s *Index) ReadOneSha(
	sh *sha.Sha,
	sk *sku.Transacted,
) (err error)

func (*Index) ReadQuery

func (i *Index) ReadQuery(
	qg sku.PrimitiveQueryGroup,
	w interfaces.FuncIter[*sku.Transacted],
) (err error)

func (*Index) SetNeedsFlushHistory

func (i *Index) SetNeedsFlushHistory(changes []string)

type ObjectIdShaMap

type ObjectIdShaMap map[string]skuWithRangeAndSigil

type Page

type Page struct {
	PageId
	// contains filtered or unexported fields
}

func (*Page) CopyJustHistory

func (pt *Page) CopyJustHistory(
	s sku.PrimitiveQueryGroup,
	w interfaces.FuncIter[*sku.Transacted],
) (err error)

func (Page) Flush

func (s Page) Flush() (err error)

func (Page) Initialize

func (s Page) Initialize(
	fs_home fs_home.Home,
) (err error)

func (*Page) MakeFlush

func (pt *Page) MakeFlush(
	changesAreHistorical bool,
) func() error

type PageDelegate

type PageDelegate interface {
	ShouldAddVerzeichnisse(*sku.Transacted) error
	ShouldFlushVerzeichnisse(*sku.Transacted) error
}

type PageDelegateGetter

type PageDelegateGetter interface {
	GetVerzeichnissePageDelegate(uint8) PageDelegate
}

type PageId

type PageId = sha.PageId

type State

type State int

Jump to

Keyboard shortcuts

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