Documentation ¶
Index ¶
- Constants
- Variables
- type BuildSlave
- type Builder
- type WorkspaceManager
- func (wm *WorkspaceManager) EnsureWorkspaceExists(repoURL *url.URL) (ws string, err error)
- func (wm *WorkspaceManager) GetWorkspaceQueue(ws string) chan bool
- func (mw *WorkspaceManager) SrcDir(workspace string) (srcDir string)
- func (wm *WorkspaceManager) SrcDirExists(workspace string) (exists bool, err error)
Constants ¶
View Source
const TokenHeader = "X-Meeko-Token"
Variables ¶
View Source
var ( ErrConnected = errors.New("build slave already connected") ErrDisconnected = errors.New("build slave has not been connected") )
View Source
var Command = &gocli.Command{
UsageLine: `
slave [-master=URL] [-token=TOKEN] [-identity=IDENTITY] [-labels=LABELS]
[-workspace=WORKSPACE] [-executors=EXECUTORS] [-verbose|-debug]`,
Short: "run a build slave",
Long: `
Start a build slave and connect it to the specified master node.
ENVIRONMENT:
CIDER_MASTER_URL
CIDER_MASTER_TOKEN
CIDER_SLAVE_IDENTITY
CIDER_SLAVE_LABELS
CIDER_SLAVE_WORKSPACE
`,
Action: enslaveThisPoorMachine,
}
Functions ¶
This section is empty.
Types ¶
type BuildSlave ¶
type BuildSlave struct {
// contains filtered or unexported fields
}
func New ¶
func New(identity, workspace string, numExecutors uint) *BuildSlave
func (*BuildSlave) Connect ¶
func (slave *BuildSlave) Connect(master, token string) (err error)
func (*BuildSlave) Terminate ¶
func (slave *BuildSlave) Terminate() error
func (*BuildSlave) Terminated ¶
func (slave *BuildSlave) Terminated() <-chan struct{}
func (*BuildSlave) Wait ¶
func (slave *BuildSlave) Wait() error
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
func (*Builder) Build ¶
func (builder *Builder) Build(request rpc.RemoteRequest)
type WorkspaceManager ¶
type WorkspaceManager struct {
// contains filtered or unexported fields
}
func (*WorkspaceManager) EnsureWorkspaceExists ¶
func (wm *WorkspaceManager) EnsureWorkspaceExists(repoURL *url.URL) (ws string, err error)
func (*WorkspaceManager) GetWorkspaceQueue ¶
func (wm *WorkspaceManager) GetWorkspaceQueue(ws string) chan bool
func (*WorkspaceManager) SrcDir ¶
func (mw *WorkspaceManager) SrcDir(workspace string) (srcDir string)
func (*WorkspaceManager) SrcDirExists ¶
func (wm *WorkspaceManager) SrcDirExists(workspace string) (exists bool, err error)
Click to show internal directories.
Click to hide internal directories.