db

May 20, 2026

Changes in this version

type DB

+ func (db *DB) UpdateCodexBrowserSessionMeta(ctx context.Context, sessionID, clientUA, codexVersion, osStr string) error

May 20, 2026

Changes in this version

+ type CodexBrowserSession struct

+ ClientIP string

+ ClientUA string

+ CodexVersion string

+ ConnectedAt time.Time

+ DisconnectedAt *time.Time

+ ID string

+ OS string

+ TokenID string

type DB

+ func (db *DB) CloseCodexBrowserSession(ctx context.Context, id string) error

+ func (db *DB) CountOpenCodexBrowserSessions(ctx context.Context, tokenID string) (int, error)

+ func (db *DB) CreateCodexBrowserSession(ctx context.Context, s CodexBrowserSession) error

+ func (db *DB) LatestCodexBrowserSession(ctx context.Context, tokenID string) (*CodexBrowserSession, error)

+ func (db *DB) SweepStaleCodexBrowserSessions(ctx context.Context, olderThan time.Time) (int64, error)

May 19, 2026

Changes in this version

type AgentSession

+ CodexThreadID *string

type DB

+ func (db *DB) SetSessionCodexThreadID(ctx context.Context, sessionID string, threadID *string) error

May 18, 2026

Changes in this version

type DB

+ func (db *DB) InsertOperation(o Operation) error

+ func (db *DB) ListOperations(f OperationFilter) ([]Operation, error)

+ func (db *DB) PruneOperationsOlderThan(cutoff time.Time) (int64, error)

+ type Operation struct

+ Arguments json.RawMessage

+ ArgumentsMeta json.RawMessage

+ CellID *string

+ CompletedAt time.Time

+ DurationMs int32

+ EnvID string

+ ID string

+ IsError bool

+ NotebookPath *string

+ RequestID *string

+ ResultMeta json.RawMessage

+ ResultSummary *string

+ Source string

+ StartedAt time.Time

+ ThreadID *string

+ Tool string

+ UserID *string

+ WorkspaceID string

+ type OperationFilter struct

+ EnvID string

+ ID string

+ IsError *bool

+ Limit int

+ Since *time.Time

+ Source string

+ Tool string

+ WorkspaceID string

May 15, 2026

Changes in this version

+ type CodexToken struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ ID string

+ LastUsedAt *time.Time

+ Name string

+ RevokedAt *time.Time

+ TokenHash string

+ UserID string

+ WorkspaceID string

type DB

+ func (db *DB) CreateCodexToken(ctx context.Context, t CodexToken) error

+ func (db *DB) GetCodexToken(ctx context.Context, id string) (*CodexToken, error)

+ func (db *DB) ListCodexTokensForWorkspace(ctx context.Context, workspaceID string, includeRevoked bool) ([]CodexToken, error)

+ func (db *DB) RevokeCodexToken(ctx context.Context, id string) error

+ func (db *DB) TouchCodexToken(ctx context.Context, id string) error

May 3, 2026

Changes in this version

type AgentSession

+ ActiveTurnID *string

+ ChannelType string

+ CreatorUserID *string

+ PermissionMode string

+ PermissionResponder *string

+ PreferredExecutorID *string

+ PreferredModel *string

+ ResponderAttachedAt *time.Time

+ type AttachResult struct

+ PreviousPreferred string

+ PreviousResponder string

+ type CreateTUISessionParams struct

+ CreatorUserID string

+ ExternalID string

+ ID string

+ PermissionMode string

+ PreferredExecutorID string

+ PreferredModel string

+ Title string

+ WorkspaceID string

type DB

+ func (db *DB) AttachResponder(ctx context.Context, sessionID, executorID string, becomePreferred bool) (AttachResult, error)

+ func (db *DB) ClaimActiveTurn(ctx context.Context, sessionID, turnID string) (bool, error)

+ func (db *DB) ClearActiveTurn(ctx context.Context, sessionID, expectedTurnID string) error

+ func (db *DB) ClearResponder(ctx context.Context, sessionID string) error

+ func (db *DB) CreateAgentSessionTUI(ctx context.Context, p CreateTUISessionParams) error

