func NewFetcher(fStatter) (*fetcher,error)

func NewResourcesMonitor(loggerslog.Logger, clockquartz.Clock, config *proto.GetResourcesMonitoringConfigurationResponse, resourcesFetcherFetcher, datapointsPusher datapointsPusher) *monitor

type Datapoint struct {CollectedAttime.TimeMemory      *MemoryDatapointVolumes     []*VolumeDatapoint}

type Fetcher interface {FetchMemory() (totalint64, usedint64, errerror)FetchVolume(volumestring) (totalint64, usedint64, errerror)}

type MemoryDatapoint struct {Totalint64Usedint64}

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

funcNewQueue¶

func NewQueue(sizeint) *Queue

newQueue creates a new Queue with the given size

func (*Queue)IsFull¶

func (q *Queue) IsFull()bool

func (*Queue)Items¶

func (q *Queue) Items() []Datapoint

func (*Queue)ItemsAsProto¶

func (q *Queue) ItemsAsProto() []*proto.PushResourcesMonitoringUsageRequest_Datapoint

func (*Queue)Push¶

func (q *Queue) Push(itemDatapoint)

Push adds a new item to the queue

type Statter interface {IsContainerized() (bool,error)ContainerMemory(pclistat.Prefix) (*clistat.Result,error)HostMemory(pclistat.Prefix) (*clistat.Result,error)Disk(pclistat.Prefix, pathstring) (*clistat.Result,error)}

type VolumeDatapoint struct {PathstringTotalint64Usedint64}