executive

Documentation

Index

• Variables
• func InitDirector(serverMode bool, interactiveMode bool) error
• func InitServerMode(port string)
• type ActionRunStatus
• type AutocompleteResponse
• type Director
  • func (d *Director) Clean()
  • func (d *Director) Wait()
• type ExecCtrlInstruction
• type ExecCtrlInstructionID
• type GenericResponse
• type HandshakeRequest
• type HandshakeResponse
• type Httpd
  • func (h *Httpd) Serve(addr *string) error
• type Manager
  • func NewManager() *Manager
  • func (m *Manager) EmancipateStages()
  • func (m *Manager) GetExecutionUUID() *string
  • func (m *Manager) GetLogger() base.ILogger
  • func (m *Manager) PrepareIRB(irb *blueprint.IRBlueprint)
  • func (m *Manager) Run() error
  • func (m *Manager) RunStages(stages []*Stage)
• type ManagerStatusID
• type Registry
  • func NewRegistry() *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 NewStage(manager *Manager, store base.IStore, startAction *blueprint.Action) *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

Variables

var ServerError error

var ServerWaiter *sync.WaitGroup = &sync.WaitGroup{}

Functions

func InitDirector

func InitDirector(serverMode bool, interactiveMode bool) error

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

func (*Director) Clean

func (d *Director) Clean()

func (*Director) Wait

func (d *Director) Wait()

Wait func

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

type GenericResponse struct {
	Fail   bool     `json:"Fail"`
	Errors []string `json:"Errors"`
}

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 Httpd

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

Httpd struct

func (*Httpd) Serve

func (h *Httpd) Serve(addr *string) error

Serve func

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 NewManager

func NewManager() *Manager

NewManager func

func (*Manager) EmancipateStages

func (m *Manager) EmancipateStages()

func (*Manager) GetExecutionUUID

func (m *Manager) GetExecutionUUID() *string

GetExecutionUUID func

func (*Manager) GetLogger

func (m *Manager) GetLogger() base.ILogger

GetLogger func

func (*Manager) PrepareIRB

func (m *Manager) PrepareIRB(irb *blueprint.IRBlueprint)

PrepareIRB func

func (*Manager) Run

func (m *Manager) Run() error

Run func

func (*Manager) RunStages

func (m *Manager) RunStages(stages []*Stage)

RunStages func

type ManagerStatusID

type ManagerStatusID int

ManagerStatusID int

type Registry

type Registry struct {
	ExecutionUUID *string

	Logger base.ILogger

	SavedOutputs []*base.ActionOutput
	ExitCode     int
	// contains filtered or unexported fields
}

Registry struct

func NewRegistry

func NewRegistry() *Registry

NewRegistry func

func (*Registry) AddWaitingID

func (r *Registry) AddWaitingID(actionID string)

AddWaitingID func

func (*Registry) DelWaitingID

func (r *Registry) DelWaitingID(actionID string)

DelWaitingID func

func (*Registry) HandleActionReport

func (r *Registry) HandleActionReport(srr *stageReport)

HandleActionReport func

func (*Registry) IsInPause

func (r *Registry) IsInPause() bool

IsInPause func

func (*Registry) IsInStop

func (r *Registry) IsInStop() bool

IsInStop func

func (*Registry) IsRunningSomeIDonMap

func (r *Registry) IsRunningSomeIDonMap(knowParents map[string]bool) bool

IsRunningSomeIDonMap func

func (*Registry) QueueAction

func (r *Registry) QueueAction(actionID string, stage *Stage)

QueueAction func

func (*Registry) SetManagerState

func (r *Registry) SetManagerState(state int)

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 NewStage

func NewStage(manager *Manager, store base.IStore, startAction *blueprint.Action) *Stage

NewStage func

func (*Stage) Divide

func (s *Stage) Divide(actions []*blueprint.Action) []*Stage

Divide func

func (*Stage) GetProvider

func (s *Stage) GetProvider(providerName string) (base.IProvider, error)

GetProvider func

func (*Stage) GetStore

func (s *Stage) GetStore() base.IStore

GetStore struct

func (*Stage) Init

func (s *Stage) Init()

Init func

func (*Stage) PostAction

func (s *Stage) PostAction(actionOutput *base.ActionOutput, actionErr error) bool

func (*Stage) SetStageID

func (s *Stage) SetStageID(stageID string)

SetStageID func

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
)