+ func (db *DB) CreateSandboxProxyToken(token, sandboxID, workspaceID string) error

+ func (db *DB) GetActiveTurn(ctx context.Context, sessionID string) (string, error)

+ func (db *DB) GetAgentSessionEventsTail(sessionID string, n int) ([]AgentSessionEvent, error)

+ func (db *DB) GetOrCreateWorkspaceToken(workspaceID string) (string, error)

+ func (db *DB) GetProxyToken(token string) (*ProxyToken, error)

+ func (db *DB) ListSessionsByChannel(ctx context.Context, workspaceID, channelType, executorID string, limit int) ([]SessionListItem, error)

+ func (db *DB) ListStaleActiveTurns(ctx context.Context, cutoff time.Time) ([]StaleActiveTurn, error)

+ func (db *DB) ListStaleResponders(ctx context.Context, cutoff time.Time) ([]string, error)

+ type ProxyToken struct

+ SandboxID sql.NullString

+ Token string

+ TokenType ProxyTokenType

+ WorkspaceID string

+ type ProxyTokenType string

+ const ProxyTokenSandbox

+ const ProxyTokenWorkspace

+ type SessionListItem struct

+ ExternalID string

+ ID string

+ LastActivityAt time.Time

+ PermissionResponder *string

+ Title string

+ type StaleActiveTurn struct

+ SessionID string

+ TurnID string

May 2, 2026

Changes in this version

type DB

+ func (db *DB) UpdateIMChannelRoutingMode(channelID, mode string) error

Apr 17, 2026

Changes in this version

type AgentSession

+ IMChannelID *string

type DB

+ func (db *DB) GetSessionByExternalID(ctx context.Context, workspaceID, externalID string) (*AgentSession, error)

+ func (db *DB) SetSessionExternalID(ctx context.Context, sessionID, externalID string) error

+ func (db *DB) SetSessionIMChannel(ctx context.Context, sessionID, channelID string) error

type IMChannel

+ RoutingMode string

Apr 13, 2026

Changes in this version

type AgentInfo

+ Capabilities json.RawMessage

type DB

+ func (db *DB) UpsertAgentCardFromCapabilities(sandboxID, workspaceID, displayName string, cardJSON json.RawMessage) error

Apr 12, 2026

Changes in this version

+ type AgentInteraction struct

+ Action string

+ ActorID *string

+ CreatedAt time.Time

+ DetailJSON json.RawMessage

+ ID int64

+ TargetID string

+ TargetType string

+ WorkspaceID string

+ type AgentMessage struct

+ CreatedAt time.Time

+ FromID string

+ ID string

+ MsgType string

+ ReadAt sql.NullTime

+ Text string

+ ToID string

+ WorkspaceID string

+ type CredentialBinding struct

+ AuthBlob []byte

+ AuthType string

+ CreatedAt time.Time

+ DisplayName string

+ ID string

+ IsDefault bool

+ Kind string

+ PublicMeta json.RawMessage

+ ServerURL string

+ UpdatedAt time.Time

+ WorkspaceID string

+ type CredentialBindingMeta struct

+ AuthType string

+ CreatedAt time.Time

+ DisplayName string

+ ID string

+ IsDefault bool

+ Kind string

+ PublicMeta json.RawMessage

+ ServerURL string

+ UpdatedAt time.Time

+ WorkspaceID string

type DB

+ func (db *DB) CountCredentialBindings(workspaceID, kind string) (int, error)

+ func (db *DB) CreateCredentialBinding(b *CredentialBinding) error

+ func (db *DB) DeleteCredentialBinding(id string) error

+ func (db *DB) GetCredentialBinding(id string) (*CredentialBinding, error)

+ func (db *DB) ListCredentialBindings(workspaceID, kind string) ([]*CredentialBinding, error)

+ func (db *DB) ListCredentialBindingsMeta(workspaceID, kind string) ([]*CredentialBindingMeta, error)

+ func (db *DB) ListInteractions(workspaceID string, limit, offset int) ([]AgentInteraction, error)

+ func (db *DB) LogInteraction(i *AgentInteraction)

