Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecResult ¶
type ExecResult struct {
FQMN string `json:"fqmn"`
Response *request.CoordinatedResponse `json:"response"`
RunErr scheduler.RunErr `json:"runErr"` // runErr is an error returned from a Runnable.
ExecErr string `json:"execErr"` // err is an annoying workaround that allows runGroup to propogate non-RunErrs out of its loop. Should be refactored when possible.
}
type Sequence ¶
type Sequence struct {
// contains filtered or unexported fields
}
func FromJSON ¶
func FromJSON(seqJSON []byte, req *request.CoordinatedRequest) (*Sequence, error)
FromJSON creates a sequence from a JSON-encoded set of steps.
func New ¶
func New(workflowSteps []tenant.WorkflowStep, req *request.CoordinatedRequest) (*Sequence, error)
New creates a new Sequence.
func (*Sequence) HandleStepResults ¶
func (seq *Sequence) HandleStepResults(results []ExecResult) error
func (*Sequence) NextStep ¶
NextStep returns the first un-complete step, nil if the sequence is over.
func (*Sequence) Request ¶
func (seq *Sequence) Request() *request.CoordinatedRequest
Request returns the request for this sequence
type Step ¶
type Step struct {
tenant.WorkflowStep `json:"inline"`
Completed bool `json:"completed"`
}
Step is a container over WorkflowStep that includes a 'Completed' field.
Click to show internal directories.
Click to hide internal directories.