shim

Documentation

Index

• Variables
• func AnonDialer(address string, timeout time.Duration) (net.Conn, error)
• func BinaryName(runtime string) string
• func Command(ctx context.Context, runtime, containerdAddress, path string, ...) (*exec.Cmd, error)
• func Connect(address string, d func(string, time.Duration) (net.Conn, error)) (net.Conn, error)
• func NewSocket(address string) (*net.UnixListener, error)
• func Reap() error
• func Run(id string, initFunc Init)
• func SetScore(pid int) error
• func SocketAddress(ctx context.Context, id string) (string, error)
• func WriteAddress(path, address string) error
• func WritePidFile(path string, pid int) error
• type Client
  • func NewShimClient(ctx context.Context, svc shimapi.TaskService, signals chan os.Signal) *Client
  • func (s *Client) Serve() error
• type Init
• type Monitor
  • func (m *Monitor) Start(c *exec.Cmd) (chan runc.Exit, error)
  • func (m *Monitor) Subscribe() chan runc.Exit
  • func (m *Monitor) Unsubscribe(c chan runc.Exit)
  • func (m *Monitor) Wait(c *exec.Cmd, ec chan runc.Exit) (int, error)
• type Shim

Variables

var Default = &Monitor{
	subscribers: make(map[chan runc.Exit]struct{}),
}

Default is the default monitor initialized for the package

var ErrNoSuchProcess = errors.New("no such process")

ErrNoSuchProcess is returned when the process no longer exists

Functions

func AnonDialer

func AnonDialer(address string, timeout time.Duration) (net.Conn, error)

AnonDialer returns a dialer for an abstract socket

func BinaryName

func BinaryName(runtime string) string

BinaryName returns the shim binary name from the runtime name

func Command

func Command(ctx context.Context, runtime, containerdAddress, path string, cmdArgs ...string) (*exec.Cmd, error)

Command returns the shim command with the provided args and configuration

func Connect

func Connect(address string, d func(string, time.Duration) (net.Conn, error)) (net.Conn, error)

Connect to the provided address

func NewSocket

func NewSocket(address string) (*net.UnixListener, error)

NewSocket returns a new socket

func Reap

func Reap() error

Reap should be called when the process receives an SIGCHLD. Reap will reap all exited processes and close their wait channels

func Run

func Run(id string, initFunc Init)

Run initializes and runs a shim server

func SetScore

func SetScore(pid int) error

SetScore sets the oom score for a process

func SocketAddress

func SocketAddress(ctx context.Context, id string) (string, error)

SocketAddress returns an abstract socket address

func WriteAddress

func WriteAddress(path, address string) error

WriteAddress writes a address file atomically

func WritePidFile

func WritePidFile(path string, pid int) error

WritePidFile writes a pid file atomically

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client for a shim server

func NewShimClient

func NewShimClient(ctx context.Context, svc shimapi.TaskService, signals chan os.Signal) *Client

NewShimClient creates a new shim server client

func (*Client) Serve

func (s *Client) Serve() error

Serve the shim server

type Init

type Init func(context.Context, string, events.Publisher) (Shim, error)

Init func for the creation of a shim server

type Monitor

type Monitor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Monitor monitors the underlying system for process status changes

func (*Monitor) Start

func (m *Monitor) Start(c *exec.Cmd) (chan runc.Exit, error)

Start starts the command a registers the process with the reaper

func (*Monitor) Subscribe

func (m *Monitor) Subscribe() chan runc.Exit

Subscribe to process exit changes

func (*Monitor) Unsubscribe

func (m *Monitor) Unsubscribe(c chan runc.Exit)

Unsubscribe to process exit changes

func (*Monitor) Wait

func (m *Monitor) Wait(c *exec.Cmd, ec chan runc.Exit) (int, error)

Wait blocks until a process is signal as dead. User should rely on the value of the exit status to determine if the command was successful or not.

type Shim

type Shim interface {
	shimapi.TaskService
	Cleanup(ctx context.Context) (*shimapi.DeleteResponse, error)
	StartShim(ctx context.Context, id, containerdBinary, containerdAddress string) (string, error)
}

Shim server interface