wstore

package

v0.12.2-beta.4 Latest Latest Go to latest Published: Nov 4, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/wavetermdev/waveterm

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func DBDelete(ctx context.Context, otype string, id string) error
func DBExistsORef(ctx context.Context, oref waveobj.ORef) (bool, error)
func DBFindTabForBlockId(ctx context.Context, blockId string) (string, error)
func DBFindWindowForWorkspaceId(ctx context.Context, workspaceId string) (string, error)
func DBFindWorkspaceForTabId(ctx context.Context, tabId string) (string, error)
func DBGet[T waveobj.WaveObj](ctx context.Context, id string) (T, error)
func DBGetAllOIDsByType(ctx context.Context, otype string) ([]string, error)
func DBGetAllObjsByType[T waveobj.WaveObj](ctx context.Context, otype string) ([]T, error)
func DBGetBlockViewCounts(ctx context.Context) (map[string]int, error)
func DBGetCount[T waveobj.WaveObj](ctx context.Context) (int, error)
func DBGetORef(ctx context.Context, oref waveobj.ORef) (waveobj.WaveObj, error)
func DBGetSingleton[T waveobj.WaveObj](ctx context.Context) (T, error)
func DBGetSingletonByType(ctx context.Context, otype string) (waveobj.WaveObj, error)
func DBGetWSCounts(ctx context.Context) (int, int, error)
func DBInsert(ctx context.Context, val waveobj.WaveObj) error
func DBMustGet[T waveobj.WaveObj](ctx context.Context, id string) (T, error)
func DBResolveEasyOID(ctx context.Context, oid string) (*waveobj.ORef, error)
func DBSelectMap[T waveobj.WaveObj](ctx context.Context, ids []string) (map[string]T, error)
func DBSelectORefs(ctx context.Context, orefs []waveobj.ORef) ([]waveobj.WaveObj, error)
func DBUpdate(ctx context.Context, val waveobj.WaveObj) error
func DeleteRTInfo(oref waveobj.ORef)
func GetDBName() string
func GetOldDBName() string
func GetRTInfo(oref waveobj.ORef) *waveobj.ObjRTInfo
func InitWStore() error
func MakeDB(ctx context.Context) (*sqlx.DB, error)
func MakeOldDB(ctx context.Context) (*sqlx.DB, error)
func MoveBlockToTab(ctx context.Context, currentTabId string, newTabId string, blockId string) error
func ReplaceOldHistory(ctx context.Context, hist []*OldHistoryType) error
func SetRTInfo(oref waveobj.ORef, info map[string]any)
func TryMigrateOldHistory() error
func UpdateObjectMeta(ctx context.Context, oref waveobj.ORef, meta waveobj.MetaMapType, ...) error
func UpdateTabName(ctx context.Context, tabId, name string) error
func WithTx(ctx context.Context, fn func(tx *TxWrap) error) (rtnErr error)
func WithTxRtn[RT any](ctx context.Context, fn func(tx *TxWrap) (RT, error)) (rtnVal RT, rtnErr error)
type OldHistoryType
- func GetAllOldHistory() ([]*OldHistoryType, error)
type TxWrap

Constants ¶

View Source

const OldDBName = "~/.waveterm/waveterm.db"

View Source

const WStoreDBName = "waveterm.db"

Variables ¶

View Source

var ErrNotFound = fmt.Errorf("not found")

Functions ¶

func DBDelete ¶

func DBDelete(ctx context.Context, otype string, id string) error

func DBExistsORef ¶

func DBExistsORef(ctx context.Context, oref waveobj.ORef) (bool, error)

func DBFindTabForBlockId ¶

func DBFindTabForBlockId(ctx context.Context, blockId string) (string, error)

func DBFindWindowForWorkspaceId ¶ added in v0.10.0

func DBFindWindowForWorkspaceId(ctx context.Context, workspaceId string) (string, error)

func DBFindWorkspaceForTabId ¶ added in v0.9.0

func DBFindWorkspaceForTabId(ctx context.Context, tabId string) (string, error)

func DBGet ¶

func DBGet[T waveobj.WaveObj](ctx context.Context, id string) (T, error)

func DBGetAllOIDsByType ¶ added in v0.10.0

