store

package
v0.0.0-...-2af310e Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2025 License: MIT Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type RevertId 

type RevertId struct {
	*ids.ObjectId
	ids.Tai
}

type Store 

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

func (*Store) CheckoutOne 

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

func (*Store) CheckoutQuery 

func (s *Store) CheckoutQuery(
	options checkout_options.Options,
	qg *query.Query,
	f interfaces.FuncIter[sku.SkuType],
) (err error)

func (*Store) Commit 

func (s *Store) Commit(
	el sku.ExternalLike,
	o sku.CommitOptions,
) (err error)

TODO add RealizeAndOrStore result

func (*Store) CreateOrUpdate 

func (s *Store) CreateOrUpdate(
	in sku.ExternalLike,
	storeOptions sku.StoreOptions,
) (err error)

func (*Store) CreateOrUpdateBlobSha 

func (s *Store) CreateOrUpdateBlobSha(
	k interfaces.ObjectId,
	sh interfaces.Sha,
) (t *sku.Transacted, err error)

func (*Store) CreateOrUpdateCheckedOut 

func (s *Store) CreateOrUpdateCheckedOut(
	col sku.SkuType,
	updateCheckout bool,
) (err error)

func (*Store) DeleteCheckedOut 

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

func (*Store) Flush 

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

func (*Store) FlushInventoryList 

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

func (*Store) GetAbbrStore 

func (s *Store) GetAbbrStore() sku.AbbrStore

func (*Store) GetBrowserStore 

func (u *Store) GetBrowserStore() *external_store.Store

func (*Store) GetConfig 

func (s *Store) GetConfig() store_config.Store

func (*Store) GetConfigBlobFormat 

func (s *Store) GetConfigBlobFormat() interfaces.Format[config_mutable_blobs.Blob]

func (*Store) GetEnnui 

func (s *Store) GetEnnui() object_probe_index.Index

func (*Store) GetEnvRepo 

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

func (*Store) GetInventoryListStore 

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

func (*Store) GetObjectStore 

func (s *Store) GetObjectStore() sku.ObjectStore

func (*Store) GetPersistentMetadataFormat 

func (s *Store) GetPersistentMetadataFormat() object_inventory_format.Format

func (*Store) GetProtoZettel 

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

func (*Store) GetStoreFS 

func (s *Store) GetStoreFS() *store_fs.Store

func (*Store) GetStreamIndex 

func (s *Store) GetStreamIndex() *stream_index.Index

func (*Store) GetTai 

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

func (*Store) GetTime 

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

func (*Store) GetTypedBlobStore 

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

func (*Store) GetZettelIdIndex 

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

func (*Store) Initialize 

func (c *Store) Initialize(
	config store_config.StoreMutable,
	envRepo env_repo.Env,
	envWorkspace env_workspace.Env,
	pmf object_inventory_format.Format,
	sunrise ids.Tai,
	envLua env_lua.Env,
	queryBuilder *query.Builder,
	options object_inventory_format.Options,
	box *box_format.BoxTransacted,
	typedBlobStore typed_blob_store.Stores,
	dormantIndex *dormant_index.Index,
	abbrStore sku.AbbrStore,
) (err error)

func (*Store) MakeBlobShaBytesMap 

func (s *Store) MakeBlobShaBytesMap() (blobShaBytes map[sha.Bytes][]string, err error)

func (*Store) MakeImporter 

func (store *Store) MakeImporter(
	options sku.ImporterOptions,
	storeOptions sku.StoreOptions,
) sku.Importer

func (*Store) MakeLuaVMPoolV1 

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

func (*Store) MakeLuaVMPoolV1WithSku 

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

func (*Store) MakeLuaVMPoolWithReader 

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

func (*Store) MakeSupplies 

func (s *Store) MakeSupplies() (es external_store.Supplies)

func (*Store) MergeConflicted 

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

TODO make this configgable

func (*Store) Open 

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

func (*Store) PutCheckedOutLike 

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

TODO remove entirely

func (*Store) QueryExactlyOne 

func (store *Store) QueryExactlyOne(
	queryGroup *query.Query,
) (sk *sku.Transacted, err error)

func (*Store) QueryExactlyOneExternal 

func (store *Store) QueryExactlyOneExternal(
	queryGroup *query.Query,
) (sk *sku.Transacted, err error)

func (*Store) QueryPrimitive 

func (s *Store) QueryPrimitive(
	qg sku.PrimitiveQueryGroup,
	f interfaces.FuncIter[*sku.Transacted],
) (err error)

func (*Store) QuerySkuType 

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

func (*Store) QueryTransacted 

func (s *Store) QueryTransacted(
	qg *query.Query,
	f interfaces.FuncIter[*sku.Transacted],
) (err error)

func (*Store) QueryTransactedAsSkuType 

func (s *Store) QueryTransactedAsSkuType(
	qg *query.Query,
	f interfaces.FuncIter[sku.SkuType],
) (err error)

func (*Store) ReadCheckedOutFromTransacted 

func (s *Store) ReadCheckedOutFromTransacted(
	repoId ids.RepoId,
	sk *sku.Transacted,
) (co *sku.CheckedOut, err error)

func (*Store) ReadExternalAndMergeIfNecessary 

func (s *Store) ReadExternalAndMergeIfNecessary(
	left, parent *sku.Transacted,
	options sku.CommitOptions,
) (err error)

func (*Store) ReadOneInto 

func (s *Store) ReadOneInto(
	objectId interfaces.ObjectId,
	out *sku.Transacted,
) (err error)

TODO add support for cwd and sigil TODO simplify

func (*Store) ReadOneObjectId 

func (s *Store) ReadOneObjectId(
	k interfaces.ObjectId,
) (sk *sku.Transacted, err error)

func (*Store) ReadPrimitiveQuery 

func (s *Store) ReadPrimitiveQuery(
	qg sku.PrimitiveQueryGroup,
	w interfaces.FuncIter[*sku.Transacted],
) (err error)

func (*Store) ReadTransactedFromObjectId 

func (s *Store) ReadTransactedFromObjectId(
	k1 interfaces.ObjectId,
) (sk1 *sku.Transacted, err error)

func (*Store) Reindex 

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

TODO-P2 add support for quiet reindexing

func (*Store) ResetIndexes 

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

func (*Store) RevertTo 

func (s *Store) RevertTo(
	ri RevertId,
) (err error)

func (*Store) RunMergeTool 

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

func (*Store) SaveBlob 

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

func (*Store) SetExternalStores 

func (s *Store) SetExternalStores(
	stores map[ids.RepoId]*external_store.Store,
) (err error)

func (*Store) SetUIDelegate 

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

func (*Store) TryFormatHook 

func (s *Store) TryFormatHook(
	kinder *sku.Transacted,
) (err error)

func (*Store) UpdateCheckoutFromCheckedOut 

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

func (*Store) UpdateKonfig 

func (s *Store) UpdateKonfig(
	sh interfaces.Sha,
) (kt *sku.Transacted, err error)

func (*Store) UpdateTransactedFromBlobs 

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

func (*Store) UpdateTransactedWithExternal 

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

Source Files

View all Source files

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.