+ func (db *DB) ReadInbox(toID string, limit int) ([]AgentMessage, error)

+ func (db *DB) SendMessage(msg *AgentMessage) error

+ func (db *DB) SetCredentialBindingDefault(workspaceID, kind, id string) error

Apr 5, 2026

Changes in this version

type DB

+ func (db *DB) GetSandboxByAnyToken(token string) (*Sandbox, error)

Apr 4, 2026

Changes in this version

+ type AgentCard struct

+ AgentStatus string

+ AgentType string

+ CardJSON json.RawMessage

+ Description string

+ DisplayName string

+ SandboxID string

+ UpdatedAt time.Time

+ Version int

+ WorkspaceID string

+ type AgentSession struct

+ ArchivedAt sql.NullTime

+ CreatedAt time.Time

+ Epoch int

+ ID string

+ SandboxID string

+ Status string

+ Tags []string

+ Title string

+ UpdatedAt time.Time

+ WorkspaceID string

+ type AgentSessionEvent struct

+ CreatedAt time.Time

+ Ephemeral bool

+ Epoch int

+ EventID string

+ EventType string

+ ID int64

+ Payload json.RawMessage

+ SessionID string

+ Source string

+ type AgentSessionWorker struct

+ Epoch int

+ ExternalMetadata json.RawMessage

+ LastHeartbeatAt time.Time

+ RegisteredAt time.Time

+ RequiresActionDetails json.RawMessage

+ SessionID string

+ State string

+ type AgentTask struct

+ AcceptedAt sql.NullTime

+ CompletedAt sql.NullTime

+ CreatedAt time.Time

+ DelegationChain []string

+ FailureReason sql.NullString

+ ID string

+ NumTurns int

+ Prompt string

+ RequesterID sql.NullString

+ ResultJSON json.RawMessage

+ SessionID sql.NullString

+ Skill sql.NullString

+ Status string

+ SystemContext sql.NullString

+ TargetID string

+ TimeoutSeconds int

+ TotalCostUSD *float64

+ WorkspaceID string

type DB

+ func (db *DB) ArchiveAgentSession(id string) error

+ func (db *DB) BumpAgentSessionEpoch(id string) (int, error)

+ func (db *DB) CreateAgentSession(id, sandboxID, workspaceID, title string, tags []string) error

+ func (db *DB) CreateAgentTask(t *AgentTask) error

+ func (db *DB) DeleteAgentCard(sandboxID string) error

+ func (db *DB) FailAgentTask(id, reason string) error

+ func (db *DB) GetAgentCard(sandboxID string) (*AgentCard, error)

+ func (db *DB) GetAgentSession(id string) (*AgentSession, error)

+ func (db *DB) GetAgentSessionEpoch(id string) (int, error)

+ func (db *DB) GetAgentSessionEventsSince(sessionID string, sinceSeqNum int64, limit int) ([]AgentSessionEvent, error)

+ func (db *DB) GetAgentSessionInternalEventsSince(sessionID string, sinceID int64, limit int) ([]struct{ ... }, error)

+ func (db *DB) GetAgentSessionWorker(sessionID string, epoch int) (*AgentSessionWorker, error)

+ func (db *DB) GetAgentTask(id string) (*AgentTask, error)

+ func (db *DB) InsertAgentSessionEvents(sessionID string, events []AgentSessionEvent) ([]InsertedEvent, error)

+ func (db *DB) InsertAgentSessionInternalEvents(sessionID string, events []struct{ ... }) error

+ func (db *DB) ListAgentCardsByWorkspace(workspaceID string) ([]AgentCard, error)

+ func (db *DB) ListAgentTasksByWorkspace(workspaceID string, limit int) ([]AgentTask, error)

+ func (db *DB) ListPendingAgentTasksByTarget(targetID string, limit int) ([]AgentTask, error)

+ func (db *DB) MarkStaleAgentCardsOffline(threshold time.Duration) (int64, error)

+ func (db *DB) UpdateAgentCardStatus(sandboxID, status string) error

+ func (db *DB) UpdateAgentSessionWorkerHeartbeat(sessionID string, epoch int) error

