local

Documentation

Index

• Constants
• Variables
• func HandleCmdCreateAction(state *store.EngineState, action CmdCreateAction)
• func HandleCmdUpdateAction(state *store.EngineState, action CmdUpdateAction)
• func NewProcessExecer() *processExecer
• func SpanIDForServeLog(procNum int) logstore.SpanID
• type Cmd
• type CmdCreateAction
  • func NewCmdCreateAction(cmd *Cmd) CmdCreateAction
  • func (CmdCreateAction) Action()
• type CmdSpec
• type CmdStateRunning
• type CmdStateTerminated
• type CmdStatus
• type CmdUpdateAction
  • func NewCmdUpdateAction(cmd *Cmd) CmdUpdateAction
  • func (CmdUpdateAction) Action()
• type Controller
  • func NewController(execer Execer, proberManager ProberManager) *Controller
  • func (c *Controller) OnChange(ctx context.Context, st store.RStore, _ store.ChangeSummary)
  • 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, w io.Writer, ...) chan struct{}
• type FakeProberManager
  • func NewFakeProberManager() *FakeProberManager
  • func (m *FakeProberManager) Exec(name string, args ...string) prober.ProberFunc
  • func (m *FakeProberManager) HTTPGet(u *url.URL, headers http.Header) prober.ProberFunc
  • func (m *FakeProberManager) ProbeCount() int
  • func (m *FakeProberManager) TCPSocket(host string, port int) prober.ProberFunc
• type ObjectMeta
• type ProberManager
  • func ProvideProberManager() ProberManager
• type ServeSpec

Constants

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

Variables

var DefaultGracePeriod = 30 * time.Second

var ErrUnsupportedProbeType = errors.New("unsupported probe type")

Functions

func HandleCmdCreateAction

func HandleCmdCreateAction(state *store.EngineState, action CmdCreateAction)

When the local controller creates a new command, link that command to the Local runtime state.

func HandleCmdUpdateAction

func HandleCmdUpdateAction(state *store.EngineState, action CmdUpdateAction)

When the Cmd controller updates a command, check to see what parts of the EngineState care about that command.

If the local serve cmd is watching the cmd, update the local runtime state to match the cmd status.

func NewProcessExecer

func NewProcessExecer() *processExecer

func SpanIDForServeLog

func SpanIDForServeLog(procNum int) logstore.SpanID

Types

type Cmd

type Cmd = v1alpha1.Cmd

type CmdCreateAction

type CmdCreateAction struct {
	Cmd *Cmd
}

func NewCmdCreateAction

func NewCmdCreateAction(cmd *Cmd) CmdCreateAction

func (CmdCreateAction) Action

func (CmdCreateAction) Action()

type CmdSpec

type CmdSpec = v1alpha1.CmdSpec

type CmdStateRunning

type CmdStateRunning = v1alpha1.CmdStateRunning

type CmdStateTerminated

type CmdStateTerminated = v1alpha1.CmdStateTerminated

type CmdStatus

type CmdStatus = v1alpha1.CmdStatus

type CmdUpdateAction

type CmdUpdateAction struct {
	Cmd *Cmd
}

func NewCmdUpdateAction

func NewCmdUpdateAction(cmd *Cmd) CmdUpdateAction

func (CmdUpdateAction) Action

func (CmdUpdateAction) Action()

type Controller

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

func NewController

func NewController(execer Execer, proberManager ProberManager) *Controller

func (*Controller) OnChange

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

func (*Controller) TearDown

func (c *Controller) TearDown(ctx context.Context)

type Execer

type Execer interface {
	Start(ctx context.Context, cmd model.Cmd, 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, w io.Writer, statusCh chan statusAndMetadata, spanID model.LogSpanID) chan struct{}

type FakeProberManager

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

func NewFakeProberManager

func NewFakeProberManager() *FakeProberManager

func (*FakeProberManager) Exec

func (m *FakeProberManager) Exec(name string, args ...string) prober.ProberFunc

func (*FakeProberManager) HTTPGet

func (m *FakeProberManager) HTTPGet(u *url.URL, headers http.Header) prober.ProberFunc

func (*FakeProberManager) ProbeCount

func (m *FakeProberManager) ProbeCount() int

func (*FakeProberManager) TCPSocket

func (m *FakeProberManager) TCPSocket(host string, port int) prober.ProberFunc

type ObjectMeta

type ObjectMeta = metav1.ObjectMeta

type ProberManager

type ProberManager interface {
	HTTPGet(u *url.URL, headers http.Header) prober.ProberFunc
	TCPSocket(host string, port int) prober.ProberFunc
	Exec(name string, args ...string) prober.ProberFunc
}

func ProvideProberManager

func ProvideProberManager() ProberManager

type ServeSpec

type ServeSpec struct {
	ManifestName   model.ManifestName
	ServeCmd       model.Cmd
	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
	ReadinessProbe *v1alpha1.Probe
}

ServeSpec describes what Runner should be running