kubernetes/test/e2e/framework/debug/log_size_monitoring.go

const pollingPeriod

const workersNo

const kubeletLogsPath

const kubeProxyLogsPath

const kubeAddonsLogsPath

const kubeMasterAddonsLogsPath

const apiServerLogsPath

const controllersLogsPath

const schedulerLogsPath

var nodeLogsToCheck

var masterLogsToCheck

type TimestampedSize

type LogSizeGatherer

type LogsSizeVerifier

type SingleLogSummary

type LogSizeDataTimeseries

type LogsSizeDataSummary

// PrintHumanReadable returns string of log size data summary.
// TODO: make sure that we don't need locking here
func (s *LogsSizeDataSummary) PrintHumanReadable() string {}

// PrintJSON returns the summary of log size data with JSON format.
func (s *LogsSizeDataSummary) PrintJSON() string {}

// SummaryKind returns the summary of log size data summary.
func (s *LogsSizeDataSummary) SummaryKind() string {}

type LogsSizeData

type WorkItem

func prepareData(masterAddress string, nodeAddresses []string) *LogsSizeData {}

func (d *LogsSizeData) addNewData(ip, path string, timestamp time.Time, size int) {}

// NewLogsVerifier creates a new LogsSizeVerifier which will stop when stopChannel is closed
func NewLogsVerifier(ctx context.Context, c clientset.Interface) *LogsSizeVerifier {}

// GetSummary returns a summary (average generation rate and number of probes) of the data gathered by LogSizeVerifier
func (s *LogsSizeVerifier) GetSummary() *LogsSizeDataSummary {}

// Run starts log size gathering. It starts a gorouting for every worker and then blocks until stopChannel is closed
func (s *LogsSizeVerifier) Run(ctx context.Context) {}

// Run starts log size gathering.
func (g *LogSizeGatherer) Run(ctx context.Context) {}

func (g *LogSizeGatherer) pushWorkItem(workItem WorkItem) {}

// Work does a single unit of work: tries to take out a WorkItem from the queue, ssh-es into a given machine,
// gathers data, writes it to the shared <data> map, and creates a gorouting which reinserts work item into
// the queue with a <pollingPeriod> delay. Returns false if worker should exit.
func (g *LogSizeGatherer) Work(ctx context.Context) bool {}