Documentation
¶
Index ¶
Constants ¶
View Source
const ( Unknown status = iota Running status = iota Done status = iota Error status = iota )
Variables ¶
View Source
var DefaultGracePeriod = 30 * time.Second
Functions ¶
func NewProcessExecer ¶
func NewProcessExecer() *processExecer
func SpanIDForServeLog ¶
Types ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(execer Execer) *Controller
func (*Controller) TearDown ¶
func (c *Controller) TearDown(ctx context.Context)
type Execer ¶
type Execer interface {
Start(ctx context.Context, cmd model.Cmd, workdir string, w io.Writer, statusCh chan statusAndMetadata, spanID model.LogSpanID) chan struct{}
}
func ProvideExecer ¶
func ProvideExecer() Execer
type FakeExecer ¶
type FakeExecer struct {
// contains filtered or unexported fields
}
func NewFakeExecer ¶
func NewFakeExecer() *FakeExecer
func (*FakeExecer) RequireNoKnownProcess ¶
func (fe *FakeExecer) RequireNoKnownProcess(t *testing.T, cmd string)
type LocalServeLogActionWriter ¶
type LocalServeLogActionWriter struct {
// contains filtered or unexported fields
}
type LocalServeStatusAction ¶
type LocalServeStatusAction struct {
ManifestName model.ManifestName
Status model.RuntimeStatus
PID int // 0 if there's no process running
SpanID model.LogSpanID
}
func (LocalServeStatusAction) Action ¶
func (LocalServeStatusAction) Action()
type ServeSpec ¶
type ServeSpec struct {
ManifestName model.ManifestName
ServeCmd model.Cmd
WorkDir string
TriggerTime time.Time // TriggerTime is how Runner knows to restart; if it's newer than the TriggerTime of the currently running command, then Runner should restart it
}
ServeSpec describes what Runner should be running
Source Files
Click to show internal directories.
Click to hide internal directories.