store

package
v0.2.13 Latest Latest
Warning

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

 Go to latest Published: Jul 9, 2026 License: MIT Imports: 57 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) IsInlineType added in v0.2.3 

func (store *Store) IsInlineType(tipe ids.Type) bool

IsInlineType resolves whether objects of the given type render their blob inline (i.e. the type's blob has binary = false). Resolution is deterministic: the type id is looked up to its latest type object via the signature-backed stream index, then the type blob is parsed and its binary flag read. This replaces the former approximate scheme (a never-populated InlineTypes set plus an ids.IsBuiltin name guess) which silently returned false for user types like !md on read-only commands.

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) 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)

Source Files

  • accessors.go
  • create.go
  • dormancy_and_tags.go
  • edge_explorer.go
  • field_reader.go
  • field_writer.go
  • flush.go
  • hooks.go
  • lua.go
  • lua_preload.go
  • main.go
  • merging.go
  • mutating.go
  • pools.go
  • query.go
  • reader.go
  • reference_discovery.go
  • reindex.go
  • stores.go
  • validate.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.