store

package
v0.0.0-...-32d88a2 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2024 License: MIT Imports: 45 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrNeedsMerge = errors.NewNormal("needs merge")

Functions

This section is empty.

Types

type AbbrStore 

type AbbrStore interface {
	ZettelId() AbbrStoreGeneric[ids.ZettelId, *ids.ZettelId]
	Shas() AbbrStoreGeneric[sha.Sha, *sha.Sha]

	AddObjectToAbbreviationStore(*sku.Transacted) error
	GetAbbr() ids.Abbr

	errors.Flusher
}

TODO-P4 make generic to just ObjectIds

type AbbrStoreCompleteGeneric 

type AbbrStoreCompleteGeneric[V any, VPtr interfaces.Ptr[V]] interface {
	AbbrStoreGeneric[V, VPtr]
	AbbrStoreMutableGeneric[V, VPtr]
}

type AbbrStoreGeneric 

type AbbrStoreGeneric[V any, VPtr interfaces.Ptr[V]] interface {
	AbbrStorePresenceGeneric[V]
	ExpandStringString(string) (string, error)
	ExpandString(string) (VPtr, error)
	Expand(VPtr) (VPtr, error)
	Abbreviate(ids.Abbreviatable) (string, error)
}

type AbbrStoreMutableGeneric 

type AbbrStoreMutableGeneric[V any, VPtr interfaces.Ptr[V]] interface {
	Add(VPtr) error
}

type AbbrStorePresenceGeneric 

type AbbrStorePresenceGeneric[V any] interface {
	Exists([3]string) error
}

type BlobCopyResult 

type BlobCopyResult struct {
	*sku.Transacted
	N int64
}

type Importer 

type Importer struct {
	*Store
	RemoteBlobStore    dir_layout.BlobStore
	BlobCopierDelegate interfaces.FuncIter[BlobCopyResult]
	ErrPrinter         interfaces.FuncIter[*sku.CheckedOut]
}

func (Importer) Import 

func (s Importer) Import(
	external *sku.Transacted,
) (co *sku.CheckedOut, err error)

type RevertId 

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

type Store 

type Store struct {
	Abbr 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.Group,
	f interfaces.FuncIter[sku.SkuType],
) (err error)

func (*Store) CreateOrUpdate 

func (s *Store) CreateOrUpdate(
	in sku.ExternalLike,
	mode object_mode.Mode,
) (err error)

func (*Store) CreateOrUpdateBlobSha 

func (s *Store) CreateOrUpdateBlobSha(
	k ids.IdLike,
	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() AbbrStore

func (*Store) GetBlobStore 

func (s *Store) GetBlobStore() *blob_store.VersionedStores

func (*Store) GetBrowserStore 

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

func (*Store) GetConfig 

func (s *Store) GetConfig() *config.Compiled

func (*Store) GetConfigBlobFormat 

func (s *Store) GetConfigBlobFormat() blob_store.Format2[mutable_config_blobs.Blob]

func (*Store) GetDirectoryLayout 

func (s *Store) GetDirectoryLayout() dir_layout.DirLayout

func (*Store) GetEnnui 

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

func (*Store) GetInventoryListStore 

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

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

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

func (*Store) Initialize 

func (c *Store) Initialize(
	flags *flag.FlagSet,
	k *config.Compiled,
	st dir_layout.DirLayout,
	pmf object_inventory_format.Format,
	t ids.Tai,
	luaVMPoolBuilder *lua.VMPoolBuilder,
	qb *query.Builder,
	options object_inventory_format.Options,
	box *box_format.BoxTransacted,
	blobStore *blob_store.VersionedStores,
) (err error)

func (*Store) MakeBlobShaBytesMap 

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

func (*Store) MakeLuaVMPoolV1 

func (u *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 (u *Store) MakeLuaVMPoolWithReader(
	selbst *sku.Transacted,
	r io.Reader,
) (vp sku.LuaVMPoolV1, err error)

func (*Store) MakeQueryExecutor 

func (s *Store) MakeQueryExecutor(
	qg *query.Group,
) (e query.Executor, err error)

func (*Store) MakeQueryExecutorPrimitive 

func (s *Store) MakeQueryExecutorPrimitive(
	qg sku.PrimitiveQueryGroup,
) (e query.ExecutorPrimitive, err error)

func (*Store) MergeCheckedOutIfNecessary 

func (s *Store) MergeCheckedOutIfNecessary(
	co *sku.CheckedOut,
) (commitOptions sku.CommitOptions, err error)

func (*Store) MergeConflicted 

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

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

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

func (*Store) QuerySkuType 

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

func (*Store) QueryTransacted 

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

func (*Store) QueryTransactedAsSkuType 

func (s *Store) QueryTransactedAsSkuType(
	qg *query.Group,
	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) ReadOneInto 

func (s *Store) ReadOneInto(
	k1 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) 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(
	tm 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 UIDelegate)

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)

type UIDelegate 

type UIDelegate struct {
	TransactedNew       interfaces.FuncIter[*sku.Transacted]
	TransactedUpdated   interfaces.FuncIter[*sku.Transacted]
	TransactedUnchanged interfaces.FuncIter[*sku.Transacted]

	CheckedOutCheckedOut interfaces.FuncIter[sku.SkuType]
	CheckedOutChanged    interfaces.FuncIter[sku.SkuType]
}

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.