Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrSkip is used as a return value when container // execution should be skipped at runtime. It is not // returned as an error by any function. ErrSkip = errors.New("Skipped") // ErrCancel is used as a return value when the // container execution receives a cancellation signal // from the context. ErrCancel = errors.New("Cancelled") // ErrInterrupt is used to signal an interrupt and // gracefully exit the runtime execution. ErrInterrupt = errors.New("Interrupt") )
Functions ¶
This section is empty.
Types ¶
type Hook ¶
type Hook struct {
// Before is called before all all steps are executed.
Before func(*State) error
// BeforeEach is called before each step is executed.
BeforeEach func(*State) error
// After is called after all steps are executed.
After func(*State) error
// AfterEach is called after each step is executed.
AfterEach func(*State) error
// GotLine is called when a line is logged.
GotLine func(*State, *Line) error
// GotLogs is called when the logs are completed.
GotLogs func(*State, []*Line) error
}
Hook provides a set of hooks to run at various stages of runtime execution.
type Line ¶
type Line struct {
Number int `json:"pos,omitempty"`
Message string `json:"out,omitempty"`
Timestamp int64 `json:"time,omitempty"`
}
Line represents a line in the container logs.
type Runtime ¶
type Runtime struct {
// contains filtered or unexported fields
}
Runtime executes a pipeline configuration.
type State ¶
type State struct {
// Global state of the runtime.
Runtime struct {
// Runtime time started
Time int64
// Runtime pipeline error state
Error error
}
// Runtime pipeline step
Step *engine.Step
// Current process state.
State *engine.State
// contains filtered or unexported fields
}
State defines the pipeline and process state.
Click to show internal directories.
Click to hide internal directories.