package utils

import "k8s.io/kubernetes/Godeps/_workspace/src/github.com/google/cadvisor/utils"

Index ¶

• func FileExists(file string) bool
• func FixCpuMask(mask string, cores int) string
• type TimedStore
• func NewTimedStore(age time.Duration, maxItems int) *TimedStore
• func (self *TimedStore) Add(timestamp time.Time, item interface{})
• func (self *TimedStore) Get(index int) interface{}
• func (self *TimedStore) InTimeRange(start, end time.Time, maxResults int) []interface{}
• func (self *TimedStore) Size() int

Functions ¶

func FileExists ¶

func FileExists(file string) bool

func FixCpuMask ¶

func FixCpuMask(mask string, cores int) string

Returns a mask of all cores on the machine if the passed-in mask is empty.

Types ¶

type TimedStore ¶

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

A time-based buffer for ContainerStats. Holds information for a specific time period and/or a max number of items.

func NewTimedStore ¶

func NewTimedStore(age time.Duration, maxItems int) *TimedStore

Returns a new thread-compatible TimedStore. A maxItems value of -1 means no limit.

func (*TimedStore) Add ¶

func (self *TimedStore) Add(timestamp time.Time, item interface{})

Adds an element to the start of the buffer (removing one from the end if necessary).

func (*TimedStore) Get ¶

func (self *TimedStore) Get(index int) interface{}

Gets the element at the specified index. Note that elements are output in LIFO order.

func (*TimedStore) InTimeRange ¶

func (self *TimedStore) InTimeRange(start, end time.Time, maxResults int) []interface{}

Returns up to maxResult elements in the specified time period (inclusive). Results are from first to last. maxResults of -1 means no limit. When first and last are specified, maxResults is ignored.

func (*TimedStore) Size ¶

func (self *TimedStore) Size() int

Source Files ¶

path.go timed_store.go utils.go

Directories ¶