containers

Documentation

Index

• Variables
• type Client
  • func NewClient(log *logging.Logger, cgroupClient *cgroup.Client, containerdSock string, ...) (*Client, error)
  • func (c *Client) AddContainerByCgroupID(ctx context.Context, cgroupID cgroup.ID) (cont *Container, rerrr error)
  • func (c *Client) CleanupCgroup(cgroup cgroup.ID)
  • func (c *Client) GetCgroupCpuStats(cont *Container) (*cgroup.CPUStat, error)
  • func (c *Client) GetCgroupMemoryStats(cont *Container) (*cgroup.MemoryStat, error)
  • func (c *Client) GetCgroupsInNamespace(namespace string) []uint64
  • func (c *Client) GetContainerForCgroup(ctx context.Context, cgroup uint64) (*Container, error)
  • func (c *Client) ListContainers() []*Container
  • func (c *Client) LoadContainerTasks(ctx context.Context) ([]ContainerProcess, error)
  • func (c *Client) LookupContainerForCgroupInCache(cgroup uint64) (*Container, bool, error)
  • func (c *Client) RegisterContainerCreatedListener(l ContainerCreatedListener)
  • func (c *Client) RegisterContainerDeletedListener(l ContainerDeletedListener)
• type Container
• type ContainerCreatedListener
• type ContainerDeletedListener
• type ContainerProcess

Variables

var (
	ErrContainerNotFound = errors.New("container not found")
)

Types

type Client

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

Client is generic container client.

func NewClient

func NewClient(log *logging.Logger, cgroupClient *cgroup.Client, containerdSock string, procHandler *proc.Proc) (*Client, error)

func (*Client) AddContainerByCgroupID

func (c *Client) AddContainerByCgroupID(ctx context.Context, cgroupID cgroup.ID) (cont *Container, rerrr error)

func (*Client) CleanupCgroup

func (c *Client) CleanupCgroup(cgroup cgroup.ID)

func (*Client) GetCgroupCpuStats

func (c *Client) GetCgroupCpuStats(cont *Container) (*cgroup.CPUStat, error)

func (*Client) GetCgroupMemoryStats

func (c *Client) GetCgroupMemoryStats(cont *Container) (*cgroup.MemoryStat, error)

func (*Client) GetCgroupsInNamespace

func (c *Client) GetCgroupsInNamespace(namespace string) []uint64

func (*Client) GetContainerForCgroup

func (c *Client) GetContainerForCgroup(ctx context.Context, cgroup uint64) (*Container, error)

func (*Client) ListContainers

func (c *Client) ListContainers() []*Container

func (*Client) LoadContainerTasks

func (c *Client) LoadContainerTasks(ctx context.Context) ([]ContainerProcess, error)

func (*Client) LookupContainerForCgroupInCache

func (c *Client) LookupContainerForCgroupInCache(cgroup uint64) (*Container, bool, error)

func (*Client) RegisterContainerCreatedListener

func (c *Client) RegisterContainerCreatedListener(l ContainerCreatedListener)

func (*Client) RegisterContainerDeletedListener

func (c *Client) RegisterContainerDeletedListener(l ContainerDeletedListener)

type Container

type Container struct {
	ID           string
	Name         string
	CgroupID     uint64
	PodNamespace string
	PodUID       string
	PodName      string
	Cgroup       *cgroup.Cgroup
	PIDs         []uint32
	Err          error
}

type ContainerCreatedListener

type ContainerCreatedListener func(c *Container)

type ContainerDeletedListener

type ContainerDeletedListener func(c *Container)

type ContainerProcess

type ContainerProcess struct {
	ContainerID string
	PID         uint32
}