Documentation
¶
Overview ¶
Package logpipeline composes a job's log pipeline: a sanitizer for secret masking, three timestampers (stdout, stderr, and rlog), and a shared mutex so per-line records from the layers don't interleave between streams in the sink.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
// Sink receives the timestamped bytes. The LogPipeline owns it and
// closes it from Close.
Sink io.WriteCloser
// MaskedPhrases are pre-known secrets scrubbed from step stdout/
// stderr — typically values of CI variables marked masked=true.
MaskedPhrases []string
}
Config configures a LogPipeline.
type LogPipeline ¶
type LogPipeline struct {
// contains filtered or unexported fields
}
LogPipeline is a Job's log writer stack. Stdout, Stderr, and Rlog return io.Writers that timestamp and secret-mask writes before forwarding to the supplied sink. Close drains the layers and closes the sink.
func New ¶
func New(cfg Config) *LogPipeline
func (*LogPipeline) Close ¶
func (p *LogPipeline) Close() error
Close drains the layers (sanitizer through timestampers, timestampers to sink) and closes the sink.
func (*LogPipeline) Rlog ¶
func (p *LogPipeline) Rlog() io.Writer
func (*LogPipeline) Stderr ¶
func (p *LogPipeline) Stderr() io.Writer
func (*LogPipeline) Stdout ¶
func (p *LogPipeline) Stdout() io.Writer
Source Files
Click to show internal directories.
Click to hide internal directories.