Documentation
¶
Index ¶
- Constants
- func ValidTransition(from, to string) bool
- type IdleWatcher
- type Sandbox
- type Store
- func (s *Store) Create(...) (*Sandbox, error)
- func (s *Store) Delete(id string) error
- func (s *Store) Get(id string) (*Sandbox, bool)
- func (s *Store) GetByShortID(shortID string) (*Sandbox, bool)
- func (s *Store) GetPodIP(sandboxID string) string
- func (s *Store) ListByWorkspace(workspaceID string) []*Sandbox
- func (s *Store) Resolve(idOrShortID string) (*Sandbox, bool)
- func (s *Store) UpdateActivity(id string)
- func (s *Store) UpdateStatus(id, status string) error
Constants ¶
const ( StatusCreating = "creating" StatusRunning = "running" StatusPausing = "pausing" StatusPaused = "paused" StatusResuming = "resuming" StatusDeleting = "deleting" StatusOffline = "offline" )
Status constants for sandbox lifecycle.
Variables ¶
This section is empty.
Functions ¶
func ValidTransition ¶
ValidTransition checks whether a status transition is allowed.
Types ¶
type IdleWatcher ¶
type IdleWatcher struct {
// contains filtered or unexported fields
}
IdleWatcher monitors sandboxes and auto-pauses idle ones.
func NewIdleWatcher ¶
func NewIdleWatcher(database *db.DB, procMgr process.Manager, store *Store, getTimeout func() time.Duration) *IdleWatcher
NewIdleWatcher creates a new idle sandbox watcher. The getTimeout function is called each check cycle to resolve the current idle timeout. If it returns 0, idle checking is skipped (disabled).
func (*IdleWatcher) SetOnPrePause ¶ added in v0.26.0
func (w *IdleWatcher) SetOnPrePause(fn func(sandboxID string))
SetOnPrePause sets a callback that is invoked before a sandbox is paused. Used to stop WeChat bridge pollers before the Pod goes away.
func (*IdleWatcher) Start ¶
func (w *IdleWatcher) Start()
Start begins the idle check loop. Call Stop() to terminate.
type Sandbox ¶
type Sandbox struct {
ID string `json:"id"`
ShortID string `json:"short_id,omitempty"`
WorkspaceID string `json:"workspace_id"`
Name string `json:"name"`
Type string `json:"type"`
Status string `json:"status"`
SandboxName string `json:"sandbox_name,omitempty"`
PodIP string `json:"pod_ip,omitempty"`
ProxyToken string `json:"-"`
OpencodeToken string `json:"-"`
OpenclawToken string `json:"-"`
NanoclawBridgeSecret string `json:"-"`
TunnelToken string `json:"-"`
CreatedAt time.Time `json:"created_at"`
LastActivityAt *time.Time `json:"last_activity_at,omitempty"`
PausedAt *time.Time `json:"paused_at,omitempty"`
IsLocal bool `json:"is_local"`
LastHeartbeatAt *time.Time `json:"last_heartbeat_at,omitempty"`
CPU int `json:"cpu,omitempty"`
Memory int64 `json:"memory,omitempty"`
IdleTimeout *int `json:"idle_timeout,omitempty"`
Metadata map[string]interface{} `json:"metadata,omitempty"`
}
Sandbox represents a sandbox with its current state.
func (*Sandbox) MetadataString ¶ added in v0.28.1
MetadataString returns a metadata value as a string, or "" if not set.
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store manages sandboxes via PostgreSQL.
func (*Store) Create ¶
func (s *Store) Create(id, workspaceID, name, sandboxType, sandboxName, opencodeToken, proxyToken, openclawToken, shortID string, cpu int, memory int64, idleTimeout *int, metadata map[string]interface{}) (*Sandbox, error)
Create inserts a new sandbox into the DB with 'creating' status.
func (*Store) GetByShortID ¶
GetByShortID returns a sandbox looked up by its short ID.
func (*Store) GetPodIP ¶ added in v0.26.0
GetPodIP returns the current PodIP for a sandbox, or "" if not found/not running. Implements the weixin.SandboxResolver interface.
func (*Store) ListByWorkspace ¶
ListByWorkspace returns all sandboxes for a workspace from the database.
func (*Store) Resolve ¶
Resolve finds a sandbox by either short ID or UUID. UUIDs are 36 chars; short IDs are 16 chars or fewer. We use 20 as the threshold.
func (*Store) UpdateActivity ¶
UpdateActivity records user activity on a sandbox.
func (*Store) UpdateStatus ¶
UpdateStatus transitions a sandbox to a new status.
Source Files