Documentation
¶
Index ¶
- func WithDefaultMemoryLimit(_ context.Context, _ oci.Client, _ *containers.Container, s *oci.Spec) error
- func WithNetNsHook(ipFile string) oci.SpecOpts
- type SnapshotManager
- type Worker
- func (m *Worker) Activate() error
- func (m *Worker) Attach() error
- func (m *Worker) AwaitMessage(messageType string) controller.Message
- func (m *Worker) AwaitSignal(waitingFor syscall.Signal)
- func (m *Worker) Checkpoints() []*State
- func (m *Worker) CleanSnapshot(name string) error
- func (m *Worker) ClearMemRefs() error
- func (m *Worker) Continue()
- func (m *Worker) ContinueTid(tid int, signal syscall.Signal)
- func (m *Worker) ContinueWith(signal syscall.Signal)
- func (m *Worker) Detach() error
- func (m *Worker) End() error
- func (m *Worker) GetImage(name string) (containerd.Image, error)
- func (m *Worker) InitialCheckpoint() (*State, error)
- func (m *Worker) ListImages() ([]containerd.Image, error)
- func (m *Worker) PauseAtSignal(waitingFor syscall.Signal)
- func (m *Worker) Pid() int
- func (m *Worker) Restore() error
- func (m *Worker) SendFunction(function string) error
- func (m *Worker) SendMessage(messageType string, data interface{}) error
- func (m *Worker) SendRequest(request interface{}) (interface{}, error)
- func (m *Worker) SendSignal(signal syscall.Signal) error
- func (m *Worker) SendSignalCont(signal syscall.Signal) error
- func (m *Worker) SetRegs(state *State) error
- func (m *Worker) Start() error
- func (m *Worker) State() (*State, error)
- func (m *Worker) Stop() error
- func (m *Worker) Streams() (*io.PipeWriter, *io.PipeReader, *io.PipeReader)
- func (m *Worker) TakeCheckpoint() error
- func (m *Worker) WithStdPipes(stderrWriter io.Writer, stdoutWriters ...io.Writer)
- func (m *Worker) WithSyscallTrace(to io.Writer)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithDefaultMemoryLimit ¶
func WithNetNsHook ¶
Types ¶
type SnapshotManager ¶
type SnapshotManager struct {
// contains filtered or unexported fields
}
func NewSnapshotManager ¶
func NewSnapshotManager(ctx context.Context, client *containerd.Client, runtime string) (*SnapshotManager, error)
func (*SnapshotManager) CreateLayerFromBase ¶
func (m *SnapshotManager) CreateLayerFromBase(layerName string) error
func (*SnapshotManager) CreateRoView ¶
func (m *SnapshotManager) CreateRoView(layerName, containerName string) ([]mount.Mount, error)
func (*SnapshotManager) GetRwMounts ¶
func (m *SnapshotManager) GetRwMounts(layerName, containerName string) ([]mount.Mount, error)
type Worker ¶
type Worker struct {
ID string
ContainerID string
IP net.IP
// contains filtered or unexported fields
}
func NewLocalWorker ¶
func NewWorkerWithSnapManager ¶
func NewWorkerWithSnapManager(id string, client *containerd.Client, runtime, targetSnapshot string, snapManager *SnapshotManager, ctx context.Context) (*Worker, error)
func (*Worker) AwaitMessage ¶
func (m *Worker) AwaitMessage(messageType string) controller.Message
func (*Worker) AwaitSignal ¶
func (*Worker) Checkpoints ¶
func (m *Worker) Checkpoints() []*State
func (*Worker) CleanSnapshot ¶
func (*Worker) ClearMemRefs ¶
func (*Worker) ContinueWith ¶
func (*Worker) InitialCheckpoint ¶
func (*Worker) ListImages ¶
func (m *Worker) ListImages() ([]containerd.Image, error)
func (*Worker) PauseAtSignal ¶
func (*Worker) SendFunction ¶
func (*Worker) SendMessage ¶
func (*Worker) SendRequest ¶
func (*Worker) Streams ¶
func (m *Worker) Streams() (*io.PipeWriter, *io.PipeReader, *io.PipeReader)
func (*Worker) TakeCheckpoint ¶
func (*Worker) WithStdPipes ¶
func (*Worker) WithSyscallTrace ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.