utils

Documentation

Index

• func CheckNamespacesExists(namespaces []LinuxNamespaceWithInode, wantedTypes ...specs.LinuxNamespaceType) error
• func CopyFileFromProcessToBundle(bundle string, pid int, path string) error
• func IsUsingHostNetwork(pid int) (bool, error)
• func ReadCgroupPath(pid int) (string, error)
• func ResolveNamespacesUsingInode(namespaces []LinuxNamespaceWithInode) []specs.LinuxNamespace
• func RootCommandContext(ctx context.Context, name string, arg ...string) *exec.Cmd
• func SidecarImagePath() string
• type KeyMutex
  • func NewHashedKeyMutex(n int) KeyMutex
• type LinuxNamespaceWithInode
  • func ReadNamespaces(pid int) ([]LinuxNamespaceWithInode, error)

Functions

func CheckNamespacesExists

func CheckNamespacesExists(namespaces []LinuxNamespaceWithInode, wantedTypes ...specs.LinuxNamespaceType) error

func CopyFileFromProcessToBundle

func CopyFileFromProcessToBundle(bundle string, pid int, path string) error

func IsUsingHostNetwork

func IsUsingHostNetwork(pid int) (bool, error)

IsUsingHostNetwork determines weather the given process has the same network as the init process.

func ReadCgroupPath

func ReadCgroupPath(pid int) (string, error)

func ResolveNamespacesUsingInode

func ResolveNamespacesUsingInode(namespaces []LinuxNamespaceWithInode) []specs.LinuxNamespace

func RootCommandContext

func RootCommandContext(ctx context.Context, name string, arg ...string) *exec.Cmd

func SidecarImagePath

func SidecarImagePath() string

Types

type KeyMutex

type KeyMutex interface {
	// Acquires a lock associated with the specified ID, creates the lock if one doesn't already exist.
	LockKey(id string)

	// Releases the lock associated with the specified ID.
	// Returns an error if the specified ID doesn't exist.
	UnlockKey(id string) error
}

KeyMutex is a thread-safe interface for acquiring locks on arbitrary strings.

func NewHashedKeyMutex

func NewHashedKeyMutex(n int) KeyMutex

NewHashedKeyMutex returns a new instance of KeyMutex which hashes arbitrary keys to a fixed set of locks. `n` specifies number of locks, if n <= 0, we use number of cpus. Note that because it uses fixed set of locks, different keys may share same lock, so it's possible to wait on same lock.

type LinuxNamespaceWithInode

type LinuxNamespaceWithInode struct {
	specs.LinuxNamespace
	Inode uint64
}

func ReadNamespaces

func ReadNamespaces(pid int) ([]LinuxNamespaceWithInode, error)