Documentation
¶
Index ¶
- func InitBgTasks(redisHost string, redisPort int, concurrency uint, codeboxInstanceId string) error
- func StopWorkspace(workspace *models.Workspace, skipErrors bool) error
- type Context
- func (jobContext *Context) DeleteRunnerTask(job *work.Job) error
- func (jobContext *Context) DeleteUserTask(job *work.Job) error
- func (jobContext *Context) DeleteWorkspaceTask(job *work.Job) error
- func (jobContext *Context) PingAgentsTask(job *work.Job) error
- func (jobContext *Context) PingRunnersTask(job *work.Job) error
- func (jobContext *Context) StartWorkspaceTask(job *work.Job) error
- func (jobContext *Context) StopWorkspaceTask(job *work.Job) error
- func (jobContext *Context) UpdateWorkspaceConfigFilesTask(job *work.Job) error
- type EnqueuerInterface
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitBgTasks ¶
Types ¶
type Context ¶
type Context struct {
WorkspaceID uint
}
func (*Context) DeleteRunnerTask ¶ added in v0.0.47
Delete a runner: - stop all workspaces running on this runner (ignoring errors) - set workspace runner as nil - delete the runner
func (*Context) DeleteUserTask ¶ added in v0.0.47
Background task that deletes a user, this task deletes the user and all his workspaces
func (*Context) DeleteWorkspaceTask ¶ added in v0.0.47
func (*Context) PingAgentsTask ¶ added in v0.0.47
func (*Context) PingRunnersTask ¶ added in v0.0.47
func (*Context) StartWorkspaceTask ¶ added in v0.0.47
func (*Context) StopWorkspaceTask ¶ added in v0.0.47
type EnqueuerInterface ¶ added in v0.0.47
type EnqueuerInterface interface {
Enqueue(jobName string, args map[string]interface{}) (*work.Job, error)
}
var (
BgTasksEnqueuer EnqueuerInterface
)
Source Files
Click to show internal directories.
Click to hide internal directories.