const dateLayout … const maxTailLines … const maxServiceLength … const maxServices … const nodeLogDir … var journal … var reServiceNameUnsafeCharacters … type journalServer … // ServeHTTP translates HTTP query parameters into arguments to be passed // to journalctl on the current system. It supports content-encoding of // gzip to reduce total content size. func (journalServer) ServeHTTP(w http.ResponseWriter, req *http.Request) { … } type nodeLogQuery … type options … // newNodeLogQuery parses query values and converts all known options into nodeLogQuery func newNodeLogQuery(query url.Values) (*nodeLogQuery, field.ErrorList) { … } func validateServices(services []string) field.ErrorList { … } func (n *nodeLogQuery) validate() field.ErrorList { … } // Copy streams the contents of the OS specific logging command executed with the current args to the provided // writer. If an error occurs a line is written to the output. func (n *nodeLogQuery) Copy(w io.Writer) { … } // copyForBoot invokes the OS specific logging command with the provided args func (n *nodeLogQuery) copyForBoot(ctx context.Context, w io.Writer, previousBoot int) { … } // splitNativeVsFileLoggers checks if each service logs to native OS logs or to a file and returns a list of services // that log natively vs maybe to a file func (n *nodeLogQuery) splitNativeVsFileLoggers(ctx context.Context) ([]string, []string) { … } // copyServiceLogs invokes journalctl or Get-WinEvent with the provided args. Note that // services are explicitly passed here to account for the heuristics. func (n *nodeLogQuery) copyServiceLogs(ctx context.Context, w io.Writer, services []string, previousBoot int) { … } // copyFileLogs loops over all the services and attempts to collect the file logs of each service func copyFileLogs(ctx context.Context, w io.Writer, services []string) { … } // heuristicsCopyFileLogs attempts to collect logs from either // /var/log/service // /var/log/service.log or // /var/log/service/service.log or // in that order stopping on first success. func heuristicsCopyFileLogs(ctx context.Context, w io.Writer, service string) { … } type readerCtx … func (r *readerCtx) Read(p []byte) (n int, err error) { … } // newReaderCtx gets a context-aware io.Reader func newReaderCtx(ctx context.Context, r io.Reader) io.Reader { … } // heuristicsCopyFileLog returns the contents of the given logFile func heuristicsCopyFileLog(ctx context.Context, w io.Writer, logFile string) error { … } func safeServiceName(s string) error { … }
Codebase Browser
kubernetes