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 { … }
Codebase Browser
kubernetes