job

Documentation

Index

• func IsExist(fname string) bool
• func NewDownloadStep(f *zip.File, b domain.Bundle, path string, r *ZipReader) *downloadBundleFile
• type BufReader
  • func (r *BufReader) ReadAt(p []byte, off int64) (int, error)
• type CheckUpdate
  • func NewCheckUpdate(r core.Runner, client *cli.ServerClient, appID, branch string) *CheckUpdate
  • func (c *CheckUpdate) Run() error
• type ContextReader
  • func (r *ContextReader) ReadAt(p []byte, off int64) (int, error)
  • func (r *ContextReader) SetContext(ctx context.Context)
• type Factory
  • func NewFactory(client *cli.ServerClient) *Factory
  • func (f *Factory) NewCheckUpdate(ctx *core.Context, app *core.Application) core.SimpleJob
  • func (f *Factory) NewJob(kind core.TaskType, app *core.Application, recover bool) core.Job
  • func (f *Factory) NewLaunch(ctx *core.Context, app *core.Application) core.SimpleJob
• type InstallDirectJob
  • func NewInstallDirectJob(s X, opts InstallOptions) *InstallDirectJob
• type InstallJob
  • func NewInstallJob(s X, opts InstallOptions) *InstallJob
• type InstallOptions
• type Launch
  • func NewLaunch(r core.Runner, client *cli.ServerClient, appID, branch, build, path string) *Launch
  • func (c *Launch) Run() error
• type MultiStep
  • func (m *MultiStep) AddStep(f Step)
  • func (m *MultiStep) AddStepFunc(f StepFunc)
  • func (m *MultiStep) Run(ctx process.Context) error
• type Step
• type StepFunc
  • func (f StepFunc) Run(ctx process.Context) error
• type Uninstall
  • func NewUninstall(opts UninstallOptions) *Uninstall
  • func (j *Uninstall) Run(ctx process.Context) error
• type UninstallOptions
• type X
• type ZipReader
  • func (zr *ZipReader) ReadAt(p []byte, off int64) (int, error)
  • func (zr *ZipReader) SetContext(ctx context.Context)

Functions

func IsExist

func IsExist(fname string) bool

func NewDownloadStep

func NewDownloadStep(f *zip.File, b domain.Bundle, path string, r *ZipReader) *downloadBundleFile

Types

type BufReader

type BufReader struct {
	// contains filtered or unexported fields
}

func (*BufReader) ReadAt

func (r *BufReader) ReadAt(p []byte, off int64) (int, error)

type CheckUpdate

type CheckUpdate struct {
	// contains filtered or unexported fields
}

func NewCheckUpdate

func NewCheckUpdate(r core.Runner, client *cli.ServerClient, appID, branch string) *CheckUpdate

func (*CheckUpdate) Run

func (c *CheckUpdate) Run() error

type ContextReader

type ContextReader struct {
	// contains filtered or unexported fields
}

func (*ContextReader) ReadAt

func (r *ContextReader) ReadAt(p []byte, off int64) (int, error)

func (*ContextReader) SetContext

func (r *ContextReader) SetContext(ctx context.Context)

type Factory

type Factory struct {
	// contains filtered or unexported fields
}

func NewFactory

func NewFactory(client *cli.ServerClient) *Factory

func (*Factory) NewCheckUpdate

func (f *Factory) NewCheckUpdate(ctx *core.Context, app *core.Application) core.SimpleJob

func (*Factory) NewJob

func (f *Factory) NewJob(kind core.TaskType, app *core.Application, recover bool) core.Job

func (*Factory) NewLaunch

func (f *Factory) NewLaunch(ctx *core.Context, app *core.Application) core.SimpleJob

type InstallDirectJob

type InstallDirectJob struct {
	MultiStep
	// contains filtered or unexported fields
}

func NewInstallDirectJob

func NewInstallDirectJob(s X, opts InstallOptions) *InstallDirectJob

type InstallJob

type InstallJob struct {
	MultiStep
	// contains filtered or unexported fields
}

func NewInstallJob

func NewInstallJob(s X, opts InstallOptions) *InstallJob

type InstallOptions

type InstallOptions struct {
	Path     string
	AppID    string
	Branch   string
	Build    string
	Locale   domain.Locale
	Platform domain.Platform
	Recover  bool
}

type Launch

type Launch struct {
	// contains filtered or unexported fields
}

func NewLaunch

func NewLaunch(r core.Runner, client *cli.ServerClient, appID, branch, build, path string) *Launch

func (*Launch) Run

func (c *Launch) Run() error

type MultiStep

type MultiStep struct {
	// contains filtered or unexported fields
}

func (*MultiStep) AddStep

func (m *MultiStep) AddStep(f Step)

func (*MultiStep) AddStepFunc

func (m *MultiStep) AddStepFunc(f StepFunc)

func (*MultiStep) Run

func (m *MultiStep) Run(ctx process.Context) error

type Step

type Step interface {
	Run(ctx process.Context) error
}

type StepFunc

type StepFunc func(ctx process.Context) error

func (StepFunc) Run

func (f StepFunc) Run(ctx process.Context) error

type Uninstall

type Uninstall struct {
	// contains filtered or unexported fields
}

func NewUninstall

func NewUninstall(opts UninstallOptions) *Uninstall

func (*Uninstall) Run

func (j *Uninstall) Run(ctx process.Context) error

type UninstallOptions

type UninstallOptions struct {
	Path string
}

type X

type X interface {
	DownloadBuild(app, branch, build string) (*domain.ApplicationManifest, string, error)
}

type ZipReader

type ZipReader struct {
	*zip.Reader
	// contains filtered or unexported fields
}

func (*ZipReader) ReadAt

func (zr *ZipReader) ReadAt(p []byte, off int64) (int, error)

func (*ZipReader) SetContext

func (zr *ZipReader) SetContext(ctx context.Context)