diagnosisreaper

Documentation

Index

• func DeleteExpiredProfilerData(path string, diagnosisTTL time.Duration, log logr.Logger) error
• type DiagnosisReaper
  • func NewDiagnosisReaper(ctx context.Context, logger logr.Logger, cli client.Client, ...) *DiagnosisReaper
  • func (dr *DiagnosisReaper) Run(stopCh <-chan struct{})

Functions

func DeleteExpiredProfilerData

func DeleteExpiredProfilerData(path string, diagnosisTTL time.Duration, log logr.Logger) error

DeleteExpiredProfilerData deletes profiler data by removing files or directories if the file age is longer than diagnosisTTL.

Types

type DiagnosisReaper

type DiagnosisReaper struct {
	// Context carries values across API boundaries.
	context.Context
	// Logger represents the ability to log messages.
	logr.Logger
	// contains filtered or unexported fields
}

DiagnosisReaper manages garbage collections of finished diagnoses.

func NewDiagnosisReaper

func NewDiagnosisReaper(
	ctx context.Context,
	logger logr.Logger,
	cli client.Client,
	scheme *runtime.Scheme,
	cache cache.Cache,
	nodeName string,
	diagnosisTTL time.Duration,
	minimumDiagnosisTTLDuration time.Duration,
	maximumDiagnosesPerNode int32,
	dataRoot string,
) *DiagnosisReaper

NewDiagnosisReaper creates a new DiagnosisReaper.

func (*DiagnosisReaper) Run

func (dr *DiagnosisReaper) Run(stopCh <-chan struct{})

Run runs the diagnosis reaper.