cmd

Documentation

Index

• Constants
• Variables
• func NewProcessExecer() *processExecer
• type Cmd
• type CmdList
• type CmdSpec
• type CmdStateRunning
• type CmdStateTerminated
• type CmdStateWaiting
• type CmdStatus
• type Controller
  • func NewController(ctx context.Context, execer Execer, proberManager ProberManager, ...) *Controller
  • func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (c *Controller) SetClient(client ctrlclient.Client)
  • func (r *Controller) SetupWithManager(mgr ctrl.Manager) error
  • 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 FileWatch
• type FileWatchSpec
• type ObjectMeta
• type ProberManager
  • func ProvideProberManager() ProberManager
• type RestartManager
  • func NewRestartManager(client client.Client) *RestartManager
• type RestartOnSpec

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")

var WireSet = wire.NewSet(
	ProvideExecer,
	ProvideProberManager,
	NewController,
)

Functions

func NewProcessExecer

func NewProcessExecer() *processExecer

Types

type Cmd

type Cmd = v1alpha1.Cmd

type CmdList

type CmdList = v1alpha1.CmdList

type CmdSpec

type CmdSpec = v1alpha1.CmdSpec

type CmdStateRunning

type CmdStateRunning = v1alpha1.CmdStateRunning

type CmdStateTerminated

type CmdStateTerminated = v1alpha1.CmdStateTerminated

type CmdStateWaiting

type CmdStateWaiting = v1alpha1.CmdStateWaiting

type CmdStatus

type CmdStatus = v1alpha1.CmdStatus

type Controller

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

A controller that reads CmdSpec and writes CmdStatus

func NewController

func NewController(ctx context.Context, execer Execer, proberManager ProberManager, client ctrlclient.Client, st store.RStore) *Controller

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*Controller) SetClient

func (c *Controller) SetClient(client ctrlclient.Client)

func (*Controller) SetupWithManager

func (r *Controller) SetupWithManager(mgr ctrl.Manager) error

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 FileWatch

type FileWatch = v1alpha1.FileWatch

type FileWatchSpec

type FileWatchSpec = v1alpha1.FileWatchSpec

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 RestartManager

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

Helper struct to help reconcilers determine when to restart their objects when a file changes.

TODO(nick): Currently this uses *Cmd types, but it could be generalized to any type with a *RestartOn field.

func NewRestartManager

func NewRestartManager(client client.Client) *RestartManager

type RestartOnSpec

type RestartOnSpec = v1alpha1.RestartOnSpec