Documentation
¶
Index ¶
- Constants
- func IsNotExist(err error) bool
- type CommandRunner
- type RuncAdapter
- type RuncClient
- type RuncLifecycle
- func (j *RuncLifecycle) ListProcesses() ([]*models.Process, error)
- func (j *RuncLifecycle) OpenShell(cfg *config.BPMConfig, stdin io.Reader, stdout, stderr io.Writer) error
- func (j *RuncLifecycle) RemoveProcess(logger lager.Logger, cfg *config.BPMConfig) error
- func (j *RuncLifecycle) RunProcess(logger lager.Logger, bpmCfg *config.BPMConfig, procCfg *config.ProcessConfig) (int, error)
- func (j *RuncLifecycle) StartProcess(logger lager.Logger, bpmCfg *config.BPMConfig, procCfg *config.ProcessConfig) error
- func (j *RuncLifecycle) StatProcess(cfg *config.BPMConfig) (*models.Process, error)
- func (j *RuncLifecycle) StopProcess(logger lager.Logger, cfg *config.BPMConfig, exitTimeout time.Duration) error
- type UserFinder
Constants ¶
View Source
const ( ContainerSigQuitGracePeriod = 2 * time.Second ContainerStatePollInterval = 1 * time.Second ContainerStateRunning = "running" ContainerStatePaused = "paused" ContainerStateStopped = "stopped" )
Variables ¶
This section is empty.
Functions ¶
func IsNotExist ¶ added in v0.6.0
Types ¶
type CommandRunner ¶
func NewCommandRunner ¶
func NewCommandRunner() CommandRunner
type RuncAdapter ¶
type RuncClient ¶
type RuncClient interface {
CreateBundle(bundlePath string, jobSpec specs.Spec, user specs.User) error
RunContainer(pidFilePath, bundlePath, containerID string, detach bool, stdout, stderr io.Writer) (int, error)
Exec(containerID, command string, stdin io.Reader, stdout, stderr io.Writer) error
ContainerState(containerID string) (*specs.State, error)
ListContainers() ([]client.ContainerState, error)
SignalContainer(containerID string, signal client.Signal) error
DeleteContainer(containerID string) error
DestroyBundle(bundlePath string) error
}
type RuncLifecycle ¶
type RuncLifecycle struct {
// contains filtered or unexported fields
}
func NewRuncLifecycle ¶
func NewRuncLifecycle( runcClient RuncClient, runcAdapter RuncAdapter, userFinder UserFinder, commandRunner CommandRunner, clock clock.Clock, deleteFile func(string) error, ) *RuncLifecycle
func (*RuncLifecycle) ListProcesses ¶
func (j *RuncLifecycle) ListProcesses() ([]*models.Process, error)
func (*RuncLifecycle) RemoveProcess ¶
func (*RuncLifecycle) RunProcess ¶ added in v0.8.0
func (j *RuncLifecycle) RunProcess(logger lager.Logger, bpmCfg *config.BPMConfig, procCfg *config.ProcessConfig) (int, error)
func (*RuncLifecycle) StartProcess ¶
func (j *RuncLifecycle) StartProcess(logger lager.Logger, bpmCfg *config.BPMConfig, procCfg *config.ProcessConfig) error
func (*RuncLifecycle) StatProcess ¶ added in v0.6.0
func (*RuncLifecycle) StopProcess ¶
Click to show internal directories.
Click to hide internal directories.