Documentation ¶
Index ¶
- func New(ic *plugin.InitContext) (interface{}, error)
- func NewPlatform() (stdio.Platform, error)
- type CheckpointConfig
- type Config
- type Process
- type TaskManager
- func (manager *TaskManager) Add(ctx context.Context, task runtime.Task) error
- func (manager *TaskManager) Create(ctx context.Context, id string, opts runtime.CreateOpts) (_ runtime.Task, retErr error)
- func (manager *TaskManager) Delete(ctx context.Context, id string)
- func (manager *TaskManager) Get(ctx context.Context, id string) (runtime.Task, error)
- func (*TaskManager) ID() string
- func (manager *TaskManager) Tasks(ctx context.Context, all bool) ([]runtime.Task, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(ic *plugin.InitContext) (interface{}, error)
func NewPlatform ¶
NewPlatform returns a linux platform for use with I/O operations
Types ¶
type CheckpointConfig ¶
type CheckpointConfig struct { WorkDir string Path string Exit bool AllowOpenTCP bool AllowExternalUnixSockets bool AllowTerminal bool FileLocks bool EmptyNamespaces []string }
CheckpointConfig holds task checkpoint configuration
type Process ¶
type Process interface { // ID returns the id for the process ID() string // Pid returns the pid for the process Pid() int // ExitStatus returns the exit status ExitStatus() int // ExitedAt is the time the process exited ExitedAt() time.Time // Stdin returns the process STDIN Stdin() io.Closer // Stdio returns io information for the container Stdio() stdio.Stdio // Status returns the process status Status(context.Context) (string, error) // Wait blocks until the process has exited Wait() // Resize resizes the process console Resize(ws console.WinSize) error // Start execution of the process Start(context.Context) error // Delete deletes the process and its resourcess Delete(context.Context) error // Kill kills the process Kill(context.Context, uint32, bool) error // SetExited sets the exit status for the process SetExited(status int) }
Process on a system
type TaskManager ¶
type TaskManager struct {
// contains filtered or unexported fields
}
func (*TaskManager) Create ¶
func (manager *TaskManager) Create(ctx context.Context, id string, opts runtime.CreateOpts) (_ runtime.Task, retErr error)
func (*TaskManager) ID ¶
func (*TaskManager) ID() string
Source Files ¶
Click to show internal directories.
Click to hide internal directories.