utils

Documentation

Index

• func FileExists(file string) bool
• func FixCpuMask(mask string, cores int) string
• type TimedStore
  • func NewTimedStore(age time.Duration) *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.

func NewTimedStore

func NewTimedStore(age time.Duration) *TimedStore

Returns a new thread-compatible TimedStore.

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