bgtasks

Documentation

Index

• Variables
• func InitBgTasks(redisHost string, redisPort int, concurrency uint, codeboxInstanceId string) error
• type Context
  • func (jobContext *Context) DeleteWorkspace(job *work.Job) error
  • func (jobContext *Context) PingAgents(job *work.Job) error
  • func (jobContext *Context) PingRunners(job *work.Job) error
  • func (jobContext *Context) StartWorkspace(job *work.Job) error
  • func (jobContext *Context) StopWorkspace(job *work.Job) error
  • func (jobContext *Context) UpdateWorkspaceConfigFiles(job *work.Job) error

Variables

var (
	BgTasksEnqueuer *work.Enqueuer
)

Functions

func InitBgTasks

func InitBgTasks(redisHost string, redisPort int, concurrency uint, codeboxInstanceId string) error

Types

type Context

type Context struct {
	WorkspaceID uint
}

func (*Context) DeleteWorkspace

func (jobContext *Context) DeleteWorkspace(job *work.Job) error

func (*Context) PingAgents

func (jobContext *Context) PingAgents(job *work.Job) error

func (*Context) PingRunners

func (jobContext *Context) PingRunners(job *work.Job) error

func (*Context) StartWorkspace

func (jobContext *Context) StartWorkspace(job *work.Job) error

func (*Context) StopWorkspace

func (jobContext *Context) StopWorkspace(job *work.Job) error

func (*Context) UpdateWorkspaceConfigFiles

func (jobContext *Context) UpdateWorkspaceConfigFiles(job *work.Job) error