+ func (db *DB) UpdateAgentSessionWorkerState(sessionID string, epoch int, state string, ...) error

+ func (db *DB) UpdateAgentTaskResult(id string, resultJSON json.RawMessage, totalCostUSD *float64, numTurns int) error

+ func (db *DB) UpdateAgentTaskStatus(id, status string) error

+ func (db *DB) UpsertAgentCard(card *AgentCard) error

+ func (db *DB) UpsertAgentSessionWorker(sessionID string, epoch int) error

+ type InsertedEvent struct

+ Event AgentSessionEvent

+ SeqNum int64

Apr 1, 2026

Changes in this version

type Sandbox

+ Metadata json.RawMessage

Mar 30, 2026

Changes in this version

type DB

+ func (db *DB) BindSandboxToChannel(sandboxID, channelID string) error

+ func (db *DB) CreateIMBinding(sandboxID, provider, botID, userID string) error

+ func (db *DB) CreateIMChannel(workspaceID, provider, botID, userID string) (string, error)

+ func (db *DB) DeleteIMBinding(sandboxID, provider, botID string) error

+ func (db *DB) DeleteIMChannel(channelID string) error

+ func (db *DB) GetActiveBindings(provider string) ([]*IMBinding, error)

+ func (db *DB) GetActiveBindingsForSandbox(sandboxID string) ([]*IMBinding, error)

+ func (db *DB) GetAllChannelMeta(channelID, userID string) (map[string]string, error)

+ func (db *DB) GetAllProviderMeta(sandboxID, provider, botID, userID string) (map[string]string, error)

+ func (db *DB) GetChannelMeta(channelID, userID, key string) (string, error)

+ func (db *DB) GetChannelRequireMention(channelID string) (bool, error)

+ func (db *DB) GetIMChannel(channelID string) (*IMChannel, error)

+ func (db *DB) GetIMChannelForSandbox(sandboxID string) (*IMChannel, error)

+ func (db *DB) GetIMCredentials(sandboxID, provider, botID string) (botToken, baseURL string, err error)

+ func (db *DB) GetProviderMeta(sandboxID, provider, botID, userID, key string) (string, error)

+ func (db *DB) GetSandboxForChannel(channelID string) (sandboxID, podIP, bridgeSecret string, err error)

+ func (db *DB) ListAllActiveChannels(provider string) ([]IMChannel, error)

+ func (db *DB) ListIMBindings(sandboxID, provider string) ([]*IMBinding, error)

+ func (db *DB) ListIMChannels(workspaceID string) ([]IMChannel, error)

+ func (db *DB) SaveIMChannelCredentials(channelID, botToken, baseURL string) error

+ func (db *DB) SaveIMCredentials(sandboxID, provider, botID, botToken, baseURL string) error

+ func (db *DB) UnbindSandboxFromChannel(sandboxID string) error

+ func (db *DB) UpdateCursor(sandboxID, provider, botID, cursor string) error

+ func (db *DB) UpdateIMChannelCursor(channelID, cursor string) error

+ func (db *DB) UpdateIMChannelSettings(channelID string, requireMention bool) error

+ func (db *DB) UpsertChannelMeta(channelID, userID, key, value string) error

+ func (db *DB) UpsertProviderMeta(sandboxID, provider, botID, userID, key, value string) error

+ type IMBinding struct

+ BaseURL string

+ BotID string

+ BotToken string

+ BoundAt time.Time

+ Cursor string

+ ID int

+ Provider string

+ SandboxID string

+ UserID string

+ type IMChannel struct

+ BaseURL string

+ BotID string

+ BotToken string

+ BoundAt time.Time

+ Cursor string

+ ID string

+ Provider string

+ RequireMention bool

+ UserID string

+ WorkspaceID string

Mar 25, 2026

Changes in this version

type DB

+ func (db *DB) GetBindingsWithBotToken() ([]*WeixinBinding, error)

+ func (db *DB) GetBotCredentials(sandboxID, botID string) (botToken, baseURL string, err error)

+ func (db *DB) GetContextToken(sandboxID, botID, userID string) (string, error)

+ func (db *DB) GetSandboxByBotID(botID string) (string, error)

