Documentation ¶
Index ¶
- Variables
- func InitDirector(serverMode bool, interactiveMode bool) error
- func InitServerMode(port string)
- type ActionRunStatus
- type AutocompleteResponse
- type Director
- type ExecCtrlInstruction
- type ExecCtrlInstructionID
- type GenericResponse
- type HandshakeRequest
- type HandshakeResponse
- type Httpd
- type Manager
- type ManagerStatusID
- type Registry
- func (r *Registry) AddWaitingID(actionID string)
- func (r *Registry) DelWaitingID(actionID string)
- func (r *Registry) HandleActionReport(srr *stageReport)
- func (r *Registry) IsInPause() bool
- func (r *Registry) IsInStop() bool
- func (r *Registry) IsRunningSomeIDonMap(knowParents map[string]bool) bool
- func (r *Registry) QueueAction(actionID string, stage *Stage)
- func (r *Registry) SetManagerState(state int)
- type Stage
- func (s *Stage) Divide(actions []*blueprint.Action) []*Stage
- func (s *Stage) GetProvider(providerName string) (base.IProvider, error)
- func (s *Stage) GetStore() base.IStore
- func (s *Stage) Init()
- func (s *Stage) PostAction(actionOutput *base.ActionOutput, actionErr error) bool
- func (s *Stage) SetStageID(stageID string)
- type StageReportReason
- type StageStatusID
Constants ¶
This section is empty.
Variables ¶
View Source
var ServerError error
View Source
var ServerWaiter *sync.WaitGroup = &sync.WaitGroup{}
Functions ¶
func InitDirector ¶
InitDirector func
func InitServerMode ¶
func InitServerMode(port string)
Types ¶
type ActionRunStatus ¶
type ActionRunStatus int
ActionRunStatus int
const ( // ActionQueued const ActionQueued ActionRunStatus = iota // ActionRunning const ActionRunning // ActionNotRunning const ActionNotRunning )
type AutocompleteResponse ¶
type AutocompleteResponse struct { Fail bool `json:"Fail"` Errors []string `json:"Errors"` Result map[string][]*base.StorageRecord `json:"result"` }
AutocompleteResponse struct
type Director ¶
type Director struct { ExecInstruction chan *ExecCtrlInstruction HandleIRB chan *blueprint.IRBlueprint UnregisterManager chan *Manager StopDirector chan int ExitCode int // contains filtered or unexported fields }
Director struct
var MDirector *Director
MDirector var
type ExecCtrlInstruction ¶
type ExecCtrlInstruction struct { Instruction ExecCtrlInstructionID ExecutionUUID *string }
type ExecCtrlInstructionID ¶
type ExecCtrlInstructionID int
ExecCtrlInstructionID int
const ( // ExecStop const ExecStop ExecCtrlInstructionID = iota // ExecStart const ExecStart // ExecPause const ExecPause // ExecResume const ExecResume // ExecState const. Cast current state ExecState // ExecEmancipation const ExecEmancipation )
type GenericResponse ¶
GenericResponse struct
type HandshakeRequest ¶
type HandshakeRequest struct {
Version string `json:"version"`
}
HandshakeRequest struct
type HandshakeResponse ¶
type HandshakeResponse struct {
Version string `json:"version"`
}
HandshakeResponse struct
type Manager ¶
type Manager struct { // The uuid generated by the builder or uuid asked to backend ExecutionUUID *string IRB *blueprint.IRBlueprint // Logger instance with remote execution uuid configured Logger *cast.Logger // Comunicate Action exec StageReport chan *stageReport ExternalRegistry *Registry // Stats *stats // contains filtered or unexported fields }
Manager struct
func (*Manager) EmancipateStages ¶
func (m *Manager) EmancipateStages()
func (*Manager) GetExecutionUUID ¶
GetExecutionUUID func
func (*Manager) PrepareIRB ¶
func (m *Manager) PrepareIRB(irb *blueprint.IRBlueprint)
PrepareIRB func
type Registry ¶
type Registry struct { ExecutionUUID *string Logger base.ILogger SavedOutputs []*base.ActionOutput ExitCode int // contains filtered or unexported fields }
Registry struct
func (*Registry) HandleActionReport ¶
func (r *Registry) HandleActionReport(srr *stageReport)
HandleActionReport func
func (*Registry) IsRunningSomeIDonMap ¶
IsRunningSomeIDonMap func
func (*Registry) QueueAction ¶
QueueAction func
func (*Registry) SetManagerState ¶
SetManagerState func
type Stage ¶
type Stage struct { StartAction *blueprint.Action CurrentAction *blueprint.Action LastAction *blueprint.Action LastActionError error // contains filtered or unexported fields }
Stage struct
func (*Stage) GetProvider ¶
GetProvider func
func (*Stage) PostAction ¶
func (s *Stage) PostAction(actionOutput *base.ActionOutput, actionErr error) bool
type StageReportReason ¶
type StageReportReason int
StageReportReason int
const ( // StageEndByDivision const StageEndByDivision StageReportReason = iota // StageEndByJoin const StageEndByJoin // StageEndByRunDone const StageEndByRunDone // StageActionReport const StageActionReport // StagePause const StagePause // StageResume const StageResume )
type StageStatusID ¶
type StageStatusID int
StageStatusID int
const ( // StageStatusStopped const StageStatusStopped StageStatusID = iota // StageStatusRunning const StageStatusRunning // StageStatusPaused const StageStatusPaused )
Source Files ¶
Click to show internal directories.
Click to hide internal directories.