Documentation
¶
Index ¶
- type BundleRunner
- type BundleTemplate
- type Bundler
- type CgroupStarter
- type Checker
- type ContainerStater
- type Containerizer
- func (c *Containerizer) Create(log lager.Logger, spec gardener.DesiredContainerSpec) error
- func (c *Containerizer) Destroy(log lager.Logger, handle string) error
- func (c *Containerizer) Handles() ([]string, error)
- func (c *Containerizer) Run(log lager.Logger, handle string, spec garden.ProcessSpec, io garden.ProcessIO) (garden.Process, error)
- func (c *Containerizer) StreamIn(log lager.Logger, handle string, spec garden.StreamInSpec) error
- type Depot
- type NstarRunner
- type StartChecker
- type Starter
- type State
- type StateChecker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BundleRunner ¶
type BundleTemplate ¶
func (BundleTemplate) Bundle ¶
func (base BundleTemplate) Bundle(spec gardener.DesiredContainerSpec) *goci.Bndl
type CgroupStarter ¶
type CgroupStarter struct { CgroupPath string CommandRunner command_runner.CommandRunner ProcCgroups io.ReadCloser Logger lager.Logger }
func (*CgroupStarter) Start ¶
func (s *CgroupStarter) Start() error
type ContainerStater ¶
type Containerizer ¶
type Containerizer struct {
// contains filtered or unexported fields
}
Containerizer knows how to manage a depot of container bundles
func New ¶
func New(depot Depot, bundler Bundler, runner BundleRunner, startChecker Checker, stateChecker ContainerStater, nstarRunner NstarRunner) *Containerizer
func (*Containerizer) Create ¶
func (c *Containerizer) Create(log lager.Logger, spec gardener.DesiredContainerSpec) error
Create creates a bundle in the depot and starts its init process
func (*Containerizer) Destroy ¶
func (c *Containerizer) Destroy(log lager.Logger, handle string) error
Destroy kills any container processes and deletes the bundle directory
func (*Containerizer) Handles ¶
func (c *Containerizer) Handles() ([]string, error)
Handles returns a list of all container handles
func (*Containerizer) Run ¶
func (c *Containerizer) Run(log lager.Logger, handle string, spec garden.ProcessSpec, io garden.ProcessIO) (garden.Process, error)
Run runs a process inside a running container
func (*Containerizer) StreamIn ¶
func (c *Containerizer) StreamIn(log lager.Logger, handle string, spec garden.StreamInSpec) error
StreamIn streams files in to the container
type NstarRunner ¶
type NstarRunner interface {
StreamIn(log lager.Logger, pid int, path string, user string, tarStream io.Reader) error
}
func NewNstarRunner ¶
func NewNstarRunner(nstarPath, tarPath string, runner command_runner.CommandRunner) NstarRunner
type StartChecker ¶
type Starter ¶
type Starter struct {
*CgroupStarter
}
func NewStarter ¶
func NewStarter(logger lager.Logger, procCgroupReader io.ReadCloser, cgroupMountpoint string, runner command_runner.CommandRunner) *Starter
Source Files
¶
Directories
¶
Path | Synopsis |
---|---|
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fake_process_tracker
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.