+ func (db *DB) SaveBotCredentials(sandboxID, botID, botToken, baseURL string) error

+ func (db *DB) UpdateGetUpdatesBuf(sandboxID, botID, buf string) error

+ func (db *DB) UpdateSandboxNanoclawBridgeSecret(id, secret string) error

+ func (db *DB) UpsertContextToken(sandboxID, botID, userID, contextToken string) error

type Sandbox

+ NanoclawBridgeSecret sql.NullString

type WeixinBinding

+ BotToken string

+ GetUpdatesBuf string

+ ILinkBaseURL string

Mar 25, 2026

Changes in this version

type AdminWorkspaceInfo

+ OwnerEmail *string

Mar 23, 2026

Changes in this version

type DB

+ func (db *DB) CreateWeixinBinding(sandboxID, botID, userID string) error

+ func (db *DB) DeleteModelserverConnection(workspaceID string) error

+ func (db *DB) DeleteWorkspaceLLMConfig(workspaceID string) error

+ func (db *DB) GetModelserverConnection(workspaceID string) (*ModelserverConnection, error)

+ func (db *DB) GetWorkspaceLLMConfig(workspaceID string) (*WorkspaceLLMConfig, error)

+ func (db *DB) HasModelserverConnection(workspaceID string) (bool, error)

+ func (db *DB) ListWeixinBindings(sandboxID string) ([]*WeixinBinding, error)

+ func (db *DB) SetModelserverConnection(c *ModelserverConnection) error

+ func (db *DB) SetWorkspaceLLMConfig(workspaceID, baseURL, apiKey string, models []LLMModel) error

+ func (db *DB) UpdateModelserverTokens(workspaceID, accessToken, refreshToken string, expiresAt time.Time) error

+ type LLMModel struct

+ ID string

+ Name string

+ type ModelserverConnection struct

+ AccessToken string

+ CreatedAt time.Time

+ Models []LLMModel

+ ProjectID string

+ ProjectName string

+ RefreshToken string

+ TokenExpiresAt time.Time

+ UpdatedAt time.Time

+ UserID string

+ WorkspaceID string

+ type WeixinBinding struct

+ BotID string

+ BoundAt time.Time

+ ID int

+ SandboxID string

+ UserID string

+ type WorkspaceLLMConfig struct

+ APIKey string

+ BaseURL string

+ CreatedAt time.Time

+ Models []LLMModel

+ UpdatedAt time.Time

+ WorkspaceID string

Mar 10, 2026

Changes in this version

type AgentInfo

+ Workdir string

Mar 9, 2026

Changes in this version

+ type AdminWorkspaceInfo struct

+ OwnerID *string

+ OwnerName *string

+ OwnerPicture *string

+ OwnerUsername *string

+ SandboxCount int

type DB

+ func (db *DB) ListAllWorkspacesAdmin() ([]*AdminWorkspaceInfo, error)

Mar 6, 2026

Changes in this version

+ type AgentInfo struct

+ AgentVersion string

+ CPUCountLogical int

+ CPUInfo json.RawMessage

+ CPUModelName string

+ DiskFree int64

+ DiskInfo json.RawMessage

+ DiskTotal int64

+ HostInfo json.RawMessage

+ Hostname string

+ KernelArch string

+ MemoryInfo json.RawMessage

+ MemoryTotal int64

+ OS string

+ OpencodeVersion string

+ Platform string

+ PlatformVersion string

+ SandboxID string

+ UpdatedAt time.Time

type DB

+ func (db *DB) GetAgentInfo(sandboxID string) (*AgentInfo, error)

+ func (db *DB) UpdateSandboxName(id, name string) error

+ func (db *DB) UpdateWorkspaceName(id, name string) error

+ func (db *DB) UpsertAgentInfo(info *AgentInfo) error

Mar 2, 2026

Changes in this version

type Sandbox

+ CPU *int

+ IdleTimeout *int

+ Memory *int64

Mar 2, 2026

Changes in this version

type DB

+ func (db *DB) AddWorkspaceVolume(id, workspaceID, pvcName, mountPath string) error

