outofmem

Documentation

Index

• Constants
• type OOMInfo
• type OomInstance
• type OomParser
  • func NewOomParser() (*OomParser, error)
  • func (p *OomParser) StreamOoms(ctx context.Context, outStream chan<- *OomInstance)
• type OutOfMemCollector
  • func (c *OutOfMemCollector) Reload(_ *configs.ExceptionBeatConfig)
  • func (c *OutOfMemCollector) Start(ctx context.Context, e chan<- define.Event, conf *configs.ExceptionBeatConfig)
  • func (c *OutOfMemCollector) StartTraceOOM()
  • func (c *OutOfMemCollector) Stop()
  • func (c *OutOfMemCollector) WatchOOMEvents(ctx context.Context, e chan<- define.Event)

Constants

const (
	IEG_DOCKER_FILE = "/etc/ieg-docker.conf"
)

Types

type OOMInfo

type OOMInfo struct {
	*OomInstance
}

type OomInstance

type OomInstance struct {
	// process id of the killed process
	Pid int
	// the name of the killed process
	ProcessName string
	// the time that the process was reported to be killed,
	// accurate to the minute
	TimeOfDeath time.Time
	// the absolute name of the container that OOMed
	ContainerName string
	// the absolute name of the container that was killed
	// due to the OOM.
	VictimContainerName string
	// the constraint that triggered the OOM.  One of CONSTRAINT_NONE,
	// CONSTRAINT_CPUSET, CONSTRAINT_MEMORY_POLICY, CONSTRAINT_MEMCG
	Constraint string
}

struct that contains information related to an OOM kill instance

type OomParser

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

OomParser wraps a kmsgparser in order to extract OOM events from the individual kernel ring buffer messages.

func NewOomParser

func NewOomParser() (*OomParser, error)

initializes an OomParser object. Returns an OomParser object and an error.

func (*OomParser) StreamOoms

func (p *OomParser) StreamOoms(ctx context.Context, outStream chan<- *OomInstance)

StreamOoms writes to a provided a stream of OomInstance objects representing OOM events that are found in the logs. It will block and should be called from a goroutine.

type OutOfMemCollector

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

func (*OutOfMemCollector) Reload

func (c *OutOfMemCollector) Reload(_ *configs.ExceptionBeatConfig)

func (*OutOfMemCollector) Start

func (c *OutOfMemCollector) Start(ctx context.Context, e chan<- define.Event, conf *configs.ExceptionBeatConfig)

func (*OutOfMemCollector) StartTraceOOM

func (c *OutOfMemCollector) StartTraceOOM()

func (*OutOfMemCollector) Stop

func (c *OutOfMemCollector) Stop()

func (*OutOfMemCollector) WatchOOMEvents

func (c *OutOfMemCollector) WatchOOMEvents(ctx context.Context, e chan<- define.Event)