store_objekten

Documentation

Index

• func IsErrExternalAkteExtensionMismatch(err error) bool
• type CreateOrUpdateDelegate
• type ErrAkteExists
  • func (e ErrAkteExists) Error() string
  • func (e ErrAkteExists) Is(target error) bool
• type ErrExternalAkteExtensionMismatch
  • func (e ErrExternalAkteExtensionMismatch) Error() string
  • func (e ErrExternalAkteExtensionMismatch) Is(target error) bool
• type Store
  • func Make(su store_util.StoreUtil) (s *Store, err error)
  • func (s *Store) AddMatchable(m *sku.Transacted) (err error)
  • func (s *Store) Create(mg metadatei.Getter) (tz *sku.Transacted, err error)
  • func (s *Store) CreateOrUpdate(mg metadatei.Getter, kennungPtr kennung.Kennung) (transactedPtr *sku.Transacted, err error)
  • func (s *Store) CreateOrUpdateAkte(mg metadatei.Getter, kennungPtr kennung.Kennung, sh schnittstellen.ShaLike) (transactedPtr *sku.Transacted, err error)
  • func (s *Store) CreateOrUpdateCheckedOut(co *sku.CheckedOut) (transactedPtr *sku.Transacted, err error)
  • func (s Store) Flush() (err error)
  • func (s *Store) GetReindexFunc(ti kennung_index.KennungIndex[kennung.Typ, *kennung.Typ]) func(*sku.Transacted) error
  • func (s *Store) Konfig() *konfigStore
  • func (s *Store) MakeReadAllSchwanzen(gs ...gattung.Gattung) func(schnittstellen.FuncIter[*sku.Transacted]) error
  • func (s *Store) Query(ms matcher.Query, f schnittstellen.FuncIter[*sku.Transacted]) (err error)
  • func (s *Store) ReadAll(gs gattungen.Set, f schnittstellen.FuncIter[*sku.Transacted]) (err error)
  • func (s Store) ReadAllMatchingAkten(akten schnittstellen.SetLike[fd.FD], f func(fd.FD, *sku.Transacted) error) (err error)
  • func (s *Store) ReadAllSchwanzen(gs gattungen.Set, f schnittstellen.FuncIter[*sku.Transacted]) (err error)
  • func (s *Store) ReadOne(k1 schnittstellen.StringerGattungGetter) (sk1 *sku.Transacted, err error)
  • func (s *Store) Reindex() (err error)
  • func (s *Store) Reset() (err error)
  • func (s *Store) RunMergeTool(tm to_merge.Sku) (err error)
  • func (s *Store) SetLogWriter(lw objekte_store.LogWriter)
  • func (s *Store) Update(mg metadatei.Getter, k schnittstellen.Stringer) (tz *sku.Transacted, err error)
  • func (s *Store) UpdateManyMetadatei(incoming sku.TransactedSet) (err error)

Functions

func IsErrExternalAkteExtensionMismatch

func IsErrExternalAkteExtensionMismatch(err error) bool

Types

type CreateOrUpdateDelegate

type CreateOrUpdateDelegate struct {
	New       schnittstellen.FuncIter[*sku.Transacted]
	Updated   schnittstellen.FuncIter[*sku.Transacted]
	Unchanged schnittstellen.FuncIter[*sku.Transacted]
}

type ErrAkteExists

type ErrAkteExists struct {
	Akte sha.Sha
	sku.TransactedMutableSet
}

func (ErrAkteExists) Error

func (e ErrAkteExists) Error() string

func (ErrAkteExists) Is

func (e ErrAkteExists) Is(target error) bool

type ErrExternalAkteExtensionMismatch

type ErrExternalAkteExtensionMismatch struct {
	Expected string
	Actual   fd.FD
}

func (ErrExternalAkteExtensionMismatch) Error

func (e ErrExternalAkteExtensionMismatch) Error() string

func (ErrExternalAkteExtensionMismatch) Is

func (e ErrExternalAkteExtensionMismatch) Is(target error) bool

type Store

type Store struct {
	store_util.StoreUtil

	objekte_store.LogWriter
	// contains filtered or unexported fields
}

func Make

func Make(
	su store_util.StoreUtil,
) (s *Store, err error)

func (*Store) AddMatchable

func (s *Store) AddMatchable(m *sku.Transacted) (err error)

func (*Store) Create

func (s *Store) Create(
	mg metadatei.Getter,
) (tz *sku.Transacted, err error)

func (*Store) CreateOrUpdate

func (s *Store) CreateOrUpdate(
	mg metadatei.Getter,
	kennungPtr kennung.Kennung,
) (transactedPtr *sku.Transacted, err error)

func (*Store) CreateOrUpdateAkte

func (s *Store) CreateOrUpdateAkte(
	mg metadatei.Getter,
	kennungPtr kennung.Kennung,
	sh schnittstellen.ShaLike,
) (transactedPtr *sku.Transacted, err error)

func (*Store) CreateOrUpdateCheckedOut

func (s *Store) CreateOrUpdateCheckedOut(
	co *sku.CheckedOut,
) (transactedPtr *sku.Transacted, err error)

func (Store) Flush

func (s Store) Flush() (err error)

func (*Store) GetReindexFunc

func (s *Store) GetReindexFunc(
	ti kennung_index.KennungIndex[kennung.Typ, *kennung.Typ],
) func(*sku.Transacted) error

func (*Store) Konfig

func (s *Store) Konfig() *konfigStore

func (*Store) MakeReadAllSchwanzen

func (s *Store) MakeReadAllSchwanzen(
	gs ...gattung.Gattung,
) func(schnittstellen.FuncIter[*sku.Transacted]) error

func (*Store) Query

func (s *Store) Query(
	ms matcher.Query,
	f schnittstellen.FuncIter[*sku.Transacted],
) (err error)

func (*Store) ReadAll

func (s *Store) ReadAll(
	gs gattungen.Set,
	f schnittstellen.FuncIter[*sku.Transacted],
) (err error)

func (Store) ReadAllMatchingAkten

func (s Store) ReadAllMatchingAkten(
	akten schnittstellen.SetLike[fd.FD],
	f func(fd.FD, *sku.Transacted) error,
) (err error)

func (*Store) ReadAllSchwanzen

func (s *Store) ReadAllSchwanzen(
	gs gattungen.Set,
	f schnittstellen.FuncIter[*sku.Transacted],
) (err error)

func (*Store) ReadOne

func (s *Store) ReadOne(
	k1 schnittstellen.StringerGattungGetter,
) (sk1 *sku.Transacted, err error)

func (*Store) Reindex

func (s *Store) Reindex() (err error)

TODO-P2 add support for quiet reindexing

func (*Store) Reset

func (s *Store) Reset() (err error)

func (*Store) RunMergeTool

func (s *Store) RunMergeTool(
	tm to_merge.Sku,
) (err error)

func (*Store) SetLogWriter

func (s *Store) SetLogWriter(
	lw objekte_store.LogWriter,
)

func (*Store) Update

func (s *Store) Update(
	mg metadatei.Getter,
	k schnittstellen.Stringer,
) (tz *sku.Transacted, err error)

func (*Store) UpdateManyMetadatei

func (s *Store) UpdateManyMetadatei(
	incoming sku.TransactedSet,
) (err error)