common

Documentation

Overview

Unmarshal's a Containers description json file. The json file contains an array of ContainerHint structs, each with a container's id and networkInterface This allows collecting stats about network interfaces configured outside docker and lxc

Handler for Docker containers.

Index

• Variables
• func CgroupExists(cgroupPaths map[string]string) bool
• func DebugInfo(watches map[string][]string) map[string][]string
• func GetContainerHintsFromFile(containerHintsFile string) (containerHints, error)
• func GetSpec(cgroupPaths map[string]string, machineInfoFactory info.MachineInfoFactory, ...) (info.ContainerSpec, error)
• func ListContainers(name string, cgroupPaths map[string]string, listType container.ListType) ([]info.ContainerReference, error)
• func ListDirectories(dirpath string, parent string, recursive bool, output map[string]struct{}) error
• func MakeCgroupPaths(mountPoints map[string]string, name string) map[string]string
• type FsHandler
  • func NewFsHandler(period time.Duration, rootfs, extraDir string, fsInfo fs.FsInfo) FsHandler
• type InotifyWatcher
  • func NewInotifyWatcher() (*InotifyWatcher, error)
  • func (iw *InotifyWatcher) AddWatch(containerName, dir string) (bool, error)
  • func (iw *InotifyWatcher) Close() error
  • func (iw *InotifyWatcher) Error() chan error
  • func (iw *InotifyWatcher) Event() chan *inotify.Event
  • func (iw *InotifyWatcher) GetWatches() map[string][]string
  • func (iw *InotifyWatcher) RemoveWatch(containerName, dir string) (bool, error)
• type Mount

Variables

var ArgContainerHints = flag.String("container_hints", "/etc/cadvisor/container_hints.json", "location of the container hints file")

Functions

func CgroupExists

func CgroupExists(cgroupPaths map[string]string) bool

func DebugInfo

func DebugInfo(watches map[string][]string) map[string][]string

func GetContainerHintsFromFile

func GetContainerHintsFromFile(containerHintsFile string) (containerHints, error)

func GetSpec

func GetSpec(cgroupPaths map[string]string, machineInfoFactory info.MachineInfoFactory, hasNetwork, hasFilesystem bool) (info.ContainerSpec, error)

func ListContainers

func ListContainers(name string, cgroupPaths map[string]string, listType container.ListType) ([]info.ContainerReference, error)

func ListDirectories

func ListDirectories(dirpath string, parent string, recursive bool, output map[string]struct{}) error

Lists all directories under "path" and outputs the results as children of "parent".

func MakeCgroupPaths

func MakeCgroupPaths(mountPoints map[string]string, name string) map[string]string

Types

type FsHandler

type FsHandler interface {
	Start()
	Usage() (baseUsageBytes uint64, totalUsageBytes uint64)
	Stop()
}

func NewFsHandler

func NewFsHandler(period time.Duration, rootfs, extraDir string, fsInfo fs.FsInfo) FsHandler

type InotifyWatcher

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

Watcher for container-related inotify events in the cgroup hierarchy.

Implementation is thread-safe.

func NewInotifyWatcher

func NewInotifyWatcher() (*InotifyWatcher, error)

func (*InotifyWatcher) AddWatch

func (iw *InotifyWatcher) AddWatch(containerName, dir string) (bool, error)

Add a watch to the specified directory. Returns if the container was already being watched.

func (*InotifyWatcher) Close

func (iw *InotifyWatcher) Close() error

Closes the inotify watcher.

func (*InotifyWatcher) Error

func (iw *InotifyWatcher) Error() chan error

Errors are returned on this channel.

func (*InotifyWatcher) Event

func (iw *InotifyWatcher) Event() chan *inotify.Event

Events are returned on this channel.

func (*InotifyWatcher) GetWatches

func (iw *InotifyWatcher) GetWatches() map[string][]string

Returns a map of containers to the cgroup paths being watched.

func (*InotifyWatcher) RemoveWatch

func (iw *InotifyWatcher) RemoveWatch(containerName, dir string) (bool, error)

Remove watch from the specified directory. Returns if this was the last watch on the specified container.

type Mount

type Mount struct {
	HostDir      string `json:"host_dir,omitempty"`
	ContainerDir string `json:"container_dir,omitempty"`
}