store

package
v0.1.21 Latest Latest
Warning

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

Go to latest
Published: Jun 3, 2026 License: MIT Imports: 52 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeEdgeExplorer

func MakeEdgeExplorer(
	objectStore sku.RepoStore,
	blobStore mad_domain_interfaces.BlobStore,
	envAdder interfaces.EnvVarsAdder,
) sku.EdgeExplorer

Types

type RevertId

type RevertId struct {
	*ids.ObjectId
	Sig mad_domain_interfaces.MarklId
}

type Store

type Store struct {
	Abbr sku.IdIndex
	// contains filtered or unexported fields
}

func (*Store) All

func (store *Store) All(
	query *queries.Query,
) interfaces.SeqError[*sku.Transacted]

func (*Store) CheckoutOne

func (store *Store) CheckoutOne(
	repoId ids.RepoId,
	options checkout_options.Options,
	sz *sku.Transacted,
) (cz sku.SkuType, err error)

func (*Store) CheckoutQuery

func (store *Store) CheckoutQuery(
	options checkout_options.Options,
	query *pkg_query.Query,
	out interfaces.FuncIter[sku.SkuType],
) (err error)

func (*Store) Commit

func (store *Store) Commit(
	daughter *sku.Transacted,
	options sku.CommitOptions,
) (err error)

func (*Store) CreateOrUpdate

func (store *Store) CreateOrUpdate(
	external *sku.Transacted,
	options sku.CommitOptions,
) (err error)

func (*Store) DeleteCheckedOut

func (store *Store) DeleteCheckedOut(col *sku.CheckedOut) (err error)

func (*Store) Flush

func (store *Store) Flush(
	printerHeader interfaces.FuncIter[string],
) (err error)

func (*Store) FlushInventoryList

func (store *Store) FlushInventoryList(
	p interfaces.FuncIter[*sku.Transacted],
) (err error)

func (*Store) GetAbbrStore

func (store *Store) GetAbbrStore() sku.IdIndex

func (*Store) GetConfigStore

func (store *Store) GetConfigStore() store_config.Store

func (*Store) GetConfigStoreMutable

func (store *Store) GetConfigStoreMutable() store_config.StoreMutable

func (*Store) GetEnvRepo

func (store *Store) GetEnvRepo() env_repo.Env

func (*Store) GetInventoryListStore

func (store *Store) GetInventoryListStore() *inventory_list_store.Store

func (*Store) GetProtoZettel

func (store *Store) GetProtoZettel() sku.Proto

func (*Store) GetStreamIndex

func (store *Store) GetStreamIndex() sku.StreamIndex

func (*Store) GetTai

func (store *Store) GetTai() ids.Tai

func (*Store) GetTime

func (store *Store) GetTime() thyme.Time

func (*Store) GetTypedBlobStore

func (store *Store) GetTypedBlobStore() typed_blob_store.Stores

func (*Store) GetZettelIdIndex

func (store *Store) GetZettelIdIndex() zettel_id_index.Index

func (*Store) Initialize

func (store *Store) Initialize(
	config store_config.StoreMutable,
	envRepo env_repo.Env,
	envWorkspace env_workspace.Env,
	sunrise ids.Tai,
	envLua env_lua.Env,
	queryBuilder *queries.Builder,
	box *box_format.BoxTransacted,
	typedBlobStore typed_blob_store.Stores,
	dormantIndex *dormant_index.Index,
	abbrStore sku.IdIndex,
) (err error)

func (*Store) MakeBlobDigestObjectIdsMap

func (store *Store) MakeBlobDigestObjectIdsMap() (blobDigestObjectIds map[string][]string, err error)

func (*Store) MakeLuaVMPoolV1

func (store *Store) MakeLuaVMPoolV1(
	self *sku.Transacted,
	script string,
) (vp sku_lua.LuaVMPoolV1, err error)

func (*Store) MakeLuaVMPoolV1WithSku

func (store *Store) MakeLuaVMPoolV1WithSku(
	sk *sku.Transacted,
) (lvp sku_lua.LuaVMPoolV1, err error)

func (*Store) MakeLuaVMPoolWithReader

func (store *Store) MakeLuaVMPoolWithReader(
	selbst *sku.Transacted,
	r io.Reader,
) (vp sku_lua.LuaVMPoolV1, err error)

func (*Store) MakeSupplies

func (store *Store) MakeSupplies(
	repoId ids.RepoId,
) (supplies store_workspace.Supplies)

func (*Store) MergeConflicted

func (store *Store) MergeConflicted(
	conflicted sku.Conflicted,
) (err error)

TODO make this configgable

func (*Store) Open

func (store *Store) Open(
	repoId ids.RepoId,
	m checkout_mode.Mode,
	ph interfaces.FuncIter[string],
	zsc sku.SkuTypeSet,
) (err error)

