All checks were successful
Test / Create distribution (push) Successful in 34s
Test / Sandbox (push) Successful in 2m13s
Test / Hakurei (push) Successful in 3m6s
Test / Hpkg (push) Successful in 4m2s
Test / Sandbox (race detector) (push) Successful in 4m5s
Test / Hakurei (race detector) (push) Successful in 4m51s
Test / Flake checks (push) Successful in 1m30s
This is now part of the hst API. This change also improves identifier generation and serialisation. Signed-off-by: Ophestra <cat@gensokyo.uk>
34 lines
1.0 KiB
Go
34 lines
1.0 KiB
Go
// Package state provides cross-process state tracking for hakurei container instances.
|
|
package state
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"hakurei.app/hst"
|
|
)
|
|
|
|
// ErrNoConfig is returned by [Cursor] when used with a nil [hst.Config].
|
|
var ErrNoConfig = errors.New("state does not contain config")
|
|
|
|
type Store interface {
|
|
// Do calls f exactly once and ensures store exclusivity until f returns.
|
|
// Returns whether f is called and any errors during the locking process.
|
|
// Cursor provided to f becomes invalid as soon as f returns.
|
|
Do(identity int, f func(c Cursor)) (ok bool, err error)
|
|
|
|
// List queries the store and returns a list of identities known to the store.
|
|
// Note that some or all returned identities might not have any active apps.
|
|
List() (identities []int, err error)
|
|
|
|
// Close releases any resources held by Store.
|
|
Close() error
|
|
}
|
|
|
|
// Cursor provides access to the store of an identity.
|
|
type Cursor interface {
|
|
Save(state *hst.State) error
|
|
Destroy(id hst.ID) error
|
|
Load() (map[hst.ID]*hst.State, error)
|
|
Len() (int, error)
|
|
}
|