local

Documentation

Index

• Constants
• Variables
• func NewProcessExecer() *processExecer
• func SpanIDForServeLog(procNum int) logstore.SpanID
• type Controller
  • func NewController(execer Execer) *Controller
  • func (c *Controller) OnChange(ctx context.Context, st store.RStore)
  • func (c *Controller) TearDown(ctx context.Context)
• type Execer
  • func ProvideExecer() Execer
• type FakeExecer
  • func NewFakeExecer() *FakeExecer
  • func (fe *FakeExecer) RequireNoKnownProcess(t *testing.T, cmd string)
  • func (e *FakeExecer) Start(ctx context.Context, cmd model.Cmd, workdir string, w io.Writer, ...) chan struct{}
• type LocalServeLogActionWriter
  • func (w LocalServeLogActionWriter) Write(level logger.Level, fields logger.Fields, p []byte) error
• type LocalServeStatusAction
  • func (LocalServeStatusAction) Action()
• type ServeSpec

Constants

const (
	Unknown status = iota
	Running status = iota
	Done    status = iota
	Error   status = iota
)

Variables

var DefaultGracePeriod = 30 * time.Second

Functions

func NewProcessExecer

func NewProcessExecer() *processExecer

func SpanIDForServeLog

func SpanIDForServeLog(procNum int) logstore.SpanID

Types

type Controller

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

func NewController

func NewController(execer Execer) *Controller

func (*Controller) OnChange

func (c *Controller) OnChange(ctx context.Context, st store.RStore)

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)

func (*FakeExecer) Start

func (e *FakeExecer) Start(ctx context.Context, cmd model.Cmd, workdir string, w io.Writer, statusCh chan statusAndMetadata, spanID model.LogSpanID) chan struct{}

type LocalServeLogActionWriter

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

func (LocalServeLogActionWriter) Write

func (w LocalServeLogActionWriter) Write(level logger.Level, fields logger.Fields, p []byte) error

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