func (*Store) PutCheckedOutLike

func (store *Store) PutCheckedOutLike(co sku.SkuType)

TODO remove entirely — callers should use repool from GetWithRepool

func (*Store) QueryExactlyOne

func (store *Store) QueryExactlyOne(
	queryGroup *queries.Query,
) (object *sku.Transacted, err error)

func (*Store) QueryExactlyOneExternal

func (store *Store) QueryExactlyOneExternal(
	query *queries.Query,
) (object *sku.Transacted, err error)

func (*Store) QueryPrimitive

func (store *Store) QueryPrimitive(
	group sku.PrimitiveQueryGroup,
	funcIter interfaces.FuncIter[*sku.Transacted],
) (err error)

TODO make iterator

func (*Store) QuerySkuType

func (store *Store) QuerySkuType(
	query *queries.Query,
	output interfaces.FuncIter[sku.SkuType],
) (err error)

TODO make iterator

func (*Store) QueryTransacted

func (store *Store) QueryTransacted(
	group *queries.Query,
	funcIter interfaces.FuncIter[*sku.Transacted],
) (err error)

TODO make iterator

func (*Store) QueryTransactedAsSkuType

func (store *Store) QueryTransactedAsSkuType(
	query *queries.Query,
	funcIter interfaces.FuncIter[sku.SkuType],
) (err error)

TODO make iterator

func (*Store) ReadCheckedOutFromTransacted

func (store *Store) ReadCheckedOutFromTransacted(
	repoId ids.RepoId,
	object *sku.Transacted,
) (checkedOut *sku.CheckedOut, err error)

func (*Store) ReadExternalAndMergeIfNecessary

func (store *Store) ReadExternalAndMergeIfNecessary(
	left, mother *sku.Transacted,
	options sku.CommitOptions,
) (err error)

func (*Store) ReadObjectTypeAndLockIfNecessary

func (store *Store) ReadObjectTypeAndLockIfNecessary(
	object *sku.Transacted,
) (typeObject *sku.Transacted, err error)

func (*Store) ReadOneInto

func (store *Store) ReadOneInto(
	objectId domain_interfaces.ObjectId,
	out *sku.Transacted,
) (err error)

TODO add support for cwd and sigil TODO simplify

func (*Store) ReadOneObjectId

func (store *Store) ReadOneObjectId(
	objectId domain_interfaces.ObjectId,
) (object *sku.Transacted, err error)

TODO https://github.com/amarbel-llc/dodder/issues/27 Transition to context-based panic/cancel semantics

func (*Store) ReadPrimitiveQuery

func (store *Store) ReadPrimitiveQuery(
	query sku.PrimitiveQueryGroup,
	funcIter interfaces.FuncIter[*sku.Transacted],
) (err error)

func (*Store) ReadTransactedFromObjectId

func (store *Store) ReadTransactedFromObjectId(
	objectId domain_interfaces.ObjectId,
) (object *sku.Transacted, err error)

func (*Store) ReadTypeObject

func (store *Store) ReadTypeObject(
	typeLock objects.TypeLock,
) (typeObject *sku.Transacted, err error)

func (*Store) Reindex

func (store *Store) Reindex(context interfaces.ActiveContext) (err error)

TODO-P2 add support for quiet reindexing

func (*Store) ResetIndexes

func (store *Store) ResetIndexes() (err error)

func (*Store) RevertTo

func (store *Store) RevertTo(
	revertId RevertId,
) (err error)

func (*Store) RunMergeTool

func (store *Store) RunMergeTool(
	conflicted sku.Conflicted,
) (err error)

func (*Store) SaveBlob

func (store *Store) SaveBlob(el sku.ExternalLike) (err error)

func (*Store) SetUIDelegate

func (store *Store) SetUIDelegate(ud sku.UIStorePrinters)

func (*Store) TryFormatHook

func (store *Store) TryFormatHook(
	object *sku.Transacted,
) (err error)

func (*Store) UpdateCheckoutFromCheckedOut

func (store *Store) UpdateCheckoutFromCheckedOut(
	options checkout_options.OptionsWithoutMode,
	col sku.SkuType,
) (err error)

func (*Store) UpdateKonfig

func (store *Store) UpdateKonfig(
	blobId mad_domain_interfaces.MarklId,
) (kt *sku.Transacted, err error)

func (*Store) UpdateTransactedFromBlobs

func (store *Store) UpdateTransactedFromBlobs(
	co *sku.CheckedOut,
) (err error)

func (*Store) UpdateTransactedWithExternal

func (store *Store) UpdateTransactedWithExternal(
	repoId ids.RepoId,
	z *sku.Transacted,
) (err error)

Jump to

Keyboard shortcuts

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