+ func (db *DB) DeleteWorkspaceQuota(workspaceID string) error

+ func (db *DB) GetPasswordHash(userID string) (*string, error)

+ func (db *DB) GetWorkspaceQuota(workspaceID string) (*WorkspaceQuota, error)

+ func (db *DB) ListWorkspaceVolumes(workspaceID string) ([]WorkspaceVolume, error)

+ func (db *DB) SetPasswordHash(userID, hash string) error

+ func (db *DB) SetWorkspaceQuota(workspaceID string, maxSandboxes *int, maxSandboxCPU *int, ...) error

+ func (db *DB) UpdateOIDCIdentityEmail(provider, subject, email string) error

+ func (db *DB) UpdateUserName(userID, name string) error

+ func (db *DB) UpdateUserPicture(userID, picture string) error

type Sandbox

+ OpenclawToken sql.NullString

+ OpencodeToken sql.NullString

type User

+ Name *string

+ Picture *string

+ UpdatedAt time.Time

+ type WorkspaceQuota struct

+ MaxDriveSize *int64

+ MaxIdleTimeout *int

+ MaxSandboxCPU *int

+ MaxSandboxMemory *int64

+ MaxSandboxes *int

+ MaxTotalCPU *int

+ MaxTotalMemory *int64

+ UpdatedAt time.Time

+ WorkspaceID string

+ type WorkspaceVolume struct

+ CreatedAt time.Time

+ ID string

+ MountPath string

+ PVCName string

+ WorkspaceID string

Mar 1, 2026

Changes in this version

type DB

+ func (db *DB) CountSandboxesByWorkspace(workspaceID string) (int, error)

+ func (db *DB) CountWorkspacesOwnedByUser(userID string) (int, error)

+ func (db *DB) DeleteUserQuota(userID string) error

+ func (db *DB) GetSystemSetting(key string) (string, error)

+ func (db *DB) GetUserQuota(userID string) (*UserQuota, error)

+ func (db *DB) SetSystemSetting(key, value string) error

+ func (db *DB) SetUserQuota(userID string, maxWorkspaces *int, maxSandboxesPerWorkspace *int, ...) error

+ func (db *DB) SumWorkspaceSandboxResources(workspaceID string) (cpuMillis int64, memBytes int64, err error)

type Sandbox

+ CPUMillicores *int

+ MemoryBytes *int64

+ type UserQuota struct

+ IdleTimeout *string

+ MaxSandboxesPerWorkspace *int

+ MaxWorkspaces *int

+ SandboxCPU *string

+ SandboxMemory *string

+ UpdatedAt time.Time

+ UserID string

+ WorkspaceDriveSize *string

+ WsMaxIdleTimeout *string

+ WsMaxTotalCPU *string

+ WsMaxTotalMemory *string

Mar 1, 2026

Changes in this version

type DB

+ func (db *DB) CountUsers() (int, error)

+ func (db *DB) ListAllSandboxes() ([]*Sandbox, error)

+ func (db *DB) ListAllUsers() ([]*User, error)

+ func (db *DB) ListAllWorkspaces() ([]*Workspace, error)

+ func (db *DB) UpdateUserRole(userID, role string) error

type User

+ Role string

Mar 1, 2026

Changes in this version

+ type AgentRegistrationCode struct

+ Code string

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ Used bool

+ UserID string

+ WorkspaceID string

+ type DB struct

+ func Open(databaseURL string) (*DB, error)

+ func (db *DB) AddWorkspaceMember(workspaceID, userID, role string) error

+ func (db *DB) ConsumeAgentRegistrationCode(code string) (*AgentRegistrationCode, error)

+ func (db *DB) CreateAgentRegistrationCode(code, userID, workspaceID string, expiresAt time.Time) error

+ func (db *DB) CreateLocalSandbox(...) error

+ func (db *DB) CreateOIDCIdentity(provider, subject, userID string, email *string) error

+ func (db *DB) CreateSandbox(...) error

+ func (db *DB) CreateToken(token, userID string, expiresAt time.Time) error

+ func (db *DB) CreateUser(id, username, passwordHash string) error

