store_verzeichnisse

Documentation

Index

• Constants
• func MakeErrConcurrentPageAccess() error
• type KennungShaMap
  • func (ksm KennungShaMap) ModifyMutter(z *sku.Transacted) (err error)
  • func (ksm KennungShaMap) SaveSha(z *sku.Transacted) (err error)
• type Page
  • func (zp *Page) Add(z *sku.Transacted) (err error)
  • func (zp *Page) Copy(w schnittstellen.FuncIter[*sku.Transacted]) (err error)
  • func (zp *Page) Flush() (err error)
  • func (zp *Page) WriteTo(w1 io.Writer) (n int64, err error)
• type PageDelegate
• type PageDelegateGetter
• type State
• type Store
  • func MakeStore(k konfig.Compiled, dir string, f schnittstellen.VerzeichnisseFactory, ...) (i *Store, err error)
  • func (i *Store) AddVerzeichnisse(tz *sku.Transacted, v string) (err error)
  • func (i *Store) Flush() (err error)
  • func (i Store) GetPage(n int) (p *Page, err error)
  • func (i *Store) GetPageIndexKeyValue(zt sku.Transacted) (key string, value string)
  • func (i Store) PageForKennung(h kennung.Kennung) (n int, err error)
  • func (i Store) PageForSha(s schnittstellen.ShaLike) (n int, err error)
  • func (i Store) PageForString(s string) (n int, err error)
  • func (i Store) PageIdForIndex(n int) (pid pageId)
  • func (i *Store) ReadMany(ws ...schnittstellen.FuncIter[*sku.Transacted]) (err error)
  • func (i *Store) SetNeedsFlush()

Constants

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

const (
	StateUnread = State(iota)
	StateChanged
)

Functions

func MakeErrConcurrentPageAccess

func MakeErrConcurrentPageAccess() error

Types

type KennungShaMap

type KennungShaMap map[string]sha.Sha

func (KennungShaMap) ModifyMutter

func (ksm KennungShaMap) ModifyMutter(z *sku.Transacted) (err error)

func (KennungShaMap) SaveSha

func (ksm KennungShaMap) SaveSha(z *sku.Transacted) (err error)

type Page

type Page struct {
	schnittstellen.VerzeichnisseFactory

	State
	// contains filtered or unexported fields
}

func (*Page) Add

func (zp *Page) Add(z *sku.Transacted) (err error)

func (*Page) Copy

func (zp *Page) Copy(
	w schnittstellen.FuncIter[*sku.Transacted],
) (err error)

func (*Page) Flush

func (zp *Page) Flush() (err error)

func (*Page) WriteTo

func (zp *Page) WriteTo(w1 io.Writer) (n int64, err error)

type PageDelegate

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

type PageDelegateGetter

type PageDelegateGetter interface {
	GetVerzeichnissePageDelegate(int) PageDelegate
}

type State

type State int

type Store

type Store struct {
	schnittstellen.VerzeichnisseFactory
	// contains filtered or unexported fields
}

func MakeStore

func MakeStore(
	k konfig.Compiled,
	dir string,
	f schnittstellen.VerzeichnisseFactory,
	fff PageDelegateGetter,
) (i *Store, err error)

func (*Store) AddVerzeichnisse

func (i *Store) AddVerzeichnisse(
	tz *sku.Transacted,
	v string,
) (err error)

func (*Store) Flush

func (i *Store) Flush() (err error)

func (Store) GetPage

func (i Store) GetPage(n int) (p *Page, err error)

func (*Store) GetPageIndexKeyValue

func (i *Store) GetPageIndexKeyValue(
	zt sku.Transacted,
) (key string, value string)

func (Store) PageForKennung

func (i Store) PageForKennung(h kennung.Kennung) (n int, err error)

func (Store) PageForSha

func (i Store) PageForSha(s schnittstellen.ShaLike) (n int, err error)

func (Store) PageForString

func (i Store) PageForString(s string) (n int, err error)

func (Store) PageIdForIndex

func (i Store) PageIdForIndex(n int) (pid pageId)

func (*Store) ReadMany

func (i *Store) ReadMany(
	ws ...schnittstellen.FuncIter[*sku.Transacted],
) (err error)

func (*Store) SetNeedsFlush

func (i *Store) SetNeedsFlush()