wstore

package

v0.9.3 Latest Latest Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 17 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 CreateBlock(ctx context.Context, tabId string, blockDef *waveobj.BlockDef, ...) (*waveobj.Block, error)
func CreateSubBlock(ctx context.Context, parentBlockId string, blockDef *waveobj.BlockDef) (*waveobj.Block, error)
func CreateTab(ctx context.Context, workspaceId string, name string) (*waveobj.Tab, error)
func CreateWorkspace(ctx context.Context) (*waveobj.Workspace, error)
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 DBFindWindowForTabId(ctx context.Context, tabId 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 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 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 DeleteBlock(ctx context.Context, blockId string) error
func DeleteTab(ctx context.Context, workspaceId string, tabId string) error
func GetDBName() string
func GetOldDBName() string
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 SetActiveTab(ctx context.Context, windowId string, tabId string) error
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 UpdateWorkspaceTabIds(ctx context.Context, workspaceId string, tabIds []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 CreateBlock ¶

func CreateBlock(ctx context.Context, tabId string, blockDef *waveobj.BlockDef, rtOpts *waveobj.RuntimeOpts) (*waveobj.Block, error)

func CreateSubBlock ¶ added in v0.9.0

func CreateSubBlock(ctx context.Context, parentBlockId string, blockDef *waveobj.BlockDef) (*waveobj.Block, error)

func CreateTab ¶

func CreateTab(ctx context.Context, workspaceId string, name string) (*waveobj.Tab, error)

func CreateWorkspace ¶

func CreateWorkspace(ctx context.Context) (*waveobj.Workspace, error)

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 DBFindWindowForTabId ¶

func DBFindWindowForTabId(ctx context.Context, tabId 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 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 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 DeleteBlock ¶

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

func DeleteTab ¶

func DeleteTab(ctx context.Context, workspaceId string, tabId string) error

must delete all blocks individually first also deletes LayoutState

func GetDBName ¶

func GetDBName() string

func GetOldDBName ¶

func GetOldDBName() string

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 SetActiveTab ¶

func SetActiveTab(ctx context.Context, windowId string, tabId string) error

func TryMigrateOldHistory ¶

func TryMigrateOldHistory() error

func UpdateObjectMeta ¶

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

func UpdateTabName ¶

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

func UpdateWorkspaceTabIds ¶

func UpdateWorkspaceTabIds(ctx context.Context, workspaceId string, tabIds []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