engine

package

v0.0.0-...-5b1f977 Latest Latest Go to latest Published: Mar 2, 2023 License: MIT Imports: 29 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gokins/gokins

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func Start() error
type BuildEngine
- func StartBuildEngine() *BuildEngine
type BuildTask
- func NewBuildTask(egn *BuildEngine, bd *runtime.Build) *BuildTask
type HbtpRunner
type JobEngine
- func StartJobEngine() *JobEngine
type Manager
type TimerEngine
- func StartTimerEngine() *TimerEngine
- func (c *TimerEngine) Delete(tmrid string)
- func (c *TimerEngine) Refresh(tmrid string) error

Constants ¶

This section is empty.

Variables ¶

View Source

var Mgr = &Manager{}

Functions ¶

func Start ¶

func Start() error

Types ¶

type BuildEngine ¶

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

func StartBuildEngine ¶

func StartBuildEngine() *BuildEngine

func (*BuildEngine) Get ¶

func (c *BuildEngine) Get(buildid string) (*BuildTask, bool)

func (*BuildEngine) Put ¶

func (c *BuildEngine) Put(bd *runtime.Build)

func (*BuildEngine) Stop ¶

func (c *BuildEngine) Stop()

type BuildTask ¶

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

func NewBuildTask ¶

func NewBuildTask(egn *BuildEngine, bd *runtime.Build) *BuildTask

func (*BuildTask) Cancel ¶

func (c *BuildTask) Cancel()

func (*BuildTask) GetJob ¶

func (c *BuildTask) GetJob(id string) (*jobSync, bool)

func (*BuildTask) Show ¶

func (c *BuildTask) Show() (*runtime.BuildShow, bool)

func (*BuildTask) UpJob ¶

func (c *BuildTask) UpJob(job *jobSync, stat, errs string, code int)

func (*BuildTask) UpJobCmd ¶

func (c *BuildTask) UpJobCmd(cmd *cmdSync, fs, code int)

func (*BuildTask) WorkProgress ¶

func (c *BuildTask) WorkProgress() int

func (*BuildTask) Write ¶

func (c *BuildTask) Write(bts []byte) (n int, err error)

type HbtpRunner ¶

type HbtpRunner struct {
}

func (HbtpRunner) AuthFun ¶

func (HbtpRunner) AuthFun() hbtp.AuthFun

func (HbtpRunner) CheckCancel ¶

func (HbtpRunner) CheckCancel(c *hbtp.Context)

func (HbtpRunner) FindArtVersionId ¶

func (HbtpRunner) FindArtVersionId(c *hbtp.Context)

func (HbtpRunner) FindJobId ¶

func (HbtpRunner) FindJobId(c *hbtp.Context)

func (HbtpRunner) GenEnv ¶

func (HbtpRunner) GenEnv(c *hbtp.Context, env utils.EnvVal)

func (HbtpRunner) GetEnv ¶

func (HbtpRunner) GetEnv(c *hbtp.Context)

func (HbtpRunner) NewArtVersionId ¶

func (HbtpRunner) NewArtVersionId(c *hbtp.Context)

func (HbtpRunner) PullJob ¶

func (HbtpRunner) PullJob(c *hbtp.Context, m *runners.ReqPullJob)

func (HbtpRunner) PushOutLine ¶

func (HbtpRunner) PushOutLine(c *hbtp.Context)

func (HbtpRunner) ReadDir ¶

func (HbtpRunner) ReadDir(c *hbtp.Context)

func (HbtpRunner) ReadFile ¶

func (HbtpRunner) ReadFile(c *hbtp.Context)

func (HbtpRunner) ServerInfo ¶

func (HbtpRunner) ServerInfo(c *hbtp.Context)

func (HbtpRunner) StatFile ¶

func (HbtpRunner) StatFile(c *hbtp.Context)

func (HbtpRunner) Update ¶

func (HbtpRunner) Update(c *hbtp.Context, m *runners.UpdateJobInfo)

func (HbtpRunner) UpdateCmd ¶

func (HbtpRunner) UpdateCmd(c *hbtp.Context)

func (HbtpRunner) UploadFile ¶

func (HbtpRunner) UploadFile(c *hbtp.Context)

type JobEngine ¶

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

func StartJobEngine ¶

func StartJobEngine() *JobEngine

func (*JobEngine) Plugins ¶

func (c *JobEngine) Plugins() []string

func (*JobEngine) Pull ¶

func (c *JobEngine) Pull(name string, plugs []string) *runners.RunJob

func (*JobEngine) Put ¶

func (c *JobEngine) Put(job *jobSync) error

type Manager ¶

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

func (*Manager) BuildEgn ¶

func (c *Manager) BuildEgn() *BuildEngine

func (*Manager) HRun ¶

func (c *Manager) HRun() *HbtpRunner

func (*Manager) Plugins ¶

func (c *Manager) Plugins() []string

func (*Manager) TimerEng ¶

func (c *Manager) TimerEng() *TimerEngine

type TimerEngine ¶

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

func StartTimerEngine ¶

func StartTimerEngine() *TimerEngine

func (*TimerEngine) Delete ¶

func (c *TimerEngine) Delete(tmrid string)

func (*TimerEngine) Refresh ¶

func (c *TimerEngine) Refresh(tmrid string) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL