stream_index

Documentation

Index

• Constants
• func MakeErrConcurrentPageAccess() error
• type Index
  • func MakeIndex(s dir_layout.DirLayout, k *config.Compiled, dir string) (i *Index, err error)
  • func (i *Index) Add(z *sku.Transacted, v string, options sku.CommitOptions) (err error)
  • func (i *Index) Flush(printerHeader interfaces.FuncIter[string]) (err error)
  • func (i *Index) GetPage(n uint8) (p *Page)
  • func (i *Index) GetProbeIndex() *probe_index
  • func (i *Index) Initialize() (err error)
  • func (s *Index) ObjectExists(id ids.IdLike) (err error)
  • func (s *Index) ReadOneObjectId(id string, sk *sku.Transacted) (err error)
  • func (s *Index) ReadOneObjectIdTai(k interfaces.ObjectId, t ids.Tai) (sk *sku.Transacted, err error)
  • func (s *Index) ReadOneSha(sh *sha.Sha, sk *sku.Transacted) (err error)
  • func (i *Index) ReadQuery(qg sku.PrimitiveQueryGroup, w interfaces.FuncIter[*sku.Transacted]) (err error)
  • func (i *Index) SetNeedsFlushHistory(changes []string)
• type ObjectIdShaMap
• type Page
  • func (pt *Page) CopyJustHistory(s sku.PrimitiveQueryGroup, w interfaces.FuncIter[*sku.Transacted]) (err error)
  • func (s Page) Flush() (err error)
  • func (s Page) Initialize(directoryLayout dir_layout.DirLayout) (err error)
  • func (pt *Page) MakeFlush(changesAreHistorical bool) func() error
• type PageDelegate
• type PageDelegateGetter
• type PageId
• type State

Constants

const (
	StateUnread = State(iota)
	StateChanged
)

const (
	DigitWidth = 1
	PageCount  = 1 << (DigitWidth * 4)
)

Functions

func MakeErrConcurrentPageAccess

func MakeErrConcurrentPageAccess() error

Types

type Index

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

func MakeIndex

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

func (*Index) Add

func (i *Index) Add(
	z *sku.Transacted,
	v string,
	options sku.CommitOptions,
) (err error)

func (*Index) Flush

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

func (*Index) GetPage

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

func (*Index) GetProbeIndex

func (i *Index) GetProbeIndex() *probe_index

func (*Index) Initialize

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

func (*Index) ObjectExists

func (s *Index) ObjectExists(
	id ids.IdLike,
) (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(
	directoryLayout dir_layout.DirLayout,
) (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