package logreduction

import "k8s.io/component-base/logs/logreduction"

Index ¶

• type LogReduction
• func NewLogReduction(identicalErrorDelay time.Duration) *LogReduction
• func (l *LogReduction) ClearID(parentID string)
• func (l *LogReduction) ShouldMessageBePrinted(message string, parentID string) bool

Types ¶

type LogReduction ¶

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

LogReduction provides a filter for consecutive identical log messages; a message will be printed no more than once per interval. If a string of messages is interrupted by a different message, the interval timer will be reset.

func NewLogReduction ¶

func NewLogReduction(identicalErrorDelay time.Duration) *LogReduction

NewLogReduction returns an initialized LogReduction

func (*LogReduction) ClearID ¶

func (l *LogReduction) ClearID(parentID string)

ClearID clears out log reduction records pertaining to a particular parent (e. g. container ID)

func (*LogReduction) ShouldMessageBePrinted ¶

func (l *LogReduction) ShouldMessageBePrinted(message string, parentID string) bool

ShouldMessageBePrinted determines whether a message should be printed based on how long ago this particular message was last printed

Source Files ¶

logreduction.go