Documentation
¶
Index ¶
- type Manager
- func (m *Manager) CancelRunningProcesses()
- func (m *Manager) DeleteProcess(id string) error
- func (m *Manager) Get(id string) (*Process, bool)
- func (m *Manager) ListProcesses() (res []*ProcessInfo)
- func (m *Manager) StartProcess(pid string, resultCtx *build.ResultHandle, cfg *build.InvokeConfig) (*Process, error)
- type Process
- type ProcessInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager manages a set of processes.
func (*Manager) CancelRunningProcesses ¶
func (m *Manager) CancelRunningProcesses()
CancelRunningProcesses cancels execution of all running processes.
func (*Manager) DeleteProcess ¶
DeleteProcess deletes the specified process.
func (*Manager) ListProcesses ¶
func (m *Manager) ListProcesses() (res []*ProcessInfo)
ListProcesses lists all running processes.
func (*Manager) StartProcess ¶
func (m *Manager) StartProcess(pid string, resultCtx *build.ResultHandle, cfg *build.InvokeConfig) (*Process, error)
StartProcess starts a process in the container. When a container isn't available (i.e. first time invoking or the container has exited) or cfg.Rollback is set, this method will start a new container and run the process in it. Otherwise, this method starts a new process in the existing container.
type Process ¶
type Process struct {
// contains filtered or unexported fields
}
Process provides methods to control a process.
func (*Process) Done ¶
Done returns a channel where error or nil will be sent when the process exits. TODO: change this to Wait()
type ProcessInfo ¶
type ProcessInfo struct {
ProcessID string
InvokeConfig *build.InvokeConfig
}
Source Files
Click to show internal directories.
Click to hide internal directories.