func DBGetAllOIDsByType(ctx context.Context, otype string) ([]string, error)

func DBGetAllObjsByType ¶ added in v0.10.0

func DBGetAllObjsByType[T waveobj.WaveObj](ctx context.Context, otype string) ([]T, error)

func DBGetBlockViewCounts ¶ added in v0.10.0

func DBGetBlockViewCounts(ctx context.Context) (map[string]int, error)

func DBGetCount ¶

func DBGetCount[T waveobj.WaveObj](ctx context.Context) (int, error)

func DBGetORef ¶

func DBGetORef(ctx context.Context, oref waveobj.ORef) (waveobj.WaveObj, error)

func DBGetSingleton ¶

func DBGetSingleton[T waveobj.WaveObj](ctx context.Context) (T, error)

func DBGetSingletonByType ¶

func DBGetSingletonByType(ctx context.Context, otype string) (waveobj.WaveObj, error)

func DBGetWSCounts ¶ added in v0.10.0

func DBGetWSCounts(ctx context.Context) (int, int, error)

returns (num named workespaces, num total workspaces, error)

func DBInsert ¶

func DBInsert(ctx context.Context, val waveobj.WaveObj) error

func DBMustGet ¶

func DBMustGet[T waveobj.WaveObj](ctx context.Context, id string) (T, error)

func DBResolveEasyOID ¶

func DBResolveEasyOID(ctx context.Context, oid string) (*waveobj.ORef, error)

func DBSelectMap ¶

func DBSelectMap[T waveobj.WaveObj](ctx context.Context, ids []string) (map[string]T, error)

func DBSelectORefs ¶

func DBSelectORefs(ctx context.Context, orefs []waveobj.ORef) ([]waveobj.WaveObj, error)

func DBUpdate ¶

func DBUpdate(ctx context.Context, val waveobj.WaveObj) error

func DeleteRTInfo ¶ added in v0.12.2

func DeleteRTInfo(oref waveobj.ORef)

DeleteRTInfo removes the ObjRTInfo for the given ORef

func GetDBName ¶

func GetDBName() string

func GetOldDBName ¶

func GetOldDBName() string

func GetRTInfo ¶ added in v0.12.2

func GetRTInfo(oref waveobj.ORef) *waveobj.ObjRTInfo

GetRTInfo returns the ObjRTInfo for the given ORef, or nil if not found

func InitWStore ¶

func InitWStore() error

func MakeDB ¶

func MakeDB(ctx context.Context) (*sqlx.DB, error)

func MakeOldDB ¶

func MakeOldDB(ctx context.Context) (*sqlx.DB, error)

func MoveBlockToTab ¶

func MoveBlockToTab(ctx context.Context, currentTabId string, newTabId string, blockId string) error

func ReplaceOldHistory ¶

func ReplaceOldHistory(ctx context.Context, hist []*OldHistoryType) error

func SetRTInfo ¶ added in v0.12.2

func SetRTInfo(oref waveobj.ORef, info map[string]any)

SetRTInfo merges the provided info map into the ObjRTInfo for the given ORef. Only updates fields that exist in the ObjRTInfo struct. Removes fields that have nil values.

func TryMigrateOldHistory ¶

func TryMigrateOldHistory() error

func UpdateObjectMeta ¶

func UpdateObjectMeta(ctx context.Context, oref waveobj.ORef, meta waveobj.MetaMapType, mergeSpecial bool) error

func UpdateTabName ¶

func UpdateTabName(ctx context.Context, tabId, name string) error

func WithTx ¶

func WithTx(ctx context.Context, fn func(tx *TxWrap) error) (rtnErr error)

func WithTxRtn ¶

func WithTxRtn[RT any](ctx context.Context, fn func(tx *TxWrap) (RT, error)) (rtnVal RT, rtnErr error)

Types ¶

type OldHistoryType ¶

type OldHistoryType struct {
	HistoryId  string
	Ts         int64
	RemoteName string
	HadError   bool
	CmdStr     string
	ExitCode   int
	DurationMs int64
}

func GetAllOldHistory ¶

func GetAllOldHistory() ([]*OldHistoryType, error)

type TxWrap ¶

type TxWrap = txwrap.TxWrap

Source Files ¶

View all Source files

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