containerd package

import "go.sbk.wtf/runj/containerd"

Index ¶

• func NewManager(name string) shim.Manager
• func NewTaskService(ctx context.Context, publisher shim.Publisher, sd shutdown.Service) (taskAPI.TTRPCTaskService, error)
• func SetReaper() error
• func SetupReaperSignals(ctx context.Context, logger *logrus.Entry) error
• func WaitNoFlush(c *exec.Cmd, ec chan runc.Exit) (int, error)

func NewManager ¶

func NewManager(name string) shim.Manager

NewManager returns a shim.Manager for the runj shim. The manager forks the shim process and handles fallback cleanup; the task API is served by the plugin-registered service (see NewTaskService).

func NewTaskService ¶

func NewTaskService(ctx context.Context, publisher shim.Publisher, sd shutdown.Service) (taskAPI.TTRPCTaskService, error)

NewTaskService creates a new runj task service implementing the v3 TTRPC task API. The publisher and shutdown service are supplied by the shim plugin init context.

func SetReaper ¶

func SetReaper() error

SetReaper sets this process as the reaper for its orphaned descendant processes

func SetupReaperSignals ¶

func SetupReaperSignals(ctx context.Context, logger *logrus.Entry) error

SetupReaperSignals configures the current process as a reaper, sets up a signal handler to receive SIGCHLD,and processes SIGCHLD events with containerd's reaper package.

func WaitNoFlush ¶

func WaitNoFlush(c *exec.Cmd, ec chan runc.Exit) (int, error)

WaitNoFlush waits for a process to exit but does not flush IO with cmd.Wait

Source Files ¶

bundle.go exec.go managed_process.go manager.go pio.go plugin.go reaper.go shim.go