+ func (db *DB) CreateUserWithEmail(id, username string, passwordHash *string, email *string) error

+ func (db *DB) CreateWorkspace(id, name string) error

+ func (db *DB) DeleteExpiredTokens() error

+ func (db *DB) DeleteSandbox(id string) error

+ func (db *DB) DeleteWorkspace(id string) error

+ func (db *DB) GetAllWorkspaceNamespaces() ([]string, error)

+ func (db *DB) GetOIDCIdentity(provider, subject string) (*OIDCIdentity, error)

+ func (db *DB) GetSandbox(id string) (*Sandbox, error)

+ func (db *DB) GetSandboxByProxyToken(proxyToken string) (*Sandbox, error)

+ func (db *DB) GetSandboxByShortID(shortID string) (*Sandbox, error)

+ func (db *DB) GetSandboxByTunnelToken(sandboxID, tunnelToken string) (*Sandbox, error)

+ func (db *DB) GetUserByEmail(email string) (*User, error)

+ func (db *DB) GetUserByID(id string) (*User, error)

+ func (db *DB) GetUserByUsername(username string) (*User, error)

+ func (db *DB) GetWorkspace(id string) (*Workspace, error)

+ func (db *DB) GetWorkspaceMember(workspaceID, userID string) (*WorkspaceMember, error)

+ func (db *DB) GetWorkspaceMemberRole(workspaceID, userID string) (string, error)

+ func (db *DB) IsWorkspaceMember(workspaceID, userID string) (bool, error)

+ func (db *DB) ListAllActiveSandboxNames() ([]string, error)

+ func (db *DB) ListIdleSandboxes(idleTimeout time.Duration) ([]*Sandbox, error)

+ func (db *DB) ListSandboxesByWorkspace(workspaceID string) ([]*Sandbox, error)

+ func (db *DB) ListWorkspaceMembers(workspaceID string) ([]*WorkspaceMember, error)

+ func (db *DB) ListWorkspacesByUser(userID string) ([]*Workspace, error)

+ func (db *DB) ListWorkspacesWithoutNamespace() ([]*Workspace, error)

+ func (db *DB) RemoveWorkspaceMember(workspaceID, userID string) error

+ func (db *DB) SetWorkspaceNamespace(id, namespace string) error

+ func (db *DB) UpdateSandboxActivity(id string) error

+ func (db *DB) UpdateSandboxHeartbeat(id string) error

+ func (db *DB) UpdateSandboxPodIP(id, podIP string) error

+ func (db *DB) UpdateSandboxSandboxName(id, sandboxName string) error

+ func (db *DB) UpdateSandboxStatus(id, status string) error

+ func (db *DB) UpdateUserEmail(userID, email string) error

+ func (db *DB) UpdateWorkspaceDiskPVC(id, pvcName string) error

+ func (db *DB) UpdateWorkspaceMemberRole(workspaceID, userID, role string) error

+ func (db *DB) ValidateToken(token string) (string, error)

+ type OIDCIdentity struct

+ CreatedAt time.Time

+ Email *string

+ Provider string

+ Subject string

+ UserID string

+ type Sandbox struct

+ CreatedAt time.Time

+ GatewayToken sql.NullString

+ ID string

+ IsLocal bool

+ LastActivityAt sql.NullTime

+ LastHeartbeatAt sql.NullTime

+ Name string

+ OpencodePassword sql.NullString

+ PausedAt sql.NullTime

+ PodIP sql.NullString

+ ProxyToken sql.NullString

+ SandboxName sql.NullString

+ ShortID sql.NullString

+ Status string

+ TelegramBotToken sql.NullString

+ TunnelToken sql.NullString

+ Type string

+ WorkspaceID string

+ type User struct

+ CreatedAt time.Time

+ Email *string

+ ID string

+ PasswordHash *string

+ Username string

+ type Workspace struct

+ CreatedAt time.Time

+ DiskPVCName sql.NullString

+ ID string

+ K8sNamespace sql.NullString

+ Name string

+ UpdatedAt time.Time

+ type WorkspaceMember struct

+ CreatedAt time.Time

+ Role string

+ UserID string

+ WorkspaceID string